Documentation ¶
Index ¶
- Variables
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetAttributes() map[string]string
- func (x *Event) GetKey() []byte
- func (x *Event) GetOrderingKey() string
- func (x *Event) GetPayload() []byte
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type FieldType
- type InvokeRequest
- func (*InvokeRequest) Descriptor() ([]byte, []int)deprecated
- func (m *InvokeRequest) GetArgument() isInvokeRequest_Argument
- func (x *InvokeRequest) GetJson() *structpb.Struct
- func (x *InvokeRequest) GetMethod() string
- func (x *InvokeRequest) GetPb() []byte
- func (x *InvokeRequest) GetService() string
- func (*InvokeRequest) ProtoMessage()
- func (x *InvokeRequest) ProtoReflect() protoreflect.Message
- func (x *InvokeRequest) Reset()
- func (x *InvokeRequest) String() string
- type InvokeRequest_Json
- type InvokeRequest_Pb
- type InvokeResponse
- type RejectAwakeableRequest
- func (*RejectAwakeableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RejectAwakeableRequest) GetId() string
- func (x *RejectAwakeableRequest) GetReason() string
- func (*RejectAwakeableRequest) ProtoMessage()
- func (x *RejectAwakeableRequest) ProtoReflect() protoreflect.Message
- func (x *RejectAwakeableRequest) Reset()
- func (x *RejectAwakeableRequest) String() string
- type ResolveAwakeableRequest
- func (*ResolveAwakeableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResolveAwakeableRequest) GetBytesResult() []byte
- func (x *ResolveAwakeableRequest) GetId() string
- func (x *ResolveAwakeableRequest) GetJsonResult() *structpb.Value
- func (m *ResolveAwakeableRequest) GetResult() isResolveAwakeableRequest_Result
- func (*ResolveAwakeableRequest) ProtoMessage()
- func (x *ResolveAwakeableRequest) ProtoReflect() protoreflect.Message
- func (x *ResolveAwakeableRequest) Reset()
- func (x *ResolveAwakeableRequest) String() string
- type ResolveAwakeableRequest_BytesResult
- type ResolveAwakeableRequest_JsonResult
- type ServiceType
- func (ServiceType) Descriptor() protoreflect.EnumDescriptor
- func (x ServiceType) Enum() *ServiceType
- func (ServiceType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ServiceType) Number() protoreflect.EnumNumber
- func (x ServiceType) String() string
- func (ServiceType) Type() protoreflect.EnumType
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ServiceType_name = map[int32]string{ 0: "UNKEYED", 1: "KEYED", 2: "SINGLETON", } ServiceType_value = map[string]int32{ "UNKEYED": 0, "KEYED": 1, "SINGLETON": 2, } )
Enum value maps for ServiceType.
View Source
var ( FieldType_name = map[int32]string{ 0: "KEY", 1: "EVENT_PAYLOAD", 2: "EVENT_METADATA", } FieldType_value = map[string]int32{ "KEY": 0, "EVENT_PAYLOAD": 1, "EVENT_METADATA": 2, } )
Enum value maps for FieldType.
View Source
var (
// optional dev.restate.ext.FieldType field = 51234;
E_Field = &file_dev_restate_ext_proto_extTypes[1]
)
Extension fields to descriptorpb.FieldOptions.
View Source
var (
// optional dev.restate.ext.ServiceType service_type = 51234;
E_ServiceType = &file_dev_restate_ext_proto_extTypes[0]
)
Extension fields to descriptorpb.ServiceOptions.
View Source
var File_dev_restate_events_proto protoreflect.FileDescriptor
View Source
var File_dev_restate_ext_proto protoreflect.FileDescriptor
View Source
var File_dev_restate_services_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Event ¶
type Event struct { OrderingKey string `protobuf:"bytes,1,opt,name=ordering_key,json=orderingKey,proto3" json:"ordering_key,omitempty"` Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` Attributes map[string]string `` /* 162-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type FieldType ¶
type FieldType int32
const ( // protolint:disable:next ENUM_FIELD_NAMES_ZERO_VALUE_END_WITH // Note: only string fields can be used for service key fields FieldType_KEY FieldType = 0 // Flag a field as event payload. When receiving events, this field will be filled with the event payload. // Note: only string fields can be used for event payload fields FieldType_EVENT_PAYLOAD FieldType = 1 // Flag a field as event metadata. When receiving events, this field will be filled with the event metadata. // Note: only type map<string, string> can be used for event payload fields FieldType_EVENT_METADATA FieldType = 2 )
func (FieldType) Descriptor ¶
func (FieldType) Descriptor() protoreflect.EnumDescriptor
func (FieldType) Number ¶
func (x FieldType) Number() protoreflect.EnumNumber
func (FieldType) Type ¶
func (FieldType) Type() protoreflect.EnumType
type InvokeRequest ¶
type InvokeRequest struct { // Fully qualified name of the service, e.g. `counter.Counter` Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` // Method name of the service to invoke, e.g. `Add` Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"` // Argument of the invocation. // You can pass the invocation argument either as protobuf or as JSON. // In case of JSON, the argument will be automatically transcoded to protobuf before sending it to the target service. // // Types that are assignable to Argument: // // *InvokeRequest_Pb // *InvokeRequest_Json Argument isInvokeRequest_Argument `protobuf_oneof:"argument"` // contains filtered or unexported fields }
func (*InvokeRequest) Descriptor
deprecated
func (*InvokeRequest) Descriptor() ([]byte, []int)
Deprecated: Use InvokeRequest.ProtoReflect.Descriptor instead.
func (*InvokeRequest) GetArgument ¶
func (m *InvokeRequest) GetArgument() isInvokeRequest_Argument
func (*InvokeRequest) GetJson ¶
func (x *InvokeRequest) GetJson() *structpb.Struct
func (*InvokeRequest) GetMethod ¶
func (x *InvokeRequest) GetMethod() string
func (*InvokeRequest) GetPb ¶
func (x *InvokeRequest) GetPb() []byte
func (*InvokeRequest) GetService ¶
func (x *InvokeRequest) GetService() string
func (*InvokeRequest) ProtoMessage ¶
func (*InvokeRequest) ProtoMessage()
func (*InvokeRequest) ProtoReflect ¶
func (x *InvokeRequest) ProtoReflect() protoreflect.Message
func (*InvokeRequest) Reset ¶
func (x *InvokeRequest) Reset()
func (*InvokeRequest) String ¶
func (x *InvokeRequest) String() string
type InvokeRequest_Json ¶
type InvokeRequest_Pb ¶
type InvokeRequest_Pb struct {
Pb []byte `protobuf:"bytes,3,opt,name=pb,proto3,oneof"`
}
type InvokeResponse ¶
type InvokeResponse struct { // Generated unique invocation identifier. // It can be used to retrieve the status of the invocation and cancel it. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*InvokeResponse) Descriptor
deprecated
func (*InvokeResponse) Descriptor() ([]byte, []int)
Deprecated: Use InvokeResponse.ProtoReflect.Descriptor instead.
func (*InvokeResponse) GetId ¶
func (x *InvokeResponse) GetId() string
func (*InvokeResponse) ProtoMessage ¶
func (*InvokeResponse) ProtoMessage()
func (*InvokeResponse) ProtoReflect ¶
func (x *InvokeResponse) ProtoReflect() protoreflect.Message
func (*InvokeResponse) Reset ¶
func (x *InvokeResponse) Reset()
func (*InvokeResponse) String ¶
func (x *InvokeResponse) String() string
type RejectAwakeableRequest ¶
type RejectAwakeableRequest struct { // Base64 encoded identifier of the Awakeable to reject. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Rejection reason. Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*RejectAwakeableRequest) Descriptor
deprecated
func (*RejectAwakeableRequest) Descriptor() ([]byte, []int)
Deprecated: Use RejectAwakeableRequest.ProtoReflect.Descriptor instead.
func (*RejectAwakeableRequest) GetId ¶
func (x *RejectAwakeableRequest) GetId() string
func (*RejectAwakeableRequest) GetReason ¶
func (x *RejectAwakeableRequest) GetReason() string
func (*RejectAwakeableRequest) ProtoMessage ¶
func (*RejectAwakeableRequest) ProtoMessage()
func (*RejectAwakeableRequest) ProtoReflect ¶
func (x *RejectAwakeableRequest) ProtoReflect() protoreflect.Message
func (*RejectAwakeableRequest) Reset ¶
func (x *RejectAwakeableRequest) Reset()
func (*RejectAwakeableRequest) String ¶
func (x *RejectAwakeableRequest) String() string
type ResolveAwakeableRequest ¶
type ResolveAwakeableRequest struct { // Base64 encoded identifier of the Awakeable to resolve. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Types that are assignable to Result: // // *ResolveAwakeableRequest_BytesResult // *ResolveAwakeableRequest_JsonResult Result isResolveAwakeableRequest_Result `protobuf_oneof:"result"` // contains filtered or unexported fields }
func (*ResolveAwakeableRequest) Descriptor
deprecated
func (*ResolveAwakeableRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResolveAwakeableRequest.ProtoReflect.Descriptor instead.
func (*ResolveAwakeableRequest) GetBytesResult ¶
func (x *ResolveAwakeableRequest) GetBytesResult() []byte
func (*ResolveAwakeableRequest) GetId ¶
func (x *ResolveAwakeableRequest) GetId() string
func (*ResolveAwakeableRequest) GetJsonResult ¶
func (x *ResolveAwakeableRequest) GetJsonResult() *structpb.Value
func (*ResolveAwakeableRequest) GetResult ¶
func (m *ResolveAwakeableRequest) GetResult() isResolveAwakeableRequest_Result
func (*ResolveAwakeableRequest) ProtoMessage ¶
func (*ResolveAwakeableRequest) ProtoMessage()
func (*ResolveAwakeableRequest) ProtoReflect ¶
func (x *ResolveAwakeableRequest) ProtoReflect() protoreflect.Message
func (*ResolveAwakeableRequest) Reset ¶
func (x *ResolveAwakeableRequest) Reset()
func (*ResolveAwakeableRequest) String ¶
func (x *ResolveAwakeableRequest) String() string
type ResolveAwakeableRequest_BytesResult ¶
type ResolveAwakeableRequest_BytesResult struct {
BytesResult []byte `protobuf:"bytes,2,opt,name=bytes_result,json=bytesResult,proto3,oneof"`
}
type ResolveAwakeableRequest_JsonResult ¶
type ResolveAwakeableRequest_JsonResult struct { // When executing requests to the ingress using JSON, you can pass a json_result directly for ease of use. // json_result will be sent back to the awakeable as string encoded JSON, not as Protobuf value. JsonResult *structpb.Value `protobuf:"bytes,3,opt,name=json_result,json=jsonResult,proto3,oneof"` }
type ServiceType ¶
type ServiceType int32
const ( // protolint:disable:next ENUM_FIELD_NAMES_ZERO_VALUE_END_WITH ServiceType_UNKEYED ServiceType = 0 ServiceType_KEYED ServiceType = 1 ServiceType_SINGLETON ServiceType = 2 )
func (ServiceType) Descriptor ¶
func (ServiceType) Descriptor() protoreflect.EnumDescriptor
func (ServiceType) Enum ¶
func (x ServiceType) Enum() *ServiceType
func (ServiceType) EnumDescriptor
deprecated
func (ServiceType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ServiceType.Descriptor instead.
func (ServiceType) Number ¶
func (x ServiceType) Number() protoreflect.EnumNumber
func (ServiceType) String ¶
func (x ServiceType) String() string
func (ServiceType) Type ¶
func (ServiceType) Type() protoreflect.EnumType
Click to show internal directories.
Click to hide internal directories.