eventbus

Documentation

Index

• func IsUnprocessableEventError(err error) bool
• type EventDesc
• type EventHandlerRegistrar
• type Handler
• type Processor
• type PublishFn
• type PublishOption
  • func WithEventContentType(t string) PublishOption
  • func WithEventSource(src string) PublishOption
• type Publisher
• type PublisherImpl
  • func NewPublisher(sender Sender, opts ...PublisherOption) *PublisherImpl
  • func (p *PublisherImpl) Publish(ctx context.Context, name string, event interface{}, opts ...PublishOption) error
• type PublisherInterceptor
• type PublisherOption
  • func WithChainPublisherInterceptor(interceptors ...PublisherInterceptor) PublisherOption
  • func WithDefaultPublishOptions(pos ...PublishOption) PublisherOption
  • func WithPublisherContentType(t string) PublisherOption
  • func WithPublisherInterceptor(f PublisherInterceptor) PublisherOption
• type Receiver
• type Sender
• type ServiceDesc
• type ServiceInfo
• type Subscriber
  • func NewSubscriber(name string, opts ...SubscriberOption) *Subscriber
  • func (s *Subscriber) GetServiceInfo() []ServiceInfo
  • func (s *Subscriber) RegisterEventHandler(sd *ServiceDesc, eventName string, h interface{})
  • func (s *Subscriber) Subscribe(ctx context.Context, r Receiver) error
• type SubscriberInterceptor
• type SubscriberOption
  • func WithChainSubscriberInterceptor(interceptors ...SubscriberInterceptor) SubscriberOption
  • func WithSubscriberInterceptor(f SubscriberInterceptor) SubscriberOption
• type UnprocessableEventError
  • func NewUnprocessableEventError(err error) *UnprocessableEventError
  • func (e *UnprocessableEventError) Error() string
  • func (e *UnprocessableEventError) Unwrap() error

Functions

func IsUnprocessableEventError

func IsUnprocessableEventError(err error) bool

Types

type EventDesc

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

type EventHandlerRegistrar

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

type Handler

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

type Processor

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

type PublishFn

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

type PublishOption

type PublishOption func(m *event.Metadata)

func WithEventContentType

func WithEventContentType(t string) PublishOption

func WithEventSource

func WithEventSource(src string) PublishOption

type Publisher

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

type PublisherImpl

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

func NewPublisher

func NewPublisher(sender Sender, opts ...PublisherOption) *PublisherImpl

func (*PublisherImpl) Publish

func (p *PublisherImpl) Publish(ctx context.Context, name string, event interface{}, opts ...PublishOption) error

type PublisherInterceptor

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

type PublisherOption

type PublisherOption func(opts *publisherOptions)

func WithChainPublisherInterceptor

func WithChainPublisherInterceptor(interceptors ...PublisherInterceptor) PublisherOption

func WithDefaultPublishOptions

func WithDefaultPublishOptions(pos ...PublishOption) PublisherOption

func WithPublisherContentType

func WithPublisherContentType(t string) PublisherOption

func WithPublisherInterceptor

func WithPublisherInterceptor(f PublisherInterceptor) PublisherOption

type Receiver

type Receiver interface {
	Setup(ctx context.Context, serviceName string, infos ...ServiceInfo) error
	Receive(ctx context.Context, p Processor) error
}

type Sender

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

type ServiceDesc

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

type ServiceInfo

type ServiceInfo struct {
	ServiceName string
	Events      []string
}

type Subscriber

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

func NewSubscriber

func NewSubscriber(name string, opts ...SubscriberOption) *Subscriber

func (*Subscriber) GetServiceInfo

func (s *Subscriber) GetServiceInfo() []ServiceInfo

func (*Subscriber) RegisterEventHandler

func (s *Subscriber) RegisterEventHandler(sd *ServiceDesc, eventName string, h interface{})

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe(ctx context.Context, r Receiver) error

type SubscriberInterceptor

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

type SubscriberOption

type SubscriberOption func(opts *subscriberOptions)

func WithChainSubscriberInterceptor

func WithChainSubscriberInterceptor(interceptors ...SubscriberInterceptor) SubscriberOption

func WithSubscriberInterceptor

func WithSubscriberInterceptor(f SubscriberInterceptor) SubscriberOption

type UnprocessableEventError

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

func NewUnprocessableEventError

func NewUnprocessableEventError(err error) *UnprocessableEventError

func (*UnprocessableEventError) Error

func (e *UnprocessableEventError) Error() string

func (*UnprocessableEventError) Unwrap

func (e *UnprocessableEventError) Unwrap() error