Versions in this module Expand all Collapse all v0 v0.1.1 Jan 25, 2023 Changes in this version + var File_pbflink_request_reply_proto protoreflect.FileDescriptor + var File_pbflink_types_proto protoreflect.FileDescriptor + var FromFunction_ExpirationSpec_ExpireMode_name = map[int32]string + var FromFunction_ExpirationSpec_ExpireMode_value = map[string]int32 + var FromFunction_PersistedValueMutation_MutationType_name = map[int32]string + var FromFunction_PersistedValueMutation_MutationType_value = map[string]int32 + type Address struct + Id string + Namespace string + Type string + func (*Address) Descriptor() ([]byte, []int) + func (*Address) ProtoMessage() + func (x *Address) GetId() string + func (x *Address) GetNamespace() string + func (x *Address) GetType() string + func (x *Address) ProtoReflect() protoreflect.Message + func (x *Address) Reset() + func (x *Address) String() string + type BooleanWrapper struct + Value bool + func (*BooleanWrapper) Descriptor() ([]byte, []int) + func (*BooleanWrapper) ProtoMessage() + func (x *BooleanWrapper) GetValue() bool + func (x *BooleanWrapper) ProtoReflect() protoreflect.Message + func (x *BooleanWrapper) Reset() + func (x *BooleanWrapper) String() string + type DoubleWrapper struct + Value float64 + func (*DoubleWrapper) Descriptor() ([]byte, []int) + func (*DoubleWrapper) ProtoMessage() + func (x *DoubleWrapper) GetValue() float64 + func (x *DoubleWrapper) ProtoReflect() protoreflect.Message + func (x *DoubleWrapper) Reset() + func (x *DoubleWrapper) String() string + type FloatWrapper struct + Value float32 + func (*FloatWrapper) Descriptor() ([]byte, []int) + func (*FloatWrapper) ProtoMessage() + func (x *FloatWrapper) GetValue() float32 + func (x *FloatWrapper) ProtoReflect() protoreflect.Message + func (x *FloatWrapper) Reset() + func (x *FloatWrapper) String() string + type FromFunction struct + Response isFromFunction_Response + func (*FromFunction) Descriptor() ([]byte, []int) + func (*FromFunction) ProtoMessage() + func (m *FromFunction) GetResponse() isFromFunction_Response + func (x *FromFunction) GetIncompleteInvocationContext() *FromFunction_IncompleteInvocationContext + func (x *FromFunction) GetInvocationResult() *FromFunction_InvocationResponse + func (x *FromFunction) ProtoReflect() protoreflect.Message + func (x *FromFunction) Reset() + func (x *FromFunction) String() string + type FromFunction_DelayedInvocation struct + Argument *TypedValue + CancellationToken string + DelayInMs int64 + IsCancellationRequest bool + Target *Address + func (*FromFunction_DelayedInvocation) Descriptor() ([]byte, []int) + func (*FromFunction_DelayedInvocation) ProtoMessage() + func (x *FromFunction_DelayedInvocation) GetArgument() *TypedValue + func (x *FromFunction_DelayedInvocation) GetCancellationToken() string + func (x *FromFunction_DelayedInvocation) GetDelayInMs() int64 + func (x *FromFunction_DelayedInvocation) GetIsCancellationRequest() bool + func (x *FromFunction_DelayedInvocation) GetTarget() *Address + func (x *FromFunction_DelayedInvocation) ProtoReflect() protoreflect.Message + func (x *FromFunction_DelayedInvocation) Reset() + func (x *FromFunction_DelayedInvocation) String() string + type FromFunction_EgressMessage struct + Argument *TypedValue + EgressNamespace string + EgressType string + func (*FromFunction_EgressMessage) Descriptor() ([]byte, []int) + func (*FromFunction_EgressMessage) ProtoMessage() + func (x *FromFunction_EgressMessage) GetArgument() *TypedValue + func (x *FromFunction_EgressMessage) GetEgressNamespace() string + func (x *FromFunction_EgressMessage) GetEgressType() string + func (x *FromFunction_EgressMessage) ProtoReflect() protoreflect.Message + func (x *FromFunction_EgressMessage) Reset() + func (x *FromFunction_EgressMessage) String() string + type FromFunction_ExpirationSpec struct + ExpireAfterMillis int64 + Mode FromFunction_ExpirationSpec_ExpireMode + func (*FromFunction_ExpirationSpec) Descriptor() ([]byte, []int) + func (*FromFunction_ExpirationSpec) ProtoMessage() + func (x *FromFunction_ExpirationSpec) GetExpireAfterMillis() int64 + func (x *FromFunction_ExpirationSpec) GetMode() FromFunction_ExpirationSpec_ExpireMode + func (x *FromFunction_ExpirationSpec) ProtoReflect() protoreflect.Message + func (x *FromFunction_ExpirationSpec) Reset() + func (x *FromFunction_ExpirationSpec) String() string + type FromFunction_ExpirationSpec_ExpireMode int32 + const FromFunction_ExpirationSpec_AFTER_INVOKE + const FromFunction_ExpirationSpec_AFTER_WRITE + const FromFunction_ExpirationSpec_NONE + func (FromFunction_ExpirationSpec_ExpireMode) Descriptor() protoreflect.EnumDescriptor + func (FromFunction_ExpirationSpec_ExpireMode) EnumDescriptor() ([]byte, []int) + func (FromFunction_ExpirationSpec_ExpireMode) Type() protoreflect.EnumType + func (x FromFunction_ExpirationSpec_ExpireMode) Enum() *FromFunction_ExpirationSpec_ExpireMode + func (x FromFunction_ExpirationSpec_ExpireMode) Number() protoreflect.EnumNumber + func (x FromFunction_ExpirationSpec_ExpireMode) String() string + type FromFunction_IncompleteInvocationContext struct + MissingValues []*FromFunction_PersistedValueSpec + func (*FromFunction_IncompleteInvocationContext) Descriptor() ([]byte, []int) + func (*FromFunction_IncompleteInvocationContext) ProtoMessage() + func (x *FromFunction_IncompleteInvocationContext) GetMissingValues() []*FromFunction_PersistedValueSpec + func (x *FromFunction_IncompleteInvocationContext) ProtoReflect() protoreflect.Message + func (x *FromFunction_IncompleteInvocationContext) Reset() + func (x *FromFunction_IncompleteInvocationContext) String() string + type FromFunction_IncompleteInvocationContext_ struct + IncompleteInvocationContext *FromFunction_IncompleteInvocationContext + type FromFunction_Invocation struct + Argument *TypedValue + Target *Address + func (*FromFunction_Invocation) Descriptor() ([]byte, []int) + func (*FromFunction_Invocation) ProtoMessage() + func (x *FromFunction_Invocation) GetArgument() *TypedValue + func (x *FromFunction_Invocation) GetTarget() *Address + func (x *FromFunction_Invocation) ProtoReflect() protoreflect.Message + func (x *FromFunction_Invocation) Reset() + func (x *FromFunction_Invocation) String() string + type FromFunction_InvocationResponse struct + DelayedInvocations []*FromFunction_DelayedInvocation + OutgoingEgresses []*FromFunction_EgressMessage + OutgoingMessages []*FromFunction_Invocation + StateMutations []*FromFunction_PersistedValueMutation + func (*FromFunction_InvocationResponse) Descriptor() ([]byte, []int) + func (*FromFunction_InvocationResponse) ProtoMessage() + func (x *FromFunction_InvocationResponse) GetDelayedInvocations() []*FromFunction_DelayedInvocation + func (x *FromFunction_InvocationResponse) GetOutgoingEgresses() []*FromFunction_EgressMessage + func (x *FromFunction_InvocationResponse) GetOutgoingMessages() []*FromFunction_Invocation + func (x *FromFunction_InvocationResponse) GetStateMutations() []*FromFunction_PersistedValueMutation + func (x *FromFunction_InvocationResponse) ProtoReflect() protoreflect.Message + func (x *FromFunction_InvocationResponse) Reset() + func (x *FromFunction_InvocationResponse) String() string + type FromFunction_InvocationResult struct + InvocationResult *FromFunction_InvocationResponse + type FromFunction_PersistedValueMutation struct + MutationType FromFunction_PersistedValueMutation_MutationType + StateName string + StateValue *TypedValue + func (*FromFunction_PersistedValueMutation) Descriptor() ([]byte, []int) + func (*FromFunction_PersistedValueMutation) ProtoMessage() + func (x *FromFunction_PersistedValueMutation) GetMutationType() FromFunction_PersistedValueMutation_MutationType + func (x *FromFunction_PersistedValueMutation) GetStateName() string + func (x *FromFunction_PersistedValueMutation) GetStateValue() *TypedValue + func (x *FromFunction_PersistedValueMutation) ProtoReflect() protoreflect.Message + func (x *FromFunction_PersistedValueMutation) Reset() + func (x *FromFunction_PersistedValueMutation) String() string + type FromFunction_PersistedValueMutation_MutationType int32 + const FromFunction_PersistedValueMutation_DELETE + const FromFunction_PersistedValueMutation_MODIFY + func (FromFunction_PersistedValueMutation_MutationType) Descriptor() protoreflect.EnumDescriptor + func (FromFunction_PersistedValueMutation_MutationType) EnumDescriptor() ([]byte, []int) + func (FromFunction_PersistedValueMutation_MutationType) Type() protoreflect.EnumType + func (x FromFunction_PersistedValueMutation_MutationType) Enum() *FromFunction_PersistedValueMutation_MutationType + func (x FromFunction_PersistedValueMutation_MutationType) Number() protoreflect.EnumNumber + func (x FromFunction_PersistedValueMutation_MutationType) String() string + type FromFunction_PersistedValueSpec struct + ExpirationSpec *FromFunction_ExpirationSpec + StateName string + TypeTypename string + func (*FromFunction_PersistedValueSpec) Descriptor() ([]byte, []int) + func (*FromFunction_PersistedValueSpec) ProtoMessage() + func (x *FromFunction_PersistedValueSpec) GetExpirationSpec() *FromFunction_ExpirationSpec + func (x *FromFunction_PersistedValueSpec) GetStateName() string + func (x *FromFunction_PersistedValueSpec) GetTypeTypename() string + func (x *FromFunction_PersistedValueSpec) ProtoReflect() protoreflect.Message + func (x *FromFunction_PersistedValueSpec) Reset() + func (x *FromFunction_PersistedValueSpec) String() string + type IntWrapper struct + Value int32 + func (*IntWrapper) Descriptor() ([]byte, []int) + func (*IntWrapper) ProtoMessage() + func (x *IntWrapper) GetValue() int32 + func (x *IntWrapper) ProtoReflect() protoreflect.Message + func (x *IntWrapper) Reset() + func (x *IntWrapper) String() string + type LongWrapper struct + Value int64 + func (*LongWrapper) Descriptor() ([]byte, []int) + func (*LongWrapper) ProtoMessage() + func (x *LongWrapper) GetValue() int64 + func (x *LongWrapper) ProtoReflect() protoreflect.Message + func (x *LongWrapper) Reset() + func (x *LongWrapper) String() string + type StringWrapper struct + Value string + func (*StringWrapper) Descriptor() ([]byte, []int) + func (*StringWrapper) ProtoMessage() + func (x *StringWrapper) GetValue() string + func (x *StringWrapper) ProtoReflect() protoreflect.Message + func (x *StringWrapper) Reset() + func (x *StringWrapper) String() string + type ToFunction struct + Request isToFunction_Request + func (*ToFunction) Descriptor() ([]byte, []int) + func (*ToFunction) ProtoMessage() + func (m *ToFunction) GetRequest() isToFunction_Request + func (x *ToFunction) GetInvocation() *ToFunction_InvocationBatchRequest + func (x *ToFunction) ProtoReflect() protoreflect.Message + func (x *ToFunction) Reset() + func (x *ToFunction) String() string + type ToFunction_Invocation struct + Argument *TypedValue + Caller *Address + func (*ToFunction_Invocation) Descriptor() ([]byte, []int) + func (*ToFunction_Invocation) ProtoMessage() + func (x *ToFunction_Invocation) GetArgument() *TypedValue + func (x *ToFunction_Invocation) GetCaller() *Address + func (x *ToFunction_Invocation) ProtoReflect() protoreflect.Message + func (x *ToFunction_Invocation) Reset() + func (x *ToFunction_Invocation) String() string + type ToFunction_InvocationBatchRequest struct + Invocations []*ToFunction_Invocation + State []*ToFunction_PersistedValue + Target *Address + func (*ToFunction_InvocationBatchRequest) Descriptor() ([]byte, []int) + func (*ToFunction_InvocationBatchRequest) ProtoMessage() + func (x *ToFunction_InvocationBatchRequest) GetInvocations() []*ToFunction_Invocation + func (x *ToFunction_InvocationBatchRequest) GetState() []*ToFunction_PersistedValue + func (x *ToFunction_InvocationBatchRequest) GetTarget() *Address + func (x *ToFunction_InvocationBatchRequest) ProtoReflect() protoreflect.Message + func (x *ToFunction_InvocationBatchRequest) Reset() + func (x *ToFunction_InvocationBatchRequest) String() string + type ToFunction_Invocation_ struct + Invocation *ToFunction_InvocationBatchRequest + type ToFunction_PersistedValue struct + StateName string + StateValue *TypedValue + func (*ToFunction_PersistedValue) Descriptor() ([]byte, []int) + func (*ToFunction_PersistedValue) ProtoMessage() + func (x *ToFunction_PersistedValue) GetStateName() string + func (x *ToFunction_PersistedValue) GetStateValue() *TypedValue + func (x *ToFunction_PersistedValue) ProtoReflect() protoreflect.Message + func (x *ToFunction_PersistedValue) Reset() + func (x *ToFunction_PersistedValue) String() string + type TypedValue struct + HasValue bool + Typename string + Value []byte + func (*TypedValue) Descriptor() ([]byte, []int) + func (*TypedValue) ProtoMessage() + func (x *TypedValue) GetHasValue() bool + func (x *TypedValue) GetTypename() string + func (x *TypedValue) GetValue() []byte + func (x *TypedValue) ProtoReflect() protoreflect.Message + func (x *TypedValue) Reset() + func (x *TypedValue) String() string
Go to main page