k8sreflector

Documentation

Index

• type EndpointReflector
  • func NewEndpointReflector(c kubernetes.Interface, s snapshots.SnapshotSetter, cfg ReflectorConfig) *EndpointReflector
  • func (r *EndpointReflector) Watch(ctx context.Context) error
• type ReflectorConfig
• type ServiceReflector
  • func NewServiceReflector(c kubernetes.Interface, s snapshots.SnapshotSetter, cfg ReflectorConfig) *ServiceReflector
  • func (r *ServiceReflector) Watch(ctx context.Context) error

Types

type EndpointReflector

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

func NewEndpointReflector

func NewEndpointReflector(c kubernetes.Interface, s snapshots.SnapshotSetter, cfg ReflectorConfig) *EndpointReflector

NewEndpointReflector ... create a new instance of *EndpointReflector

func (*EndpointReflector) Watch

func (r *EndpointReflector) Watch(ctx context.Context) error

Watch ... run the reflector to watching against k8s API to get the information about endpoint resources

type ReflectorConfig

type ReflectorConfig struct {
	ResyncPeriod time.Duration
}

ReflectorConfig ... reflector configuration

type ServiceReflector

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

func NewServiceReflector

func NewServiceReflector(c kubernetes.Interface, s snapshots.SnapshotSetter, cfg ReflectorConfig) *ServiceReflector

NewServiceReflector ... create a new instance of *ServiceReflector

func (*ServiceReflector) Watch

func (r *ServiceReflector) Watch(ctx context.Context) error

Watch ... run the reflector to watching against k8s API to get the information about service resources