sinks

Documentation

Index

• type ContributoorSink
  • func NewStdoutSink(log *logrus.Logger, config *config.Config, networkName string) (ContributoorSink, error)
  • func NewXatuSink(log *logrus.Logger, config *config.Config, networkName string) (ContributoorSink, error)

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.Logger, config *config.Config, networkName string) (ContributoorSink, error)

NewStdoutSink creates a new StdoutSink.

func NewXatuSink

func NewXatuSink(log *logrus.Logger, config *config.Config, networkName string) (ContributoorSink, error)

NewXatuSink creates a new XatuSink.