Interface ActionsServiceClient

gen/go/flyteidl2/actions/actions_service_grpc.pb.go:32–51

ActionsServiceClient is the client API for ActionsService service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type ActionsServiceClient interface {
	// Enqueue queues a new action for execution.
	Enqueue(ctx context.Context, in *EnqueueRequest, opts ...grpc.CallOption) (*EnqueueResponse, error)
	// WatchForUpdates watches for updates to the state of actions.
	// This API guarantees at-least-once delivery semantics.
	WatchForUpdates(ctx context.Context, in *WatchForUpdatesRequest, opts ...grpc.CallOption) (ActionsService_WatchForUpdatesClient, error)
	// Update updates the status of an action and saves serialized NodeStatus.
	// This deprecates Put in the current StateService.
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
	// Abort aborts a single action that was previously queued or is currently being processed by a worker.
	// Note that this will cascade aborts to all descendant actions of the specified action.
	Abort(ctx context.Context, in *AbortRequest, opts ...grpc.CallOption) (*AbortResponse, error)
	// Signal resolves a ConditionAction by providing its signal value.
	// On success, transitions the condition to SUCCEEDED with the provided
	// value as its output.
	// Returns FAILED_PRECONDITION if the action is not a condition or is
	// already terminal. Returns NOT_FOUND if the action does not exist.
	// Returns ABORTED if the action has a write in-flight (retry).
	Signal(ctx context.Context, in *SignalRequest, opts ...grpc.CallOption) (*SignalResponse, error)
}

type actionsServiceClient struct {
	cc grpc.ClientConnInterface