ktog

Documentation

Index

• Constants
• type GatewaySource
  • func (gw *GatewaySource) Delete(key string, raw interface{}) error
  • func (gw *GatewaySource) Informer() cache.SharedIndexInformer
  • func (gw *GatewaySource) SetServiceResource(serviceResource *KtoGSource)
  • func (gw *GatewaySource) Upsert(key string, raw interface{}) error
• type KtoGSource
  • func NewKtoGSource(controller connector.ConnectController, syncer Syncer, ...) *KtoGSource
  • func (t *KtoGSource) Delete(key string, _ interface{}) error
  • func (t *KtoGSource) Informer() cache.SharedIndexInformer
  • func (t *KtoGSource) Run(ch <-chan struct{})
  • func (t *KtoGSource) Upsert(key string, raw interface{}) error
• type KtoGSyncer
  • func NewKtoGSyncer(controller connector.ConnectController, gatewaySource *GatewaySource) *KtoGSyncer
  • func (s *KtoGSyncer) Run(ctx context.Context, ctrls ...*connector.CacheController)
  • func (s *KtoGSyncer) Sync(rs []*corev1.Service)
• type Syncer

Constants

const (
	// SyncPeriod is how often the syncer will attempt to
	// reconcile the expected Service states.
	SyncPeriod = 5 * time.Second

	// ServicePollPeriod is how often a Service is checked for
	// whether it has instances to reap.
	ServicePollPeriod = 10 * time.Second
)

Types

type GatewaySource

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

GatewaySource implements controller.Resource and starts a background watcher o gateway to keep track of changing gateway.

func (*GatewaySource) Delete

func (gw *GatewaySource) Delete(key string, raw interface{}) error

func (*GatewaySource) Informer

func (gw *GatewaySource) Informer() cache.SharedIndexInformer

func (*GatewaySource) SetServiceResource

func (gw *GatewaySource) SetServiceResource(serviceResource *KtoGSource)

func (*GatewaySource) Upsert

func (gw *GatewaySource) Upsert(key string, raw interface{}) error

type KtoGSource

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

KtoGSource implements controller.Resource to sync Service source types from K8S.

func NewKtoGSource

func NewKtoGSource(controller connector.ConnectController, syncer Syncer,
	gatewaySource *GatewaySource,
	fsmNamespace string,
	kubeClient kubernetes.Interface,
	gatewayClient gwapi.Interface,
	ctx context.Context) *KtoGSource

func (*KtoGSource) Delete

func (t *KtoGSource) Delete(key string, _ interface{}) error

Delete implements the controller.Resource interface.

func (*KtoGSource) Informer

func (t *KtoGSource) Informer() cache.SharedIndexInformer

Informer implements the controller.Resource interface.

func (*KtoGSource) Run

func (t *KtoGSource) Run(ch <-chan struct{})

Run implements the controller.Backgrounder interface.

func (*KtoGSource) Upsert

func (t *KtoGSource) Upsert(key string, raw interface{}) error

Upsert implements the controller.Resource interface.

type KtoGSyncer

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

KtoGSyncer is a Syncer that takes the set of gateway routes.

func NewKtoGSyncer

func NewKtoGSyncer(controller connector.ConnectController,
	gatewaySource *GatewaySource) *KtoGSyncer

func (*KtoGSyncer) Run

func (s *KtoGSyncer) Run(ctx context.Context, ctrls ...*connector.CacheController)

Run is the long-running runloop for reconciling the local set of services to register with the remote state.

func (*KtoGSyncer) Sync

func (s *KtoGSyncer) Sync(rs []*corev1.Service)

Sync implements Syncer.

type Syncer

type Syncer interface {
	// Sync is called to sync the full set of registrations.
	Sync([]*corev1.Service)
}

Syncer is responsible for syncing a set of gateway routes.