bridge

Documentation

Index

• func Send(msg model.GobMessage)
• func SendAndRecv(msg model.GobMessage, timeout int) (reply *model.GobMessage, err error)
• func SetupBridge(cfg *config.Dendrite)
• type Bridge
  • func (b *Bridge) OnMessage(ctx context.Context, topic string, partition int32, data []byte, ...)
  • func (b *Bridge) Send(msg model.GobMessage)
  • func (b *Bridge) SendAndRecv(msg model.GobMessage, timeout int) (reply *model.GobMessage, err error)
  • func (b *Bridge) SetupBridge(cfg *config.Dendrite)

Functions

func Send

func Send(msg model.GobMessage)

func SendAndRecv

func SendAndRecv(msg model.GobMessage, timeout int) (reply *model.GobMessage, err error)

func SetupBridge

func SetupBridge(cfg *config.Dendrite)

Types

type Bridge

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

func (*Bridge) OnMessage

func (b *Bridge) OnMessage(ctx context.Context, topic string, partition int32, data []byte, rawMsg interface{})

func (*Bridge) Send

func (b *Bridge) Send(msg model.GobMessage)

func (*Bridge) SendAndRecv

func (b *Bridge) SendAndRecv(msg model.GobMessage, timeout int) (reply *model.GobMessage, err error)

func (*Bridge) SetupBridge

func (b *Bridge) SetupBridge(cfg *config.Dendrite)