handler

Documentation

Index

• type Handler
  • func (h *Handler) Accepted(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)
  • func (h *Handler) AcceptedFrontier(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)
  • func (h *Handler) Chits(validatorID ids.ShortID, requestID uint32, votes ids.Set)
  • func (h *Handler) Context() *snow.Context
  • func (h *Handler) Dispatch()
  • func (h *Handler) Get(validatorID ids.ShortID, requestID uint32, containerID ids.ID)
  • func (h *Handler) GetAccepted(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)
  • func (h *Handler) GetAcceptedFailed(validatorID ids.ShortID, requestID uint32)
  • func (h *Handler) GetAcceptedFrontier(validatorID ids.ShortID, requestID uint32)
  • func (h *Handler) GetAcceptedFrontierFailed(validatorID ids.ShortID, requestID uint32)
  • func (h *Handler) GetFailed(validatorID ids.ShortID, requestID uint32, containerID ids.ID)
  • func (h *Handler) Initialize(engine common.Engine, msgChan <-chan common.Message, bufferSize int)
  • func (h *Handler) Notify(msg common.Message)
  • func (h *Handler) PullQuery(validatorID ids.ShortID, requestID uint32, blockID ids.ID)
  • func (h *Handler) PushQuery(validatorID ids.ShortID, requestID uint32, blockID ids.ID, block []byte)
  • func (h *Handler) Put(validatorID ids.ShortID, requestID uint32, containerID ids.ID, ...)
  • func (h *Handler) QueryFailed(validatorID ids.ShortID, requestID uint32)
  • func (h *Handler) Shutdown()

Types

type Handler

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

Handler passes incoming messages from the network to the consensus engine (Actually, it receives the incoming messages from a ChainRouter, but same difference)

func (*Handler) Accepted

func (h *Handler) Accepted(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

Accepted passes a Accepted message received from the network to the consensus engine.

func (*Handler) AcceptedFrontier

func (h *Handler) AcceptedFrontier(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

AcceptedFrontier passes a AcceptedFrontier message received from the network to the consensus engine.

func (*Handler) Chits

func (h *Handler) Chits(validatorID ids.ShortID, requestID uint32, votes ids.Set)

Chits passes a Chits message received from the network to the consensus engine.

func (*Handler) Context

func (h *Handler) Context() *snow.Context

Context of this Handler

func (*Handler) Dispatch

func (h *Handler) Dispatch()

Dispatch waits for incoming messages from the network and, when they arrive, sends them to the consensus engine

func (*Handler) Get

func (h *Handler) Get(validatorID ids.ShortID, requestID uint32, containerID ids.ID)

Get passes a Get message received from the network to the consensus engine.

func (*Handler) GetAccepted

func (h *Handler) GetAccepted(validatorID ids.ShortID, requestID uint32, containerIDs ids.Set)

GetAccepted passes a GetAccepted message received from the network to the consensus engine.

func (*Handler) GetAcceptedFailed

func (h *Handler) GetAcceptedFailed(validatorID ids.ShortID, requestID uint32)

GetAcceptedFailed passes a GetAcceptedFailed message received from the network to the consensus engine.

func (*Handler) GetAcceptedFrontier

func (h *Handler) GetAcceptedFrontier(validatorID ids.ShortID, requestID uint32)

GetAcceptedFrontier passes a GetAcceptedFrontier message received from the network to the consensus engine.

func (*Handler) GetAcceptedFrontierFailed

func (h *Handler) GetAcceptedFrontierFailed(validatorID ids.ShortID, requestID uint32)

GetAcceptedFrontierFailed passes a GetAcceptedFrontierFailed message received from the network to the consensus engine.

func (*Handler) GetFailed

func (h *Handler) GetFailed(validatorID ids.ShortID, requestID uint32, containerID ids.ID)

GetFailed passes a GetFailed message to the consensus engine.

func (*Handler) Initialize

func (h *Handler) Initialize(engine common.Engine, msgChan <-chan common.Message, bufferSize int)

Initialize this consensus handler

func (*Handler) Notify

func (h *Handler) Notify(msg common.Message)

Notify ...

func (*Handler) PullQuery

func (h *Handler) PullQuery(validatorID ids.ShortID, requestID uint32, blockID ids.ID)

PullQuery passes a PullQuery message received from the network to the consensus engine.

func (*Handler) PushQuery

func (h *Handler) PushQuery(validatorID ids.ShortID, requestID uint32, blockID ids.ID, block []byte)

PushQuery passes a PushQuery message received from the network to the consensus engine.

func (*Handler) Put

func (h *Handler) Put(validatorID ids.ShortID, requestID uint32, containerID ids.ID, container []byte)

Put passes a Put message received from the network to the consensus engine.

func (*Handler) QueryFailed

func (h *Handler) QueryFailed(validatorID ids.ShortID, requestID uint32)

QueryFailed passes a QueryFailed message received from the network to the consensus engine.

func (*Handler) Shutdown

func (h *Handler) Shutdown()

Shutdown shuts down the dispatcher