module

type ActionDesc struct {
	Name        string `json:"name"`
	Description string `json:"description"`
	ParamSchema string `json:"param_schema"`
	// contains filtered or unexported fields
}

type ActionRequest struct {
	Name   string          `json:"name"`
	Params json.RawMessage `json:"params"`
}

type Descriptor struct {
	Kind         string            `json:"kind"`
	Actions      []ActionDesc      `json:"actions"`
	Dependencies map[string]string `json:"dependencies"`
	Module       Module            `json:"-"`
}

type LogChunk struct {
	Data   []byte            `json:"data"`
	Labels map[string]string `json:"labels"`
}

type Loggable interface {
	Module

	Log(ctx context.Context, spec Spec, filter map[string]string) (<-chan LogChunk, error)
}

type Module interface {
	// Plan SHOULD validate the action on the current version of the resource,
	// return the resource with config/status/state changes (if any) applied.
	// Plan SHOULD NOT have side effects on anything other than the resource.
	Plan(ctx context.Context, spec Spec, act ActionRequest) (*resource.Resource, error)

	// Sync is called repeatedly by Entropy core until the returned state is
	// a terminal status. Module implementation is free to execute an action
	// in a single Sync() call or split into steps for better feedback to the
	// end-user about the progress.
	// Sync can return state in resource.StatusDeleted to indicate resource
	// should be removed from the Entropy storage.
	Sync(ctx context.Context, spec Spec) (*resource.State, error)
}

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

type ResolvedDependency struct {
	Kind   string          `json:"kind"`
	Output json.RawMessage `json:"output"`
}

type Spec struct {
	Resource     resource.Resource             `json:"resource"`
	Dependencies map[string]ResolvedDependency `json:"dependencies"`
}