priority

type Consensus ¶

type Consensus interface {
	ProposePriority(context.Context, Instance, *pbv1.PriorityResult) error
	SubscribePriority(func(context.Context, Instance, *pbv1.PriorityResult) error)
}

type Instance ¶ added in v0.11.0

type Instance proto.Message

Instance identifies an instance of the priority protocol.

type Prioritiser ¶

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

Prioritiser resolves cluster wide priorities.

func NewForT(tcpNode host.Host, peers []peer.ID, minRequired int, sendFunc p2p.SendReceiveFunc, registerHandlerFunc p2p.RegisterHandlerFunc,
	consensus Consensus, msgValidator msgValidator,
	consensusTimeout time.Duration, tickerProvider tickerProvider,
) *Prioritiser

func (p *Prioritiser) Prioritise(ctx context.Context, msg *pbv1.PriorityMsg) error

func (p *Prioritiser) Run(ctx context.Context) error

func (p *Prioritiser) Subscribe(fn subscriber)

type Priority ¶ added in v0.11.0

type Priority proto.Message

Priority is one of many grouped by a Topic being prioritised in an Instance.

type Topic ¶ added in v0.11.0

type Topic proto.Message

Topic groups priorities in an instance.