mq

Documentation

Index

• func CreateChannel(ctx context.Context, prjName string, hdl OnMessage) error
• func StopChannel(prjName string)
• type ChannelContext
  • func (cc *ChannelContext) Run(ctx context.Context)
  • func (cc *ChannelContext) Stop()
• type OnMessage

Functions

func CreateChannel

func CreateChannel(ctx context.Context, prjName string, hdl OnMessage) error

func StopChannel

func StopChannel(prjName string)

Types

type ChannelContext

type ChannelContext struct {
	Name string
	// contains filtered or unexported fields
}

func (*ChannelContext) Run

func (cc *ChannelContext) Run(ctx context.Context)

func (*ChannelContext) Stop

func (cc *ChannelContext) Stop()

type OnMessage

type OnMessage func(ctx context.Context, channel string, data *eventpb.Event) (interface{}, error)