consumer

Documentation

Index

• Constants
• type FinishedCb
• type Nexus
  • func NewConsumerNexus(belowNexus nexus.Nexus) *Nexus
  • func (c *Nexus) ConsumerFinishedCb()
  • func (c *Nexus) IsLayerMessage(message base2.MoneysocketMessage) bool
  • func (c *Nexus) OnBinMessage(belowNexus nexus.Nexus, msg []byte)
  • func (c *Nexus) OnMessage(belowNexus nexus.Nexus, msg base2.MoneysocketMessage)
  • func (c *Nexus) OnPing(consumerNexus nexus.Nexus, milliseconds int)
  • func (c *Nexus) SendPing()
  • func (c *Nexus) SetOnPing(fn OnPingFn)
  • func (c *Nexus) StartHandshake(cb FinishedCb)
  • func (c *Nexus) StartPinging()
  • func (c *Nexus) StopPinging()
• type OnPingFn

Constants

const NexusName = "ConsumerNexus"

Types

type FinishedCb

type FinishedCb func(consumerNexus Nexus)

type Nexus

type Nexus struct {
	*base.NexusBase
	// contains filtered or unexported fields
}

func NewConsumerNexus

func NewConsumerNexus(belowNexus nexus.Nexus) *Nexus

func (*Nexus) ConsumerFinishedCb

func (c *Nexus) ConsumerFinishedCb()

func (*Nexus) IsLayerMessage

func (c *Nexus) IsLayerMessage(message base2.MoneysocketMessage) bool

func (*Nexus) OnBinMessage

func (c *Nexus) OnBinMessage(belowNexus nexus.Nexus, msg []byte)

func (*Nexus) OnMessage

func (c *Nexus) OnMessage(belowNexus nexus.Nexus, msg base2.MoneysocketMessage)

func (*Nexus) OnPing

func (c *Nexus) OnPing(consumerNexus nexus.Nexus, milliseconds int)

func (*Nexus) SendPing

func (c *Nexus) SendPing()

send a ping up the chain

func (*Nexus) SetOnPing

func (c *Nexus) SetOnPing(fn OnPingFn)

func (*Nexus) StartHandshake

func (c *Nexus) StartHandshake(cb FinishedCb)

func (*Nexus) StartPinging

func (c *Nexus) StartPinging()

start pining on a set interval

func (*Nexus) StopPinging

func (c *Nexus) StopPinging()

type OnPingFn

type OnPingFn func(nexus nexus.Nexus, msecs int)