maestro

package
v0.29.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 21, 2023 License: MPL-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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, otelCfg config.OtelConfig, db *sqlx.DB, svcCfg config.BaseSvcConfig) Service

type SinkConfig

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

Directories

Path Synopsis
consumer
Package esconsumer contains events esconsumer for events
Package esconsumer contains events esconsumer for events

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL