runtime

package
v0.0.0-...-13c49c2 Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2024 License: Apache-2.0 Imports: 10 Imported by: 17

README

How to compile these proto files into golang code and documentation

Please visit https://mosn.io/layotto/en-US/docs/api_reference/how_to_generate_api_doc

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TopicEventResponse_TopicEventResponseStatus_name = map[int32]string{
		0: "SUCCESS",
		1: "RETRY",
		2: "DROP",
	}
	TopicEventResponse_TopicEventResponseStatus_value = map[string]int32{
		"SUCCESS": 0,
		"RETRY":   1,
		"DROP":    2,
	}
)

Enum value maps for TopicEventResponse_TopicEventResponseStatus.

View Source 
var (
	SequencerOptions_AutoIncrement_name = map[int32]string{
		0: "WEAK",
		1: "STRONG",
	}
	SequencerOptions_AutoIncrement_value = map[string]int32{
		"WEAK":   0,
		"STRONG": 1,
	}
)

Enum value maps for SequencerOptions_AutoIncrement.

View Source 
var (
	UnlockResponse_Status_name = map[int32]string{
		0: "SUCCESS",
		1: "LOCK_UNEXIST",
		2: "LOCK_BELONG_TO_OTHERS",
		3: "INTERNAL_ERROR",
	}
	UnlockResponse_Status_value = map[string]int32{
		"SUCCESS":               0,
		"LOCK_UNEXIST":          1,
		"LOCK_BELONG_TO_OTHERS": 2,
		"INTERNAL_ERROR":        3,
	}
)

Enum value maps for UnlockResponse_Status.

View Source 
var (
	LockKeepAliveResponse_Status_name = map[int32]string{
		0: "SUCCESS",
		1: "LOCK_UNEXIST",
		2: "LOCK_BELONG_TO_OTHERS",
		3: "INTERNAL_ERROR",
	}
	LockKeepAliveResponse_Status_value = map[string]int32{
		"SUCCESS":               0,
		"LOCK_UNEXIST":          1,
		"LOCK_BELONG_TO_OTHERS": 2,
		"INTERNAL_ERROR":        3,
	}
)

Enum value maps for LockKeepAliveResponse_Status.

View Source 
var (
	HTTPExtension_Verb_name = map[int32]string{
		0: "NONE",
		1: "GET",
		2: "HEAD",
		3: "POST",
		4: "PUT",
		5: "DELETE",
		6: "CONNECT",
		7: "OPTIONS",
		8: "TRACE",
		9: "PATCH",
	}
	HTTPExtension_Verb_value = map[string]int32{
		"NONE":    0,
		"GET":     1,
		"HEAD":    2,
		"POST":    3,
		"PUT":     4,
		"DELETE":  5,
		"CONNECT": 6,
		"OPTIONS": 7,
		"TRACE":   8,
		"PATCH":   9,
	}
)

Enum value maps for HTTPExtension_Verb.

View Source 
var (
	StateOptions_StateConcurrency_name = map[int32]string{
		0: "CONCURRENCY_UNSPECIFIED",
		1: "CONCURRENCY_FIRST_WRITE",
		2: "CONCURRENCY_LAST_WRITE",
	}
	StateOptions_StateConcurrency_value = map[string]int32{
		"CONCURRENCY_UNSPECIFIED": 0,
		"CONCURRENCY_FIRST_WRITE": 1,
		"CONCURRENCY_LAST_WRITE":  2,
	}
)

Enum value maps for StateOptions_StateConcurrency.

View Source 
var (
	StateOptions_StateConsistency_name = map[int32]string{
		0: "CONSISTENCY_UNSPECIFIED",
		1: "CONSISTENCY_EVENTUAL",
		2: "CONSISTENCY_STRONG",
	}
	StateOptions_StateConsistency_value = map[string]int32{
		"CONSISTENCY_UNSPECIFIED": 0,
		"CONSISTENCY_EVENTUAL":    1,
		"CONSISTENCY_STRONG":      2,
	}
)

Enum value maps for StateOptions_StateConsistency.

View Source 
var AppCallback_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spec.proto.runtime.v1.AppCallback",
	HandlerType: (*AppCallbackServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListTopicSubscriptions",
			Handler:    _AppCallback_ListTopicSubscriptions_Handler,
		},
		{
			MethodName: "OnTopicEvent",
			Handler:    _AppCallback_OnTopicEvent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "appcallback.proto",
}

AppCallback_ServiceDesc is the grpc.ServiceDesc for AppCallback service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_appcallback_proto protoreflect.FileDescriptor
View Source 
var File_lifecycle_proto protoreflect.FileDescriptor
View Source 
var File_runtime_proto protoreflect.FileDescriptor
View Source 
var Lifecycle_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spec.proto.runtime.v1.Lifecycle",
	HandlerType: (*LifecycleServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ApplyConfiguration",
			Handler:    _Lifecycle_ApplyConfiguration_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "lifecycle.proto",
}

Lifecycle_ServiceDesc is the grpc.ServiceDesc for Lifecycle service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Runtime_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "spec.proto.runtime.v1.Runtime",
	HandlerType: (*RuntimeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SayHello",
			Handler:    _Runtime_SayHello_Handler,
		},
		{
			MethodName: "InvokeService",
			Handler:    _Runtime_InvokeService_Handler,
		},
		{
			MethodName: "GetConfiguration",
			Handler:    _Runtime_GetConfiguration_Handler,
		},
		{
			MethodName: "SaveConfiguration",
			Handler:    _Runtime_SaveConfiguration_Handler,
		},
		{
			MethodName: "DeleteConfiguration",
			Handler:    _Runtime_DeleteConfiguration_Handler,
		},
		{
			MethodName: "TryLock",
			Handler:    _Runtime_TryLock_Handler,
		},
		{
			MethodName: "Unlock",
			Handler:    _Runtime_Unlock_Handler,
		},
		{
			MethodName: "LockKeepAlive",
			Handler:    _Runtime_LockKeepAlive_Handler,
		},
		{
			MethodName: "GetNextId",
			Handler:    _Runtime_GetNextId_Handler,
		},
		{
			MethodName: "GetState",
			Handler:    _Runtime_GetState_Handler,
		},
		{
			MethodName: "GetBulkState",
			Handler:    _Runtime_GetBulkState_Handler,
		},
		{
			MethodName: "SaveState",
			Handler:    _Runtime_SaveState_Handler,
		},
		{
			MethodName: "DeleteState",
			Handler:    _Runtime_DeleteState_Handler,
		},
		{
			MethodName: "DeleteBulkState",
			Handler:    _Runtime_DeleteBulkState_Handler,
		},
		{
			MethodName: "ExecuteStateTransaction",
			Handler:    _Runtime_ExecuteStateTransaction_Handler,
		},
		{
			MethodName: "PublishEvent",
			Handler:    _Runtime_PublishEvent_Handler,
		},
		{
			MethodName: "ListFile",
			Handler:    _Runtime_ListFile_Handler,
		},
		{
			MethodName: "DelFile",
			Handler:    _Runtime_DelFile_Handler,
		},
		{
			MethodName: "GetFileMeta",
			Handler:    _Runtime_GetFileMeta_Handler,
		},
		{
			MethodName: "InvokeBinding",
			Handler:    _Runtime_InvokeBinding_Handler,
		},
		{
			MethodName: "GetSecret",
			Handler:    _Runtime_GetSecret_Handler,
		},
		{
			MethodName: "GetBulkSecret",
			Handler:    _Runtime_GetBulkSecret_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeConfiguration",
			Handler:       _Runtime_SubscribeConfiguration_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SubscribeTopicEvents",
			Handler:       _Runtime_SubscribeTopicEvents_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "GetFile",
			Handler:       _Runtime_GetFile_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "PutFile",
			Handler:       _Runtime_PutFile_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "runtime.proto",
}

Runtime_ServiceDesc is the grpc.ServiceDesc for Runtime service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAppCallbackServer 

func RegisterAppCallbackServer(s grpc.ServiceRegistrar, srv AppCallbackServer)

func RegisterLifecycleServer 

func RegisterLifecycleServer(s grpc.ServiceRegistrar, srv LifecycleServer)

func RegisterRuntimeServer 

func RegisterRuntimeServer(s grpc.ServiceRegistrar, srv RuntimeServer)

Types

type AppCallbackClient 

type AppCallbackClient interface {
	// Lists all topics subscribed by this app.
	ListTopicSubscriptions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListTopicSubscriptionsResponse, error)
	// Subscribes events from Pubsub
	OnTopicEvent(ctx context.Context, in *TopicEventRequest, opts ...grpc.CallOption) (*TopicEventResponse, error)
}

AppCallbackClient is the client API for AppCallback service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAppCallbackClient 

func NewAppCallbackClient(cc grpc.ClientConnInterface) AppCallbackClient

type AppCallbackServer 

type AppCallbackServer interface {
	// Lists all topics subscribed by this app.
	ListTopicSubscriptions(context.Context, *emptypb.Empty) (*ListTopicSubscriptionsResponse, error)
	// Subscribes events from Pubsub
	OnTopicEvent(context.Context, *TopicEventRequest) (*TopicEventResponse, error)
}

AppCallbackServer is the server API for AppCallback service. All implementations should embed UnimplementedAppCallbackServer for forward compatibility

type ApplyConfigurationResponse 

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

The response of the `ApplyConfiguration` method.

func (*ApplyConfigurationResponse) Descriptor deprecated 

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

Deprecated: Use ApplyConfigurationResponse.ProtoReflect.Descriptor instead.

func (*ApplyConfigurationResponse) ProtoMessage 

func (*ApplyConfigurationResponse) ProtoMessage()

func (*ApplyConfigurationResponse) ProtoReflect 

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

func (*ApplyConfigurationResponse) Reset 

func (x *ApplyConfigurationResponse) Reset()

func (*ApplyConfigurationResponse) String 

func (x *ApplyConfigurationResponse) String() string

type BulkStateItem 

type BulkStateItem struct {

	// state item key
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The byte array data
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// The entity tag which represents the specific version of data.
	// ETag format is defined by the corresponding data store.
	Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// The error that was returned from the state store in case of a failed get operation.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// The metadata which will be sent to app.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

BulkStateItem is the response item for a bulk get operation. Return values include the item key, data and etag.

func (*BulkStateItem) Descriptor deprecated 

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

Deprecated: Use BulkStateItem.ProtoReflect.Descriptor instead.

func (*BulkStateItem) GetData 

func (x *BulkStateItem) GetData() []byte

func (*BulkStateItem) GetError 

func (x *BulkStateItem) GetError() string

func (*BulkStateItem) GetEtag 

func (x *BulkStateItem) GetEtag() string

func (*BulkStateItem) GetKey 

func (x *BulkStateItem) GetKey() string

func (*BulkStateItem) GetMetadata 

func (x *BulkStateItem) GetMetadata() map[string]string

func (*BulkStateItem) ProtoMessage 

func (*BulkStateItem) ProtoMessage()

func (*BulkStateItem) ProtoReflect 

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

func (*BulkStateItem) Reset 

func (x *BulkStateItem) Reset()

func (*BulkStateItem) String 

func (x *BulkStateItem) String() string

type CommonInvokeRequest 

type CommonInvokeRequest struct {

	// The method of requset
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	// The request data
	Data *anypb.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// The content type of request data
	ContentType string `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// The extra information of http
	HttpExtension *HTTPExtension `protobuf:"bytes,4,opt,name=http_extension,json=httpExtension,proto3" json:"http_extension,omitempty"`
	// contains filtered or unexported fields
}

Common invoke request message which includes invoke method and data

func (*CommonInvokeRequest) Descriptor deprecated 

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

Deprecated: Use CommonInvokeRequest.ProtoReflect.Descriptor instead.

func (*CommonInvokeRequest) GetContentType 

func (x *CommonInvokeRequest) GetContentType() string

func (*CommonInvokeRequest) GetData 

func (x *CommonInvokeRequest) GetData() *anypb.Any

func (*CommonInvokeRequest) GetHttpExtension 

func (x *CommonInvokeRequest) GetHttpExtension() *HTTPExtension

func (*CommonInvokeRequest) GetMethod 

func (x *CommonInvokeRequest) GetMethod() string

func (*CommonInvokeRequest) ProtoMessage 

func (*CommonInvokeRequest) ProtoMessage()

func (*CommonInvokeRequest) ProtoReflect 

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

func (*CommonInvokeRequest) Reset 

func (x *CommonInvokeRequest) Reset()

func (*CommonInvokeRequest) String 

func (x *CommonInvokeRequest) String() string

type ComponentConfig 

type ComponentConfig struct {

	// Required. Which kind of API you are using, e.g. `lock`, `state`
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	// Required. The component name, e.g. `state_demo`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The dynamic configuration of this component
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

The dynamic configuration of a component

func (*ComponentConfig) Descriptor deprecated 

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

Deprecated: Use ComponentConfig.ProtoReflect.Descriptor instead.

func (*ComponentConfig) GetKind 

func (x *ComponentConfig) GetKind() string

func (*ComponentConfig) GetMetadata 

func (x *ComponentConfig) GetMetadata() map[string]string

func (*ComponentConfig) GetName 

func (x *ComponentConfig) GetName() string

func (*ComponentConfig) ProtoMessage 

func (*ComponentConfig) ProtoMessage()

func (*ComponentConfig) ProtoReflect 

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

func (*ComponentConfig) Reset 

func (x *ComponentConfig) Reset()

func (*ComponentConfig) String 

func (x *ComponentConfig) String() string

type ConfigurationItem 

type ConfigurationItem struct {

	// Required. The key of configuration item
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The content of configuration item
	// Empty if the configuration is not set, including the case that the configuration is changed from value-set to value-not-set.
	Content string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// The group of configuration item.
	Group string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	// The label of configuration item.
	Label string `protobuf:"bytes,4,opt,name=label,proto3" json:"label,omitempty"`
	// The tag list of configuration item.
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// The metadata which will be passed to configuration store component.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

ConfigurationItem represents a configuration item with key, content and other information.

func (*ConfigurationItem) Descriptor deprecated 

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

Deprecated: Use ConfigurationItem.ProtoReflect.Descriptor instead.

func (*ConfigurationItem) GetContent 

func (x *ConfigurationItem) GetContent() string

func (*ConfigurationItem) GetGroup 

func (x *ConfigurationItem) GetGroup() string

func (*ConfigurationItem) GetKey 

func (x *ConfigurationItem) GetKey() string

func (*ConfigurationItem) GetLabel 

func (x *ConfigurationItem) GetLabel() string

func (*ConfigurationItem) GetMetadata 

func (x *ConfigurationItem) GetMetadata() map[string]string

func (*ConfigurationItem) GetTags 

func (x *ConfigurationItem) GetTags() map[string]string

func (*ConfigurationItem) ProtoMessage 

func (*ConfigurationItem) ProtoMessage()

func (*ConfigurationItem) ProtoReflect 

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

func (*ConfigurationItem) Reset 

func (x *ConfigurationItem) Reset()

func (*ConfigurationItem) String 

func (x *ConfigurationItem) String() string

type DelFileRequest 

type DelFileRequest struct {

	// File request
	Request *FileRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

Delete file request message

func (*DelFileRequest) Descriptor deprecated 

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

Deprecated: Use DelFileRequest.ProtoReflect.Descriptor instead.

func (*DelFileRequest) GetRequest 

func (x *DelFileRequest) GetRequest() *FileRequest

func (*DelFileRequest) ProtoMessage 

func (*DelFileRequest) ProtoMessage()

func (*DelFileRequest) ProtoReflect 

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

func (*DelFileRequest) Reset 

func (x *DelFileRequest) Reset()

func (*DelFileRequest) String 

func (x *DelFileRequest) String() string

type DeleteBulkStateRequest 

type DeleteBulkStateRequest struct {

	// Required. The name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// Required. The array of the state key values.
	States []*StateItem `protobuf:"bytes,2,rep,name=states,proto3" json:"states,omitempty"`
	// contains filtered or unexported fields
}

DeleteBulkStateRequest is the message to delete a list of key-value states from specific state store.

func (*DeleteBulkStateRequest) Descriptor deprecated 

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

Deprecated: Use DeleteBulkStateRequest.ProtoReflect.Descriptor instead.

func (*DeleteBulkStateRequest) GetStates 

func (x *DeleteBulkStateRequest) GetStates() []*StateItem

func (*DeleteBulkStateRequest) GetStoreName 

func (x *DeleteBulkStateRequest) GetStoreName() string

func (*DeleteBulkStateRequest) ProtoMessage 

func (*DeleteBulkStateRequest) ProtoMessage()

func (*DeleteBulkStateRequest) ProtoReflect 

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

func (*DeleteBulkStateRequest) Reset 

func (x *DeleteBulkStateRequest) Reset()

func (*DeleteBulkStateRequest) String 

func (x *DeleteBulkStateRequest) String() string

type DeleteConfigurationRequest 

type DeleteConfigurationRequest struct {

	// The name of configuration store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The application id which
	// Only used for admin, Ignored and reset for normal client
	AppId string `protobuf:"bytes,2,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	// The group of keys.
	Group string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	// The label for keys.
	Label string `protobuf:"bytes,4,opt,name=label,proto3" json:"label,omitempty"`
	// The keys to get.
	Keys []string `protobuf:"bytes,5,rep,name=keys,proto3" json:"keys,omitempty"`
	// The metadata which will be sent to configuration store components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

DeleteConfigurationRequest is the message to delete a list of key-value configuration from specified configuration store.

func (*DeleteConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use DeleteConfigurationRequest.ProtoReflect.Descriptor instead.

func (*DeleteConfigurationRequest) GetAppId 

func (x *DeleteConfigurationRequest) GetAppId() string

func (*DeleteConfigurationRequest) GetGroup 

func (x *DeleteConfigurationRequest) GetGroup() string

func (*DeleteConfigurationRequest) GetKeys 

func (x *DeleteConfigurationRequest) GetKeys() []string

func (*DeleteConfigurationRequest) GetLabel 

func (x *DeleteConfigurationRequest) GetLabel() string

func (*DeleteConfigurationRequest) GetMetadata 

func (x *DeleteConfigurationRequest) GetMetadata() map[string]string

func (*DeleteConfigurationRequest) GetStoreName 

func (x *DeleteConfigurationRequest) GetStoreName() string

func (*DeleteConfigurationRequest) ProtoMessage 

func (*DeleteConfigurationRequest) ProtoMessage()

func (*DeleteConfigurationRequest) ProtoReflect 

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

func (*DeleteConfigurationRequest) Reset 

func (x *DeleteConfigurationRequest) Reset()

func (*DeleteConfigurationRequest) String 

func (x *DeleteConfigurationRequest) String() string

type DeleteStateRequest 

type DeleteStateRequest struct {

	// Required. The name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// Required. The key of the desired state
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// (optional) The entity tag which represents the specific version of data.
	// The exact ETag format is defined by the corresponding data store.
	Etag *Etag `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// (optional) State operation options which includes concurrency/
	// consistency/retry_policy.
	Options *StateOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// (optional) The metadata which will be sent to state store components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

DeleteStateRequest is the message to delete key-value states in the specific state store.

func (*DeleteStateRequest) Descriptor deprecated 

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

Deprecated: Use DeleteStateRequest.ProtoReflect.Descriptor instead.

func (*DeleteStateRequest) GetEtag 

func (x *DeleteStateRequest) GetEtag() *Etag

func (*DeleteStateRequest) GetKey 

func (x *DeleteStateRequest) GetKey() string

func (*DeleteStateRequest) GetMetadata 

func (x *DeleteStateRequest) GetMetadata() map[string]string

func (*DeleteStateRequest) GetOptions 

func (x *DeleteStateRequest) GetOptions() *StateOptions

func (*DeleteStateRequest) GetStoreName 

func (x *DeleteStateRequest) GetStoreName() string

func (*DeleteStateRequest) ProtoMessage 

func (*DeleteStateRequest) ProtoMessage()

func (*DeleteStateRequest) ProtoReflect 

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

func (*DeleteStateRequest) Reset 

func (x *DeleteStateRequest) Reset()

func (*DeleteStateRequest) String 

func (x *DeleteStateRequest) String() string

type DynamicConfiguration 

type DynamicConfiguration struct {

	// Required. The dynamic configuration of a component
	ComponentConfig *ComponentConfig `protobuf:"bytes,1,opt,name=component_config,json=componentConfig,proto3" json:"component_config,omitempty"`
	// contains filtered or unexported fields
}

The dynamic configuration of the sidecar

func (*DynamicConfiguration) Descriptor deprecated 

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

Deprecated: Use DynamicConfiguration.ProtoReflect.Descriptor instead.

func (*DynamicConfiguration) GetComponentConfig 

func (x *DynamicConfiguration) GetComponentConfig() *ComponentConfig

func (*DynamicConfiguration) ProtoMessage 

func (*DynamicConfiguration) ProtoMessage()

func (*DynamicConfiguration) ProtoReflect 

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

func (*DynamicConfiguration) Reset 

func (x *DynamicConfiguration) Reset()

func (*DynamicConfiguration) String 

func (x *DynamicConfiguration) String() string

type Etag 

type Etag struct {

	// value sets the etag value
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Etag represents a state item version

func (*Etag) Descriptor deprecated 

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

Deprecated: Use Etag.ProtoReflect.Descriptor instead.

func (*Etag) GetValue 

func (x *Etag) GetValue() string

func (*Etag) ProtoMessage 

func (*Etag) ProtoMessage()

func (*Etag) ProtoReflect 

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

func (*Etag) Reset 

func (x *Etag) Reset()

func (*Etag) String 

func (x *Etag) String() string

type ExecuteStateTransactionRequest 

type ExecuteStateTransactionRequest struct {

	// Required. name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=storeName,proto3" json:"storeName,omitempty"`
	// Required. transactional operation list.
	Operations []*TransactionalStateOperation `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"`
	// (optional) The metadata used for transactional operations.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

ExecuteStateTransactionRequest is the message to execute multiple operations on a specified store.

func (*ExecuteStateTransactionRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteStateTransactionRequest.ProtoReflect.Descriptor instead.

func (*ExecuteStateTransactionRequest) GetMetadata 

func (x *ExecuteStateTransactionRequest) GetMetadata() map[string]string

func (*ExecuteStateTransactionRequest) GetOperations 

func (x *ExecuteStateTransactionRequest) GetOperations() []*TransactionalStateOperation

func (*ExecuteStateTransactionRequest) GetStoreName 

func (x *ExecuteStateTransactionRequest) GetStoreName() string

func (*ExecuteStateTransactionRequest) ProtoMessage 

func (*ExecuteStateTransactionRequest) ProtoMessage()

func (*ExecuteStateTransactionRequest) ProtoReflect 

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

func (*ExecuteStateTransactionRequest) Reset 

func (x *ExecuteStateTransactionRequest) Reset()

func (*ExecuteStateTransactionRequest) String 

func (x *ExecuteStateTransactionRequest) String() string

type FileInfo 

type FileInfo struct {

	// The name of file
	FileName string `protobuf:"bytes,1,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// The size of file
	Size int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// The modified time of file
	LastModified string `protobuf:"bytes,3,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
	// The metadata for user extension.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

File info message

func (*FileInfo) Descriptor deprecated 

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

Deprecated: Use FileInfo.ProtoReflect.Descriptor instead.

func (*FileInfo) GetFileName 

func (x *FileInfo) GetFileName() string

func (*FileInfo) GetLastModified 

func (x *FileInfo) GetLastModified() string

func (*FileInfo) GetMetadata 

func (x *FileInfo) GetMetadata() map[string]string

func (*FileInfo) GetSize 

func (x *FileInfo) GetSize() int64

func (*FileInfo) ProtoMessage 

func (*FileInfo) ProtoMessage()

func (*FileInfo) ProtoReflect 

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

func (*FileInfo) Reset 

func (x *FileInfo) Reset()

func (*FileInfo) String 

func (x *FileInfo) String() string

type FileMeta 

type FileMeta struct {

	// A data structure to store metadata
	Metadata map[string]*FileMetaValue `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

A map that store FileMetaValue

func (*FileMeta) Descriptor deprecated 

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

Deprecated: Use FileMeta.ProtoReflect.Descriptor instead.

func (*FileMeta) GetMetadata 

func (x *FileMeta) GetMetadata() map[string]*FileMetaValue

func (*FileMeta) ProtoMessage 

func (*FileMeta) ProtoMessage()

func (*FileMeta) ProtoReflect 

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

func (*FileMeta) Reset 

func (x *FileMeta) Reset()

func (*FileMeta) String 

func (x *FileMeta) String() string

type FileMetaValue 

type FileMetaValue struct {

	// File meta value
	Value []string `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

FileMeta value

func (*FileMetaValue) Descriptor deprecated 

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

Deprecated: Use FileMetaValue.ProtoReflect.Descriptor instead.

func (*FileMetaValue) GetValue 

func (x *FileMetaValue) GetValue() []string

func (*FileMetaValue) ProtoMessage 

func (*FileMetaValue) ProtoMessage()

func (*FileMetaValue) ProtoReflect 

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

func (*FileMetaValue) Reset 

func (x *FileMetaValue) Reset()

func (*FileMetaValue) String 

func (x *FileMetaValue) String() string

type FileRequest 

type FileRequest struct {

	// The name of store
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The name of the directory
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The metadata for user extension.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

File request message

func (*FileRequest) Descriptor deprecated 

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

Deprecated: Use FileRequest.ProtoReflect.Descriptor instead.

func (*FileRequest) GetMetadata 

func (x *FileRequest) GetMetadata() map[string]string

func (*FileRequest) GetName 

func (x *FileRequest) GetName() string

func (*FileRequest) GetStoreName 

func (x *FileRequest) GetStoreName() string

func (*FileRequest) ProtoMessage 

func (*FileRequest) ProtoMessage()

func (*FileRequest) ProtoReflect 

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

func (*FileRequest) Reset 

func (x *FileRequest) Reset()

func (*FileRequest) String 

func (x *FileRequest) String() string

type GetBulkSecretRequest 

type GetBulkSecretRequest struct {

	// The name of secret store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The metadata which will be sent to secret store components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetBulkSecretRequest is the message to get the secrets from secret store.

func (*GetBulkSecretRequest) Descriptor deprecated 

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

Deprecated: Use GetBulkSecretRequest.ProtoReflect.Descriptor instead.

func (*GetBulkSecretRequest) GetMetadata 

func (x *GetBulkSecretRequest) GetMetadata() map[string]string

func (*GetBulkSecretRequest) GetStoreName 

func (x *GetBulkSecretRequest) GetStoreName() string

func (*GetBulkSecretRequest) ProtoMessage 

func (*GetBulkSecretRequest) ProtoMessage()

func (*GetBulkSecretRequest) ProtoReflect 

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

func (*GetBulkSecretRequest) Reset 

func (x *GetBulkSecretRequest) Reset()

func (*GetBulkSecretRequest) String 

func (x *GetBulkSecretRequest) String() string

type GetBulkSecretResponse 

type GetBulkSecretResponse struct {

	// data hold the secret values. Some secret store, such as kubernetes secret
	// store, can save multiple secrets for single secret key.
	Data map[string]*SecretResponse `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetBulkSecretResponse is the response message to convey the requested secrets.

func (*GetBulkSecretResponse) Descriptor deprecated 

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

Deprecated: Use GetBulkSecretResponse.ProtoReflect.Descriptor instead.

func (*GetBulkSecretResponse) GetData 

func (x *GetBulkSecretResponse) GetData() map[string]*SecretResponse

func (*GetBulkSecretResponse) ProtoMessage 

func (*GetBulkSecretResponse) ProtoMessage()

func (*GetBulkSecretResponse) ProtoReflect 

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

func (*GetBulkSecretResponse) Reset 

func (x *GetBulkSecretResponse) Reset()

func (*GetBulkSecretResponse) String 

func (x *GetBulkSecretResponse) String() string

type GetBulkStateRequest 

type GetBulkStateRequest struct {

	// Required. The name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// Required. The keys to get.
	Keys []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// (optional) The number of parallel operations executed on the state store for a get operation.
	Parallelism int32 `protobuf:"varint,3,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	// (optional) The metadata which will be sent to state store components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetBulkStateRequest is the message to get a list of key-value states from specific state store.

func (*GetBulkStateRequest) Descriptor deprecated 

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

Deprecated: Use GetBulkStateRequest.ProtoReflect.Descriptor instead.

func (*GetBulkStateRequest) GetKeys 

func (x *GetBulkStateRequest) GetKeys() []string

func (*GetBulkStateRequest) GetMetadata 

func (x *GetBulkStateRequest) GetMetadata() map[string]string

func (*GetBulkStateRequest) GetParallelism 

func (x *GetBulkStateRequest) GetParallelism() int32

func (*GetBulkStateRequest) GetStoreName 

func (x *GetBulkStateRequest) GetStoreName() string

func (*GetBulkStateRequest) ProtoMessage 

func (*GetBulkStateRequest) ProtoMessage()

func (*GetBulkStateRequest) ProtoReflect 

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

func (*GetBulkStateRequest) Reset 

func (x *GetBulkStateRequest) Reset()

func (*GetBulkStateRequest) String 

func (x *GetBulkStateRequest) String() string

type GetBulkStateResponse 

type GetBulkStateResponse struct {

	// The list of items containing the keys to get values for.
	Items []*BulkStateItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

GetBulkStateResponse is the response conveying the list of state values.

func (*GetBulkStateResponse) Descriptor deprecated 

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

Deprecated: Use GetBulkStateResponse.ProtoReflect.Descriptor instead.

func (*GetBulkStateResponse) GetItems 

func (x *GetBulkStateResponse) GetItems() []*BulkStateItem

func (*GetBulkStateResponse) ProtoMessage 

func (*GetBulkStateResponse) ProtoMessage()

func (*GetBulkStateResponse) ProtoReflect 

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

func (*GetBulkStateResponse) Reset 

func (x *GetBulkStateResponse) Reset()

func (*GetBulkStateResponse) String 

func (x *GetBulkStateResponse) String() string

type GetConfigurationRequest 

type GetConfigurationRequest struct {

	// The name of configuration store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The application id which
	// Only used for admin, Ignored and reset for normal client
	AppId string `protobuf:"bytes,2,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	// The group of keys.
	Group string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	// The label for keys.
	Label string `protobuf:"bytes,4,opt,name=label,proto3" json:"label,omitempty"`
	// The keys to get.
	Keys []string `protobuf:"bytes,5,rep,name=keys,proto3" json:"keys,omitempty"`
	// The metadata which will be sent to configuration store components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// Subscribes update event for given keys.
	// If true, when any configuration item in this request is updated, app will receive event by OnConfigurationEvent() of app callback
	SubscribeUpdate bool `protobuf:"varint,7,opt,name=subscribe_update,json=subscribeUpdate,proto3" json:"subscribe_update,omitempty"`
	// contains filtered or unexported fields
}

GetConfigurationRequest is the message to get a list of key-value configuration from specified configuration store.

func (*GetConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use GetConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetConfigurationRequest) GetAppId 

func (x *GetConfigurationRequest) GetAppId() string

func (*GetConfigurationRequest) GetGroup 

func (x *GetConfigurationRequest) GetGroup() string

func (*GetConfigurationRequest) GetKeys 

func (x *GetConfigurationRequest) GetKeys() []string

func (*GetConfigurationRequest) GetLabel 

func (x *GetConfigurationRequest) GetLabel() string

func (*GetConfigurationRequest) GetMetadata 

func (x *GetConfigurationRequest) GetMetadata() map[string]string

func (*GetConfigurationRequest) GetStoreName 

func (x *GetConfigurationRequest) GetStoreName() string

func (*GetConfigurationRequest) GetSubscribeUpdate 

func (x *GetConfigurationRequest) GetSubscribeUpdate() bool

func (*GetConfigurationRequest) ProtoMessage 

func (*GetConfigurationRequest) ProtoMessage()

func (*GetConfigurationRequest) ProtoReflect 

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

func (*GetConfigurationRequest) Reset 

func (x *GetConfigurationRequest) Reset()

func (*GetConfigurationRequest) String 

func (x *GetConfigurationRequest) String() string

type GetConfigurationResponse 

type GetConfigurationResponse struct {

	// The list of items containing configuration values.
	Items []*ConfigurationItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

GetConfigurationResponse is the response conveying the list of configuration values.

func (*GetConfigurationResponse) Descriptor deprecated 

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

Deprecated: Use GetConfigurationResponse.ProtoReflect.Descriptor instead.

func (*GetConfigurationResponse) GetItems 

func (x *GetConfigurationResponse) GetItems() []*ConfigurationItem

func (*GetConfigurationResponse) ProtoMessage 

func (*GetConfigurationResponse) ProtoMessage()

func (*GetConfigurationResponse) ProtoReflect 

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

func (*GetConfigurationResponse) Reset 

func (x *GetConfigurationResponse) Reset()

func (*GetConfigurationResponse) String 

func (x *GetConfigurationResponse) String() string

type GetFileMetaRequest 

type GetFileMetaRequest struct {

	// File meta request
	Request *FileRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

Get fileMeta request message

func (*GetFileMetaRequest) Descriptor deprecated 

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

Deprecated: Use GetFileMetaRequest.ProtoReflect.Descriptor instead.

func (*GetFileMetaRequest) GetRequest 

func (x *GetFileMetaRequest) GetRequest() *FileRequest

func (*GetFileMetaRequest) ProtoMessage 

func (*GetFileMetaRequest) ProtoMessage()

func (*GetFileMetaRequest) ProtoReflect 

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

func (*GetFileMetaRequest) Reset 

func (x *GetFileMetaRequest) Reset()

func (*GetFileMetaRequest) String 

func (x *GetFileMetaRequest) String() string

type GetFileMetaResponse 

type GetFileMetaResponse struct {

	// The size of file
	Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// The modified time of file
	LastModified string `protobuf:"bytes,2,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
	// File meta response
	Response *FileMeta `protobuf:"bytes,3,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

Get fileMeta response message

func (*GetFileMetaResponse) Descriptor deprecated 

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

Deprecated: Use GetFileMetaResponse.ProtoReflect.Descriptor instead.

func (*GetFileMetaResponse) GetLastModified 

func (x *GetFileMetaResponse) GetLastModified() string

func (*GetFileMetaResponse) GetResponse 

func (x *GetFileMetaResponse) GetResponse() *FileMeta

func (*GetFileMetaResponse) GetSize 

func (x *GetFileMetaResponse) GetSize() int64

func (*GetFileMetaResponse) ProtoMessage 

func (*GetFileMetaResponse) ProtoMessage()

func (*GetFileMetaResponse) ProtoReflect 

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

func (*GetFileMetaResponse) Reset 

func (x *GetFileMetaResponse) Reset()

func (*GetFileMetaResponse) String 

func (x *GetFileMetaResponse) String() string

type GetFileRequest 

type GetFileRequest struct {

	// The name of store
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The name of the file or object want to get.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The metadata for user extension.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

Get file request message

func (*GetFileRequest) Descriptor deprecated 

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

Deprecated: Use GetFileRequest.ProtoReflect.Descriptor instead.

func (*GetFileRequest) GetMetadata 

func (x *GetFileRequest) GetMetadata() map[string]string

func (*GetFileRequest) GetName 

func (x *GetFileRequest) GetName() string

func (*GetFileRequest) GetStoreName 

func (x *GetFileRequest) GetStoreName() string

func (*GetFileRequest) ProtoMessage 

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) ProtoReflect 

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

func (*GetFileRequest) Reset 

func (x *GetFileRequest) Reset()

func (*GetFileRequest) String 

func (x *GetFileRequest) String() string

type GetFileResponse 

type GetFileResponse struct {

	// The data of file
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Get file response message

func (*GetFileResponse) Descriptor deprecated 

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

Deprecated: Use GetFileResponse.ProtoReflect.Descriptor instead.

func (*GetFileResponse) GetData 

func (x *GetFileResponse) GetData() []byte

func (*GetFileResponse) ProtoMessage 

func (*GetFileResponse) ProtoMessage()

func (*GetFileResponse) ProtoReflect 

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

func (*GetFileResponse) Reset 

func (x *GetFileResponse) Reset()

func (*GetFileResponse) String 

func (x *GetFileResponse) String() string

type GetNextIdRequest 

type GetNextIdRequest struct {

	// Required. Name of sequencer storage
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// Required. key is the identifier of a sequencer namespace,e.g. "order_table".
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// (optional) SequencerOptions configures requirements for auto-increment guarantee
	Options *SequencerOptions `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// (optional) The metadata which will be sent to the component.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

Get next id request message

func (*GetNextIdRequest) Descriptor deprecated 

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

Deprecated: Use GetNextIdRequest.ProtoReflect.Descriptor instead.

func (*GetNextIdRequest) GetKey 

func (x *GetNextIdRequest) GetKey() string

func (*GetNextIdRequest) GetMetadata 

func (x *GetNextIdRequest) GetMetadata() map[string]string

func (*GetNextIdRequest) GetOptions 

func (x *GetNextIdRequest) GetOptions() *SequencerOptions

func (*GetNextIdRequest) GetStoreName 

func (x *GetNextIdRequest) GetStoreName() string

func (*GetNextIdRequest) ProtoMessage 

func (*GetNextIdRequest) ProtoMessage()

func (*GetNextIdRequest) ProtoReflect 

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

func (*GetNextIdRequest) Reset 

func (x *GetNextIdRequest) Reset()

func (*GetNextIdRequest) String 

func (x *GetNextIdRequest) String() string

type GetNextIdResponse 

type GetNextIdResponse struct {

	// The next unique id
	// Fixed int64 overflow problems on JavaScript https://github.com/improbable-eng/ts-protoc-gen#gotchas
	NextId int64 `protobuf:"varint,1,opt,name=next_id,json=nextId,proto3" json:"next_id,omitempty"`
	// contains filtered or unexported fields
}

Get next id response message

func (*GetNextIdResponse) Descriptor deprecated 

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

Deprecated: Use GetNextIdResponse.ProtoReflect.Descriptor instead.

func (*GetNextIdResponse) GetNextId 

func (x *GetNextIdResponse) GetNextId() int64

func (*GetNextIdResponse) ProtoMessage 

func (*GetNextIdResponse) ProtoMessage()

func (*GetNextIdResponse) ProtoReflect 

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

func (*GetNextIdResponse) Reset 

func (x *GetNextIdResponse) Reset()

func (*GetNextIdResponse) String 

func (x *GetNextIdResponse) String() string

type GetSecretRequest 

type GetSecretRequest struct {

	// The name of secret store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The name of secret key.
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// The metadata which will be sent to secret store components.
	// Contains version, status, and so on...
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetSecretRequest is the message to get secret from secret store.

func (*GetSecretRequest) Descriptor deprecated 

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

Deprecated: Use GetSecretRequest.ProtoReflect.Descriptor instead.

func (*GetSecretRequest) GetKey 

func (x *GetSecretRequest) GetKey() string

func (*GetSecretRequest) GetMetadata 

func (x *GetSecretRequest) GetMetadata() map[string]string

func (*GetSecretRequest) GetStoreName 

func (x *GetSecretRequest) GetStoreName() string

func (*GetSecretRequest) ProtoMessage 

func (*GetSecretRequest) ProtoMessage()

func (*GetSecretRequest) ProtoReflect 

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

func (*GetSecretRequest) Reset 

func (x *GetSecretRequest) Reset()

func (*GetSecretRequest) String 

func (x *GetSecretRequest) String() string

type GetSecretResponse 

type GetSecretResponse struct {

	// data is the secret value. Some secret store, such as kubernetes secret
	// store, can save multiple secrets for single secret key.
	Data map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetSecretResponse is the response message to convey the requested secret.

func (*GetSecretResponse) Descriptor deprecated 

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

Deprecated: Use GetSecretResponse.ProtoReflect.Descriptor instead.

func (*GetSecretResponse) GetData 

func (x *GetSecretResponse) GetData() map[string]string

func (*GetSecretResponse) ProtoMessage 

func (*GetSecretResponse) ProtoMessage()

func (*GetSecretResponse) ProtoReflect 

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

func (*GetSecretResponse) Reset 

func (x *GetSecretResponse) Reset()

func (*GetSecretResponse) String 

func (x *GetSecretResponse) String() string

type GetStateRequest 

type GetStateRequest struct {

	// Required. The name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// Required. The key of the desired state
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// (optional) read consistency mode
	Consistency StateOptions_StateConsistency `` /* 133-byte string literal not displayed */
	// (optional) The metadata which will be sent to state store components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetStateRequest is the message to get key-value states from specific state store.

func (*GetStateRequest) Descriptor deprecated 

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

Deprecated: Use GetStateRequest.ProtoReflect.Descriptor instead.

func (*GetStateRequest) GetConsistency 

func (x *GetStateRequest) GetConsistency() StateOptions_StateConsistency

func (*GetStateRequest) GetKey 

func (x *GetStateRequest) GetKey() string

func (*GetStateRequest) GetMetadata 

func (x *GetStateRequest) GetMetadata() map[string]string

func (*GetStateRequest) GetStoreName 

func (x *GetStateRequest) GetStoreName() string

func (*GetStateRequest) ProtoMessage 

func (*GetStateRequest) ProtoMessage()

func (*GetStateRequest) ProtoReflect 

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

func (*GetStateRequest) Reset 

func (x *GetStateRequest) Reset()

func (*GetStateRequest) String 

func (x *GetStateRequest) String() string

type GetStateResponse 

type GetStateResponse struct {

	// The byte array data
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The entity tag which represents the specific version of data.
	// ETag format is defined by the corresponding data store.
	Etag string `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	// The metadata which will be sent to app.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetStateResponse is the response conveying the state value and etag.

func (*GetStateResponse) Descriptor deprecated 

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

Deprecated: Use GetStateResponse.ProtoReflect.Descriptor instead.

func (*GetStateResponse) GetData 

func (x *GetStateResponse) GetData() []byte

func (*GetStateResponse) GetEtag 

func (x *GetStateResponse) GetEtag() string

func (*GetStateResponse) GetMetadata 

func (x *GetStateResponse) GetMetadata() map[string]string

func (*GetStateResponse) ProtoMessage 

func (*GetStateResponse) ProtoMessage()

func (*GetStateResponse) ProtoReflect 

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

func (*GetStateResponse) Reset 

func (x *GetStateResponse) Reset()

func (*GetStateResponse) String 

func (x *GetStateResponse) String() string

type HTTPExtension 

type HTTPExtension struct {

	// The method of http reuest
	Verb HTTPExtension_Verb `protobuf:"varint,1,opt,name=verb,proto3,enum=spec.proto.runtime.v1.HTTPExtension_Verb" json:"verb,omitempty"`
	// The query information of http
	Querystring string `protobuf:"bytes,2,opt,name=querystring,proto3" json:"querystring,omitempty"`
	// contains filtered or unexported fields
}

Http extension message is about invoke http information

func (*HTTPExtension) Descriptor deprecated 

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

Deprecated: Use HTTPExtension.ProtoReflect.Descriptor instead.

func (*HTTPExtension) GetQuerystring 

func (x *HTTPExtension) GetQuerystring() string

func (*HTTPExtension) GetVerb 

func (x *HTTPExtension) GetVerb() HTTPExtension_Verb

func (*HTTPExtension) ProtoMessage 

func (*HTTPExtension) ProtoMessage()

func (*HTTPExtension) ProtoReflect 

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

func (*HTTPExtension) Reset 

func (x *HTTPExtension) Reset()

func (*HTTPExtension) String 

func (x *HTTPExtension) String() string

type HTTPExtension_Verb 

type HTTPExtension_Verb int32

The enum of http reuest method 

const (
	// NONE
	HTTPExtension_NONE HTTPExtension_Verb = 0
	// GET method
	HTTPExtension_GET HTTPExtension_Verb = 1
	// HEAD method
	HTTPExtension_HEAD HTTPExtension_Verb = 2
	// POST method
	HTTPExtension_POST HTTPExtension_Verb = 3
	// PUT method
	HTTPExtension_PUT HTTPExtension_Verb = 4
	// DELETE method
	HTTPExtension_DELETE HTTPExtension_Verb = 5
	// CONNECT method
	HTTPExtension_CONNECT HTTPExtension_Verb = 6
	// CONNECT method
	HTTPExtension_OPTIONS HTTPExtension_Verb = 7
	// CONNECT method
	HTTPExtension_TRACE HTTPExtension_Verb = 8
	// PATCH method
	HTTPExtension_PATCH HTTPExtension_Verb = 9
)

func (HTTPExtension_Verb) Descriptor 

func (HTTPExtension_Verb) Descriptor() protoreflect.EnumDescriptor

func (HTTPExtension_Verb) Enum 

func (x HTTPExtension_Verb) Enum() *HTTPExtension_Verb

func (HTTPExtension_Verb) EnumDescriptor deprecated 

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

Deprecated: Use HTTPExtension_Verb.Descriptor instead.

func (HTTPExtension_Verb) Number 

func (x HTTPExtension_Verb) Number() protoreflect.EnumNumber

func (HTTPExtension_Verb) String 

func (x HTTPExtension_Verb) String() string

func (HTTPExtension_Verb) Type 

func (HTTPExtension_Verb) Type() protoreflect.EnumType

type InvokeBindingRequest 

type InvokeBindingRequest struct {

	// The name of the output binding to invoke.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The data which will be sent to output binding.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// The metadata passing to output binding components
	// Common metadata property:
	// - ttlInSeconds : the time to live in seconds for the message.
	// If set in the binding definition will cause all messages to
	// have a default time to live. The message ttl overrides any value
	// in the binding definition.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The name of the operation type for the binding to invoke
	Operation string `protobuf:"bytes,4,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

InvokeBindingRequest is the message to send data to output bindings

func (*InvokeBindingRequest) Descriptor deprecated 

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

Deprecated: Use InvokeBindingRequest.ProtoReflect.Descriptor instead.

func (*InvokeBindingRequest) GetData 

func (x *InvokeBindingRequest) GetData() []byte

func (*InvokeBindingRequest) GetMetadata 

func (x *InvokeBindingRequest) GetMetadata() map[string]string

func (*InvokeBindingRequest) GetName 

func (x *InvokeBindingRequest) GetName() string

func (*InvokeBindingRequest) GetOperation 

func (x *InvokeBindingRequest) GetOperation() string

func (*InvokeBindingRequest) ProtoMessage 

func (*InvokeBindingRequest) ProtoMessage()

func (*InvokeBindingRequest) ProtoReflect 

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

func (*InvokeBindingRequest) Reset 

func (x *InvokeBindingRequest) Reset()

func (*InvokeBindingRequest) String 

func (x *InvokeBindingRequest) String() string

type InvokeBindingResponse 

type InvokeBindingResponse struct {

	// The data which will be sent to output binding.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The metadata returned from an external system
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

InvokeBindingResponse is the message returned from an output binding invocation

func (*InvokeBindingResponse) Descriptor deprecated 

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

Deprecated: Use InvokeBindingResponse.ProtoReflect.Descriptor instead.

func (*InvokeBindingResponse) GetData 

func (x *InvokeBindingResponse) GetData() []byte

func (*InvokeBindingResponse) GetMetadata 

func (x *InvokeBindingResponse) GetMetadata() map[string]string

func (*InvokeBindingResponse) ProtoMessage 

func (*InvokeBindingResponse) ProtoMessage()

func (*InvokeBindingResponse) ProtoReflect 

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

func (*InvokeBindingResponse) Reset 

func (x *InvokeBindingResponse) Reset()

func (*InvokeBindingResponse) String 

func (x *InvokeBindingResponse) String() string

type InvokeResponse 

type InvokeResponse struct {

	// The response data
	Data *anypb.Any `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The content type of response data
	ContentType string `protobuf:"bytes,2,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// contains filtered or unexported fields
}

Invoke service response message is result of invoke service queset

func (*InvokeResponse) Descriptor deprecated 

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

Deprecated: Use InvokeResponse.ProtoReflect.Descriptor instead.

func (*InvokeResponse) GetContentType 

func (x *InvokeResponse) GetContentType() string

func (*InvokeResponse) GetData 

func (x *InvokeResponse) GetData() *anypb.Any

func (*InvokeResponse) ProtoMessage 

func (*InvokeResponse) ProtoMessage()

func (*InvokeResponse) ProtoReflect 

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

func (*InvokeResponse) Reset 

func (x *InvokeResponse) Reset()

func (*InvokeResponse) String 

func (x *InvokeResponse) String() string

type InvokeServiceRequest 

type InvokeServiceRequest struct {

	// The identify of InvokeServiceRequest
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// InvokeServiceRequest message
	Message *CommonInvokeRequest `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Invoke service request message

func (*InvokeServiceRequest) Descriptor deprecated 

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

Deprecated: Use InvokeServiceRequest.ProtoReflect.Descriptor instead.

func (*InvokeServiceRequest) GetId 

func (x *InvokeServiceRequest) GetId() string

func (*InvokeServiceRequest) GetMessage 

func (x *InvokeServiceRequest) GetMessage() *CommonInvokeRequest

func (*InvokeServiceRequest) ProtoMessage 

func (*InvokeServiceRequest) ProtoMessage()

func (*InvokeServiceRequest) ProtoReflect 

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

func (*InvokeServiceRequest) Reset 

func (x *InvokeServiceRequest) Reset()

func (*InvokeServiceRequest) String 

func (x *InvokeServiceRequest) String() string

type LifecycleClient 

type LifecycleClient interface {
	// Apply the dynamic configuration.
	// The DynamicConfiguration here should be full configuration, not incremental configuration
	ApplyConfiguration(ctx context.Context, in *DynamicConfiguration, opts ...grpc.CallOption) (*ApplyConfigurationResponse, error)
}

LifecycleClient is the client API for Lifecycle service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLifecycleClient 

func NewLifecycleClient(cc grpc.ClientConnInterface) LifecycleClient

type LifecycleServer 

type LifecycleServer interface {
	// Apply the dynamic configuration.
	// The DynamicConfiguration here should be full configuration, not incremental configuration
	ApplyConfiguration(context.Context, *DynamicConfiguration) (*ApplyConfigurationResponse, error)
}

LifecycleServer is the server API for Lifecycle service. All implementations should embed UnimplementedLifecycleServer for forward compatibility

type ListFileRequest 

type ListFileRequest struct {

	// File request
	Request *FileRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Page size
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Marker
	Marker string `protobuf:"bytes,3,opt,name=marker,proto3" json:"marker,omitempty"`
	// contains filtered or unexported fields
}

List file request message

func (*ListFileRequest) Descriptor deprecated 

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

Deprecated: Use ListFileRequest.ProtoReflect.Descriptor instead.

func (*ListFileRequest) GetMarker 

func (x *ListFileRequest) GetMarker() string

func (*ListFileRequest) GetPageSize 

func (x *ListFileRequest) GetPageSize() int32

func (*ListFileRequest) GetRequest 

func (x *ListFileRequest) GetRequest() *FileRequest

func (*ListFileRequest) ProtoMessage 

func (*ListFileRequest) ProtoMessage()

func (*ListFileRequest) ProtoReflect 

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

func (*ListFileRequest) Reset 

func (x *ListFileRequest) Reset()

func (*ListFileRequest) String 

func (x *ListFileRequest) String() string

type ListFileResp 

type ListFileResp struct {

	// File info
	Files []*FileInfo `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
	// Marker
	Marker string `protobuf:"bytes,2,opt,name=marker,proto3" json:"marker,omitempty"`
	// Is truncated
	IsTruncated bool `protobuf:"varint,3,opt,name=is_truncated,json=isTruncated,proto3" json:"is_truncated,omitempty"`
	// contains filtered or unexported fields
}

List file response message

func (*ListFileResp) Descriptor deprecated 

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

Deprecated: Use ListFileResp.ProtoReflect.Descriptor instead.

func (*ListFileResp) GetFiles 

func (x *ListFileResp) GetFiles() []*FileInfo

func (*ListFileResp) GetIsTruncated 

func (x *ListFileResp) GetIsTruncated() bool

func (*ListFileResp) GetMarker 

func (x *ListFileResp) GetMarker() string

func (*ListFileResp) ProtoMessage 

func (*ListFileResp) ProtoMessage()

func (*ListFileResp) ProtoReflect 

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

func (*ListFileResp) Reset 

func (x *ListFileResp) Reset()

func (*ListFileResp) String 

func (x *ListFileResp) String() string

type ListTopicSubscriptionsResponse 

type ListTopicSubscriptionsResponse struct {

	// The list of topics.
	Subscriptions []*TopicSubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// contains filtered or unexported fields
}

ListTopicSubscriptionsResponse is the message including the list of the subscribing topics.

func (*ListTopicSubscriptionsResponse) Descriptor deprecated 

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

Deprecated: Use ListTopicSubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*ListTopicSubscriptionsResponse) GetSubscriptions 

func (x *ListTopicSubscriptionsResponse) GetSubscriptions() []*TopicSubscription

func (*ListTopicSubscriptionsResponse) ProtoMessage 

func (*ListTopicSubscriptionsResponse) ProtoMessage()

func (*ListTopicSubscriptionsResponse) ProtoReflect 

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

func (*ListTopicSubscriptionsResponse) Reset 

func (x *ListTopicSubscriptionsResponse) Reset()

func (*ListTopicSubscriptionsResponse) String 

func (x *ListTopicSubscriptionsResponse) String() string

type LockKeepAliveRequest 

type LockKeepAliveRequest struct {

	// Required. The lock store name,e.g. `redis`.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// Required. resource_id is the lock key.
	ResourceId string `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// Required. The owner of the lock.
	LockOwner string `protobuf:"bytes,3,opt,name=lock_owner,json=lockOwner,proto3" json:"lock_owner,omitempty"`
	// Required. expire is the time before expire.The time unit is second.
	Expire int32 `protobuf:"varint,4,opt,name=expire,proto3" json:"expire,omitempty"`
	// contains filtered or unexported fields
}

LockKeepAlive request message

func (*LockKeepAliveRequest) Descriptor deprecated 

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

Deprecated: Use LockKeepAliveRequest.ProtoReflect.Descriptor instead.

func (*LockKeepAliveRequest) GetExpire 

func (x *LockKeepAliveRequest) GetExpire() int32

func (*LockKeepAliveRequest) GetLockOwner 

func (x *LockKeepAliveRequest) GetLockOwner() string

func (*LockKeepAliveRequest) GetResourceId 

func (x *LockKeepAliveRequest) GetResourceId() string

func (*LockKeepAliveRequest) GetStoreName 

func (x *LockKeepAliveRequest) GetStoreName() string

func (*LockKeepAliveRequest) ProtoMessage 

func (*LockKeepAliveRequest) ProtoMessage()

func (*LockKeepAliveRequest) ProtoReflect 

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

func (*LockKeepAliveRequest) Reset 

func (x *LockKeepAliveRequest) Reset()

func (*LockKeepAliveRequest) String 

func (x *LockKeepAliveRequest) String() string

type LockKeepAliveResponse 

type LockKeepAliveResponse struct {

	// The status of LockKeepAlive
	Status LockKeepAliveResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=spec.proto.runtime.v1.LockKeepAliveResponse_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

LockKeepAlive response message

func (*LockKeepAliveResponse) Descriptor deprecated 

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

Deprecated: Use LockKeepAliveResponse.ProtoReflect.Descriptor instead.

func (*LockKeepAliveResponse) GetStatus 

func (x *LockKeepAliveResponse) GetStatus() LockKeepAliveResponse_Status

func (*LockKeepAliveResponse) ProtoMessage 

func (*LockKeepAliveResponse) ProtoMessage()

func (*LockKeepAliveResponse) ProtoReflect 

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

func (*LockKeepAliveResponse) Reset 

func (x *LockKeepAliveResponse) Reset()

func (*LockKeepAliveResponse) String 

func (x *LockKeepAliveResponse) String() string

type LockKeepAliveResponse_Status 

type LockKeepAliveResponse_Status int32

The enum of LockKeepAlive status 

const (
	// Lease renewal success
	LockKeepAliveResponse_SUCCESS LockKeepAliveResponse_Status = 0
	// The lock is not exist
	LockKeepAliveResponse_LOCK_UNEXIST LockKeepAliveResponse_Status = 1
	// The lock is belong to others
	LockKeepAliveResponse_LOCK_BELONG_TO_OTHERS LockKeepAliveResponse_Status = 2
	// Internal error
	LockKeepAliveResponse_INTERNAL_ERROR LockKeepAliveResponse_Status = 3
)

func (LockKeepAliveResponse_Status) Descriptor 

func (LockKeepAliveResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (LockKeepAliveResponse_Status) Enum 

func (x LockKeepAliveResponse_Status) Enum() *LockKeepAliveResponse_Status

func (LockKeepAliveResponse_Status) EnumDescriptor deprecated 

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

Deprecated: Use LockKeepAliveResponse_Status.Descriptor instead.

func (LockKeepAliveResponse_Status) Number 

func (x LockKeepAliveResponse_Status) Number() protoreflect.EnumNumber

func (LockKeepAliveResponse_Status) String 

func (x LockKeepAliveResponse_Status) String() string

func (LockKeepAliveResponse_Status) Type 

func (LockKeepAliveResponse_Status) Type() protoreflect.EnumType

type PublishEventRequest 

type PublishEventRequest struct {

	// The name of the pubsub component
	PubsubName string `protobuf:"bytes,1,opt,name=pubsub_name,json=pubsubName,proto3" json:"pubsub_name,omitempty"`
	// The pubsub topic
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// The data which will be published to topic.
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// The content type for the data (optional).
	DataContentType string `protobuf:"bytes,4,opt,name=data_content_type,json=dataContentType,proto3" json:"data_content_type,omitempty"`
	// The metadata passing to pub components
	//
	// metadata property:
	// - key : the key of the message.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

PublishEventRequest is the message to publish event data to pubsub topic

func (*PublishEventRequest) Descriptor deprecated 

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

Deprecated: Use PublishEventRequest.ProtoReflect.Descriptor instead.

func (*PublishEventRequest) GetData 

func (x *PublishEventRequest) GetData() []byte

func (*PublishEventRequest) GetDataContentType 

func (x *PublishEventRequest) GetDataContentType() string

func (*PublishEventRequest) GetMetadata 

func (x *PublishEventRequest) GetMetadata() map[string]string

func (*PublishEventRequest) GetPubsubName 

func (x *PublishEventRequest) GetPubsubName() string

func (*PublishEventRequest) GetTopic 

func (x *PublishEventRequest) GetTopic() string

func (*PublishEventRequest) ProtoMessage 

func (*PublishEventRequest) ProtoMessage()

func (*PublishEventRequest) ProtoReflect 

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

func (*PublishEventRequest) Reset 

func (x *PublishEventRequest) Reset()

func (*PublishEventRequest) String 

func (x *PublishEventRequest) String() string

type PutFileRequest 

type PutFileRequest struct {

	// The name of store
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The name of the file or object want to put.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The data will be store.
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// The metadata for user extension.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

Put file request message

func (*PutFileRequest) Descriptor deprecated 

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

Deprecated: Use PutFileRequest.ProtoReflect.Descriptor instead.

func (*PutFileRequest) GetData 

func (x *PutFileRequest) GetData() []byte

func (*PutFileRequest) GetMetadata 

func (x *PutFileRequest) GetMetadata() map[string]string

func (*PutFileRequest) GetName 

func (x *PutFileRequest) GetName() string

func (*PutFileRequest) GetStoreName 

func (x *PutFileRequest) GetStoreName() string

func (*PutFileRequest) ProtoMessage 

func (*PutFileRequest) ProtoMessage()

func (*PutFileRequest) ProtoReflect 

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

func (*PutFileRequest) Reset 

func (x *PutFileRequest) Reset()

func (*PutFileRequest) String 

func (x *PutFileRequest) String() string

type RuntimeClient 

type RuntimeClient interface {
	//SayHello used for test
	SayHello(ctx context.Context, in *SayHelloRequest, opts ...grpc.CallOption) (*SayHelloResponse, error)
	// InvokeService do rpc calls
	InvokeService(ctx context.Context, in *InvokeServiceRequest, opts ...grpc.CallOption) (*InvokeResponse, error)
	// GetConfiguration gets configuration from configuration store.
	GetConfiguration(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*GetConfigurationResponse, error)
	// SaveConfiguration saves configuration into configuration store.
	SaveConfiguration(ctx context.Context, in *SaveConfigurationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// DeleteConfiguration deletes configuration from configuration store.
	DeleteConfiguration(ctx context.Context, in *DeleteConfigurationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// SubscribeConfiguration gets configuration from configuration store and subscribe the updates.
	SubscribeConfiguration(ctx context.Context, opts ...grpc.CallOption) (Runtime_SubscribeConfigurationClient, error)
	// Distributed Lock API
	// A non-blocking method trying to get a lock with ttl.
	TryLock(ctx context.Context, in *TryLockRequest, opts ...grpc.CallOption) (*TryLockResponse, error)
	// A method trying to unlock.
	Unlock(ctx context.Context, in *UnlockRequest, opts ...grpc.CallOption) (*UnlockResponse, error)
	// A method used to support lease renewal for distributed lock.
	LockKeepAlive(ctx context.Context, in *LockKeepAliveRequest, opts ...grpc.CallOption) (*LockKeepAliveResponse, error)
	// Sequencer API
	// Get next unique id with some auto-increment guarantee
	GetNextId(ctx context.Context, in *GetNextIdRequest, opts ...grpc.CallOption) (*GetNextIdResponse, error)
	// Gets the state for a specific key.
	GetState(ctx context.Context, in *GetStateRequest, opts ...grpc.CallOption) (*GetStateResponse, error)
	// Gets a bulk of state items for a list of keys
	GetBulkState(ctx context.Context, in *GetBulkStateRequest, opts ...grpc.CallOption) (*GetBulkStateResponse, error)
	// Saves an array of state objects
	SaveState(ctx context.Context, in *SaveStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Deletes the state for a specific key.
	DeleteState(ctx context.Context, in *DeleteStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Deletes a bulk of state items for a list of keys
	DeleteBulkState(ctx context.Context, in *DeleteBulkStateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Executes transactions for a specified store
	ExecuteStateTransaction(ctx context.Context, in *ExecuteStateTransactionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Publishes events to the specific topic
	PublishEvent(ctx context.Context, in *PublishEventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// SubscribeTopicEvents subscribes to a PubSub topic and receives topic
	// events from it.
	SubscribeTopicEvents(ctx context.Context, opts ...grpc.CallOption) (Runtime_SubscribeTopicEventsClient, error)
	// Get file with stream
	GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (Runtime_GetFileClient, error)
	// Put file with stream
	PutFile(ctx context.Context, opts ...grpc.CallOption) (Runtime_PutFileClient, error)
	// List all files
	ListFile(ctx context.Context, in *ListFileRequest, opts ...grpc.CallOption) (*ListFileResp, error)
	// Delete specific file
	DelFile(ctx context.Context, in *DelFileRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Get file meta data, if file not exist,return code.NotFound error
	GetFileMeta(ctx context.Context, in *GetFileMetaRequest, opts ...grpc.CallOption) (*GetFileMetaResponse, error)
	// Invokes binding data to specific output bindings
	InvokeBinding(ctx context.Context, in *InvokeBindingRequest, opts ...grpc.CallOption) (*InvokeBindingResponse, error)
	// Gets secrets from secret stores.
	GetSecret(ctx context.Context, in *GetSecretRequest, opts ...grpc.CallOption) (*GetSecretResponse, error)
	// Gets a bulk of secrets
	GetBulkSecret(ctx context.Context, in *GetBulkSecretRequest, opts ...grpc.CallOption) (*GetBulkSecretResponse, error)
}

RuntimeClient is the client API for Runtime service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRuntimeClient 

func NewRuntimeClient(cc grpc.ClientConnInterface) RuntimeClient

type RuntimeServer 

type RuntimeServer interface {
	//SayHello used for test
	SayHello(context.Context, *SayHelloRequest) (*SayHelloResponse, error)
	// InvokeService do rpc calls
	InvokeService(context.Context, *InvokeServiceRequest) (*InvokeResponse, error)
	// GetConfiguration gets configuration from configuration store.
	GetConfiguration(context.Context, *GetConfigurationRequest) (*GetConfigurationResponse, error)
	// SaveConfiguration saves configuration into configuration store.
	SaveConfiguration(context.Context, *SaveConfigurationRequest) (*emptypb.Empty, error)
	// DeleteConfiguration deletes configuration from configuration store.
	DeleteConfiguration(context.Context, *DeleteConfigurationRequest) (*emptypb.Empty, error)
	// SubscribeConfiguration gets configuration from configuration store and subscribe the updates.
	SubscribeConfiguration(Runtime_SubscribeConfigurationServer) error
	// Distributed Lock API
	// A non-blocking method trying to get a lock with ttl.
	TryLock(context.Context, *TryLockRequest) (*TryLockResponse, error)
	// A method trying to unlock.
	Unlock(context.Context, *UnlockRequest) (*UnlockResponse, error)
	// A method used to support lease renewal for distributed lock.
	LockKeepAlive(context.Context, *LockKeepAliveRequest) (*LockKeepAliveResponse, error)
	// Sequencer API
	// Get next unique id with some auto-increment guarantee
	GetNextId(context.Context, *GetNextIdRequest) (*GetNextIdResponse, error)
	// Gets the state for a specific key.
	GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)
	// Gets a bulk of state items for a list of keys
	GetBulkState(context.Context, *GetBulkStateRequest) (*GetBulkStateResponse, error)
	// Saves an array of state objects
	SaveState(context.Context, *SaveStateRequest) (*emptypb.Empty, error)
	// Deletes the state for a specific key.
	DeleteState(context.Context, *DeleteStateRequest) (*emptypb.Empty, error)
	// Deletes a bulk of state items for a list of keys
	DeleteBulkState(context.Context, *DeleteBulkStateRequest) (*emptypb.Empty, error)
	// Executes transactions for a specified store
	ExecuteStateTransaction(context.Context, *ExecuteStateTransactionRequest) (*emptypb.Empty, error)
	// Publishes events to the specific topic
	PublishEvent(context.Context, *PublishEventRequest) (*emptypb.Empty, error)
	// SubscribeTopicEvents subscribes to a PubSub topic and receives topic
	// events from it.
	SubscribeTopicEvents(Runtime_SubscribeTopicEventsServer) error
	// Get file with stream
	GetFile(*GetFileRequest, Runtime_GetFileServer) error
	// Put file with stream
	PutFile(Runtime_PutFileServer) error
	// List all files
	ListFile(context.Context, *ListFileRequest) (*ListFileResp, error)
	// Delete specific file
	DelFile(context.Context, *DelFileRequest) (*emptypb.Empty, error)
	// Get file meta data, if file not exist,return code.NotFound error
	GetFileMeta(context.Context, *GetFileMetaRequest) (*GetFileMetaResponse, error)
	// Invokes binding data to specific output bindings
	InvokeBinding(context.Context, *InvokeBindingRequest) (*InvokeBindingResponse, error)
	// Gets secrets from secret stores.
	GetSecret(context.Context, *GetSecretRequest) (*GetSecretResponse, error)
	// Gets a bulk of secrets
	GetBulkSecret(context.Context, *GetBulkSecretRequest) (*GetBulkSecretResponse, error)
}

RuntimeServer is the server API for Runtime service. All implementations should embed UnimplementedRuntimeServer for forward compatibility

type Runtime_GetFileClient 

type Runtime_GetFileClient interface {
	Recv() (*GetFileResponse, error)
	grpc.ClientStream
}

type Runtime_GetFileServer 

type Runtime_GetFileServer interface {
	Send(*GetFileResponse) error
	grpc.ServerStream
}

type Runtime_PutFileClient 

type Runtime_PutFileClient interface {
	Send(*PutFileRequest) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type Runtime_PutFileServer 

type Runtime_PutFileServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*PutFileRequest, error)
	grpc.ServerStream
}

type Runtime_SubscribeConfigurationClient 

type Runtime_SubscribeConfigurationClient interface {
	Send(*SubscribeConfigurationRequest) error
	Recv() (*SubscribeConfigurationResponse, error)
	grpc.ClientStream
}

type Runtime_SubscribeConfigurationServer 

type Runtime_SubscribeConfigurationServer interface {
	Send(*SubscribeConfigurationResponse) error
	Recv() (*SubscribeConfigurationRequest, error)
	grpc.ServerStream
}

type Runtime_SubscribeTopicEventsClient 

type Runtime_SubscribeTopicEventsClient interface {
	Send(*SubscribeTopicEventsRequest) error
	Recv() (*SubscribeTopicEventsResponse, error)
	grpc.ClientStream
}

type Runtime_SubscribeTopicEventsServer 

type Runtime_SubscribeTopicEventsServer interface {
	Send(*SubscribeTopicEventsResponse) error
	Recv() (*SubscribeTopicEventsRequest, error)
	grpc.ServerStream
}

type SaveConfigurationRequest 

type SaveConfigurationRequest struct {

	// The name of configuration store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The application id which
	// Only used for admin, ignored and reset for normal client
	AppId string `protobuf:"bytes,2,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	// The list of configuration items to save.
	// To delete a exist item, set the key (also label) and let content to be empty
	Items []*ConfigurationItem `protobuf:"bytes,3,rep,name=items,proto3" json:"items,omitempty"`
	// The metadata which will be sent to configuration store components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

SaveConfigurationRequest is the message to save a list of key-value configuration into specified configuration store.

func (*SaveConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use SaveConfigurationRequest.ProtoReflect.Descriptor instead.

func (*SaveConfigurationRequest) GetAppId 

func (x *SaveConfigurationRequest) GetAppId() string

func (*SaveConfigurationRequest) GetItems 

func (x *SaveConfigurationRequest) GetItems() []*ConfigurationItem

func (*SaveConfigurationRequest) GetMetadata 

func (x *SaveConfigurationRequest) GetMetadata() map[string]string

func (*SaveConfigurationRequest) GetStoreName 

func (x *SaveConfigurationRequest) GetStoreName() string

func (*SaveConfigurationRequest) ProtoMessage 

func (*SaveConfigurationRequest) ProtoMessage()

func (*SaveConfigurationRequest) ProtoReflect 

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

func (*SaveConfigurationRequest) Reset 

func (x *SaveConfigurationRequest) Reset()

func (*SaveConfigurationRequest) String 

func (x *SaveConfigurationRequest) String() string

type SaveStateRequest 

type SaveStateRequest struct {

	// Required. The name of state store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// Required. The array of the state key values.
	States []*StateItem `protobuf:"bytes,2,rep,name=states,proto3" json:"states,omitempty"`
	// contains filtered or unexported fields
}

SaveStateRequest is the message to save multiple states into state store.

func (*SaveStateRequest) Descriptor deprecated 

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

Deprecated: Use SaveStateRequest.ProtoReflect.Descriptor instead.

func (*SaveStateRequest) GetStates 

func (x *SaveStateRequest) GetStates() []*StateItem

func (*SaveStateRequest) GetStoreName 

func (x *SaveStateRequest) GetStoreName() string

func (*SaveStateRequest) ProtoMessage 

func (*SaveStateRequest) ProtoMessage()

func (*SaveStateRequest) ProtoReflect 

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

func (*SaveStateRequest) Reset 

func (x *SaveStateRequest) Reset()

func (*SaveStateRequest) String 

func (x *SaveStateRequest) String() string

type SayHelloRequest 

type SayHelloRequest struct {

	// The name of service
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// Reuqest name
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. This field is used to control the packet size during load tests.
	Data *anypb.Any `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Hello request message

func (*SayHelloRequest) Descriptor deprecated 

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

Deprecated: Use SayHelloRequest.ProtoReflect.Descriptor instead.

func (*SayHelloRequest) GetData 

func (x *SayHelloRequest) GetData() *anypb.Any

func (*SayHelloRequest) GetName 

func (x *SayHelloRequest) GetName() string

func (*SayHelloRequest) GetServiceName 

func (x *SayHelloRequest) GetServiceName() string

func (*SayHelloRequest) ProtoMessage 

func (*SayHelloRequest) ProtoMessage()

func (*SayHelloRequest) ProtoReflect 

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

func (*SayHelloRequest) Reset 

func (x *SayHelloRequest) Reset()

func (*SayHelloRequest) String 

func (x *SayHelloRequest) String() string

type SayHelloResponse 

type SayHelloResponse struct {

	// Hello
	Hello string `protobuf:"bytes,1,opt,name=hello,proto3" json:"hello,omitempty"`
	// Hello message of data
	Data *anypb.Any `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Hello response message

func (*SayHelloResponse) Descriptor deprecated 

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

Deprecated: Use SayHelloResponse.ProtoReflect.Descriptor instead.

func (*SayHelloResponse) GetData 

func (x *SayHelloResponse) GetData() *anypb.Any

func (*SayHelloResponse) GetHello 

func (x *SayHelloResponse) GetHello() string

func (*SayHelloResponse) ProtoMessage 

func (*SayHelloResponse) ProtoMessage()

func (*SayHelloResponse) ProtoReflect 

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

func (*SayHelloResponse) Reset 

func (x *SayHelloResponse) Reset()

func (*SayHelloResponse) String 

func (x *SayHelloResponse) String() string

type SecretResponse 

type SecretResponse struct {

	// The data struct of secrets
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

SecretResponse is a map of decrypted string/string values

func (*SecretResponse) Descriptor deprecated 

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

Deprecated: Use SecretResponse.ProtoReflect.Descriptor instead.

func (*SecretResponse) GetSecrets 

func (x *SecretResponse) GetSecrets() map[string]string

func (*SecretResponse) ProtoMessage 

func (*SecretResponse) ProtoMessage()

func (*SecretResponse) ProtoReflect 

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

func (*SecretResponse) Reset 

func (x *SecretResponse) Reset()

func (*SecretResponse) String 

func (x *SecretResponse) String() string

type SequencerOptions 

type SequencerOptions struct {

	// Default STRONG auto-increment
	Increment SequencerOptions_AutoIncrement `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

SequencerOptions configures requirements for auto-increment guarantee

func (*SequencerOptions) Descriptor deprecated 

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

Deprecated: Use SequencerOptions.ProtoReflect.Descriptor instead.

func (*SequencerOptions) GetIncrement 

func (x *SequencerOptions) GetIncrement() SequencerOptions_AutoIncrement

func (*SequencerOptions) ProtoMessage 

func (*SequencerOptions) ProtoMessage()

func (*SequencerOptions) ProtoReflect 

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

func (*SequencerOptions) Reset 

func (x *SequencerOptions) Reset()

func (*SequencerOptions) String 

func (x *SequencerOptions) String() string

type SequencerOptions_AutoIncrement 

type SequencerOptions_AutoIncrement int32

requirements for auto-increment guarantee 

const (
	// (default) WEAK means a "best effort" incrementing service.But there is no strict guarantee of global monotonically increasing.
	//The next id is "probably" greater than current id.
	SequencerOptions_WEAK SequencerOptions_AutoIncrement = 0
	// STRONG means a strict guarantee of global monotonically increasing.
	//The next id "must" be greater than current id.
	SequencerOptions_STRONG SequencerOptions_AutoIncrement = 1
)

func (SequencerOptions_AutoIncrement) Descriptor 

func (SequencerOptions_AutoIncrement) Descriptor() protoreflect.EnumDescriptor

func (SequencerOptions_AutoIncrement) Enum 

func (x SequencerOptions_AutoIncrement) Enum() *SequencerOptions_AutoIncrement

func (SequencerOptions_AutoIncrement) EnumDescriptor deprecated 

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

Deprecated: Use SequencerOptions_AutoIncrement.Descriptor instead.

func (SequencerOptions_AutoIncrement) Number 

func (x SequencerOptions_AutoIncrement) Number() protoreflect.EnumNumber

func (SequencerOptions_AutoIncrement) String 

func (x SequencerOptions_AutoIncrement) String() string

func (SequencerOptions_AutoIncrement) Type 

func (SequencerOptions_AutoIncrement) Type() protoreflect.EnumType

type StateItem 

type StateItem struct {

	// Required. The state key
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Required. The state data for key
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// (optional) The entity tag which represents the specific version of data.
	// The exact ETag format is defined by the corresponding data store. Layotto runtime only treats ETags as opaque strings.
	Etag *Etag `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// (optional) additional key-value pairs to be passed to the state store.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// (optional) Options for concurrency and consistency to save the state.
	Options *StateOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

StateItem represents state key, value, and additional options to save state.

func (*StateItem) Descriptor deprecated 

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

Deprecated: Use StateItem.ProtoReflect.Descriptor instead.

func (*StateItem) GetEtag 

func (x *StateItem) GetEtag() *Etag

func (*StateItem) GetKey 

func (x *StateItem) GetKey() string

func (*StateItem) GetMetadata 

func (x *StateItem) GetMetadata() map[string]string

func (*StateItem) GetOptions 

func (x *StateItem) GetOptions() *StateOptions

func (*StateItem) GetValue 

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

func (*StateItem) ProtoMessage 

func (*StateItem) ProtoMessage()

func (*StateItem) ProtoReflect 

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

func (*StateItem) Reset 

func (x *StateItem) Reset()

func (*StateItem) String 

func (x *StateItem) String() string

type StateOptions 

type StateOptions struct {

	// The state operation of concurrency
	Concurrency StateOptions_StateConcurrency `` /* 133-byte string literal not displayed */
	// The state operation of consistency
	Consistency StateOptions_StateConsistency `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

StateOptions configures concurrency and consistency for state operations

func (*StateOptions) Descriptor deprecated 

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

Deprecated: Use StateOptions.ProtoReflect.Descriptor instead.

func (*StateOptions) GetConcurrency 

func (x *StateOptions) GetConcurrency() StateOptions_StateConcurrency

func (*StateOptions) GetConsistency 

func (x *StateOptions) GetConsistency() StateOptions_StateConsistency

func (*StateOptions) ProtoMessage 

func (*StateOptions) ProtoMessage()

func (*StateOptions) ProtoReflect 

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

func (*StateOptions) Reset 

func (x *StateOptions) Reset()

func (*StateOptions) String 

func (x *StateOptions) String() string

type StateOptions_StateConcurrency 

type StateOptions_StateConcurrency int32

Enum describing the supported concurrency for state. The API server uses Optimized Concurrency Control (OCC) with ETags. When an ETag is associated with an save or delete request, the store shall allow the update only if the attached ETag matches with the latest ETag in the database. But when ETag is missing in the write requests, the state store shall handle the requests in the specified strategy(e.g. a last-write-wins fashion). 

const (
	// Concurrency state is unspecified
	StateOptions_CONCURRENCY_UNSPECIFIED StateOptions_StateConcurrency = 0
	// First write wins
	StateOptions_CONCURRENCY_FIRST_WRITE StateOptions_StateConcurrency = 1
	// Last write wins
	StateOptions_CONCURRENCY_LAST_WRITE StateOptions_StateConcurrency = 2
)

func (StateOptions_StateConcurrency) Descriptor 

func (StateOptions_StateConcurrency) Descriptor() protoreflect.EnumDescriptor

func (StateOptions_StateConcurrency) Enum 

func (x StateOptions_StateConcurrency) Enum() *StateOptions_StateConcurrency

func (StateOptions_StateConcurrency) EnumDescriptor deprecated 

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

Deprecated: Use StateOptions_StateConcurrency.Descriptor instead.

func (StateOptions_StateConcurrency) Number 

func (x StateOptions_StateConcurrency) Number() protoreflect.EnumNumber

func (StateOptions_StateConcurrency) String 

func (x StateOptions_StateConcurrency) String() string

func (StateOptions_StateConcurrency) Type 

func (StateOptions_StateConcurrency) Type() protoreflect.EnumType

type StateOptions_StateConsistency 

type StateOptions_StateConsistency int32

Enum describing the supported consistency for state. 

const (
	// Consistency state is unspecified
	StateOptions_CONSISTENCY_UNSPECIFIED StateOptions_StateConsistency = 0
	//  The API server assumes data stores are eventually consistent by default.A state store should:
	// - For read requests, the state store can return data from any of the replicas
	// - For write request, the state store should asynchronously replicate updates to configured quorum after acknowledging the update request.
	StateOptions_CONSISTENCY_EVENTUAL StateOptions_StateConsistency = 1
	// When a strong consistency hint is attached, a state store should:
	// - For read requests, the state store should return the most up-to-date data consistently across replicas.
	// - For write/delete requests, the state store should synchronisely replicate updated data to configured quorum before completing the write request.
	StateOptions_CONSISTENCY_STRONG StateOptions_StateConsistency = 2
)

func (StateOptions_StateConsistency) Descriptor 

func (StateOptions_StateConsistency) Descriptor() protoreflect.EnumDescriptor

func (StateOptions_StateConsistency) Enum 

func (x StateOptions_StateConsistency) Enum() *StateOptions_StateConsistency

func (StateOptions_StateConsistency) EnumDescriptor deprecated 

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

Deprecated: Use StateOptions_StateConsistency.Descriptor instead.

func (StateOptions_StateConsistency) Number 

func (x StateOptions_StateConsistency) Number() protoreflect.EnumNumber

func (StateOptions_StateConsistency) String 

func (x StateOptions_StateConsistency) String() string

func (StateOptions_StateConsistency) Type 

func (StateOptions_StateConsistency) Type() protoreflect.EnumType

type SubscribeConfigurationRequest 

type SubscribeConfigurationRequest struct {

	// The name of configuration store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The application id which
	// Only used for admin, ignored and reset for normal client
	AppId string `protobuf:"bytes,2,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	// The group of keys.
	Group string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	// The label for keys.
	Label string `protobuf:"bytes,4,opt,name=label,proto3" json:"label,omitempty"`
	// The keys to get.
	Keys []string `protobuf:"bytes,5,rep,name=keys,proto3" json:"keys,omitempty"`
	// The metadata which will be sent to configuration store components.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

SubscribeConfigurationRequest is the message to get a list of key-value configuration from specified configuration store.

func (*SubscribeConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeConfigurationRequest.ProtoReflect.Descriptor instead.

func (*SubscribeConfigurationRequest) GetAppId 

func (x *SubscribeConfigurationRequest) GetAppId() string

func (*SubscribeConfigurationRequest) GetGroup 

func (x *SubscribeConfigurationRequest) GetGroup() string

func (*SubscribeConfigurationRequest) GetKeys 

func (x *SubscribeConfigurationRequest) GetKeys() []string

func (*SubscribeConfigurationRequest) GetLabel 

func (x *SubscribeConfigurationRequest) GetLabel() string

func (*SubscribeConfigurationRequest) GetMetadata 

func (x *SubscribeConfigurationRequest) GetMetadata() map[string]string

func (*SubscribeConfigurationRequest) GetStoreName 

func (x *SubscribeConfigurationRequest) GetStoreName() string

func (*SubscribeConfigurationRequest) ProtoMessage 

func (*SubscribeConfigurationRequest) ProtoMessage()

func (*SubscribeConfigurationRequest) ProtoReflect 

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

func (*SubscribeConfigurationRequest) Reset 

func (x *SubscribeConfigurationRequest) Reset()

func (*SubscribeConfigurationRequest) String 

func (x *SubscribeConfigurationRequest) String() string

type SubscribeConfigurationResponse 

type SubscribeConfigurationResponse struct {

	// The name of configuration store.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// The application id.
	// Only used for admin client.
	AppId string `protobuf:"bytes,2,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	// The list of items containing configuration values.
	Items []*ConfigurationItem `protobuf:"bytes,3,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

SubscribeConfigurationResponse is the response conveying the list of configuration values.

func (*SubscribeConfigurationResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeConfigurationResponse.ProtoReflect.Descriptor instead.

func (*SubscribeConfigurationResponse) GetAppId 

func (x *SubscribeConfigurationResponse) GetAppId() string

func (*SubscribeConfigurationResponse) GetItems 

func (x *SubscribeConfigurationResponse) GetItems() []*ConfigurationItem

func (*SubscribeConfigurationResponse) GetStoreName 

func (x *SubscribeConfigurationResponse) GetStoreName() string

func (*SubscribeConfigurationResponse) ProtoMessage 

func (*SubscribeConfigurationResponse) ProtoMessage()

func (*SubscribeConfigurationResponse) ProtoReflect 

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

func (*SubscribeConfigurationResponse) Reset 

func (x *SubscribeConfigurationResponse) Reset()

func (*SubscribeConfigurationResponse) String 

func (x *SubscribeConfigurationResponse) String() string

type SubscribeTopicEventsRequest 

type SubscribeTopicEventsRequest struct {

	// Types that are assignable to SubscribeTopicEventsRequestType:
	//	*SubscribeTopicEventsRequest_InitialRequest
	//	*SubscribeTopicEventsRequest_EventProcessed
	SubscribeTopicEventsRequestType isSubscribeTopicEventsRequest_SubscribeTopicEventsRequestType `protobuf_oneof:"subscribe_topic_events_request_type"`
	// contains filtered or unexported fields
}

SubscribeTopicEventsRequest is a message containing the details for subscribing to a topic via streaming. The first message must always be the initial request. All subsequent messages must be event processed responses.

func (*SubscribeTopicEventsRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeTopicEventsRequest.ProtoReflect.Descriptor instead.

func (*SubscribeTopicEventsRequest) GetEventProcessed 

func (x *SubscribeTopicEventsRequest) GetEventProcessed() *SubscribeTopicEventsRequestProcessed

func (*SubscribeTopicEventsRequest) GetInitialRequest 

func (x *SubscribeTopicEventsRequest) GetInitialRequest() *SubscribeTopicEventsRequestInitial

func (*SubscribeTopicEventsRequest) GetSubscribeTopicEventsRequestType 

func (m *SubscribeTopicEventsRequest) GetSubscribeTopicEventsRequestType() isSubscribeTopicEventsRequest_SubscribeTopicEventsRequestType

func (*SubscribeTopicEventsRequest) ProtoMessage 

func (*SubscribeTopicEventsRequest) ProtoMessage()

func (*SubscribeTopicEventsRequest) ProtoReflect 

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

func (*SubscribeTopicEventsRequest) Reset 

func (x *SubscribeTopicEventsRequest) Reset()

func (*SubscribeTopicEventsRequest) String 

func (x *SubscribeTopicEventsRequest) String() string

type SubscribeTopicEventsRequestInitial 

type SubscribeTopicEventsRequestInitial struct {

	// The name of the pubsub component
	PubsubName string `protobuf:"bytes,1,opt,name=pubsub_name,json=pubsubName,proto3" json:"pubsub_name,omitempty"`
	// The pubsub topic
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// The metadata passing to pub components
	//
	// metadata property:
	// - key : the key of the message.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// dead_letter_topic is the topic to which messages that fail to be processed
	// are sent.
	DeadLetterTopic *string `protobuf:"bytes,4,opt,name=dead_letter_topic,json=deadLetterTopic,proto3,oneof" json:"dead_letter_topic,omitempty"`
	// contains filtered or unexported fields
}

SubscribeTopicEventsRequestInitial is the initial message containing the details for subscribing to a topic via streaming.

func (*SubscribeTopicEventsRequestInitial) Descriptor deprecated 

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

Deprecated: Use SubscribeTopicEventsRequestInitial.ProtoReflect.Descriptor instead.

func (*SubscribeTopicEventsRequestInitial) GetDeadLetterTopic 

func (x *SubscribeTopicEventsRequestInitial) GetDeadLetterTopic() string

func (*SubscribeTopicEventsRequestInitial) GetMetadata 

func (x *SubscribeTopicEventsRequestInitial) GetMetadata() map[string]string

func (*SubscribeTopicEventsRequestInitial) GetPubsubName 

func (x *SubscribeTopicEventsRequestInitial) GetPubsubName() string

func (*SubscribeTopicEventsRequestInitial) GetTopic 

func (x *SubscribeTopicEventsRequestInitial) GetTopic() string

func (*SubscribeTopicEventsRequestInitial) ProtoMessage 

func (*SubscribeTopicEventsRequestInitial) ProtoMessage()

func (*SubscribeTopicEventsRequestInitial) ProtoReflect 

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

func (*SubscribeTopicEventsRequestInitial) Reset 

func (x *SubscribeTopicEventsRequestInitial) Reset()

func (*SubscribeTopicEventsRequestInitial) String 

func (x *SubscribeTopicEventsRequestInitial) String() string

type SubscribeTopicEventsRequestProcessed 

type SubscribeTopicEventsRequestProcessed struct {

	// id is the unique identifier for the subscription request.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// status is the result of the subscription request.
	Status *TopicEventResponse `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

SubscribeTopicEventsRequestProcessed is the message containing the subscription to a topic.

func (*SubscribeTopicEventsRequestProcessed) Descriptor deprecated 

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

Deprecated: Use SubscribeTopicEventsRequestProcessed.ProtoReflect.Descriptor instead.

func (*SubscribeTopicEventsRequestProcessed) GetId 

func (x *SubscribeTopicEventsRequestProcessed) GetId() string

func (*SubscribeTopicEventsRequestProcessed) GetStatus 

func (x *SubscribeTopicEventsRequestProcessed) GetStatus() *TopicEventResponse

func (*SubscribeTopicEventsRequestProcessed) ProtoMessage 

func (*SubscribeTopicEventsRequestProcessed) ProtoMessage()

func (*SubscribeTopicEventsRequestProcessed) ProtoReflect 

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

func (*SubscribeTopicEventsRequestProcessed) Reset 

func (x *SubscribeTopicEventsRequestProcessed) Reset()

func (*SubscribeTopicEventsRequestProcessed) String 

func (x *SubscribeTopicEventsRequestProcessed) String() string

type SubscribeTopicEventsRequest_EventProcessed 

type SubscribeTopicEventsRequest_EventProcessed struct {
	EventProcessed *SubscribeTopicEventsRequestProcessed `protobuf:"bytes,2,opt,name=event_processed,json=eventProcessed,proto3,oneof"`
}

type SubscribeTopicEventsRequest_InitialRequest 

type SubscribeTopicEventsRequest_InitialRequest struct {
	InitialRequest *SubscribeTopicEventsRequestInitial `protobuf:"bytes,1,opt,name=initial_request,json=initialRequest,proto3,oneof"`
}

type SubscribeTopicEventsResponse 

type SubscribeTopicEventsResponse struct {

	// Types that are assignable to SubscribeTopicEventsResponseType:
	//	*SubscribeTopicEventsResponse_InitialResponse
	//	*SubscribeTopicEventsResponse_EventMessage
	SubscribeTopicEventsResponseType isSubscribeTopicEventsResponse_SubscribeTopicEventsResponseType `protobuf_oneof:"subscribe_topic_events_response_type"`
	// contains filtered or unexported fields
}

SubscribeTopicEventsResponse is a message returned from layotto when subscribing to a topic via streaming.

func (*SubscribeTopicEventsResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeTopicEventsResponse.ProtoReflect.Descriptor instead.

func (*SubscribeTopicEventsResponse) GetEventMessage 

func (x *SubscribeTopicEventsResponse) GetEventMessage() *TopicEventRequest

func (*SubscribeTopicEventsResponse) GetInitialResponse 

func (x *SubscribeTopicEventsResponse) GetInitialResponse() *SubscribeTopicEventsResponseInitial

func (*SubscribeTopicEventsResponse) GetSubscribeTopicEventsResponseType 

func (m *SubscribeTopicEventsResponse) GetSubscribeTopicEventsResponseType() isSubscribeTopicEventsResponse_SubscribeTopicEventsResponseType

func (*SubscribeTopicEventsResponse) ProtoMessage 

func (*SubscribeTopicEventsResponse) ProtoMessage()

func (*SubscribeTopicEventsResponse) ProtoReflect 

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

func (*SubscribeTopicEventsResponse) Reset 

func (x *SubscribeTopicEventsResponse) Reset()

func (*SubscribeTopicEventsResponse) String 

func (x *SubscribeTopicEventsResponse) String() string

type SubscribeTopicEventsResponseInitial 

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

SubscribeTopicEventsResponseInitialAlpha1 is the initial response from layotto when subscribing to a topic.

func (*SubscribeTopicEventsResponseInitial) Descriptor deprecated 

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

Deprecated: Use SubscribeTopicEventsResponseInitial.ProtoReflect.Descriptor instead.

func (*SubscribeTopicEventsResponseInitial) ProtoMessage 

func (*SubscribeTopicEventsResponseInitial) ProtoMessage()

func (*SubscribeTopicEventsResponseInitial) ProtoReflect 

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

func (*SubscribeTopicEventsResponseInitial) Reset 

func (x *SubscribeTopicEventsResponseInitial) Reset()

func (*SubscribeTopicEventsResponseInitial) String 

func (x *SubscribeTopicEventsResponseInitial) String() string

type SubscribeTopicEventsResponse_EventMessage 

type SubscribeTopicEventsResponse_EventMessage struct {
	EventMessage *TopicEventRequest `protobuf:"bytes,2,opt,name=event_message,json=eventMessage,proto3,oneof"`
}

type SubscribeTopicEventsResponse_InitialResponse 

type SubscribeTopicEventsResponse_InitialResponse struct {
	InitialResponse *SubscribeTopicEventsResponseInitial `protobuf:"bytes,1,opt,name=initial_response,json=initialResponse,proto3,oneof"`
}

type TopicEventRequest 

type TopicEventRequest struct {

	// id identifies the event. Producers MUST ensure that source + id
	// is unique for each distinct event. If a duplicate event is re-sent
	// (e.g. due to a network error) it MAY have the same id.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// source identifies the context in which an event happened.
	// Often this will include information such as the type of the
	// event source, the organization publishing the event or the process
	// that produced the event. The exact syntax and semantics behind
	// the data encoded in the URI is defined by the event producer.
	Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	// The type of event related to the originating occurrence.
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// The version of the CloudEvents specification.
	SpecVersion string `protobuf:"bytes,4,opt,name=spec_version,json=specVersion,proto3" json:"spec_version,omitempty"`
	// The content type of data value.
	DataContentType string `protobuf:"bytes,5,opt,name=data_content_type,json=dataContentType,proto3" json:"data_content_type,omitempty"`
	// The content of the event.
	Data []byte `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	// The pubsub topic which publisher sent to.
	Topic string `protobuf:"bytes,6,opt,name=topic,proto3" json:"topic,omitempty"`
	// The name of the pubsub the publisher sent to.
	PubsubName string `protobuf:"bytes,8,opt,name=pubsub_name,json=pubsubName,proto3" json:"pubsub_name,omitempty"`
	// add a map to pass some extra properties.
	Metadata map[string]string `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

TopicEventRequest message is compatible with CloudEvent spec v1.0 https://github.com/cloudevents/spec/blob/v1.0/spec.md

func (*TopicEventRequest) Descriptor deprecated 

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

Deprecated: Use TopicEventRequest.ProtoReflect.Descriptor instead.

func (*TopicEventRequest) GetData 

func (x *TopicEventRequest) GetData() []byte

func (*TopicEventRequest) GetDataContentType 

func (x *TopicEventRequest) GetDataContentType() string

func (*TopicEventRequest) GetId 

func (x *TopicEventRequest) GetId() string

func (*TopicEventRequest) GetMetadata 

func (x *TopicEventRequest) GetMetadata() map[string]string

func (*TopicEventRequest) GetPubsubName 

func (x *TopicEventRequest) GetPubsubName() string

func (*TopicEventRequest) GetSource 

func (x *TopicEventRequest) GetSource() string

func (*TopicEventRequest) GetSpecVersion 

func (x *TopicEventRequest) GetSpecVersion() string

func (*TopicEventRequest) GetTopic 

func (x *TopicEventRequest) GetTopic() string

func (*TopicEventRequest) GetType 

func (x *TopicEventRequest) GetType() string

func (*TopicEventRequest) ProtoMessage 

func (*TopicEventRequest) ProtoMessage()

func (*TopicEventRequest) ProtoReflect 

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

func (*TopicEventRequest) Reset 

func (x *TopicEventRequest) Reset()

func (*TopicEventRequest) String 

func (x *TopicEventRequest) String() string

type TopicEventResponse 

type TopicEventResponse struct {

	// The list of output bindings.
	Status TopicEventResponse_TopicEventResponseStatus `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

TopicEventResponse is response from app on published message

func (*TopicEventResponse) Descriptor deprecated 

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

Deprecated: Use TopicEventResponse.ProtoReflect.Descriptor instead.

func (*TopicEventResponse) GetStatus 

func (x *TopicEventResponse) GetStatus() TopicEventResponse_TopicEventResponseStatus

func (*TopicEventResponse) ProtoMessage 

func (*TopicEventResponse) ProtoMessage()

func (*TopicEventResponse) ProtoReflect 

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

func (*TopicEventResponse) Reset 

func (x *TopicEventResponse) Reset()

func (*TopicEventResponse) String 

func (x *TopicEventResponse) String() string

type TopicEventResponse_TopicEventResponseStatus 

type TopicEventResponse_TopicEventResponseStatus int32

TopicEventResponseStatus allows apps to have finer control over handling of the message. 

const (
	// SUCCESS is the default behavior: message is acknowledged and not retried or logged.
	TopicEventResponse_SUCCESS TopicEventResponse_TopicEventResponseStatus = 0
	// RETRY status signals runtime to retry the message as part of an expected scenario (no warning is logged).
	TopicEventResponse_RETRY TopicEventResponse_TopicEventResponseStatus = 1
	// DROP status signals runtime to drop the message as part of an unexpected scenario (warning is logged).
	TopicEventResponse_DROP TopicEventResponse_TopicEventResponseStatus = 2
)

func (TopicEventResponse_TopicEventResponseStatus) Descriptor 

func (TopicEventResponse_TopicEventResponseStatus) Descriptor() protoreflect.EnumDescriptor

func (TopicEventResponse_TopicEventResponseStatus) Enum 

func (x TopicEventResponse_TopicEventResponseStatus) Enum() *TopicEventResponse_TopicEventResponseStatus

func (TopicEventResponse_TopicEventResponseStatus) EnumDescriptor deprecated 

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

Deprecated: Use TopicEventResponse_TopicEventResponseStatus.Descriptor instead.

func (TopicEventResponse_TopicEventResponseStatus) Number 

func (x TopicEventResponse_TopicEventResponseStatus) Number() protoreflect.EnumNumber

func (TopicEventResponse_TopicEventResponseStatus) String 

func (x TopicEventResponse_TopicEventResponseStatus) String() string

func (TopicEventResponse_TopicEventResponseStatus) Type 

func (TopicEventResponse_TopicEventResponseStatus) Type() protoreflect.EnumType

type TopicSubscription 

type TopicSubscription struct {

	// Required. The name of the pubsub containing the topic below to subscribe to.
	PubsubName string `protobuf:"bytes,1,opt,name=pubsub_name,json=pubsubName,proto3" json:"pubsub_name,omitempty"`
	// Required. The name of topic which will be subscribed
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// The optional properties used for this topic's subscription e.g. session id
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

TopicSubscription represents topic and metadata.

func (*TopicSubscription) Descriptor deprecated 

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

Deprecated: Use TopicSubscription.ProtoReflect.Descriptor instead.

func (*TopicSubscription) GetMetadata 

func (x *TopicSubscription) GetMetadata() map[string]string

func (*TopicSubscription) GetPubsubName 

func (x *TopicSubscription) GetPubsubName() string

func (*TopicSubscription) GetTopic 

func (x *TopicSubscription) GetTopic() string

func (*TopicSubscription) ProtoMessage 

func (*TopicSubscription) ProtoMessage()

func (*TopicSubscription) ProtoReflect 

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

func (*TopicSubscription) Reset 

func (x *TopicSubscription) Reset()

func (*TopicSubscription) String 

func (x *TopicSubscription) String() string

type TransactionalStateOperation 

type TransactionalStateOperation struct {

	// Required. The type of operation to be executed.
	// Legal values include:
	// "upsert" represents an update or create operation
	// "delete" represents a delete operation
	OperationType string `protobuf:"bytes,1,opt,name=operationType,proto3" json:"operationType,omitempty"`
	// Required. State values to be operated on
	Request *StateItem `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

TransactionalStateOperation is the message to execute a specified operation with a key-value pair.

func (*TransactionalStateOperation) Descriptor deprecated 

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

Deprecated: Use TransactionalStateOperation.ProtoReflect.Descriptor instead.

func (*TransactionalStateOperation) GetOperationType 

func (x *TransactionalStateOperation) GetOperationType() string

func (*TransactionalStateOperation) GetRequest 

func (x *TransactionalStateOperation) GetRequest() *StateItem

func (*TransactionalStateOperation) ProtoMessage 

func (*TransactionalStateOperation) ProtoMessage()

func (*TransactionalStateOperation) ProtoReflect 

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

func (*TransactionalStateOperation) Reset 

func (x *TransactionalStateOperation) Reset()

func (*TransactionalStateOperation) String 

func (x *TransactionalStateOperation) String() string

type TryLockRequest 

type TryLockRequest struct {

	// Required. The lock store name,e.g. `redis`.
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// Required. resource_id is the lock key. e.g. `order_id_111`
	// It stands for "which resource I want to protect"
	ResourceId string `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// Required. lock_owner indicate the identifier of lock owner.
	// You can generate a uuid as lock_owner.For example,in golang:
	// req.LockOwner = uuid.New().String()
	// This field is per request,not per process,so it is different for each request,
	// which aims to prevent multi-thread in the same process trying the same lock concurrently.
	// The reason why we don't make it automatically generated is:
	// 1. If it is automatically generated,there must be a 'my_lock_owner_id' field in the response.
	// This name is so weird that we think it is inappropriate to put it into the api spec
	// 2. If we change the field 'my_lock_owner_id' in the response to 'lock_owner',which means the current lock owner of this lock,
	// we find that in some lock services users can't get the current lock owner.Actually users don't need it at all.
	// 3. When reentrant lock is needed,the existing lock_owner is required to identify client and check "whether this client can reenter this lock".
	// So this field in the request shouldn't be removed.
	LockOwner string `protobuf:"bytes,3,opt,name=lock_owner,json=lockOwner,proto3" json:"lock_owner,omitempty"`
	// Required. expire is the time before expire.The time unit is second.
	Expire int32 `protobuf:"varint,4,opt,name=expire,proto3" json:"expire,omitempty"`
	// contains filtered or unexported fields
}

Lock request message is distributed lock API which is not blocking method tring to get a lock with ttl

func (*TryLockRequest) Descriptor deprecated 

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

Deprecated: Use TryLockRequest.ProtoReflect.Descriptor instead.

func (*TryLockRequest) GetExpire 

func (x *TryLockRequest) GetExpire() int32

func (*TryLockRequest) GetLockOwner 

func (x *TryLockRequest) GetLockOwner() string

func (*TryLockRequest) GetResourceId 

func (x *TryLockRequest) GetResourceId() string

func (*TryLockRequest) GetStoreName 

func (x *TryLockRequest) GetStoreName() string

func (*TryLockRequest) ProtoMessage 

func (*TryLockRequest) ProtoMessage()

func (*TryLockRequest) ProtoReflect 

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

func (*TryLockRequest) Reset 

func (x *TryLockRequest) Reset()

func (*TryLockRequest) String 

func (x *TryLockRequest) String() string

type TryLockResponse 

type TryLockResponse struct {

	// Is lock success
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

Lock response message returns is the lock obtained.

func (*TryLockResponse) Descriptor deprecated 

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

Deprecated: Use TryLockResponse.ProtoReflect.Descriptor instead.

func (*TryLockResponse) GetSuccess 

func (x *TryLockResponse) GetSuccess() bool

func (*TryLockResponse) ProtoMessage 

func (*TryLockResponse) ProtoMessage()

func (*TryLockResponse) ProtoReflect 

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

func (*TryLockResponse) Reset 

func (x *TryLockResponse) Reset()

func (*TryLockResponse) String 

func (x *TryLockResponse) String() string

type UnimplementedAppCallbackServer 

type UnimplementedAppCallbackServer struct {
}

UnimplementedAppCallbackServer should be embedded to have forward compatible implementations.

func (UnimplementedAppCallbackServer) ListTopicSubscriptions 

func (UnimplementedAppCallbackServer) ListTopicSubscriptions(context.Context, *emptypb.Empty) (*ListTopicSubscriptionsResponse, error)

func (UnimplementedAppCallbackServer) OnTopicEvent 

func (UnimplementedAppCallbackServer) OnTopicEvent(context.Context, *TopicEventRequest) (*TopicEventResponse, error)

type UnimplementedLifecycleServer 

type UnimplementedLifecycleServer struct {
}

UnimplementedLifecycleServer should be embedded to have forward compatible implementations.

func (UnimplementedLifecycleServer) ApplyConfiguration 

func (UnimplementedLifecycleServer) ApplyConfiguration(context.Context, *DynamicConfiguration) (*ApplyConfigurationResponse, error)

type UnimplementedRuntimeServer 

type UnimplementedRuntimeServer struct {
}

UnimplementedRuntimeServer should be embedded to have forward compatible implementations.

func (UnimplementedRuntimeServer) DelFile 

func (UnimplementedRuntimeServer) DelFile(context.Context, *DelFileRequest) (*emptypb.Empty, error)

func (UnimplementedRuntimeServer) DeleteBulkState 

func (UnimplementedRuntimeServer) DeleteBulkState(context.Context, *DeleteBulkStateRequest) (*emptypb.Empty, error)

func (UnimplementedRuntimeServer) DeleteConfiguration 

func (UnimplementedRuntimeServer) DeleteConfiguration(context.Context, *DeleteConfigurationRequest) (*emptypb.Empty, error)

func (UnimplementedRuntimeServer) DeleteState 

func (UnimplementedRuntimeServer) DeleteState(context.Context, *DeleteStateRequest) (*emptypb.Empty, error)

func (UnimplementedRuntimeServer) ExecuteStateTransaction 

func (UnimplementedRuntimeServer) ExecuteStateTransaction(context.Context, *ExecuteStateTransactionRequest) (*emptypb.Empty, error)

func (UnimplementedRuntimeServer) GetBulkSecret 

func (UnimplementedRuntimeServer) GetBulkSecret(context.Context, *GetBulkSecretRequest) (*GetBulkSecretResponse, error)

func (UnimplementedRuntimeServer) GetBulkState 

func (UnimplementedRuntimeServer) GetBulkState(context.Context, *GetBulkStateRequest) (*GetBulkStateResponse, error)

func (UnimplementedRuntimeServer) GetConfiguration 

func (UnimplementedRuntimeServer) GetConfiguration(context.Context, *GetConfigurationRequest) (*GetConfigurationResponse, error)

func (UnimplementedRuntimeServer) GetFile 

func (UnimplementedRuntimeServer) GetFile(*GetFileRequest, Runtime_GetFileServer) error

func (UnimplementedRuntimeServer) GetFileMeta 

func (UnimplementedRuntimeServer) GetFileMeta(context.Context, *GetFileMetaRequest) (*GetFileMetaResponse, error)

func (UnimplementedRuntimeServer) GetNextId 

func (UnimplementedRuntimeServer) GetNextId(context.Context, *GetNextIdRequest) (*GetNextIdResponse, error)

func (UnimplementedRuntimeServer) GetSecret 

func (UnimplementedRuntimeServer) GetSecret(context.Context, *GetSecretRequest) (*GetSecretResponse, error)

func (UnimplementedRuntimeServer) GetState 

func (UnimplementedRuntimeServer) GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)

func (UnimplementedRuntimeServer) InvokeBinding 

func (UnimplementedRuntimeServer) InvokeBinding(context.Context, *InvokeBindingRequest) (*InvokeBindingResponse, error)

func (UnimplementedRuntimeServer) InvokeService 

func (UnimplementedRuntimeServer) InvokeService(context.Context, *InvokeServiceRequest) (*InvokeResponse, error)

func (UnimplementedRuntimeServer) ListFile 

func (UnimplementedRuntimeServer) ListFile(context.Context, *ListFileRequest) (*ListFileResp, error)

func (UnimplementedRuntimeServer) LockKeepAlive 

func (UnimplementedRuntimeServer) LockKeepAlive(context.Context, *LockKeepAliveRequest) (*LockKeepAliveResponse, error)

func (UnimplementedRuntimeServer) PublishEvent 

func (UnimplementedRuntimeServer) PublishEvent(context.Context, *PublishEventRequest) (*emptypb.Empty, error)

func (UnimplementedRuntimeServer) PutFile 

func (UnimplementedRuntimeServer) PutFile(Runtime_PutFileServer) error

func (UnimplementedRuntimeServer) SaveConfiguration 

func (UnimplementedRuntimeServer) SaveConfiguration(context.Context, *SaveConfigurationRequest) (*emptypb.Empty, error)

func (UnimplementedRuntimeServer) SaveState 

func (UnimplementedRuntimeServer) SaveState(context.Context, *SaveStateRequest) (*emptypb.Empty, error)

func (UnimplementedRuntimeServer) SayHello 

func (UnimplementedRuntimeServer) SayHello(context.Context, *SayHelloRequest) (*SayHelloResponse, error)

func (UnimplementedRuntimeServer) SubscribeConfiguration 

func (UnimplementedRuntimeServer) SubscribeConfiguration(Runtime_SubscribeConfigurationServer) error

func (UnimplementedRuntimeServer) SubscribeTopicEvents 

func (UnimplementedRuntimeServer) SubscribeTopicEvents(Runtime_SubscribeTopicEventsServer) error

func (UnimplementedRuntimeServer) TryLock 

func (UnimplementedRuntimeServer) TryLock(context.Context, *TryLockRequest) (*TryLockResponse, error)

func (UnimplementedRuntimeServer) Unlock 

func (UnimplementedRuntimeServer) Unlock(context.Context, *UnlockRequest) (*UnlockResponse, error)

type UnlockRequest 

type UnlockRequest struct {

	// The name of store
	StoreName string `protobuf:"bytes,1,opt,name=store_name,json=storeName,proto3" json:"store_name,omitempty"`
	// resource_id is the lock key.
	ResourceId string `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// The owner of the lock
	LockOwner string `protobuf:"bytes,3,opt,name=lock_owner,json=lockOwner,proto3" json:"lock_owner,omitempty"`
	// contains filtered or unexported fields
}

UnLock request message

func (*UnlockRequest) Descriptor deprecated 

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

Deprecated: Use UnlockRequest.ProtoReflect.Descriptor instead.

func (*UnlockRequest) GetLockOwner 

func (x *UnlockRequest) GetLockOwner() string

func (*UnlockRequest) GetResourceId 

func (x *UnlockRequest) GetResourceId() string

func (*UnlockRequest) GetStoreName 

func (x *UnlockRequest) GetStoreName() string

func (*UnlockRequest) ProtoMessage 

func (*UnlockRequest) ProtoMessage()

func (*UnlockRequest) ProtoReflect 

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

func (*UnlockRequest) Reset 

func (x *UnlockRequest) Reset()

func (*UnlockRequest) String 

func (x *UnlockRequest) String() string

type UnlockResponse 

type UnlockResponse struct {

	// The status of unlock
	Status UnlockResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=spec.proto.runtime.v1.UnlockResponse_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

UnLock response message

func (*UnlockResponse) Descriptor deprecated 

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

Deprecated: Use UnlockResponse.ProtoReflect.Descriptor instead.

func (*UnlockResponse) GetStatus 

func (x *UnlockResponse) GetStatus() UnlockResponse_Status

func (*UnlockResponse) ProtoMessage 

func (*UnlockResponse) ProtoMessage()

func (*UnlockResponse) ProtoReflect 

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

func (*UnlockResponse) Reset 

func (x *UnlockResponse) Reset()

func (*UnlockResponse) String 

func (x *UnlockResponse) String() string

type UnlockResponse_Status 

type UnlockResponse_Status int32

The enum of unlock status 

const (
	// Unlock is success
	UnlockResponse_SUCCESS UnlockResponse_Status = 0
	// The lock is not exist
	UnlockResponse_LOCK_UNEXIST UnlockResponse_Status = 1
	// The lock is belong to others
	UnlockResponse_LOCK_BELONG_TO_OTHERS UnlockResponse_Status = 2
	// Internal error
	UnlockResponse_INTERNAL_ERROR UnlockResponse_Status = 3
)

func (UnlockResponse_Status) Descriptor 

func (UnlockResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (UnlockResponse_Status) Enum 

func (x UnlockResponse_Status) Enum() *UnlockResponse_Status

func (UnlockResponse_Status) EnumDescriptor deprecated 

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

Deprecated: Use UnlockResponse_Status.Descriptor instead.

func (UnlockResponse_Status) Number 

func (x UnlockResponse_Status) Number() protoreflect.EnumNumber

func (UnlockResponse_Status) String 

func (x UnlockResponse_Status) String() string

func (UnlockResponse_Status) Type 

func (UnlockResponse_Status) Type() protoreflect.EnumType

type UnsafeAppCallbackServer 

type UnsafeAppCallbackServer interface {
	// contains filtered or unexported methods
}

UnsafeAppCallbackServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AppCallbackServer will result in compilation errors.

type UnsafeLifecycleServer 

type UnsafeLifecycleServer interface {
	// contains filtered or unexported methods
}

UnsafeLifecycleServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LifecycleServer will result in compilation errors.

type UnsafeRuntimeServer 

type UnsafeRuntimeServer interface {
	// contains filtered or unexported methods
}

UnsafeRuntimeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RuntimeServer will result in compilation errors.

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.