store2diff

Documentation

Index

• type Job
  • func (j *Job) Run(ctx context.Context) (err error)
• type Sink

Types

type Job

type Job struct {
	Store *proxystore.Store
	Sets  []localv1.Set
	Sink  Sink
}

func (*Job) Run

func (j *Job) Run(ctx context.Context) (err error)

type Sink

type Sink interface {
	localv1.OpSink

	Wait() error
	Update(tx *proxystore.Tx, w *watchstate.WatchState)
	SendDiff(w *watchstate.WatchState) (updated bool)
}