Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ContributoorSink ¶
type ContributoorSink interface {
// Start initializes and starts the sink.
Start(ctx context.Context) error
// Stop gracefully shuts down the sink.
Stop(ctx context.Context) error
// HandleEvent processes an event and forwards it to the appropriate destination.
HandleEvent(ctx context.Context, event events.Event) error
// Name returns the name of the sink for logging purposes.
Name() string
}
ContributoorSink defines the interface for event sinks.
func NewStdoutSink ¶
func NewStdoutSink(log logrus.FieldLogger, config *config.Config, networkName string) (ContributoorSink, error)
NewStdoutSink creates a new StdoutSink.
func NewXatuSink ¶
func NewXatuSink(log logrus.FieldLogger, config *config.Config, networkName string) (ContributoorSink, error)
NewXatuSink creates a new XatuSink.
Click to show internal directories.
Click to hide internal directories.