lifecycle

Nov 8, 2024

Changes in this version

+ type ConnectorPluginService interface

+ NewDispenser func(logger log.CtxLogger, name string, connectorID string) (connectorPlugin.Dispenser, error)

+ type ConnectorService interface

+ Create func(ctx context.Context, id string, t connector.Type, plugin string, ...) (*connector.Instance, error)

+ Get func(ctx context.Context, id string) (*connector.Instance, error)

+ type FailureEvent struct

+ Error error

+ ID string

+ type FailureHandler func(FailureEvent)

+ type PipelineService interface

+ Get func(ctx context.Context, pipelineID string) (*pipeline.Instance, error)

+ List func(ctx context.Context) map[string]*pipeline.Instance

+ UpdateStatus func(ctx context.Context, pipelineID string, status pipeline.Status, errMsg string) error

+ type ProcessorService interface

+ Get func(ctx context.Context, id string) (*processor.Instance, error)

+ MakeRunnableProcessor func(ctx context.Context, i *processor.Instance) (*processor.RunnableProcessor, error)

+ type Service struct

+ func NewService(logger log.CtxLogger, connectors ConnectorService, processors ProcessorService, ...) *Service

+ func (s *Service) Init(ctx context.Context) error

+ func (s *Service) OnFailure(handler FailureHandler)

+ func (s *Service) Start(ctx context.Context, pipelineID string) error

+ func (s *Service) Stop(ctx context.Context, pipelineID string, force bool) error

+ func (s *Service) StopAll(ctx context.Context, force bool) error

+ func (s *Service) Wait(timeout time.Duration) error

+ func (s *Service) WaitPipeline(id string) error