syncers

Documentation

Index

• Constants
• Variables
• func NewBatchSyncer(svcPort NegSyncerKey, networkEndpointGroupName string, ...) *batchSyncer
• func NewDelayRetryHandler(retryFunc func(), backoff backoffHandler) *backoffRetryHandler
• func NewExponentialBackendOffHandler(maxRetries int, minRetryDelay, maxRetryDelay time.Duration) *exponentialBackOffHandler
• func NewTransactionSyncer(negSyncerKey NegSyncerKey, networkEndpointGroupName string, ...) negtypes.NegSyncer
• func NewTransactionTable() transactionTable
• type ErrorList
  • func (e *ErrorList) Add(err error)
  • func (e *ErrorList) List() []error
• type NegSyncerKey
  • func (key NegSyncerKey) String() string

Constants

const (
	MAX_NETWORK_ENDPOINTS_PER_BATCH = 500
)

Variables

var ErrHandlerRetrying = fmt.Errorf("retry handler is retrying")

var ErrRetriesExceeded = fmt.Errorf("maximum retry exceeded")

Functions

func NewBatchSyncer

func NewBatchSyncer(svcPort NegSyncerKey, networkEndpointGroupName string, recorder record.EventRecorder, cloud negtypes.NetworkEndpointGroupCloud, zoneGetter negtypes.ZoneGetter, serviceLister cache.Indexer, endpointLister cache.Indexer) *batchSyncer

func NewDelayRetryHandler

func NewDelayRetryHandler(retryFunc func(), backoff backoffHandler) *backoffRetryHandler

func NewExponentialBackendOffHandler

func NewExponentialBackendOffHandler(maxRetries int, minRetryDelay, maxRetryDelay time.Duration) *exponentialBackOffHandler

func NewTransactionSyncer

func NewTransactionSyncer(negSyncerKey NegSyncerKey, networkEndpointGroupName string, recorder record.EventRecorder, cloud negtypes.NetworkEndpointGroupCloud, zoneGetter negtypes.ZoneGetter, serviceLister cache.Indexer, endpointLister cache.Indexer) negtypes.NegSyncer

func NewTransactionTable

func NewTransactionTable() transactionTable

Types

type ErrorList

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

func (*ErrorList) Add

func (e *ErrorList) Add(err error)

func (*ErrorList) List

func (e *ErrorList) List() []error

type NegSyncerKey

type NegSyncerKey struct {
	Namespace  string
	Name       string
	Port       int32
	TargetPort string
}

NegSyncerKey includes information to uniquely identify a NEG

func (NegSyncerKey) String

func (key NegSyncerKey) String() string