node

Documentation

Index

• Constants
• Variables
• type GWOptions
• type Gateway
  • func NewGateway(opts GWOptions) *Gateway
  • func (n *Gateway) AwaitSMCRound(stream proto.Gateway_AwaitSMCRoundServer) error
  • func (n *Gateway) Ping(ctx context.Context, in *proto.SMCInfo) (*pbJob.CmdResult, error)
  • func (g *Gateway) Run()
• type Options
• type Peer
  • func NewPeer(opts PeerOptions) *Peer
  • func (p *Peer) Init()
  • func (p *Peer) Operate()
  • func (p *Peer) Run()
• type PeerOptions
• type RunState

Constants

const RetryConnection = 5

Variables

var (
	ErrPermDenied = errors.New("access denied")
)

Types

type GWOptions

type GWOptions struct {
	Registry        *directory.Registry
	SRpcOpts        []server.Option
	AnnounceService bool
	Options
}

type Gateway

type Gateway struct {
	// sRPC mandatory base layer
	server.Server
	// contains filtered or unexported fields
}

func NewGateway

func NewGateway(opts GWOptions) *Gateway

func (*Gateway) AwaitSMCRound

func (n *Gateway) AwaitSMCRound(stream proto.Gateway_AwaitSMCRoundServer) error

func (*Gateway) Ping

func (n *Gateway) Ping(ctx context.Context, in *proto.SMCInfo) (*pbJob.CmdResult, error)

func (*Gateway) Run

func (g *Gateway) Run()

type Options

type Options struct {
	// Certificate for TLS Client Auth and Identification.
	CertFile string
	KeyFile  string
	// Interface specifies the interface to pin for discovery.
	Inteface string
	// Pairing and registration.
	NodeInfo   string
	UsePairing bool
}

type Peer

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

func NewPeer

func NewPeer(opts PeerOptions) *Peer

func (*Peer) Init

func (p *Peer) Init()

func (*Peer) Operate

func (p *Peer) Operate()

func (*Peer) Run

func (p *Peer) Run()

type PeerOptions

type PeerOptions struct {
	GatewayID  string
	SmcBackend smc.Connector
	SRpcOpts   []client.Option
	Options
}

type RunState

type RunState uint8

const (
	Discovery RunState = iota
	Pairing
	Resolving
	Connecting
	Operating
	Restart
)