daemon

Documentation

Index

• Variables
• type Daemon
  • func New(cfg *config.Config, nw *networkallocator.NetworkAllocator, opts ...Opts) *Daemon
  • func (d *Daemon) CleanUp() error
  • func (d *Daemon) Connect(ctx context.Context, endpointName string) error
  • func (d *Daemon) DNSEntries() []dnsallocator.DNSEntry
  • func (d *Daemon) Disconnect(endpoint string) error
  • func (d *Daemon) Exit()
  • func (d *Daemon) GetConfig() *config.Config
  • func (d *Daemon) GetStatus() Status
  • func (d *Daemon) StartService(ctx context.Context, endpoint string, svc string) error
  • func (d *Daemon) StopService(endpoint string, svc string) error
• type OperationalBridge
• type OperationalEndPoint
  • func NewOperationalEndPoint() *OperationalEndPoint
• type Opts
  • func WithMetrics(m metrics.Factory) Opts
• type Status
• type StatusBridges
• type StatusEndPoints

Variables

var (
	ErrEndpointAlreadyConnected = fmt.Errorf("endpoint already connect")
	ErrEndpointNotConnected     = fmt.Errorf("endpoint not connect")
	ErrBridgeNotFound           = fmt.Errorf("bridge not found")
	ErrBridgeAlreadyConnected   = fmt.Errorf("bridge already connected")
	ErrBridgeDirectionInvalid   = fmt.Errorf("bridge direction invalid")
)

Types

type Daemon

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

func New

func New(cfg *config.Config, nw *networkallocator.NetworkAllocator, opts ...Opts) *Daemon

func (*Daemon) CleanUp

func (d *Daemon) CleanUp() error

func (*Daemon) Connect

func (d *Daemon) Connect(ctx context.Context, endpointName string) error

func (*Daemon) DNSEntries

func (d *Daemon) DNSEntries() []dnsallocator.DNSEntry

func (*Daemon) Disconnect

func (d *Daemon) Disconnect(endpoint string) error

func (*Daemon) Exit

func (d *Daemon) Exit()

func (*Daemon) GetConfig

func (d *Daemon) GetConfig() *config.Config

func (*Daemon) GetStatus

func (d *Daemon) GetStatus() Status

func (*Daemon) StartService

func (d *Daemon) StartService(ctx context.Context, endpoint string, svc string) error

func (*Daemon) StopService

func (d *Daemon) StopService(endpoint string, svc string) error

type OperationalBridge

type OperationalBridge struct {
	netmux.Bridge
	// contains filtered or unexported fields
}

type OperationalEndPoint

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

func NewOperationalEndPoint

func NewOperationalEndPoint() *OperationalEndPoint

type Opts

type Opts func(d *Daemon)

func WithMetrics

func WithMetrics(m metrics.Factory) Opts

type Status

type Status struct {
	Endpoints []StatusEndPoints `json:"endpoints"`
}

type StatusBridges

type StatusBridges struct {
	netmux.Bridge
	Status string `json:"status"`
}

type StatusEndPoints

type StatusEndPoints struct {
	config.Endpoint
	Status  string          `json:"status"`
	Bridges []StatusBridges `json:"bridges"`
}