executor

type ActionResult struct {

	// Types that are valid to be assigned to Outcome:
	//
	//	*ActionResult_Output
	//	*ActionResult_Error
	Outcome isActionResult_Outcome `protobuf_oneof:"outcome"`
	// contains filtered or unexported fields
}

type ActionResult_Error struct {
	Error *errorcode.ActionPlatformError `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type ActionResult_Output struct {
	Output []byte `protobuf:"bytes,1,opt,name=output,proto3,oneof"`
}

type ActionStatus struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ExecutorClient interface {
	// RunAction runs a single action and streams updates ending in a final ActionResult.
	RunAction(ctx context.Context, in *RunActionRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[RunActionResponse], error)
	// Health reports executor readiness and liveness; used to gate dispatch.
	Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
}

type ExecutorServer interface {
	// RunAction runs a single action and streams updates ending in a final ActionResult.
	RunAction(*RunActionRequest, grpc.ServerStreamingServer[RunActionResponse]) error
	// Health reports executor readiness and liveness; used to gate dispatch.
	Health(context.Context, *HealthRequest) (*HealthResponse, error)
	// contains filtered or unexported methods
}

type Executor_RunActionClient = grpc.ServerStreamingClient[RunActionResponse]

type Executor_RunActionServer = grpc.ServerStreamingServer[RunActionResponse]

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

type HealthResponse struct {
	Ready         bool   `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	ActiveActions int32  `protobuf:"varint,2,opt,name=active_actions,json=activeActions,proto3" json:"active_actions,omitempty"`
	Version       string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type RunActionRequest struct {
	Task []byte `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

type RunActionResponse struct {

	// Types that are valid to be assigned to Event:
	//
	//	*RunActionResponse_Status
	//	*RunActionResponse_Result
	Event isRunActionResponse_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

type RunActionResponse_Result struct {
	Result *ActionResult `protobuf:"bytes,2,opt,name=result,proto3,oneof"`
}

type RunActionResponse_Status struct {
	Status *ActionStatus `protobuf:"bytes,1,opt,name=status,proto3,oneof"`
}

type UnimplementedExecutorServer struct{}

type UnsafeExecutorServer interface {
	// contains filtered or unexported methods
}