consumer

Documentation

Index

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

Constants

const ConsumerNexusName = "ConsumerNexus"

Types

type ConsumerFinishedCb

type ConsumerFinishedCb func(consumerNexus ConsumerNexus)

type ConsumerNexus

type ConsumerNexus struct {
	*base.BaseNexus
	// contains filtered or unexported fields
}

func NewConsumerNexus

func NewConsumerNexus(belowNexus nexus.Nexus) *ConsumerNexus

func (*ConsumerNexus) ConsumerFinishedCb

func (c *ConsumerNexus) ConsumerFinishedCb()

func (*ConsumerNexus) OnBinMessage

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

func (*ConsumerNexus) OnMessage

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

func (*ConsumerNexus) OnPing

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

func (*ConsumerNexus) SendPing

func (c *ConsumerNexus) SendPing()

send a ping up the chain

func (*ConsumerNexus) SetOnPing

func (c *ConsumerNexus) SetOnPing(fn OnPingFn)

func (*ConsumerNexus) StartHandshake

func (c *ConsumerNexus) StartHandshake(cb ConsumerFinishedCb)

func (*ConsumerNexus) StartPinging

func (c *ConsumerNexus) StartPinging()

start pining on a set interval

func (*ConsumerNexus) StopPinging

func (c *ConsumerNexus) StopPinging()

type OnPingFn

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