services

type CleanupRequest struct {

	// User provided operation id, this is used as idempotency key.
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// contains filtered or unexported fields
}

type GetResultRequest struct {

	// User provided operation id, this is used as idempotency key.
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// contains filtered or unexported fields
}

type GetResultResponse struct {

	// Types that are assignable to Response:
	//
	//	*GetResultResponse_None
	//	*GetResultResponse_Success
	//	*GetResultResponse_Failure
	Response isGetResultResponse_Response `protobuf_oneof:"response"`
	// Timestamp of the response expiry time in RFC3339.
	// Empty if response = none
	ExpiryTime string `protobuf:"bytes,15,opt,name=expiry_time,json=expiryTime,proto3" json:"expiry_time,omitempty"`
	// contains filtered or unexported fields
}

type GetResultResponse_Failure struct {
	Failure *GetResultResponse_InvocationFailure `protobuf:"bytes,3,opt,name=failure,proto3,oneof"`
}

type GetResultResponse_InvocationFailure struct {
	Code    uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type GetResultResponse_None struct {
	// See GetResult documentation
	None *emptypb.Empty `protobuf:"bytes,1,opt,name=none,proto3,oneof"`
}

type GetResultResponse_Success struct {
	Success []byte `protobuf:"bytes,2,opt,name=success,proto3,oneof"`
}

type RecvRequest struct {

	// User provided operation id, this is used as idempotency key.
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// Stream id to uniquely identify a open stream between client and Restate.
	// There can be at most one open stream at the same time.
	StreamId string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// contains filtered or unexported fields
}

type RecvResponse struct {

	// Types that are assignable to Response:
	//
	//	*RecvResponse_Messages
	//	*RecvResponse_InvalidStream
	//	*RecvResponse_InvocationCompleted
	Response isRecvResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

type RecvResponse_InvalidStream struct {
	// This means the provided stream_id is invalid, and it should not be
	// reused, nor the client should create a new stream using Start(). The
	// client can instead read the invocation result using GetResult().
	InvalidStream *emptypb.Empty `protobuf:"bytes,2,opt,name=invalid_stream,json=invalidStream,proto3,oneof"`
}

type RecvResponse_InvocationCompleted struct {
	// This means the invocation is completed, and the result should be
	// collected using GetResult
	InvocationCompleted *emptypb.Empty `protobuf:"bytes,3,opt,name=invocation_completed,json=invocationCompleted,proto3,oneof"`
}

type RecvResponse_Messages struct {
	// Contains the concatenated messages of the stream, encoded using the same
	// framing used by service-protocol
	Messages []byte `protobuf:"bytes,1,opt,name=messages,proto3,oneof"`
}

type SendRequest struct {

	// User provided operation id, this is used as idempotency key.
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// Stream id to uniquely identify a open stream between client and Restate.
	// There can be at most one open stream at the same time.
	StreamId string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// Contains the concatenated messages of the stream, encoded using the same
	// framing used by service-protocol
	Messages []byte `protobuf:"bytes,3,opt,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

type SendResponse struct {

	// Types that are assignable to Response:
	//
	//	*SendResponse_Ok
	//	*SendResponse_InvalidStream
	//	*SendResponse_InvocationCompleted
	Response isSendResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

type SendResponse_InvalidStream struct {
	// This means the provided stream_id is invalid, and it should not be
	// reused, nor the client should create a new stream using Start(). The
	// client can instead read the invocation result using GetResult().
	InvalidStream *emptypb.Empty `protobuf:"bytes,2,opt,name=invalid_stream,json=invalidStream,proto3,oneof"`
}

type SendResponse_InvocationCompleted struct {
	// This means the invocation is completed, and the result should be
	// collected using GetResult
	InvocationCompleted *emptypb.Empty `protobuf:"bytes,3,opt,name=invocation_completed,json=invocationCompleted,proto3,oneof"`
}

type SendResponse_Ok struct {
	Ok *emptypb.Empty `protobuf:"bytes,1,opt,name=ok,proto3,oneof"`
}

type StartRequest struct {

	// User provided operation id, this is used as idempotency key.
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// Stream id to uniquely identify a open stream between client and Restate.
	// There can be at most one open stream at the same time.
	StreamId string `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// Retention period for the response in seconds.
	// After the invocation completes, the response will be persisted for the
	// given duration. Afterwards, the system will cleanup the response and treats
	// any subsequent invocation with same operation_id as new.
	//
	// If not set, 30 minutes will be used as retention period.
	RetentionPeriodSec uint32 `protobuf:"varint,3,opt,name=retention_period_sec,json=retentionPeriodSec,proto3" json:"retention_period_sec,omitempty"`
	// Argument of the invocation
	Argument []byte `protobuf:"bytes,4,opt,name=argument,proto3" json:"argument,omitempty"`
	// contains filtered or unexported fields
}

type StartResponse struct {

	// Types that are assignable to InvocationStatus:
	//
	//	*StartResponse_Executing
	//	*StartResponse_Completed
	InvocationStatus isStartResponse_InvocationStatus `protobuf_oneof:"invocation_status"`
	// contains filtered or unexported fields
}

type StartResponse_Completed struct {
	// Contains the result of the invocation
	Completed *GetResultResponse `protobuf:"bytes,2,opt,name=completed,proto3,oneof"`
}

type StartResponse_Executing struct {
	// Contains the concatenated first messages of the stream, encoded using the
	// same framing used by service-protocol
	Executing []byte `protobuf:"bytes,1,opt,name=executing,proto3,oneof"`
}