endpoint

Documentation

Index

• type EndpointEvent
  • func NewEndpointEvent(t EventType, obj interface{}) *EndpointEvent
• type EndpointWatcher
  • func Watcher() *EndpointWatcher
  • func (e *EndpointWatcher) Init(ctx context.Context) error
  • func (e *EndpointWatcher) Refresh(ctx context.Context) error
  • func (e *EndpointWatcher) Stop(ctx context.Context) error
• type EventType
  • func (e EventType) String() string

Types

type EndpointEvent

type EndpointEvent struct {
	// Type is the type of the event.
	Type EventType
	// Obj is the object that the event is about.
	Obj interface{}
}

func NewEndpointEvent

func NewEndpointEvent(t EventType, obj interface{}) *EndpointEvent

type EndpointWatcher

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

func Watcher

func Watcher() *EndpointWatcher

NewEndpointWatcher creates a new endpoint watcher.

func (*EndpointWatcher) Init

func (e *EndpointWatcher) Init(ctx context.Context) error

func (*EndpointWatcher) Refresh

func (e *EndpointWatcher) Refresh(ctx context.Context) error

func (*EndpointWatcher) Stop

func (e *EndpointWatcher) Stop(ctx context.Context) error

type EventType

type EventType int

const (
	EndpointCreated EventType = iota
	EndpointDeleted
)

func (EventType) String

func (e EventType) String() string