node

Documentation

Index

• type Config
  • func NewConfig(path string) (Config, error)
• type HandlerStatus
  • func (h HandlerStatus) String() string
• type Node
  • func New(ctx context.Context, c Config, key *ecdsa.PrivateKey) (*Node, error)
  • func (n *Node) InterceptStreamRequest(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
  • func (n *Node) Serve() error

Types

type Config

type Config interface {
	// ListenAddress is gRPC endpoint that Node binds to
	ListenAddress() string
	// MarketEndpoint is Marketplace gRPC endpoint
	MarketEndpoint() string
	// HubEndpoint is Hub's gRPC endpoint (not required)
	HubEndpoint() string
	// LocatorEndpoint is Locator service gRPC endpoint
	LocatorEndpoint() string
	// LogLevel return log verbosity
	LogLevel() int
	// MetricsListenAddr returns the address that can be used by Prometheus to get
	// metrics.
	MetricsListenAddr() string
	// KeyStorager included into config because of
	// Node instance must know how to open the keystore
	accounts.KeyStorager
}

Config is LocalNode config

func NewConfig

func NewConfig(path string) (Config, error)

NewConfig loads localNode config from given .yaml file

type HandlerStatus

type HandlerStatus uint8

func (HandlerStatus) String

func (h HandlerStatus) String() string

type Node

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

Node is LocalNode instance

func New

func New(ctx context.Context, c Config, key *ecdsa.PrivateKey) (*Node, error)

New creates new Local Node instance also method starts internal gRPC client connections to the external services like Market and Hub

func (*Node) InterceptStreamRequest

func (n *Node) InterceptStreamRequest(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func (*Node) Serve

func (n *Node) Serve() error

Serve binds gRPC services and start it