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(param wal.HandleParam) wal.HandleResult

Functions

func AdaptImplsToBuilder

func AdaptImplsToBuilder(builder walimpls.OpenerBuilderImpls) wal.OpenerBuilder

Types

type MsgPackAdaptorHandler

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

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(param wal.HandleParam) wal.HandleResult

Handle is the callback for handling message.