adaptor

Documentation

Index

• func AdaptImplsToBuilder(builder walimpls.OpenerBuilderImpls) wal.OpenerBuilder
• type MsgPackAdaptorHandler
  • func NewMsgPackAdaptorHandler() *MsgPackAdaptorHandler
  • func (m *MsgPackAdaptorHandler) Chan() <-chan *msgstream.MsgPack
  • func (m *MsgPackAdaptorHandler) Close()
  • func (m *MsgPackAdaptorHandler) Handle(ctx context.Context, upstream <-chan message.ImmutableMessage, ...) (incoming message.ImmutableMessage, ok bool, err error)

Functions

func AdaptImplsToBuilder

func AdaptImplsToBuilder(builder walimpls.OpenerBuilderImpls) wal.OpenerBuilder

Types

type MsgPackAdaptorHandler

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

MsgPackAdaptorHandler is the handler for message pack.

func NewMsgPackAdaptorHandler

func NewMsgPackAdaptorHandler() *MsgPackAdaptorHandler

NewMsgPackAdaptorHandler create a new message pack adaptor handler.

func (*MsgPackAdaptorHandler) Chan

func (m *MsgPackAdaptorHandler) Chan() <-chan *msgstream.MsgPack

Chan is the channel for message.

func (*MsgPackAdaptorHandler) Close

func (m *MsgPackAdaptorHandler) Close()

Close closes the handler.

func (*MsgPackAdaptorHandler) Handle

func (m *MsgPackAdaptorHandler) Handle(ctx context.Context, upstream <-chan message.ImmutableMessage, msg message.ImmutableMessage) (incoming message.ImmutableMessage, ok bool, err error)

Handle is the callback for handling message.