syncers

Documentation

Index

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

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 negtypes.NegSyncerKey, networkEndpointGroupName string, recorder record.EventRecorder, cloud negtypes.NetworkEndpointGroupCloud, zoneGetter negtypes.ZoneGetter, serviceLister cache.Indexer, endpointLister cache.Indexer, podLister 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 negtypes.NegSyncerKey, networkEndpointGroupName string, recorder record.EventRecorder, cloud negtypes.NetworkEndpointGroupCloud, zoneGetter negtypes.ZoneGetter, podLister cache.Indexer, serviceLister cache.Indexer, endpointLister cache.Indexer, reflector readiness.Reflector) negtypes.NegSyncer

func NewTransactionTable

func NewTransactionTable() networkEndpointTransactionTable

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