supervisorproxy

Documentation

Overview

Package supervisorproxy package implements the supervisor interface and forwards the requests on this interface to a remote supervisor over an rpc call.

Index

• func NewTestSupervisorLauncher() supervisor.Supervisor
• type ProxyInfo
  • func NewProxySupervisor() *ProxyInfo
  • func (s *ProxyInfo) CleanUp() error
  • func (s *ProxyInfo) EnableIPTablesPacketTracing(ctx context.Context, contextID string, interval time.Duration) error
  • func (s *ProxyInfo) Run(ctx context.Context) error
  • func (s *ProxyInfo) SetTargetNetworks(cfg *runtime.Configuration) error
  • func (s *ProxyInfo) Supervise(contextID string, puInfo *policy.PUInfo) error
  • func (s *ProxyInfo) Unsupervise(contextID string) error
• type TestSupervisorLauncher

Functions

func NewTestSupervisorLauncher

func NewTestSupervisorLauncher() supervisor.Supervisor

NewTestSupervisorLauncher creates a mock supervisor

Types

type ProxyInfo

type ProxyInfo struct{}

ProxyInfo is a struct used to store state for the remote launcher.

func NewProxySupervisor

func NewProxySupervisor() *ProxyInfo

NewProxySupervisor creates a new IptablesSupervisor launcher

func (*ProxyInfo) CleanUp

func (s *ProxyInfo) CleanUp() error

CleanUp implements the cleanup interface, but it doesn't need to do anything.

func (*ProxyInfo) EnableIPTablesPacketTracing

func (s *ProxyInfo) EnableIPTablesPacketTracing(ctx context.Context, contextID string, interval time.Duration) error

EnableIPTablesPacketTracing enable iptables tracing

func (*ProxyInfo) Run

func (s *ProxyInfo) Run(ctx context.Context) error

Run runs the proxy supervisor and initializes the cleaners.

func (*ProxyInfo) SetTargetNetworks

func (s *ProxyInfo) SetTargetNetworks(cfg *runtime.Configuration) error

SetTargetNetworks sets the target networks in case of an update

func (*ProxyInfo) Supervise

func (s *ProxyInfo) Supervise(contextID string, puInfo *policy.PUInfo) error

Supervise just keeps track of the active remotes so that it can initiate updates.

func (*ProxyInfo) Unsupervise

func (s *ProxyInfo) Unsupervise(contextID string) error

Unsupervise just keeps track of the active remotes so

type TestSupervisorLauncher

type TestSupervisorLauncher interface {
	supervisor.Supervisor
}

TestSupervisorLauncher is a mock