consumer

Documentation

Index

• type ConsumerLayer
  • func NewConsumerLayer() *ConsumerLayer
  • func (c *ConsumerLayer) AnnounceNexus(belowNexus nexus.Nexus)
  • func (c *ConsumerLayer) ConsumerFinishedCb(consumerNexus consumer.ConsumerNexus)
  • func (c *ConsumerLayer) OnPing(consumerNexus nexus.Nexus, milliseconds int)
  • func (c *ConsumerLayer) RegisterAboveLayer(belowLayer layer.Layer)
  • func (c *ConsumerLayer) RevokeNexus(belowNexus nexus.Nexus)
  • func (c *ConsumerLayer) SetOnPing(fn consumer.OnPingFn)
  • func (c *ConsumerLayer) SetupConsumerNexus(belowNexus nexus.Nexus)

Types

type ConsumerLayer

type ConsumerLayer struct {
	layer.BaseLayer
	// contains filtered or unexported fields
}

func NewConsumerLayer

func NewConsumerLayer() *ConsumerLayer

func (*ConsumerLayer) AnnounceNexus

func (c *ConsumerLayer) AnnounceNexus(belowNexus nexus.Nexus)

AnnounceNexus creates a new consumer.ConsumerNexus and starts the handshake

func (*ConsumerLayer) ConsumerFinishedCb

func (c *ConsumerLayer) ConsumerFinishedCb(consumerNexus consumer.ConsumerNexus)

consume finished

func (*ConsumerLayer) OnPing

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

event fired on ping

func (*ConsumerLayer) RegisterAboveLayer

func (c *ConsumerLayer) RegisterAboveLayer(belowLayer layer.Layer)

RegisterAboveLayer registers the current nexuses announce/revoke nexuses to the below layer

func (*ConsumerLayer) RevokeNexus

func (c *ConsumerLayer) RevokeNexus(belowNexus nexus.Nexus)

func (*ConsumerLayer) SetOnPing

func (c *ConsumerLayer) SetOnPing(fn consumer.OnPingFn)

func (*ConsumerLayer) SetupConsumerNexus

func (c *ConsumerLayer) SetupConsumerNexus(belowNexus nexus.Nexus)

initialize consumer nexus and tie the onping event back to this layer