agentspecbackfillprocess

type Config struct {
	ControllerImageDigest string
	WatchRetry            time.Duration
}

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

type Source interface {
	List(context.Context) ([][]byte, error)
	Watch(context.Context) (Watch, error)
}

type StatusStore interface {
	ReadTerminal(context.Context, agentspecbackfillcr.Request) (agentspecbackfillcr.Status, bool, error)
	CreateTerminal(context.Context, agentspecbackfillcr.Request, agentspecbackfillcr.Status) (stored agentspecbackfillcr.Status, created bool, err error)
}

type Wait func(context.Context, time.Duration) error

type Watch interface {
	Next(context.Context) ([]byte, error)
	Close() error
}