biz

type Bus struct {
	Name           string
	Mode           v1.BusWorkMode
	Source         MQTopic
	SourceDelay    MQTopic
	TargetExpDecay MQTopic
	TargetBackoff  MQTopic
}

type BusRepo interface {
	ListBus(ctx context.Context, prefix *string, limit int32, nextToken uint64) ([]*Bus, uint64, error)
	CreateBus(
		ctx context.Context, bus string, mode v1.BusWorkMode, source MQTopic,
		sourceDelay MQTopic, targetExpDecay MQTopic, targetBackoff MQTopic,
	) (uint64, error)
	DeleteBus(ctx context.Context, bus string) error
}

type BusUseCase struct {
	// contains filtered or unexported fields
}

type DispatcherSchema struct {
	Type         string
	ParamsSchema string
}

type EventInfo struct {
	ID         uint64
	MessageID  string
	MessageKey string
	TraceID    string
}

type EventRepo interface {
	PostEvent(ctx context.Context, eventExt *rule.EventExt, pubTime *timestamppb.Timestamp) (*EventInfo, error)
	ListSchema(
		ctx context.Context, source *string, sType *string, busName *string, time *timestamppb.Timestamp,
	) ([]*Schema, error)
	CreateSchema(ctx context.Context, source string, sType string, busName string, spec []byte) error
	UpdateSchema(ctx context.Context, source string, sType string, busName *string, spec []byte) error
	DeleteSchema(ctx context.Context, source string, sType *string) error
}

type EventUseCase struct {
	// contains filtered or unexported fields
}

type MQTopic struct {
	Type      v1.MQType `json:"type"`
	Endpoints string    `json:"endpoints"` // "endpoint1;endpoint2"
	Topic     string    `json:"topic"`
}

type RuleRepo interface {
	ListRule(
		ctx context.Context, bus string, prefix *string, status v1.RuleStatus, limit int32, nextToken uint64,
	) ([]*rule.Rule, uint64, error)
	CreateRule(
		ctx context.Context, bus string, name string, status v1.RuleStatus, pattern []byte, targets []*rule.Target,
	) (uint64, error)
	UpdateRule(ctx context.Context, bus string, name string, status v1.RuleStatus, pattern []byte) error
	DeleteRule(ctx context.Context, bus string, name string) error
	CreateTargets(ctx context.Context, bus string, ruleName string, targets []*rule.Target) error
	DeleteTargets(ctx context.Context, bus string, ruleName string, targetIDs []uint64) error
	ListDispatcherSchema(ctx context.Context, types []string) ([]*DispatcherSchema, error)
}

type RuleUseCase struct {
	// contains filtered or unexported fields
}

type Schema struct {
	Source  string
	Type    string
	BusName string
	Spec    string
	Time    *timestamppb.Timestamp
	// contains filtered or unexported fields
}