gochan

Documentation

Index

• Variables
• type SendReceiver
  • func New() *SendReceiver
  • func (sr *SendReceiver) Close(_ context.Context)
  • func (sr *SendReceiver) Receive(ctx context.Context, processor eventbus.Processor) error
  • func (sr *SendReceiver) Send(ctx context.Context, meta *event.Metadata, data []byte) error
  • func (sr *SendReceiver) Setup(ctx context.Context, serviceName string, infos ...eventbus.ServiceInfo) error

Variables

var (
	ErrNilContext  = errors.New("nil Context")
	ErrNilMetadata = errors.New("nil Metadata")
)

Types

type SendReceiver

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

func New

func New() *SendReceiver

func (*SendReceiver) Close

func (sr *SendReceiver) Close(_ context.Context)

func (*SendReceiver) Receive

func (sr *SendReceiver) Receive(ctx context.Context, processor eventbus.Processor) error

func (*SendReceiver) Send

func (sr *SendReceiver) Send(ctx context.Context, meta *event.Metadata, data []byte) error

func (*SendReceiver) Setup

func (sr *SendReceiver) Setup(ctx context.Context, serviceName string, infos ...eventbus.ServiceInfo) error