znet

Documentation

Index

• Constants
• Variables
• func LoadEnvironment(cfg *config.VaultConfig, e *config.EnvironmentConfig) (map[string]string, error)
• func PeerCN(streamContext context.Context) string
• type Config
  • func LoadConfig(file string) (Config, error)
  • func (c *Config) RegisterFlagsAndApplyDefaults(prefix string, f *flag.FlagSet)
• type Znet
  • func New(cfg Config) (*Znet, error)
  • func (z *Znet) Run() error

Constants

const (
	Server string = "server"

	Harvester string = "harvester"
	Timer     string = "timer"

	Telemetry string = "telemetry"
	IOT       string = "iot"
	Lights    string = "lights"
	Inventory string = "inventory"

	All string = "all"
)

Variables

var ErrNoGRPCServices = errors.New("no grpc services")

ErrNoGRPCServices is used to indicate that no grpc services are found on the server.

Functions

func LoadEnvironment

func LoadEnvironment(cfg *config.VaultConfig, e *config.EnvironmentConfig) (map[string]string, error)

LoadEnvironment reads reads environment variables out of vault for return.

func PeerCN

func PeerCN(streamContext context.Context) string

Types

type Config

type Config struct {
	Target       string `yaml:"target"`
	OtelEndpoint string `yaml:"otel_endpoint"`

	// modules
	Server    server.Config    `yaml:"server,omitempty"`
	Harvester harvester.Config `yaml:"harvester"`
	Inventory inventory.Config `yaml:"inventory"`
	IOT       iot.Config       `yaml:"iot"`
	Lights    lights.Config    `yaml:"lights"`
	Telemetry telemetry.Config `yaml:"telemetry"`
	Timer     timer.Config     `yaml:"timer"`

	RPC config.RPCConfig `yaml:"rpc,omitempty"`
}

func LoadConfig

func LoadConfig(file string) (Config, error)

LoadConfig receives a file path for a configuration to load.

func (*Config) RegisterFlagsAndApplyDefaults

func (c *Config) RegisterFlagsAndApplyDefaults(prefix string, f *flag.FlagSet)

type Znet

type Znet struct {
	Server *server.Server

	ModuleManager *modules.Manager
	// contains filtered or unexported fields
}

Znet is the core object for this project. It keeps track of the data, configuration and flow control for starting the server process.

func New

func New(cfg Config) (*Znet, error)

New creates and returns a new Znet object.

func (*Znet) Run

func (z *Znet) Run() error