core

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

type LocalCmd struct {
	Sync    bool            `json:"sync"`
	Content json.RawMessage `json:"content"`
}

type LocalResult struct {
	State  string          `json:"state"`
	Error  string          `json:"error,omitempty"`
	Result *core.JobResult `json:"result,omitempty"`
}

type Sink interface {
	Run()
}

type SinkClient interface {
	GetNext(command *core.Command) error
	Respond(result *core.JobResult) error
}