Help us shape the future of Go! Take the 2026 Go Developer Survey

service

package
v0.13.2 Latest Latest
Warning

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

Go to latest
Published: Dec 11, 2024 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 (*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 (*CompleteAwakeableEntryMessage) GetName

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 (*CompleteAwakeableEntryMessage) Reset

func (x *CompleteAwakeableEntryMessage) Reset()

func (*CompleteAwakeableEntryMessage) 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 (*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 (*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 (*GetStateKeysEntryMessage_StateKeys) Reset

func (*GetStateKeysEntryMessage_StateKeys) 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) Enum

func (ServiceDiscoveryProtocolVersion) EnumDescriptor deprecated

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

Deprecated: Use ServiceDiscoveryProtocolVersion.Descriptor instead.

func (ServiceDiscoveryProtocolVersion) Number

func (ServiceDiscoveryProtocolVersion) String

func (ServiceDiscoveryProtocolVersion) Type

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) Enum

func (ServiceProtocolVersion) EnumDescriptor deprecated

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

Deprecated: Use ServiceProtocolVersion.Descriptor instead.

func (ServiceProtocolVersion) Number

func (ServiceProtocolVersion) String

func (x ServiceProtocolVersion) String() string

func (ServiceProtocolVersion) Type

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL