node

Documentation

Index

• func LoadBuiltins(syncReq chan struct{}) chan types.PluginUpdateResponse
• type Config
• type ID
• type Node
  • func New(cfg Config) (Node, context.Context, error)
  • func (n *Node) Close() error
  • func (n *Node) Connect(ctx context.Context) error
  • func (n *Node) Handshake(ctx context.Context) error
  • func (n *Node) KeepPluginsUpToDate(ctxMetadata context.Context, specsSync chan struct{})
  • func (n *Node) KillPlugins()
  • func (n *Node) ListenTaskRequest(ctx context.Context) error
  • func (n *Node) NodePlugins(ctx context.Context) (map[string]string, error)
• type SpecsManager
  • func NewSpecsManager() (*SpecsManager, error)
  • func (s *SpecsManager) All() (map[string]any, error)
  • func (s *SpecsManager) Get(spec string) (any, error)
  • func (s *SpecsManager) List() ([]string, error)
  • func (s *SpecsManager) StartSpecCollector(ctx context.Context, syncReq chan struct{})

Functions

func LoadBuiltins

func LoadBuiltins(syncReq chan struct{}) chan types.PluginUpdateResponse

Types

type Config

type Config struct {
	ManagerAddress     string
	ManagerPort        string
	NodeID             string
	MTLSEnabled        bool
	MTLSCert           string
	MTLSKey            string
	MTLSManagerCA      string
	PluginDir          string
	PluginServerPort   string
	CustomResolvers    []string
	MaxConcurrentTasks int
	MaxWaitingRequests int
}

Config holds the configuration for creating a new Node.

type ID

type ID string

type Node

type Node struct {
	SpecManager *SpecsManager
	// contains filtered or unexported fields
}

func New

func New(cfg Config) (Node, context.Context, error)

New returns a new Node and an initialized context containing values like node_id.

While the node is the client from GRPC perspective, it is the server from application perspective, i.e. the manager (GRPC server) sends requests to the node (GRPC client) via a bidi GRPC stream.

func (*Node) Close

func (n *Node) Close() error

func (*Node) Connect

func (n *Node) Connect(ctx context.Context) error

func (*Node) Handshake

func (n *Node) Handshake(ctx context.Context) error

func (*Node) KeepPluginsUpToDate

func (n *Node) KeepPluginsUpToDate(ctxMetadata context.Context, specsSync chan struct{})

func (*Node) KillPlugins

func (n *Node) KillPlugins()

func (*Node) ListenTaskRequest

func (n *Node) ListenTaskRequest(ctx context.Context) error

func (*Node) NodePlugins

func (n *Node) NodePlugins(ctx context.Context) (map[string]string, error)

type SpecsManager

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

func NewSpecsManager

func NewSpecsManager() (*SpecsManager, error)

func (*SpecsManager) All

func (s *SpecsManager) All() (map[string]any, error)

func (*SpecsManager) Get

func (s *SpecsManager) Get(spec string) (any, error)

func (*SpecsManager) List

func (s *SpecsManager) List() ([]string, error)

func (*SpecsManager) StartSpecCollector

func (s *SpecsManager) StartSpecCollector(ctx context.Context, syncReq chan struct{})