service

package
v0.14.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 20, 2025 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ServiceDiscoveryProtocolVersion_name = map[int32]string{
		0: "SERVICE_DISCOVERY_PROTOCOL_VERSION_UNSPECIFIED",
		1: "V1",
	}
	ServiceDiscoveryProtocolVersion_value = map[string]int32{
		"SERVICE_DISCOVERY_PROTOCOL_VERSION_UNSPECIFIED": 0,
		"V1": 1,
	}
)

Enum value maps for ServiceDiscoveryProtocolVersion.

View Source 
var (
	ServiceProtocolVersion_name = map[int32]string{
		0: "SERVICE_PROTOCOL_VERSION_UNSPECIFIED",
		1: "V1",
	}
	ServiceProtocolVersion_value = map[string]int32{
		"SERVICE_PROTOCOL_VERSION_UNSPECIFIED": 0,
		"V1":                                   1,
	}
)

Enum value maps for ServiceProtocolVersion.

View Source 
var File_dev_restate_service_discovery_proto protoreflect.FileDescriptor
View Source 
var File_dev_restate_service_protocol_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AwakeableEntryMessage 

type AwakeableEntryMessage struct {

	// Types that are assignable to Result:
	//
	//	*AwakeableEntryMessage_Value
	//	*AwakeableEntryMessage_Failure
	Result isAwakeableEntryMessage_Result `protobuf_oneof:"result"`
	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: Yes Fallible: No Type: 0x0C00 + 3 Awakeables are addressed by an identifier exposed to the user. See the spec for more details.

func (*AwakeableEntryMessage) Descriptor deprecated 

func (*AwakeableEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use AwakeableEntryMessage.ProtoReflect.Descriptor instead.

func (*AwakeableEntryMessage) GetFailure 

func (x *AwakeableEntryMessage) GetFailure() *Failure

func (*AwakeableEntryMessage) GetName 

func (x *AwakeableEntryMessage) GetName() string

func (*AwakeableEntryMessage) GetResult 

func (m *AwakeableEntryMessage) GetResult() isAwakeableEntryMessage_Result

func (*AwakeableEntryMessage) GetValue 

func (x *AwakeableEntryMessage) GetValue() []byte

func (*AwakeableEntryMessage) ProtoMessage 

func (*AwakeableEntryMessage) ProtoMessage()

func (*AwakeableEntryMessage) ProtoReflect 

func (x *AwakeableEntryMessage) ProtoReflect() protoreflect.Message

func (*AwakeableEntryMessage) Reset 

func (x *AwakeableEntryMessage) Reset()

func (*AwakeableEntryMessage) String 

func (x *AwakeableEntryMessage) String() string

type AwakeableEntryMessage_Failure 

type AwakeableEntryMessage_Failure struct {
	Failure *Failure `protobuf:"bytes,15,opt,name=failure,proto3,oneof"`
}

type AwakeableEntryMessage_Value 

type AwakeableEntryMessage_Value struct {
	Value []byte `protobuf:"bytes,14,opt,name=value,proto3,oneof"`
}

type CallEntryMessage 

type CallEntryMessage struct {
	ServiceName string    `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	HandlerName string    `protobuf:"bytes,2,opt,name=handler_name,json=handlerName,proto3" json:"handler_name,omitempty"`
	Parameter   []byte    `protobuf:"bytes,3,opt,name=parameter,proto3" json:"parameter,omitempty"`
	Headers     []*Header `protobuf:"bytes,4,rep,name=headers,proto3" json:"headers,omitempty"`
	// If this invocation has a key associated (e.g. for objects and workflows), then this key is filled in. Empty otherwise.
	Key string `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are assignable to Result:
	//
	//	*CallEntryMessage_Value
	//	*CallEntryMessage_Failure
	Result isCallEntryMessage_Result `protobuf_oneof:"result"`
	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: Yes Fallible: Yes Type: 0x0C00 + 1

func (*CallEntryMessage) Descriptor deprecated 

func (*CallEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use CallEntryMessage.ProtoReflect.Descriptor instead.

func (*CallEntryMessage) GetFailure 

func (x *CallEntryMessage) GetFailure() *Failure

func (*CallEntryMessage) GetHandlerName 

func (x *CallEntryMessage) GetHandlerName() string

func (*CallEntryMessage) GetHeaders 

func (x *CallEntryMessage) GetHeaders() []*Header

func (*CallEntryMessage) GetKey 

func (x *CallEntryMessage) GetKey() string

func (*CallEntryMessage) GetName 

func (x *CallEntryMessage) GetName() string

func (*CallEntryMessage) GetParameter 

func (x *CallEntryMessage) GetParameter() []byte

func (*CallEntryMessage) GetResult 

func (m *CallEntryMessage) GetResult() isCallEntryMessage_Result

func (*CallEntryMessage) GetServiceName 

func (x *CallEntryMessage) GetServiceName() string

func (*CallEntryMessage) GetValue 

func (x *CallEntryMessage) GetValue() []byte

func (*CallEntryMessage) ProtoMessage 

func (*CallEntryMessage) ProtoMessage()

func (*CallEntryMessage) ProtoReflect 

func (x *CallEntryMessage) ProtoReflect() protoreflect.Message

func (*CallEntryMessage) Reset 

func (x *CallEntryMessage) Reset()

func (*CallEntryMessage) String 

func (x *CallEntryMessage) String() string

type CallEntryMessage_Failure 

type CallEntryMessage_Failure struct {
	Failure *Failure `protobuf:"bytes,15,opt,name=failure,proto3,oneof"`
}

type CallEntryMessage_Value 

type CallEntryMessage_Value struct {
	Value []byte `protobuf:"bytes,14,opt,name=value,proto3,oneof"`
}

type ClearAllStateEntryMessage 

type ClearAllStateEntryMessage struct {

	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: No Fallible: No Type: 0x0800 + 3

func (*ClearAllStateEntryMessage) Descriptor deprecated 

func (*ClearAllStateEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use ClearAllStateEntryMessage.ProtoReflect.Descriptor instead.

func (*ClearAllStateEntryMessage) GetName 

func (x *ClearAllStateEntryMessage) GetName() string

func (*ClearAllStateEntryMessage) ProtoMessage 

func (*ClearAllStateEntryMessage) ProtoMessage()

func (*ClearAllStateEntryMessage) ProtoReflect 

func (x *ClearAllStateEntryMessage) ProtoReflect() protoreflect.Message

func (*ClearAllStateEntryMessage) Reset 

func (x *ClearAllStateEntryMessage) Reset()

func (*ClearAllStateEntryMessage) String 

func (x *ClearAllStateEntryMessage) String() string

type ClearStateEntryMessage 

type ClearStateEntryMessage struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: No Fallible: No Type: 0x0800 + 2

func (*ClearStateEntryMessage) Descriptor deprecated 

func (*ClearStateEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use ClearStateEntryMessage.ProtoReflect.Descriptor instead.

func (*ClearStateEntryMessage) GetKey 

func (x *ClearStateEntryMessage) GetKey() []byte

func (*ClearStateEntryMessage) GetName 

func (x *ClearStateEntryMessage) GetName() string

func (*ClearStateEntryMessage) ProtoMessage 

func (*ClearStateEntryMessage) ProtoMessage()

func (*ClearStateEntryMessage) ProtoReflect 

func (x *ClearStateEntryMessage) ProtoReflect() protoreflect.Message

func (*ClearStateEntryMessage) Reset 

func (x *ClearStateEntryMessage) Reset()

func (*ClearStateEntryMessage) String 

func (x *ClearStateEntryMessage) String() string

type CompleteAwakeableEntryMessage 

type CompleteAwakeableEntryMessage struct {

	// Identifier of the awakeable. See the spec for more details.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Result:
	//
	//	*CompleteAwakeableEntryMessage_Value
	//	*CompleteAwakeableEntryMessage_Failure
	Result isCompleteAwakeableEntryMessage_Result `protobuf_oneof:"result"`
	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: No Fallible: Yes Type: 0x0C00 + 4

func (*CompleteAwakeableEntryMessage) Descriptor deprecated 

func (*CompleteAwakeableEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use CompleteAwakeableEntryMessage.ProtoReflect.Descriptor instead.

func (*CompleteAwakeableEntryMessage) GetFailure 

func (x *CompleteAwakeableEntryMessage) GetFailure() *Failure

func (*CompleteAwakeableEntryMessage) GetId 

func (x *CompleteAwakeableEntryMessage) GetId() string

func (*CompleteAwakeableEntryMessage) GetName 

func (x *CompleteAwakeableEntryMessage) GetName() string

func (*CompleteAwakeableEntryMessage) GetResult 

func (m *CompleteAwakeableEntryMessage) GetResult() isCompleteAwakeableEntryMessage_Result

func (*CompleteAwakeableEntryMessage) GetValue 

func (x *CompleteAwakeableEntryMessage) GetValue() []byte

func (*CompleteAwakeableEntryMessage) ProtoMessage 

func (*CompleteAwakeableEntryMessage) ProtoMessage()

func (*CompleteAwakeableEntryMessage) ProtoReflect 

func (x *CompleteAwakeableEntryMessage) ProtoReflect() protoreflect.Message

func (*CompleteAwakeableEntryMessage) Reset 

func (x *CompleteAwakeableEntryMessage) Reset()

func (*CompleteAwakeableEntryMessage) String 

func (x *CompleteAwakeableEntryMessage) String() string

type CompleteAwakeableEntryMessage_Failure 

type CompleteAwakeableEntryMessage_Failure struct {
	Failure *Failure `protobuf:"bytes,15,opt,name=failure,proto3,oneof"`
}

type CompleteAwakeableEntryMessage_Value 

type CompleteAwakeableEntryMessage_Value struct {
	Value []byte `protobuf:"bytes,14,opt,name=value,proto3,oneof"`
}

type CompletePromiseEntryMessage 

type CompletePromiseEntryMessage struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The value to use to complete the promise
	//
	// Types that are assignable to Completion:
	//
	//	*CompletePromiseEntryMessage_CompletionValue
	//	*CompletePromiseEntryMessage_CompletionFailure
	Completion isCompletePromiseEntryMessage_Completion `protobuf_oneof:"completion"`
	// Types that are assignable to Result:
	//
	//	*CompletePromiseEntryMessage_Empty
	//	*CompletePromiseEntryMessage_Failure
	Result isCompletePromiseEntryMessage_Result `protobuf_oneof:"result"`
	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: Yes Fallible: No Type: 0x0800 + A

func (*CompletePromiseEntryMessage) Descriptor deprecated 

func (*CompletePromiseEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use CompletePromiseEntryMessage.ProtoReflect.Descriptor instead.

func (*CompletePromiseEntryMessage) GetCompletion 

func (m *CompletePromiseEntryMessage) GetCompletion() isCompletePromiseEntryMessage_Completion

func (*CompletePromiseEntryMessage) GetCompletionFailure 

func (x *CompletePromiseEntryMessage) GetCompletionFailure() *Failure

func (*CompletePromiseEntryMessage) GetCompletionValue 

func (x *CompletePromiseEntryMessage) GetCompletionValue() []byte

func (*CompletePromiseEntryMessage) GetEmpty 

func (x *CompletePromiseEntryMessage) GetEmpty() *Empty

func (*CompletePromiseEntryMessage) GetFailure 

func (x *CompletePromiseEntryMessage) GetFailure() *Failure

func (*CompletePromiseEntryMessage) GetKey 

func (x *CompletePromiseEntryMessage) GetKey() string

func (*CompletePromiseEntryMessage) GetName 

func (x *CompletePromiseEntryMessage) GetName() string

func (*CompletePromiseEntryMessage) GetResult 

func (m *CompletePromiseEntryMessage) GetResult() isCompletePromiseEntryMessage_Result

func (*CompletePromiseEntryMessage) ProtoMessage 

func (*CompletePromiseEntryMessage) ProtoMessage()

func (*CompletePromiseEntryMessage) ProtoReflect 

func (x *CompletePromiseEntryMessage) ProtoReflect() protoreflect.Message

func (*CompletePromiseEntryMessage) Reset 

func (x *CompletePromiseEntryMessage) Reset()

func (*CompletePromiseEntryMessage) String 

func (x *CompletePromiseEntryMessage) String() string

type CompletePromiseEntryMessage_CompletionFailure 

type CompletePromiseEntryMessage_CompletionFailure struct {
	CompletionFailure *Failure `protobuf:"bytes,3,opt,name=completion_failure,json=completionFailure,proto3,oneof"`
}

type CompletePromiseEntryMessage_CompletionValue 

type CompletePromiseEntryMessage_CompletionValue struct {
	CompletionValue []byte `protobuf:"bytes,2,opt,name=completion_value,json=completionValue,proto3,oneof"`
}

type CompletePromiseEntryMessage_Empty 

type CompletePromiseEntryMessage_Empty struct {
	// Returns empty if value was set successfully
	Empty *Empty `protobuf:"bytes,13,opt,name=empty,proto3,oneof"`
}

type CompletePromiseEntryMessage_Failure 

type CompletePromiseEntryMessage_Failure struct {
	// Returns a failure if the promise was already completed
	Failure *Failure `protobuf:"bytes,15,opt,name=failure,proto3,oneof"`
}

type CompletionMessage 

type CompletionMessage struct {
	EntryIndex uint32 `protobuf:"varint,1,opt,name=entry_index,json=entryIndex,proto3" json:"entry_index,omitempty"`
	// Types that are assignable to Result:
	//
	//	*CompletionMessage_Empty
	//	*CompletionMessage_Value
	//	*CompletionMessage_Failure
	Result isCompletionMessage_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

Type: 0x0000 + 1

func (*CompletionMessage) Descriptor deprecated 

func (*CompletionMessage) Descriptor() ([]byte, []int)

Deprecated: Use CompletionMessage.ProtoReflect.Descriptor instead.

func (*CompletionMessage) GetEmpty 

func (x *CompletionMessage) GetEmpty() *Empty

func (*CompletionMessage) GetEntryIndex 

func (x *CompletionMessage) GetEntryIndex() uint32

func (*CompletionMessage) GetFailure 

func (x *CompletionMessage) GetFailure() *Failure

func (*CompletionMessage) GetResult 

func (m *CompletionMessage) GetResult() isCompletionMessage_Result

func (*CompletionMessage) GetValue 

func (x *CompletionMessage) GetValue() []byte

func (*CompletionMessage) ProtoMessage 

func (*CompletionMessage) ProtoMessage()

func (*CompletionMessage) ProtoReflect 

func (x *CompletionMessage) ProtoReflect() protoreflect.Message

func (*CompletionMessage) Reset 

func (x *CompletionMessage) Reset()

func (*CompletionMessage) String 

func (x *CompletionMessage) String() string

type CompletionMessage_Empty 

type CompletionMessage_Empty struct {
	Empty *Empty `protobuf:"bytes,13,opt,name=empty,proto3,oneof"`
}

type CompletionMessage_Failure 

type CompletionMessage_Failure struct {
	Failure *Failure `protobuf:"bytes,15,opt,name=failure,proto3,oneof"`
}

type CompletionMessage_Value 

type CompletionMessage_Value struct {
	Value []byte `protobuf:"bytes,14,opt,name=value,proto3,oneof"`
}

type Empty 

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

func (*Empty) Descriptor deprecated 

func (*Empty) Descriptor() ([]byte, []int)

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type EndMessage 

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

Type: 0x0000 + 5 Implementations MUST send this message when the invocation lifecycle ends.

func (*EndMessage) Descriptor deprecated 

func (*EndMessage) Descriptor() ([]byte, []int)

Deprecated: Use EndMessage.ProtoReflect.Descriptor instead.

func (*EndMessage) ProtoMessage 

func (*EndMessage) ProtoMessage()

func (*EndMessage) ProtoReflect 

func (x *EndMessage) ProtoReflect() protoreflect.Message

func (*EndMessage) Reset 

func (x *EndMessage) Reset()

func (*EndMessage) String 

func (x *EndMessage) String() string

type EntryAckMessage 

type EntryAckMessage struct {
	EntryIndex uint32 `protobuf:"varint,1,opt,name=entry_index,json=entryIndex,proto3" json:"entry_index,omitempty"`
	// contains filtered or unexported fields
}

Type: 0x0000 + 4

func (*EntryAckMessage) Descriptor deprecated 

func (*EntryAckMessage) Descriptor() ([]byte, []int)

Deprecated: Use EntryAckMessage.ProtoReflect.Descriptor instead.

func (*EntryAckMessage) GetEntryIndex 

func (x *EntryAckMessage) GetEntryIndex() uint32

func (*EntryAckMessage) ProtoMessage 

func (*EntryAckMessage) ProtoMessage()

func (*EntryAckMessage) ProtoReflect 

func (x *EntryAckMessage) ProtoReflect() protoreflect.Message

func (*EntryAckMessage) Reset 

func (x *EntryAckMessage) Reset()

func (*EntryAckMessage) String 

func (x *EntryAckMessage) String() string

type ErrorMessage 

type ErrorMessage struct {

	// The code can be any HTTP status code, as described https://www.iana.org/assignments/http-status-codes/http-status-codes.xhtml.
	// In addition, we define the following error codes that MAY be used by the SDK for better error reporting:
	// * JOURNAL_MISMATCH = 570, that is when the SDK cannot replay a journal due to the mismatch between the journal and the actual code.
	// * PROTOCOL_VIOLATION = 571, that is when the SDK receives an unexpected message or an expected message variant, given its state.
	Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// Contains a concise error message, e.g. Throwable#getMessage() in Java.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Contains a verbose error description, e.g. the exception stacktrace.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Entry that caused the failure. This may be outside the current stored journal size.
	// If no specific entry caused the failure, the current replayed/processed entry can be used.
	RelatedEntryIndex *uint32 `protobuf:"varint,4,opt,name=related_entry_index,json=relatedEntryIndex,proto3,oneof" json:"related_entry_index,omitempty"`
	// Name of the entry that caused the failure.
	RelatedEntryName *string `protobuf:"bytes,5,opt,name=related_entry_name,json=relatedEntryName,proto3,oneof" json:"related_entry_name,omitempty"`
	// Entry type.
	RelatedEntryType *uint32 `protobuf:"varint,6,opt,name=related_entry_type,json=relatedEntryType,proto3,oneof" json:"related_entry_type,omitempty"`
	// contains filtered or unexported fields
}

Type: 0x0000 + 3

func (*ErrorMessage) Descriptor deprecated 

func (*ErrorMessage) Descriptor() ([]byte, []int)

Deprecated: Use ErrorMessage.ProtoReflect.Descriptor instead.

func (*ErrorMessage) GetCode 

func (x *ErrorMessage) GetCode() uint32

func (*ErrorMessage) GetDescription 

func (x *ErrorMessage) GetDescription() string

func (*ErrorMessage) GetMessage 

func (x *ErrorMessage) GetMessage() string

func (*ErrorMessage) GetRelatedEntryIndex 

func (x *ErrorMessage) GetRelatedEntryIndex() uint32

func (*ErrorMessage) GetRelatedEntryName 

func (x *ErrorMessage) GetRelatedEntryName() string

func (*ErrorMessage) GetRelatedEntryType 

func (x *ErrorMessage) GetRelatedEntryType() uint32

func (*ErrorMessage) ProtoMessage 

func (*ErrorMessage) ProtoMessage()

func (*ErrorMessage) ProtoReflect 

func (x *ErrorMessage) ProtoReflect() protoreflect.Message

func (*ErrorMessage) Reset 

func (x *ErrorMessage) Reset()

func (*ErrorMessage) String 

func (x *ErrorMessage) String() string

type Failure 

type Failure struct {

	// The code can be any HTTP status code, as described https://www.iana.org/assignments/http-status-codes/http-status-codes.xhtml.
	Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// Contains a concise error message, e.g. Throwable#getMessage() in Java.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

This failure object carries user visible errors, e.g. invocation failure return value or failure result of an InvokeEntryMessage.

func (*Failure) Descriptor deprecated 

func (*Failure) Descriptor() ([]byte, []int)

Deprecated: Use Failure.ProtoReflect.Descriptor instead.

func (*Failure) GetCode 

func (x *Failure) GetCode() uint32

func (*Failure) GetMessage 

func (x *Failure) GetMessage() string

func (*Failure) ProtoMessage 

func (*Failure) ProtoMessage()

func (*Failure) ProtoReflect 

func (x *Failure) ProtoReflect() protoreflect.Message

func (*Failure) Reset 

func (x *Failure) Reset()

func (*Failure) String 

func (x *Failure) String() string

type GetPromiseEntryMessage 

type GetPromiseEntryMessage struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are assignable to Result:
	//
	//	*GetPromiseEntryMessage_Value
	//	*GetPromiseEntryMessage_Failure
	Result isGetPromiseEntryMessage_Result `protobuf_oneof:"result"`
	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: Yes Fallible: No Type: 0x0800 + 8

func (*GetPromiseEntryMessage) Descriptor deprecated 

func (*GetPromiseEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use GetPromiseEntryMessage.ProtoReflect.Descriptor instead.

func (*GetPromiseEntryMessage) GetFailure 

func (x *GetPromiseEntryMessage) GetFailure() *Failure

func (*GetPromiseEntryMessage) GetKey 

func (x *GetPromiseEntryMessage) GetKey() string

func (*GetPromiseEntryMessage) GetName 

func (x *GetPromiseEntryMessage) GetName() string

func (*GetPromiseEntryMessage) GetResult 

func (m *GetPromiseEntryMessage) GetResult() isGetPromiseEntryMessage_Result

func (*GetPromiseEntryMessage) GetValue 

func (x *GetPromiseEntryMessage) GetValue() []byte

func (*GetPromiseEntryMessage) ProtoMessage 

func (*GetPromiseEntryMessage) ProtoMessage()

func (*GetPromiseEntryMessage) ProtoReflect 

func (x *GetPromiseEntryMessage) ProtoReflect() protoreflect.Message

func (*GetPromiseEntryMessage) Reset 

func (x *GetPromiseEntryMessage) Reset()

func (*GetPromiseEntryMessage) String 

func (x *GetPromiseEntryMessage) String() string

type GetPromiseEntryMessage_Failure 

type GetPromiseEntryMessage_Failure struct {
	Failure *Failure `protobuf:"bytes,15,opt,name=failure,proto3,oneof"`
}

type GetPromiseEntryMessage_Value 

type GetPromiseEntryMessage_Value struct {
	Value []byte `protobuf:"bytes,14,opt,name=value,proto3,oneof"`
}

type GetStateEntryMessage 

type GetStateEntryMessage struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are assignable to Result:
	//
	//	*GetStateEntryMessage_Empty
	//	*GetStateEntryMessage_Value
	//	*GetStateEntryMessage_Failure
	Result isGetStateEntryMessage_Result `protobuf_oneof:"result"`
	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: Yes Fallible: No Type: 0x0800 + 0

func (*GetStateEntryMessage) Descriptor deprecated 

func (*GetStateEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use GetStateEntryMessage.ProtoReflect.Descriptor instead.

func (*GetStateEntryMessage) GetEmpty 

func (x *GetStateEntryMessage) GetEmpty() *Empty

func (*GetStateEntryMessage) GetFailure 

func (x *GetStateEntryMessage) GetFailure() *Failure

func (*GetStateEntryMessage) GetKey 

func (x *GetStateEntryMessage) GetKey() []byte

func (*GetStateEntryMessage) GetName 

func (x *GetStateEntryMessage) GetName() string

func (*GetStateEntryMessage) GetResult 

func (m *GetStateEntryMessage) GetResult() isGetStateEntryMessage_Result

func (*GetStateEntryMessage) GetValue 

func (x *GetStateEntryMessage) GetValue() []byte

func (*GetStateEntryMessage) ProtoMessage 

func (*GetStateEntryMessage) ProtoMessage()

func (*GetStateEntryMessage) ProtoReflect 

func (x *GetStateEntryMessage) ProtoReflect() protoreflect.Message

func (*GetStateEntryMessage) Reset 

func (x *GetStateEntryMessage) Reset()

func (*GetStateEntryMessage) String 

func (x *GetStateEntryMessage) String() string

type GetStateEntryMessage_Empty 

type GetStateEntryMessage_Empty struct {
	Empty *Empty `protobuf:"bytes,13,opt,name=empty,proto3,oneof"`
}

type GetStateEntryMessage_Failure 

type GetStateEntryMessage_Failure struct {
	Failure *Failure `protobuf:"bytes,15,opt,name=failure,proto3,oneof"`
}

type GetStateEntryMessage_Value 

type GetStateEntryMessage_Value struct {
	Value []byte `protobuf:"bytes,14,opt,name=value,proto3,oneof"`
}

type GetStateKeysEntryMessage 

type GetStateKeysEntryMessage struct {

	// Types that are assignable to Result:
	//
	//	*GetStateKeysEntryMessage_Value
	//	*GetStateKeysEntryMessage_Failure
	Result isGetStateKeysEntryMessage_Result `protobuf_oneof:"result"`
	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: Yes Fallible: No Type: 0x0800 + 4

func (*GetStateKeysEntryMessage) Descriptor deprecated 

func (*GetStateKeysEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use GetStateKeysEntryMessage.ProtoReflect.Descriptor instead.

func (*GetStateKeysEntryMessage) GetFailure 

func (x *GetStateKeysEntryMessage) GetFailure() *Failure

func (*GetStateKeysEntryMessage) GetName 

func (x *GetStateKeysEntryMessage) GetName() string

func (*GetStateKeysEntryMessage) GetResult 

func (m *GetStateKeysEntryMessage) GetResult() isGetStateKeysEntryMessage_Result

func (*GetStateKeysEntryMessage) GetValue 

func (x *GetStateKeysEntryMessage) GetValue() *GetStateKeysEntryMessage_StateKeys

func (*GetStateKeysEntryMessage) ProtoMessage 

func (*GetStateKeysEntryMessage) ProtoMessage()

func (*GetStateKeysEntryMessage) ProtoReflect 

func (x *GetStateKeysEntryMessage) ProtoReflect() protoreflect.Message

func (*GetStateKeysEntryMessage) Reset 

func (x *GetStateKeysEntryMessage) Reset()

func (*GetStateKeysEntryMessage) String 

func (x *GetStateKeysEntryMessage) String() string

type GetStateKeysEntryMessage_Failure 

type GetStateKeysEntryMessage_Failure struct {
	Failure *Failure `protobuf:"bytes,15,opt,name=failure,proto3,oneof"`
}

type GetStateKeysEntryMessage_StateKeys 

type GetStateKeysEntryMessage_StateKeys struct {
	Keys [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStateKeysEntryMessage_StateKeys) Descriptor deprecated 

func (*GetStateKeysEntryMessage_StateKeys) Descriptor() ([]byte, []int)

Deprecated: Use GetStateKeysEntryMessage_StateKeys.ProtoReflect.Descriptor instead.

func (*GetStateKeysEntryMessage_StateKeys) GetKeys 

func (x *GetStateKeysEntryMessage_StateKeys) GetKeys() [][]byte

func (*GetStateKeysEntryMessage_StateKeys) ProtoMessage 

func (*GetStateKeysEntryMessage_StateKeys) ProtoMessage()

func (*GetStateKeysEntryMessage_StateKeys) ProtoReflect 

func (x *GetStateKeysEntryMessage_StateKeys) ProtoReflect() protoreflect.Message

func (*GetStateKeysEntryMessage_StateKeys) Reset 

func (x *GetStateKeysEntryMessage_StateKeys) Reset()

func (*GetStateKeysEntryMessage_StateKeys) String 

func (x *GetStateKeysEntryMessage_StateKeys) String() string

type GetStateKeysEntryMessage_Value 

type GetStateKeysEntryMessage_Value struct {
	Value *GetStateKeysEntryMessage_StateKeys `protobuf:"bytes,14,opt,name=value,proto3,oneof"`
}
type Header struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated 

func (*Header) Descriptor() ([]byte, []int)

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetKey 

func (x *Header) GetKey() string

func (*Header) GetValue 

func (x *Header) GetValue() string

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

func (x *Header) ProtoReflect() protoreflect.Message

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type InputEntryMessage 

type InputEntryMessage struct {
	Headers []*Header `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"`
	Value   []byte    `protobuf:"bytes,14,opt,name=value,proto3" json:"value,omitempty"`
	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: No Fallible: No Type: 0x0400 + 0

func (*InputEntryMessage) Descriptor deprecated 

func (*InputEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use InputEntryMessage.ProtoReflect.Descriptor instead.

func (*InputEntryMessage) GetHeaders 

func (x *InputEntryMessage) GetHeaders() []*Header

func (*InputEntryMessage) GetName 

func (x *InputEntryMessage) GetName() string

func (*InputEntryMessage) GetValue 

func (x *InputEntryMessage) GetValue() []byte

func (*InputEntryMessage) ProtoMessage 

func (*InputEntryMessage) ProtoMessage()

func (*InputEntryMessage) ProtoReflect 

func (x *InputEntryMessage) ProtoReflect() protoreflect.Message

func (*InputEntryMessage) Reset 

func (x *InputEntryMessage) Reset()

func (*InputEntryMessage) String 

func (x *InputEntryMessage) String() string

type OneWayCallEntryMessage 

type OneWayCallEntryMessage struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	HandlerName string `protobuf:"bytes,2,opt,name=handler_name,json=handlerName,proto3" json:"handler_name,omitempty"`
	Parameter   []byte `protobuf:"bytes,3,opt,name=parameter,proto3" json:"parameter,omitempty"`
	// Time when this BackgroundInvoke should be executed.
	// The time is set as duration since UNIX Epoch.
	// If this value is not set, equal to 0, or past in time,
	// the runtime will execute this BackgroundInvoke as soon as possible.
	InvokeTime uint64    `protobuf:"varint,4,opt,name=invoke_time,json=invokeTime,proto3" json:"invoke_time,omitempty"`
	Headers    []*Header `protobuf:"bytes,5,rep,name=headers,proto3" json:"headers,omitempty"`
	// If this invocation has a key associated (e.g. for objects and workflows), then this key is filled in. Empty otherwise.
	Key string `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"`
	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: No Fallible: Yes Type: 0x0C00 + 2

func (*OneWayCallEntryMessage) Descriptor deprecated 

func (*OneWayCallEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use OneWayCallEntryMessage.ProtoReflect.Descriptor instead.

func (*OneWayCallEntryMessage) GetHandlerName 

func (x *OneWayCallEntryMessage) GetHandlerName() string

func (*OneWayCallEntryMessage) GetHeaders 

func (x *OneWayCallEntryMessage) GetHeaders() []*Header

func (*OneWayCallEntryMessage) GetInvokeTime 

func (x *OneWayCallEntryMessage) GetInvokeTime() uint64

func (*OneWayCallEntryMessage) GetKey 

func (x *OneWayCallEntryMessage) GetKey() string

func (*OneWayCallEntryMessage) GetName 

func (x *OneWayCallEntryMessage) GetName() string

func (*OneWayCallEntryMessage) GetParameter 

func (x *OneWayCallEntryMessage) GetParameter() []byte

func (*OneWayCallEntryMessage) GetServiceName 

func (x *OneWayCallEntryMessage) GetServiceName() string

func (*OneWayCallEntryMessage) ProtoMessage 

func (*OneWayCallEntryMessage) ProtoMessage()

func (*OneWayCallEntryMessage) ProtoReflect 

func (x *OneWayCallEntryMessage) ProtoReflect() protoreflect.Message

func (*OneWayCallEntryMessage) Reset 

func (x *OneWayCallEntryMessage) Reset()

func (*OneWayCallEntryMessage) String 

func (x *OneWayCallEntryMessage) String() string

type OutputEntryMessage 

type OutputEntryMessage struct {

	// Types that are assignable to Result:
	//
	//	*OutputEntryMessage_Value
	//	*OutputEntryMessage_Failure
	Result isOutputEntryMessage_Result `protobuf_oneof:"result"`
	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: No Fallible: No Type: 0x0400 + 1

func (*OutputEntryMessage) Descriptor deprecated 

func (*OutputEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use OutputEntryMessage.ProtoReflect.Descriptor instead.

func (*OutputEntryMessage) GetFailure 

func (x *OutputEntryMessage) GetFailure() *Failure

func (*OutputEntryMessage) GetName 

func (x *OutputEntryMessage) GetName() string

func (*OutputEntryMessage) GetResult 

func (m *OutputEntryMessage) GetResult() isOutputEntryMessage_Result

func (*OutputEntryMessage) GetValue 

func (x *OutputEntryMessage) GetValue() []byte

func (*OutputEntryMessage) ProtoMessage 

func (*OutputEntryMessage) ProtoMessage()

func (*OutputEntryMessage) ProtoReflect 

func (x *OutputEntryMessage) ProtoReflect() protoreflect.Message

func (*OutputEntryMessage) Reset 

func (x *OutputEntryMessage) Reset()

func (*OutputEntryMessage) String 

func (x *OutputEntryMessage) String() string

type OutputEntryMessage_Failure 

type OutputEntryMessage_Failure struct {
	Failure *Failure `protobuf:"bytes,15,opt,name=failure,proto3,oneof"`
}

type OutputEntryMessage_Value 

type OutputEntryMessage_Value struct {
	Value []byte `protobuf:"bytes,14,opt,name=value,proto3,oneof"`
}

type PeekPromiseEntryMessage 

type PeekPromiseEntryMessage struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are assignable to Result:
	//
	//	*PeekPromiseEntryMessage_Empty
	//	*PeekPromiseEntryMessage_Value
	//	*PeekPromiseEntryMessage_Failure
	Result isPeekPromiseEntryMessage_Result `protobuf_oneof:"result"`
	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: Yes Fallible: No Type: 0x0800 + 9

func (*PeekPromiseEntryMessage) Descriptor deprecated 

func (*PeekPromiseEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use PeekPromiseEntryMessage.ProtoReflect.Descriptor instead.

func (*PeekPromiseEntryMessage) GetEmpty 

func (x *PeekPromiseEntryMessage) GetEmpty() *Empty

func (*PeekPromiseEntryMessage) GetFailure 

func (x *PeekPromiseEntryMessage) GetFailure() *Failure

func (*PeekPromiseEntryMessage) GetKey 

func (x *PeekPromiseEntryMessage) GetKey() string

func (*PeekPromiseEntryMessage) GetName 

func (x *PeekPromiseEntryMessage) GetName() string

func (*PeekPromiseEntryMessage) GetResult 

func (m *PeekPromiseEntryMessage) GetResult() isPeekPromiseEntryMessage_Result

func (*PeekPromiseEntryMessage) GetValue 

func (x *PeekPromiseEntryMessage) GetValue() []byte

func (*PeekPromiseEntryMessage) ProtoMessage 

func (*PeekPromiseEntryMessage) ProtoMessage()

func (*PeekPromiseEntryMessage) ProtoReflect 

func (x *PeekPromiseEntryMessage) ProtoReflect() protoreflect.Message

func (*PeekPromiseEntryMessage) Reset 

func (x *PeekPromiseEntryMessage) Reset()

func (*PeekPromiseEntryMessage) String 

func (x *PeekPromiseEntryMessage) String() string

type PeekPromiseEntryMessage_Empty 

type PeekPromiseEntryMessage_Empty struct {
	Empty *Empty `protobuf:"bytes,13,opt,name=empty,proto3,oneof"`
}

type PeekPromiseEntryMessage_Failure 

type PeekPromiseEntryMessage_Failure struct {
	Failure *Failure `protobuf:"bytes,15,opt,name=failure,proto3,oneof"`
}

type PeekPromiseEntryMessage_Value 

type PeekPromiseEntryMessage_Value struct {
	Value []byte `protobuf:"bytes,14,opt,name=value,proto3,oneof"`
}

type RunEntryMessage 

type RunEntryMessage struct {

	// Types that are assignable to Result:
	//
	//	*RunEntryMessage_Value
	//	*RunEntryMessage_Failure
	Result isRunEntryMessage_Result `protobuf_oneof:"result"`
	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: No Fallible: No Type: 0x0C00 + 5 Flag: RequiresRuntimeAck

func (*RunEntryMessage) Descriptor deprecated 

func (*RunEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use RunEntryMessage.ProtoReflect.Descriptor instead.

func (*RunEntryMessage) GetFailure 

func (x *RunEntryMessage) GetFailure() *Failure

func (*RunEntryMessage) GetName 

func (x *RunEntryMessage) GetName() string

func (*RunEntryMessage) GetResult 

func (m *RunEntryMessage) GetResult() isRunEntryMessage_Result

func (*RunEntryMessage) GetValue 

func (x *RunEntryMessage) GetValue() []byte

func (*RunEntryMessage) ProtoMessage 

func (*RunEntryMessage) ProtoMessage()

func (*RunEntryMessage) ProtoReflect 

func (x *RunEntryMessage) ProtoReflect() protoreflect.Message

func (*RunEntryMessage) Reset 

func (x *RunEntryMessage) Reset()

func (*RunEntryMessage) String 

func (x *RunEntryMessage) String() string

type RunEntryMessage_Failure 

type RunEntryMessage_Failure struct {
	Failure *Failure `protobuf:"bytes,15,opt,name=failure,proto3,oneof"`
}

type RunEntryMessage_Value 

type RunEntryMessage_Value struct {
	Value []byte `protobuf:"bytes,14,opt,name=value,proto3,oneof"`
}

type ServiceDiscoveryProtocolVersion 

type ServiceDiscoveryProtocolVersion int32

Service discovery protocol version. 

const (
	ServiceDiscoveryProtocolVersion_SERVICE_DISCOVERY_PROTOCOL_VERSION_UNSPECIFIED ServiceDiscoveryProtocolVersion = 0
	// initial service discovery protocol version using endpoint_manifest_schema.json
	ServiceDiscoveryProtocolVersion_V1 ServiceDiscoveryProtocolVersion = 1
)

func (ServiceDiscoveryProtocolVersion) Descriptor 

func (ServiceDiscoveryProtocolVersion) Descriptor() protoreflect.EnumDescriptor

func (ServiceDiscoveryProtocolVersion) Enum 

func (x ServiceDiscoveryProtocolVersion) Enum() *ServiceDiscoveryProtocolVersion

func (ServiceDiscoveryProtocolVersion) EnumDescriptor deprecated 

func (ServiceDiscoveryProtocolVersion) EnumDescriptor() ([]byte, []int)

Deprecated: Use ServiceDiscoveryProtocolVersion.Descriptor instead.

func (ServiceDiscoveryProtocolVersion) Number 

func (x ServiceDiscoveryProtocolVersion) Number() protoreflect.EnumNumber

func (ServiceDiscoveryProtocolVersion) String 

func (x ServiceDiscoveryProtocolVersion) String() string

func (ServiceDiscoveryProtocolVersion) Type 

func (ServiceDiscoveryProtocolVersion) Type() protoreflect.EnumType

type ServiceProtocolVersion 

type ServiceProtocolVersion int32

Service protocol version. 

const (
	ServiceProtocolVersion_SERVICE_PROTOCOL_VERSION_UNSPECIFIED ServiceProtocolVersion = 0
	// initial service protocol version
	ServiceProtocolVersion_V1 ServiceProtocolVersion = 1
)

func (ServiceProtocolVersion) Descriptor 

func (ServiceProtocolVersion) Descriptor() protoreflect.EnumDescriptor

func (ServiceProtocolVersion) Enum 

func (x ServiceProtocolVersion) Enum() *ServiceProtocolVersion

func (ServiceProtocolVersion) EnumDescriptor deprecated 

func (ServiceProtocolVersion) EnumDescriptor() ([]byte, []int)

Deprecated: Use ServiceProtocolVersion.Descriptor instead.

func (ServiceProtocolVersion) Number 

func (x ServiceProtocolVersion) Number() protoreflect.EnumNumber

func (ServiceProtocolVersion) String 

func (x ServiceProtocolVersion) String() string

func (ServiceProtocolVersion) Type 

func (ServiceProtocolVersion) Type() protoreflect.EnumType

type SetStateEntryMessage 

type SetStateEntryMessage struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: No Fallible: No Type: 0x0800 + 1

func (*SetStateEntryMessage) Descriptor deprecated 

func (*SetStateEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use SetStateEntryMessage.ProtoReflect.Descriptor instead.

func (*SetStateEntryMessage) GetKey 

func (x *SetStateEntryMessage) GetKey() []byte

func (*SetStateEntryMessage) GetName 

func (x *SetStateEntryMessage) GetName() string

func (*SetStateEntryMessage) GetValue 

func (x *SetStateEntryMessage) GetValue() []byte

func (*SetStateEntryMessage) ProtoMessage 

func (*SetStateEntryMessage) ProtoMessage()

func (*SetStateEntryMessage) ProtoReflect 

func (x *SetStateEntryMessage) ProtoReflect() protoreflect.Message

func (*SetStateEntryMessage) Reset 

func (x *SetStateEntryMessage) Reset()

func (*SetStateEntryMessage) String 

func (x *SetStateEntryMessage) String() string

type SleepEntryMessage 

type SleepEntryMessage struct {

	// Wake up time.
	// The time is set as duration since UNIX Epoch.
	WakeUpTime uint64 `protobuf:"varint,1,opt,name=wake_up_time,json=wakeUpTime,proto3" json:"wake_up_time,omitempty"`
	// Types that are assignable to Result:
	//
	//	*SleepEntryMessage_Empty
	//	*SleepEntryMessage_Failure
	Result isSleepEntryMessage_Result `protobuf_oneof:"result"`
	// Entry name
	Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Completable: Yes Fallible: No Type: 0x0C00 + 0

func (*SleepEntryMessage) Descriptor deprecated 

func (*SleepEntryMessage) Descriptor() ([]byte, []int)

Deprecated: Use SleepEntryMessage.ProtoReflect.Descriptor instead.

func (*SleepEntryMessage) GetEmpty 

func (x *SleepEntryMessage) GetEmpty() *Empty

func (*SleepEntryMessage) GetFailure 

func (x *SleepEntryMessage) GetFailure() *Failure

func (*SleepEntryMessage) GetName 

func (x *SleepEntryMessage) GetName() string

func (*SleepEntryMessage) GetResult 

func (m *SleepEntryMessage) GetResult() isSleepEntryMessage_Result

func (*SleepEntryMessage) GetWakeUpTime 

func (x *SleepEntryMessage) GetWakeUpTime() uint64

func (*SleepEntryMessage) ProtoMessage 

func (*SleepEntryMessage) ProtoMessage()

func (*SleepEntryMessage) ProtoReflect 

func (x *SleepEntryMessage) ProtoReflect() protoreflect.Message

func (*SleepEntryMessage) Reset 

func (x *SleepEntryMessage) Reset()

func (*SleepEntryMessage) String 

func (x *SleepEntryMessage) String() string

type SleepEntryMessage_Empty 

type SleepEntryMessage_Empty struct {
	Empty *Empty `protobuf:"bytes,13,opt,name=empty,proto3,oneof"`
}

type SleepEntryMessage_Failure 

type SleepEntryMessage_Failure struct {
	Failure *Failure `protobuf:"bytes,15,opt,name=failure,proto3,oneof"`
}

type StartMessage 

type StartMessage struct {

	// Unique id of the invocation. This id is unique across invocations and won't change when replaying the journal.
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Invocation id that can be used for logging.
	// The user can use this id to address this invocation in admin and status introspection apis.
	DebugId      string `protobuf:"bytes,2,opt,name=debug_id,json=debugId,proto3" json:"debug_id,omitempty"`
	KnownEntries uint32 `protobuf:"varint,3,opt,name=known_entries,json=knownEntries,proto3" json:"known_entries,omitempty"`
	// protolint:disable:next REPEATED_FIELD_NAMES_PLURALIZED
	StateMap     []*StartMessage_StateEntry `protobuf:"bytes,4,rep,name=state_map,json=stateMap,proto3" json:"state_map,omitempty"`
	PartialState bool                       `protobuf:"varint,5,opt,name=partial_state,json=partialState,proto3" json:"partial_state,omitempty"`
	// If this invocation has a key associated (e.g. for objects and workflows), then this key is filled in. Empty otherwise.
	Key string `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

Type: 0x0000 + 0

func (*StartMessage) Descriptor deprecated 

func (*StartMessage) Descriptor() ([]byte, []int)

Deprecated: Use StartMessage.ProtoReflect.Descriptor instead.

func (*StartMessage) GetDebugId 

func (x *StartMessage) GetDebugId() string

func (*StartMessage) GetId 

func (x *StartMessage) GetId() []byte

func (*StartMessage) GetKey 

func (x *StartMessage) GetKey() string

func (*StartMessage) GetKnownEntries 

func (x *StartMessage) GetKnownEntries() uint32

func (*StartMessage) GetPartialState 

func (x *StartMessage) GetPartialState() bool

func (*StartMessage) GetStateMap 

func (x *StartMessage) GetStateMap() []*StartMessage_StateEntry

func (*StartMessage) ProtoMessage 

func (*StartMessage) ProtoMessage()

func (*StartMessage) ProtoReflect 

func (x *StartMessage) ProtoReflect() protoreflect.Message

func (*StartMessage) Reset 

func (x *StartMessage) Reset()

func (*StartMessage) String 

func (x *StartMessage) String() string

type StartMessage_StateEntry 

type StartMessage_StateEntry struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// If value is an empty byte array,
	// then it means the value is empty and not "missing" (e.g. empty string).
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*StartMessage_StateEntry) Descriptor deprecated 

func (*StartMessage_StateEntry) Descriptor() ([]byte, []int)

Deprecated: Use StartMessage_StateEntry.ProtoReflect.Descriptor instead.

func (*StartMessage_StateEntry) GetKey 

func (x *StartMessage_StateEntry) GetKey() []byte

func (*StartMessage_StateEntry) GetValue 

func (x *StartMessage_StateEntry) GetValue() []byte

func (*StartMessage_StateEntry) ProtoMessage 

func (*StartMessage_StateEntry) ProtoMessage()

func (*StartMessage_StateEntry) ProtoReflect 

func (x *StartMessage_StateEntry) ProtoReflect() protoreflect.Message

func (*StartMessage_StateEntry) Reset 

func (x *StartMessage_StateEntry) Reset()

func (*StartMessage_StateEntry) String 

func (x *StartMessage_StateEntry) String() string

type SuspensionMessage 

type SuspensionMessage struct {

	// This list represents any of the entry_index the invocation is waiting on to progress.
	// The runtime will resume the invocation as soon as one of the given entry_index is completed.
	// This list MUST not be empty.
	// False positive, entry_indexes is a valid plural of entry_indices.
	// https://learn.microsoft.com/en-us/style-guide/a-z-word-list-term-collections/i/index-indexes-indices
	EntryIndexes []uint32 `protobuf:"varint,1,rep,packed,name=entry_indexes,json=entryIndexes,proto3" json:"entry_indexes,omitempty"` // protolint:disable:this REPEATED_FIELD_NAMES_PLURALIZED
	// contains filtered or unexported fields
}

Type: 0x0000 + 2 Implementations MUST send this message when suspending an invocation.

func (*SuspensionMessage) Descriptor deprecated 

func (*SuspensionMessage) Descriptor() ([]byte, []int)

Deprecated: Use SuspensionMessage.ProtoReflect.Descriptor instead.

func (*SuspensionMessage) GetEntryIndexes 

func (x *SuspensionMessage) GetEntryIndexes() []uint32

func (*SuspensionMessage) ProtoMessage 

func (*SuspensionMessage) ProtoMessage()

func (*SuspensionMessage) ProtoReflect 

func (x *SuspensionMessage) ProtoReflect() protoreflect.Message

func (*SuspensionMessage) Reset 

func (x *SuspensionMessage) Reset()

func (*SuspensionMessage) String 

func (x *SuspensionMessage) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.