options

Documentation

Index

• type GrpcProxyAgentOptions
  • func NewGrpcProxyAgentOptions() *GrpcProxyAgentOptions
  • func (o *GrpcProxyAgentOptions) ClientSetConfig(dialOptions ...grpc.DialOption) *agent.ClientSetConfig
  • func (o *GrpcProxyAgentOptions) Flags() *pflag.FlagSet
  • func (o *GrpcProxyAgentOptions) Print()
  • func (o *GrpcProxyAgentOptions) Validate() error

Types

type GrpcProxyAgentOptions

type GrpcProxyAgentOptions struct {
	// Configuration for authenticating with the proxy-server
	AgentCert string
	AgentKey  string
	CaCert    string

	// Configuration for connecting to the proxy-server
	ProxyServerHost string
	ProxyServerPort int
	AlpnProtos      []string

	// Bind address for the health connections.
	HealthServerHost string
	// Port we listen for health connections on.
	HealthServerPort int
	// Bind address for the admin connections.
	AdminBindAddress string
	// Port we listen for admin connections on.
	AdminServerPort int
	// Enables pprof at host:adminPort/debug/pprof.
	EnableProfiling bool
	// If EnableProfiling is true, this enables the lock contention
	// profiling at host:adminPort/debug/pprof/block.
	EnableContentionProfiling bool

	AgentID          string
	AgentIdentifiers string
	SyncInterval     time.Duration
	ProbeInterval    time.Duration
	SyncIntervalCap  time.Duration
	// After a duration of this time if the agent doesn't see any activity it
	// pings the server to see if the transport is still alive.
	KeepaliveTime time.Duration

	// file contains service account authorization token for enabling proxy-server token based authorization
	ServiceAccountTokenPath string

	// This warns if we attempt to push onto a "full" transfer channel.
	// However checking that the transfer channel is full is not safe.
	// It violates our race condition checking. Adding locks around a potentially
	// blocking call has its own problems, so it cannot easily be made race condition safe.
	// The check is an "unlocked" read but is still use at your own peril.
	WarnOnChannelLimit bool

	SyncForever bool
}

func NewGrpcProxyAgentOptions

func NewGrpcProxyAgentOptions() *GrpcProxyAgentOptions

func (*GrpcProxyAgentOptions) ClientSetConfig

func (o *GrpcProxyAgentOptions) ClientSetConfig(dialOptions ...grpc.DialOption) *agent.ClientSetConfig

func (*GrpcProxyAgentOptions) Flags

func (o *GrpcProxyAgentOptions) Flags() *pflag.FlagSet

func (*GrpcProxyAgentOptions) Print

func (o *GrpcProxyAgentOptions) Print()

func (*GrpcProxyAgentOptions) Validate

func (o *GrpcProxyAgentOptions) Validate() error