remoteexecution

type ExecuteRequest struct {
	Action   *encryptedaction.Action `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
	Priority int32                   `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteResponse struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are valid to be assigned to Stage:
	//
	//	*ExecuteResponse_Queued_
	//	*ExecuteResponse_Executing_
	//	*ExecuteResponse_Completed_
	Stage isExecuteResponse_Stage `protobuf_oneof:"stage"`
	// contains filtered or unexported fields
}

type ExecuteResponse_Completed struct {
	CompletionEvent *encryptedaction.Event `protobuf:"bytes,1,opt,name=completion_event,json=completionEvent,proto3" json:"completion_event,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteResponse_Completed_ struct {
	Completed *ExecuteResponse_Completed `protobuf:"bytes,4,opt,name=completed,proto3,oneof"`
}

type ExecuteResponse_Executing struct {
	LastEvent *encryptedaction.Event `protobuf:"bytes,1,opt,name=last_event,json=lastEvent,proto3" json:"last_event,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteResponse_Executing_ struct {
	Executing *ExecuteResponse_Executing `protobuf:"bytes,3,opt,name=executing,proto3,oneof"`
}

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

type ExecuteResponse_Queued_ struct {
	Queued *ExecuteResponse_Queued `protobuf:"bytes,2,opt,name=queued,proto3,oneof"`
}

type ExecutionClient interface {
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ExecuteResponse], error)
	WaitExecution(ctx context.Context, in *WaitExecutionRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ExecuteResponse], error)
}

type ExecutionServer interface {
	Execute(*ExecuteRequest, grpc.ServerStreamingServer[ExecuteResponse]) error
	WaitExecution(*WaitExecutionRequest, grpc.ServerStreamingServer[ExecuteResponse]) error
}

type Execution_ExecuteClient = grpc.ServerStreamingClient[ExecuteResponse]

type Execution_ExecuteServer = grpc.ServerStreamingServer[ExecuteResponse]

type Execution_WaitExecutionClient = grpc.ServerStreamingClient[ExecuteResponse]

type Execution_WaitExecutionServer = grpc.ServerStreamingServer[ExecuteResponse]

type UnimplementedExecutionServer struct{}

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

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