infosync

Documentation

Overview

Package infosync provides a simple use-case of the priority protocol that prioritises cluster supported versions.

Index

• type Component
  • func New(prioritiser *priority.Component, versions []string, protocols []protocol.ID) *Component
  • func (c *Component) Protocols(slot int64) []protocol.ID
  • func (c *Component) Trigger(ctx context.Context, slot int64) error

Types

type Component

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

func New

func New(prioritiser *priority.Component, versions []string, protocols []protocol.ID) *Component

New returns a new infosync component.

func (*Component) Protocols

func (c *Component) Protocols(slot int64) []protocol.ID

Protocols returns the latest cluster wide supported protocols before the slot. It returns the local protocols if no results before the slot are available.

func (*Component) Trigger

func (c *Component) Trigger(ctx context.Context, slot int64) error