destination

Documentation

Index

• Variables
• type NVCKey
  • func (nv NVCKey) String() string
• type Scheme
  • func NewScheme(logger *zap.Logger) *Scheme
  • func (s *Scheme) Add(t Target)
  • func (s *Scheme) AddManager(address string)
  • func (s *Scheme) Get(nv NVCKey) (Target, bool)
  • func (s *Scheme) Refresh(ctx context.Context) error
  • func (s *Scheme) RegisterHandles(smux *http.ServeMux)
• type Target
• type WorkerConnection
• type WorkerInfoStatic
• type WorkerNetworkStatic

Variables

var WorkerStateOnline int64 = 1

Types

type NVCKey

type NVCKey struct {
	Network string
	Version string
	ChainID string
}

func (NVCKey) String

func (nv NVCKey) String() string

type Scheme

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

func NewScheme

func NewScheme(logger *zap.Logger) *Scheme

func (*Scheme) Add

func (s *Scheme) Add(t Target)

func (*Scheme) AddManager

func (s *Scheme) AddManager(address string)

func (*Scheme) Get

func (s *Scheme) Get(nv NVCKey) (Target, bool)

func (*Scheme) Refresh

func (s *Scheme) Refresh(ctx context.Context) error

func (*Scheme) RegisterHandles

func (s *Scheme) RegisterHandles(smux *http.ServeMux)

type Target

type Target struct {
	ChainID string
	Network string
	Version string
	Address string
}

type WorkerConnection

type WorkerConnection struct {
	Version string `json:"version"`
	ChainID string `json:"chain_id"`
	Type    string `json:"type"`
}

type WorkerInfoStatic

type WorkerInfoStatic struct {
	NodeSelfID     string             `json:"node_id"`
	Type           string             `json:"type"`
	State          int64              `json:"state"`
	ConnectionInfo []WorkerConnection `json:"connection"`
	LastCheck      time.Time          `json:"last_check"`
}

type WorkerNetworkStatic

type WorkerNetworkStatic struct {
	Workers map[string]WorkerInfoStatic `json:"workers"`
	All     int                         `json:"all"`
	Active  int                         `json:"active"`
}