consumer

Documentation

Index

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

Types

type Layer

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

func NewConsumerLayer

func NewConsumerLayer() *Layer

func (*Layer) AnnounceNexus

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

AnnounceNexus creates a new consumer.ConsumerNexus and starts the handshake

func (*Layer) ConsumerFinishedCb

func (c *Layer) ConsumerFinishedCb(consumerNexus consumer.Nexus)

consume finished

func (*Layer) OnPing

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

event fired on ping

func (*Layer) RegisterAboveLayer

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

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

func (*Layer) RevokeNexus

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

func (*Layer) SetOnPing

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

func (*Layer) SetupConsumerNexus

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

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