bus

type FakeMessagePipe struct {
	// contains filtered or unexported fields
}

type Info struct {
	Name string
}

type Message struct {
	Topic string
	Data  Payload
}

type MessagePipe struct {
	// contains filtered or unexported fields
}

type MessagePipeInterface interface {
	Register(size int, plugins []Plugin) error
	DeRegister(ctx context.Context, plugins []string) error
	Process(ctx context.Context, messages ...*Message)
	Run(ctx context.Context)
	GetPlugins() []Plugin
	IsPluginRegistered(pluginName string) bool
}

type MessageWithContext struct {
	// contains filtered or unexported fields
}

type Payload interface{}

type Plugin interface {
	Init(ctx context.Context, messagePipe MessagePipeInterface) error
	Close(ctx context.Context) error
	Info() *Info
	Process(ctx context.Context, msg *Message)
	Subscriptions() []string
}