maestro

Documentation

Index

• type Maestro
• type Service
  • func NewMaestroService(logger *zap.Logger, streamRedisClient *redis.Client, ...) Service
• type SinkConfig

Types

type Maestro

type Maestro struct {
	ID          string
	Name        types.Identifier
	MFOwnerID   string
	Description string
	Backend     string
	Config      types.Metadata
	Error       string
	Created     time.Time
}

type Service

type Service interface {
	// Start starts the service - load the configuration
	Start(ctx context.Context, cancelFunction context.CancelFunc) error
}

func NewMaestroService

func NewMaestroService(logger *zap.Logger, streamRedisClient *redis.Client, sinkerRedisClient *redis.Client, sinksGrpcClient sinkspb.SinkServiceClient, esCfg config.EsConfig, otelCfg config.OtelConfig) Service

type SinkConfig

type SinkConfig struct {
	Id       string
	Url      string
	Username string
	Password string
}