fullstate

package

v0.0.0-...-edb81cd Latest Latest Go to latest Published: Jul 9, 2024 License: Apache-2.0 Imports: 4 Imported by: 6

Details

This section is empty.

This section is empty.

This section is empty.

type Callback func(item <-chan *ServiceEndpoints)

func ArrayCallback(callback func([]*ServiceEndpoints)) Callback

ArrayCallback wraps a array callback

type ServiceEndpoints struct {
	Service   *localv1.Service
	Endpoints []*localv1.Endpoint
}

type Setup func()

type Sink struct {
	Config    *localsink.Config
	Callback  Callback
	SetupFunc Setup
	// contains filtered or unexported fields
}

func New(config *localsink.Config) *Sink

func (s *Sink) Reset()

func (s *Sink) Send(op *localv1.OpItem) (err error)

func (s *Sink) Setup()

func (s *Sink) WaitRequest() (nodeName string, err error)

Path	Synopsis
fullstatepipe