eventbus

type EventDesc struct {
	Name        string
	HandlerType interface{}
	Handler     eventHandler
}

type EventHandlerRegistrar interface {
	RegisterEventHandler(desc *ServiceDesc, event string, impl interface{})
}

type Handler func(ctx context.Context, event interface{}) error

type Processor func(md *event.Metadata, data []byte) error

type PublishFn func(ctx context.Context, name string, e interface{}, p *PublisherImpl, opts ...PublishOption) error

type PublishOption func(m *event.Metadata)

type Publisher interface {
	Publish(ctx context.Context, name string, event interface{}, opts ...PublishOption) error
}

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

type PublisherInterceptor func(ctx context.Context, name string, e interface{}, p *PublisherImpl, pf PublishFn, opts ...PublishOption) error

type PublisherOption func(opts *publisherOptions)

type Receiver interface {
	Receive(ctx context.Context, p Processor) error
}

type Sender interface {
	Send(ctx context.Context, metadata *event.Metadata, data []byte) error
}

type ServiceDesc struct {
	ServiceName string
	Events      []EventDesc
	Metadata    string
}

type ServiceInfo struct {
	ServiceName string
	Events      []string
}

type Setuper interface {
	Setup(ctx context.Context, serviceName string, info ...ServiceInfo) error
}

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

type SubscriberInterceptor func(ctx context.Context, md *event.Metadata, event interface{}, handler Handler) error

type SubscriberOption func(opts *subscriberOptions)

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