syncers

Documentation

Index

• Constants
• Variables
• 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

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 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