app

Documentation

Index

• Constants
• func NewAgentCommand(a *Agent, o *options.GrpcProxyAgentOptions) *cobra.Command
• func SetupSignalHandler() (drainCh, stopCh <-chan struct{})
• type Agent
  • func (a *Agent) ClientSet() *agent.ClientSet
  • func (a *Agent) Run(o *options.GrpcProxyAgentOptions, drainCh, stopCh <-chan struct{}) error

Constants

const (
	ReadHeaderTimeout   = 60 * time.Second
	LeaseInformerResync = time.Second * 10
)

Functions

func NewAgentCommand

func NewAgentCommand(a *Agent, o *options.GrpcProxyAgentOptions) *cobra.Command

func SetupSignalHandler

func SetupSignalHandler() (drainCh, stopCh <-chan struct{})

Types

type Agent

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

func (*Agent) ClientSet

func (a *Agent) ClientSet() *agent.ClientSet

ClientSet exposes internal state for testing.

func (*Agent) Run

func (a *Agent) Run(o *options.GrpcProxyAgentOptions, drainCh, stopCh <-chan struct{}) error