localsink

Documentation

Index

• type Config
  • func (c *Config) BindFlags(flags *pflag.FlagSet)
  • func (c *Config) WaitRequest() (nodeName string, err error)
• type Sink

Types

type Config

type Config struct {
	NodeName string
}

func (*Config) BindFlags

func (c *Config) BindFlags(flags *pflag.FlagSet)

func (*Config) WaitRequest

func (c *Config) WaitRequest() (nodeName string, err error)

type Sink

type Sink interface {
	// Setup is called once, when the job starts
	Setup()

	// WaitRequest waits for the next diff request, returning the requested node name. If an error is returned, it will cancel the job.
	WaitRequest() (nodeName string, err error)

	// Reset the state of the Sink (ie: when the client is disconnected and reconnects)
	Reset()

	localv1.OpSink
}