components

package
v1.13.2 Latest Latest
Warning

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

Go to latest
Published: Apr 3, 2024 License: Apache-2.0 Imports: 9 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Sorting_Order_name = map[int32]string{
		0: "ASC",
		1: "DESC",
	}
	Sorting_Order_value = map[string]int32{
		"ASC":  0,
		"DESC": 1,
	}
)

Enum value maps for Sorting_Order.

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 File_dapr_proto_components_v1_bindings_proto protoreflect.FileDescriptor
View Source
var File_dapr_proto_components_v1_common_proto protoreflect.FileDescriptor
View Source
var File_dapr_proto_components_v1_pubsub_proto protoreflect.FileDescriptor
View Source
var File_dapr_proto_components_v1_secretstore_proto protoreflect.FileDescriptor
View Source
var File_dapr_proto_components_v1_state_proto protoreflect.FileDescriptor
View Source
var InputBinding_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dapr.proto.components.v1.InputBinding",
	HandlerType: (*InputBindingServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Init",
			Handler:    _InputBinding_Init_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _InputBinding_Ping_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Read",
			Handler:       _InputBinding_Read_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "dapr/proto/components/v1/bindings.proto",
}

InputBinding_ServiceDesc is the grpc.ServiceDesc for InputBinding 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 OutputBinding_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dapr.proto.components.v1.OutputBinding",
	HandlerType: (*OutputBindingServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Init",
			Handler:    _OutputBinding_Init_Handler,
		},
		{
			MethodName: "Invoke",
			Handler:    _OutputBinding_Invoke_Handler,
		},
		{
			MethodName: "ListOperations",
			Handler:    _OutputBinding_ListOperations_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _OutputBinding_Ping_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dapr/proto/components/v1/bindings.proto",
}

OutputBinding_ServiceDesc is the grpc.ServiceDesc for OutputBinding 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 PubSub_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dapr.proto.components.v1.PubSub",
	HandlerType: (*PubSubServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Init",
			Handler:    _PubSub_Init_Handler,
		},
		{
			MethodName: "Features",
			Handler:    _PubSub_Features_Handler,
		},
		{
			MethodName: "Publish",
			Handler:    _PubSub_Publish_Handler,
		},
		{
			MethodName: "BulkPublish",
			Handler:    _PubSub_BulkPublish_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _PubSub_Ping_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PullMessages",
			Handler:       _PubSub_PullMessages_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "dapr/proto/components/v1/pubsub.proto",
}

PubSub_ServiceDesc is the grpc.ServiceDesc for PubSub 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 QueriableStateStore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dapr.proto.components.v1.QueriableStateStore",
	HandlerType: (*QueriableStateStoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Query",
			Handler:    _QueriableStateStore_Query_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dapr/proto/components/v1/state.proto",
}

QueriableStateStore_ServiceDesc is the grpc.ServiceDesc for QueriableStateStore 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 SecretStore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dapr.proto.components.v1.SecretStore",
	HandlerType: (*SecretStoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Init",
			Handler:    _SecretStore_Init_Handler,
		},
		{
			MethodName: "Features",
			Handler:    _SecretStore_Features_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _SecretStore_Get_Handler,
		},
		{
			MethodName: "BulkGet",
			Handler:    _SecretStore_BulkGet_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _SecretStore_Ping_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dapr/proto/components/v1/secretstore.proto",
}

SecretStore_ServiceDesc is the grpc.ServiceDesc for SecretStore 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 StateStore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dapr.proto.components.v1.StateStore",
	HandlerType: (*StateStoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Init",
			Handler:    _StateStore_Init_Handler,
		},
		{
			MethodName: "Features",
			Handler:    _StateStore_Features_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _StateStore_Delete_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _StateStore_Get_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _StateStore_Set_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _StateStore_Ping_Handler,
		},
		{
			MethodName: "BulkDelete",
			Handler:    _StateStore_BulkDelete_Handler,
		},
		{
			MethodName: "BulkGet",
			Handler:    _StateStore_BulkGet_Handler,
		},
		{
			MethodName: "BulkSet",
			Handler:    _StateStore_BulkSet_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dapr/proto/components/v1/state.proto",
}

StateStore_ServiceDesc is the grpc.ServiceDesc for StateStore 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 TransactionalStateStore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dapr.proto.components.v1.TransactionalStateStore",
	HandlerType: (*TransactionalStateStoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Transact",
			Handler:    _TransactionalStateStore_Transact_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dapr/proto/components/v1/state.proto",
}

TransactionalStateStore_ServiceDesc is the grpc.ServiceDesc for TransactionalStateStore 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 TransactionalStoreMultiMaxSize_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dapr.proto.components.v1.TransactionalStoreMultiMaxSize",
	HandlerType: (*TransactionalStoreMultiMaxSizeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "MultiMaxSize",
			Handler:    _TransactionalStoreMultiMaxSize_MultiMaxSize_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dapr/proto/components/v1/state.proto",
}

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

Functions

func RegisterInputBindingServer

func RegisterInputBindingServer(s grpc.ServiceRegistrar, srv InputBindingServer)

func RegisterOutputBindingServer

func RegisterOutputBindingServer(s grpc.ServiceRegistrar, srv OutputBindingServer)

func RegisterPubSubServer

func RegisterPubSubServer(s grpc.ServiceRegistrar, srv PubSubServer)

func RegisterQueriableStateStoreServer

func RegisterQueriableStateStoreServer(s grpc.ServiceRegistrar, srv QueriableStateStoreServer)

func RegisterSecretStoreServer added in v1.12.0

func RegisterSecretStoreServer(s grpc.ServiceRegistrar, srv SecretStoreServer)

func RegisterStateStoreServer

func RegisterStateStoreServer(s grpc.ServiceRegistrar, srv StateStoreServer)

func RegisterTransactionalStateStoreServer

func RegisterTransactionalStateStoreServer(s grpc.ServiceRegistrar, srv TransactionalStateStoreServer)

func RegisterTransactionalStoreMultiMaxSizeServer added in v1.13.0

func RegisterTransactionalStoreMultiMaxSizeServer(s grpc.ServiceRegistrar, srv TransactionalStoreMultiMaxSizeServer)

Types

type AckMessageError

type AckMessageError struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Used for describing errors when ack'ing messages.

func (*AckMessageError) Descriptor deprecated

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

Deprecated: Use AckMessageError.ProtoReflect.Descriptor instead.

func (*AckMessageError) GetMessage

func (x *AckMessageError) GetMessage() string

func (*AckMessageError) ProtoMessage

func (*AckMessageError) ProtoMessage()

func (*AckMessageError) ProtoReflect

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

func (*AckMessageError) Reset

func (x *AckMessageError) Reset()

func (*AckMessageError) String

func (x *AckMessageError) String() string

type AckResponseError

type AckResponseError struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Used for describing errors when ack'ing messages.

func (*AckResponseError) Descriptor deprecated

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

Deprecated: Use AckResponseError.ProtoReflect.Descriptor instead.

func (*AckResponseError) GetMessage

func (x *AckResponseError) GetMessage() string

func (*AckResponseError) ProtoMessage

func (*AckResponseError) ProtoMessage()

func (*AckResponseError) ProtoReflect

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

func (*AckResponseError) Reset

func (x *AckResponseError) Reset()

func (*AckResponseError) String

func (x *AckResponseError) String() string

type BulkDeleteRequest

type BulkDeleteRequest struct {
	Items   []*DeleteRequest          `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	Options *BulkDeleteRequestOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkDeleteRequest) Descriptor deprecated

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

Deprecated: Use BulkDeleteRequest.ProtoReflect.Descriptor instead.

func (*BulkDeleteRequest) GetItems

func (x *BulkDeleteRequest) GetItems() []*DeleteRequest

func (*BulkDeleteRequest) GetOptions added in v1.11.0

func (*BulkDeleteRequest) ProtoMessage

func (*BulkDeleteRequest) ProtoMessage()

func (*BulkDeleteRequest) ProtoReflect

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

func (*BulkDeleteRequest) Reset

func (x *BulkDeleteRequest) Reset()

func (*BulkDeleteRequest) String

func (x *BulkDeleteRequest) String() string

type BulkDeleteRequestOptions added in v1.11.0

type BulkDeleteRequestOptions struct {
	Parallelism int64 `protobuf:"varint,1,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkDeleteRequestOptions) Descriptor deprecated added in v1.11.0

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

Deprecated: Use BulkDeleteRequestOptions.ProtoReflect.Descriptor instead.

func (*BulkDeleteRequestOptions) GetParallelism added in v1.11.0

func (x *BulkDeleteRequestOptions) GetParallelism() int64

func (*BulkDeleteRequestOptions) ProtoMessage added in v1.11.0

func (*BulkDeleteRequestOptions) ProtoMessage()

func (*BulkDeleteRequestOptions) ProtoReflect added in v1.11.0

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

func (*BulkDeleteRequestOptions) Reset added in v1.11.0

func (x *BulkDeleteRequestOptions) Reset()

func (*BulkDeleteRequestOptions) String added in v1.11.0

func (x *BulkDeleteRequestOptions) String() string

type BulkDeleteResponse

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

reserved for future-proof extensibility

func (*BulkDeleteResponse) Descriptor deprecated

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

Deprecated: Use BulkDeleteResponse.ProtoReflect.Descriptor instead.

func (*BulkDeleteResponse) ProtoMessage

func (*BulkDeleteResponse) ProtoMessage()

func (*BulkDeleteResponse) ProtoReflect

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

func (*BulkDeleteResponse) Reset

func (x *BulkDeleteResponse) Reset()

func (*BulkDeleteResponse) String

func (x *BulkDeleteResponse) String() string

type BulkGetRequest

type BulkGetRequest struct {
	Items   []*GetRequest          `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	Options *BulkGetRequestOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkGetRequest) Descriptor deprecated

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

Deprecated: Use BulkGetRequest.ProtoReflect.Descriptor instead.

func (*BulkGetRequest) GetItems

func (x *BulkGetRequest) GetItems() []*GetRequest

func (*BulkGetRequest) GetOptions added in v1.11.0

func (x *BulkGetRequest) GetOptions() *BulkGetRequestOptions

func (*BulkGetRequest) ProtoMessage

func (*BulkGetRequest) ProtoMessage()

func (*BulkGetRequest) ProtoReflect

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

func (*BulkGetRequest) Reset

func (x *BulkGetRequest) Reset()

func (*BulkGetRequest) String

func (x *BulkGetRequest) String() string

type BulkGetRequestOptions added in v1.11.0

type BulkGetRequestOptions struct {
	Parallelism int64 `protobuf:"varint,1,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkGetRequestOptions) Descriptor deprecated added in v1.11.0

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

Deprecated: Use BulkGetRequestOptions.ProtoReflect.Descriptor instead.

func (*BulkGetRequestOptions) GetParallelism added in v1.11.0

func (x *BulkGetRequestOptions) GetParallelism() int64

func (*BulkGetRequestOptions) ProtoMessage added in v1.11.0

func (*BulkGetRequestOptions) ProtoMessage()

func (*BulkGetRequestOptions) ProtoReflect added in v1.11.0

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

func (*BulkGetRequestOptions) Reset added in v1.11.0

func (x *BulkGetRequestOptions) Reset()

func (*BulkGetRequestOptions) String added in v1.11.0

func (x *BulkGetRequestOptions) String() string

type BulkGetResponse

type BulkGetResponse struct {
	Items []*BulkStateItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkGetResponse) Descriptor deprecated

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

Deprecated: Use BulkGetResponse.ProtoReflect.Descriptor instead.

func (*BulkGetResponse) GetItems

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

func (*BulkGetResponse) ProtoMessage

func (*BulkGetResponse) ProtoMessage()

func (*BulkGetResponse) ProtoReflect

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

func (*BulkGetResponse) Reset

func (x *BulkGetResponse) Reset()

func (*BulkGetResponse) String

func (x *BulkGetResponse) String() string

type BulkGetSecretRequest added in v1.12.0

type BulkGetSecretRequest struct {

	// 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
}

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

func (*BulkGetSecretRequest) Descriptor deprecated added in v1.12.0

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

Deprecated: Use BulkGetSecretRequest.ProtoReflect.Descriptor instead.

func (*BulkGetSecretRequest) GetMetadata added in v1.12.0

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

func (*BulkGetSecretRequest) ProtoMessage added in v1.12.0

func (*BulkGetSecretRequest) ProtoMessage()

func (*BulkGetSecretRequest) ProtoReflect added in v1.12.0

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

func (*BulkGetSecretRequest) Reset added in v1.12.0

func (x *BulkGetSecretRequest) Reset()

func (*BulkGetSecretRequest) String added in v1.12.0

func (x *BulkGetSecretRequest) String() string

type BulkGetSecretResponse added in v1.12.0

type BulkGetSecretResponse 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
}

BulkGetSecretResponse is the response message to convey the requested secrets.

func (*BulkGetSecretResponse) Descriptor deprecated added in v1.12.0

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

Deprecated: Use BulkGetSecretResponse.ProtoReflect.Descriptor instead.

func (*BulkGetSecretResponse) GetData added in v1.12.0

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

func (*BulkGetSecretResponse) ProtoMessage added in v1.12.0

func (*BulkGetSecretResponse) ProtoMessage()

func (*BulkGetSecretResponse) ProtoReflect added in v1.12.0

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

func (*BulkGetSecretResponse) Reset added in v1.12.0

func (x *BulkGetSecretResponse) Reset()

func (*BulkGetSecretResponse) String added in v1.12.0

func (x *BulkGetSecretResponse) String() string

type BulkMessageEntry added in v1.12.0

type BulkMessageEntry struct {
	EntryId     string            `protobuf:"bytes,1,opt,name=entry_id,json=entryId,proto3" json:"entry_id,omitempty"`
	Event       []byte            `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	ContentType string            `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	Metadata    map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BulkMessageEntry) Descriptor deprecated added in v1.12.0

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

Deprecated: Use BulkMessageEntry.ProtoReflect.Descriptor instead.

func (*BulkMessageEntry) GetContentType added in v1.12.0

func (x *BulkMessageEntry) GetContentType() string

func (*BulkMessageEntry) GetEntryId added in v1.12.0

func (x *BulkMessageEntry) GetEntryId() string

func (*BulkMessageEntry) GetEvent added in v1.12.0

func (x *BulkMessageEntry) GetEvent() []byte

func (*BulkMessageEntry) GetMetadata added in v1.12.0

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

func (*BulkMessageEntry) ProtoMessage added in v1.12.0

func (*BulkMessageEntry) ProtoMessage()

func (*BulkMessageEntry) ProtoReflect added in v1.12.0

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

func (*BulkMessageEntry) Reset added in v1.12.0

func (x *BulkMessageEntry) Reset()

func (*BulkMessageEntry) String added in v1.12.0

func (x *BulkMessageEntry) String() string

type BulkPublishRequest added in v1.12.0

type BulkPublishRequest struct {
	Entries    []*BulkMessageEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	PubsubName string              `protobuf:"bytes,2,opt,name=pubsub_name,json=pubsubName,proto3" json:"pubsub_name,omitempty"`
	Topic      string              `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	Metadata   map[string]string   `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BulkPublishRequest) Descriptor deprecated added in v1.12.0

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

Deprecated: Use BulkPublishRequest.ProtoReflect.Descriptor instead.

func (*BulkPublishRequest) GetEntries added in v1.12.0

func (x *BulkPublishRequest) GetEntries() []*BulkMessageEntry

func (*BulkPublishRequest) GetMetadata added in v1.12.0

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

func (*BulkPublishRequest) GetPubsubName added in v1.12.0

func (x *BulkPublishRequest) GetPubsubName() string

func (*BulkPublishRequest) GetTopic added in v1.12.0

func (x *BulkPublishRequest) GetTopic() string

func (*BulkPublishRequest) ProtoMessage added in v1.12.0

func (*BulkPublishRequest) ProtoMessage()

func (*BulkPublishRequest) ProtoReflect added in v1.12.0

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

func (*BulkPublishRequest) Reset added in v1.12.0

func (x *BulkPublishRequest) Reset()

func (*BulkPublishRequest) String added in v1.12.0

func (x *BulkPublishRequest) String() string

type BulkPublishResponse added in v1.12.0

type BulkPublishResponse struct {
	FailedEntries []*BulkPublishResponseFailedEntry `protobuf:"bytes,1,rep,name=failed_entries,json=failedEntries,proto3" json:"failed_entries,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkPublishResponse) Descriptor deprecated added in v1.12.0

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

Deprecated: Use BulkPublishResponse.ProtoReflect.Descriptor instead.

func (*BulkPublishResponse) GetFailedEntries added in v1.12.0

func (x *BulkPublishResponse) GetFailedEntries() []*BulkPublishResponseFailedEntry

func (*BulkPublishResponse) ProtoMessage added in v1.12.0

func (*BulkPublishResponse) ProtoMessage()

func (*BulkPublishResponse) ProtoReflect added in v1.12.0

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

func (*BulkPublishResponse) Reset added in v1.12.0

func (x *BulkPublishResponse) Reset()

func (*BulkPublishResponse) String added in v1.12.0

func (x *BulkPublishResponse) String() string

type BulkPublishResponseFailedEntry added in v1.12.0

type BulkPublishResponseFailedEntry struct {
	EntryId string `protobuf:"bytes,1,opt,name=entry_id,json=entryId,proto3" json:"entry_id,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkPublishResponseFailedEntry) Descriptor deprecated added in v1.12.0

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

Deprecated: Use BulkPublishResponseFailedEntry.ProtoReflect.Descriptor instead.

func (*BulkPublishResponseFailedEntry) GetEntryId added in v1.12.0

func (x *BulkPublishResponseFailedEntry) GetEntryId() string

func (*BulkPublishResponseFailedEntry) GetError added in v1.12.0

func (x *BulkPublishResponseFailedEntry) GetError() string

func (*BulkPublishResponseFailedEntry) ProtoMessage added in v1.12.0

func (*BulkPublishResponseFailedEntry) ProtoMessage()

func (*BulkPublishResponseFailedEntry) ProtoReflect added in v1.12.0

func (*BulkPublishResponseFailedEntry) Reset added in v1.12.0

func (x *BulkPublishResponseFailedEntry) Reset()

func (*BulkPublishResponseFailedEntry) String added in v1.12.0

type BulkSetRequest

type BulkSetRequest struct {
	Items   []*SetRequest          `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	Options *BulkSetRequestOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkSetRequest) Descriptor deprecated

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

Deprecated: Use BulkSetRequest.ProtoReflect.Descriptor instead.

func (*BulkSetRequest) GetItems

func (x *BulkSetRequest) GetItems() []*SetRequest

func (*BulkSetRequest) GetOptions added in v1.11.0

func (x *BulkSetRequest) GetOptions() *BulkSetRequestOptions

func (*BulkSetRequest) ProtoMessage

func (*BulkSetRequest) ProtoMessage()

func (*BulkSetRequest) ProtoReflect

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

func (*BulkSetRequest) Reset

func (x *BulkSetRequest) Reset()

func (*BulkSetRequest) String

func (x *BulkSetRequest) String() string

type BulkSetRequestOptions added in v1.11.0

type BulkSetRequestOptions struct {
	Parallelism int64 `protobuf:"varint,1,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkSetRequestOptions) Descriptor deprecated added in v1.11.0

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

Deprecated: Use BulkSetRequestOptions.ProtoReflect.Descriptor instead.

func (*BulkSetRequestOptions) GetParallelism added in v1.11.0

func (x *BulkSetRequestOptions) GetParallelism() int64

func (*BulkSetRequestOptions) ProtoMessage added in v1.11.0

func (*BulkSetRequestOptions) ProtoMessage()

func (*BulkSetRequestOptions) ProtoReflect added in v1.11.0

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

func (*BulkSetRequestOptions) Reset added in v1.11.0

func (x *BulkSetRequestOptions) Reset()

func (*BulkSetRequestOptions) String added in v1.11.0

func (x *BulkSetRequestOptions) String() string

type BulkSetResponse

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

reserved for future-proof extensibility

func (*BulkSetResponse) Descriptor deprecated

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

Deprecated: Use BulkSetResponse.ProtoReflect.Descriptor instead.

func (*BulkSetResponse) ProtoMessage

func (*BulkSetResponse) ProtoMessage()

func (*BulkSetResponse) ProtoReflect

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

func (*BulkSetResponse) Reset

func (x *BulkSetResponse) Reset()

func (*BulkSetResponse) String

func (x *BulkSetResponse) String() string

type BulkStateItem

type BulkStateItem struct {

	// The key of the fetched item.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The associated data of the fetched item.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// The item ETag
	Etag *Etag `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// A fetch error if there's some.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// The State Item metadata.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The data contenttype
	ContentType string `protobuf:"bytes,6,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// contains filtered or unexported fields
}

func (*BulkStateItem) Descriptor deprecated

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

Deprecated: Use BulkStateItem.ProtoReflect.Descriptor instead.

func (*BulkStateItem) GetContentType

func (x *BulkStateItem) GetContentType() string

func (*BulkStateItem) GetData

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

func (*BulkStateItem) GetError

func (x *BulkStateItem) GetError() string

func (*BulkStateItem) GetEtag

func (x *BulkStateItem) GetEtag() *Etag

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 DeleteRequest

type DeleteRequest struct {

	// The key that should be deleted.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The etag is used as a If-Match header, to allow certain levels of
	// consistency.
	Etag *Etag `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	// The request metadata.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	Options  *StateOptions     `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetEtag

func (x *DeleteRequest) GetEtag() *Etag

func (*DeleteRequest) GetKey

func (x *DeleteRequest) GetKey() string

func (*DeleteRequest) GetMetadata

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

func (*DeleteRequest) GetOptions

func (x *DeleteRequest) GetOptions() *StateOptions

func (*DeleteRequest) ProtoMessage

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect

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

func (*DeleteRequest) Reset

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String

func (x *DeleteRequest) String() string

type DeleteResponse

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

reserved for future-proof extensibility

func (*DeleteResponse) Descriptor deprecated

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) ProtoMessage

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect

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

func (*DeleteResponse) Reset

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String

func (x *DeleteResponse) 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 FeaturesRequest

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

reserved for future-proof extensibility

func (*FeaturesRequest) Descriptor deprecated

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

Deprecated: Use FeaturesRequest.ProtoReflect.Descriptor instead.

func (*FeaturesRequest) ProtoMessage

func (*FeaturesRequest) ProtoMessage()

func (*FeaturesRequest) ProtoReflect

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

func (*FeaturesRequest) Reset

func (x *FeaturesRequest) Reset()

func (*FeaturesRequest) String

func (x *FeaturesRequest) String() string

type FeaturesResponse

type FeaturesResponse struct {
	Features []string `protobuf:"bytes,1,rep,name=features,proto3" json:"features,omitempty"`
	// contains filtered or unexported fields
}

func (*FeaturesResponse) Descriptor deprecated

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

Deprecated: Use FeaturesResponse.ProtoReflect.Descriptor instead.

func (*FeaturesResponse) GetFeatures

func (x *FeaturesResponse) GetFeatures() []string

func (*FeaturesResponse) ProtoMessage

func (*FeaturesResponse) ProtoMessage()

func (*FeaturesResponse) ProtoReflect

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

func (*FeaturesResponse) Reset

func (x *FeaturesResponse) Reset()

func (*FeaturesResponse) String

func (x *FeaturesResponse) String() string

type GetRequest

type GetRequest struct {

	// The key that should be retrieved.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Request associated metadata.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The get consistency level.
	Consistency StateOptions_StateConsistency `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetConsistency

func (x *GetRequest) GetConsistency() StateOptions_StateConsistency

func (*GetRequest) GetKey

func (x *GetRequest) GetKey() string

func (*GetRequest) GetMetadata

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

func (*GetRequest) ProtoMessage

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect

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

func (*GetRequest) Reset

func (x *GetRequest) Reset()

func (*GetRequest) String

func (x *GetRequest) String() string

type GetResponse

type GetResponse struct {

	// The data of the GetRequest response.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The etag of the associated key.
	Etag *Etag `protobuf:"bytes,2,opt,name=etag,proto3" json:"etag,omitempty"`
	// Metadata related to the response.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The response data contenttype
	ContentType string `protobuf:"bytes,4,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetContentType

func (x *GetResponse) GetContentType() string

func (*GetResponse) GetData

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

func (*GetResponse) GetEtag

func (x *GetResponse) GetEtag() *Etag

func (*GetResponse) GetMetadata

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

func (*GetResponse) ProtoMessage

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect

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

func (*GetResponse) Reset

func (x *GetResponse) Reset()

func (*GetResponse) String

func (x *GetResponse) String() string

type GetSecretRequest added in v1.12.0

type GetSecretRequest struct {

	// The name of secret key.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,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
}

GetSecretRequest is the message to get secret from secret store.

func (*GetSecretRequest) Descriptor deprecated added in v1.12.0

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

Deprecated: Use GetSecretRequest.ProtoReflect.Descriptor instead.

func (*GetSecretRequest) GetKey added in v1.12.0

func (x *GetSecretRequest) GetKey() string

func (*GetSecretRequest) GetMetadata added in v1.12.0

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

func (*GetSecretRequest) ProtoMessage added in v1.12.0

func (*GetSecretRequest) ProtoMessage()

func (*GetSecretRequest) ProtoReflect added in v1.12.0

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

func (*GetSecretRequest) Reset added in v1.12.0

func (x *GetSecretRequest) Reset()

func (*GetSecretRequest) String added in v1.12.0

func (x *GetSecretRequest) String() string

type GetSecretResponse added in v1.12.0

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 added in v1.12.0

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

Deprecated: Use GetSecretResponse.ProtoReflect.Descriptor instead.

func (*GetSecretResponse) GetData added in v1.12.0

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

func (*GetSecretResponse) ProtoMessage added in v1.12.0

func (*GetSecretResponse) ProtoMessage()

func (*GetSecretResponse) ProtoReflect added in v1.12.0

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

func (*GetSecretResponse) Reset added in v1.12.0

func (x *GetSecretResponse) Reset()

func (*GetSecretResponse) String added in v1.12.0

func (x *GetSecretResponse) String() string

type InitRequest

type InitRequest struct {
	Metadata *MetadataRequest `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

InitRequest is the request for initializing the component.

func (*InitRequest) Descriptor deprecated

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

Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.

func (*InitRequest) GetMetadata

func (x *InitRequest) GetMetadata() *MetadataRequest

func (*InitRequest) ProtoMessage

func (*InitRequest) ProtoMessage()

func (*InitRequest) ProtoReflect

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

func (*InitRequest) Reset

func (x *InitRequest) Reset()

func (*InitRequest) String

func (x *InitRequest) String() string

type InitResponse

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

reserved for future-proof extensibility

func (*InitResponse) Descriptor deprecated

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

Deprecated: Use InitResponse.ProtoReflect.Descriptor instead.

func (*InitResponse) ProtoMessage

func (*InitResponse) ProtoMessage()

func (*InitResponse) ProtoReflect

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

func (*InitResponse) Reset

func (x *InitResponse) Reset()

func (*InitResponse) String

func (x *InitResponse) String() string

type InputBindingClient

type InputBindingClient interface {
	// Initializes the inputbinding component component with the given metadata.
	Init(ctx context.Context, in *InputBindingInitRequest, opts ...grpc.CallOption) (*InputBindingInitResponse, error)
	// Establishes a stream with the server, which sends messages down to the
	// client. The client streams acknowledgements back to the server. The server
	// will close the stream and return the status on any error. In case of closed
	// connection, the client should re-establish the stream.
	Read(ctx context.Context, opts ...grpc.CallOption) (InputBinding_ReadClient, error)
	// Ping the InputBinding. Used for liveness porpuses.
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
}

InputBindingClient is the client API for InputBinding 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.

type InputBindingInitRequest

type InputBindingInitRequest struct {

	// The metadata request.
	Metadata *MetadataRequest `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

InputBindingInitRequest is the request for initializing the input binding component.

func (*InputBindingInitRequest) Descriptor deprecated

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

Deprecated: Use InputBindingInitRequest.ProtoReflect.Descriptor instead.

func (*InputBindingInitRequest) GetMetadata

func (x *InputBindingInitRequest) GetMetadata() *MetadataRequest

func (*InputBindingInitRequest) ProtoMessage

func (*InputBindingInitRequest) ProtoMessage()

func (*InputBindingInitRequest) ProtoReflect

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

func (*InputBindingInitRequest) Reset

func (x *InputBindingInitRequest) Reset()

func (*InputBindingInitRequest) String

func (x *InputBindingInitRequest) String() string

type InputBindingInitResponse

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

reserved for future-proof extensibility

func (*InputBindingInitResponse) Descriptor deprecated

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

Deprecated: Use InputBindingInitResponse.ProtoReflect.Descriptor instead.

func (*InputBindingInitResponse) ProtoMessage

func (*InputBindingInitResponse) ProtoMessage()

func (*InputBindingInitResponse) ProtoReflect

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

func (*InputBindingInitResponse) Reset

func (x *InputBindingInitResponse) Reset()

func (*InputBindingInitResponse) String

func (x *InputBindingInitResponse) String() string

type InputBindingServer

type InputBindingServer interface {
	// Initializes the inputbinding component component with the given metadata.
	Init(context.Context, *InputBindingInitRequest) (*InputBindingInitResponse, error)
	// Establishes a stream with the server, which sends messages down to the
	// client. The client streams acknowledgements back to the server. The server
	// will close the stream and return the status on any error. In case of closed
	// connection, the client should re-establish the stream.
	Read(InputBinding_ReadServer) error
	// Ping the InputBinding. Used for liveness porpuses.
	Ping(context.Context, *PingRequest) (*PingResponse, error)
}

InputBindingServer is the server API for InputBinding service. All implementations should embed UnimplementedInputBindingServer for forward compatibility

type InputBinding_ReadClient

type InputBinding_ReadClient interface {
	Send(*ReadRequest) error
	Recv() (*ReadResponse, error)
	grpc.ClientStream
}

type InputBinding_ReadServer

type InputBinding_ReadServer interface {
	Send(*ReadResponse) error
	Recv() (*ReadRequest, error)
	grpc.ServerStream
}

type InvokeRequest

type InvokeRequest struct {

	// The invoke payload.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The invoke metadata.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The system supported operation.
	Operation string `protobuf:"bytes,3,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

Used for invoking systems with optional payload.

func (*InvokeRequest) Descriptor deprecated

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

Deprecated: Use InvokeRequest.ProtoReflect.Descriptor instead.

func (*InvokeRequest) GetData

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

func (*InvokeRequest) GetMetadata

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

func (*InvokeRequest) GetOperation

func (x *InvokeRequest) GetOperation() string

func (*InvokeRequest) ProtoMessage

func (*InvokeRequest) ProtoMessage()

func (*InvokeRequest) ProtoReflect

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

func (*InvokeRequest) Reset

func (x *InvokeRequest) Reset()

func (*InvokeRequest) String

func (x *InvokeRequest) String() string

type InvokeResponse

type InvokeResponse struct {

	// The response payload.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The response metadata.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The response content-type.
	ContentType string `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// contains filtered or unexported fields
}

Response from the invoked system.

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() []byte

func (*InvokeResponse) GetMetadata

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

func (*InvokeResponse) ProtoMessage

func (*InvokeResponse) ProtoMessage()

func (*InvokeResponse) ProtoReflect

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

func (*InvokeResponse) Reset

func (x *InvokeResponse) Reset()

func (*InvokeResponse) String

func (x *InvokeResponse) String() string

type ListOperationsRequest

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

reserved for future-proof extensibility

func (*ListOperationsRequest) Descriptor deprecated

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

Deprecated: Use ListOperationsRequest.ProtoReflect.Descriptor instead.

func (*ListOperationsRequest) ProtoMessage

func (*ListOperationsRequest) ProtoMessage()

func (*ListOperationsRequest) ProtoReflect

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

func (*ListOperationsRequest) Reset

func (x *ListOperationsRequest) Reset()

func (*ListOperationsRequest) String

func (x *ListOperationsRequest) String() string

type ListOperationsResponse

type ListOperationsResponse struct {

	// the list of all supported component operations.
	Operations []string `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

func (*ListOperationsResponse) Descriptor deprecated

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

Deprecated: Use ListOperationsResponse.ProtoReflect.Descriptor instead.

func (*ListOperationsResponse) GetOperations

func (x *ListOperationsResponse) GetOperations() []string

func (*ListOperationsResponse) ProtoMessage

func (*ListOperationsResponse) ProtoMessage()

func (*ListOperationsResponse) ProtoReflect

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

func (*ListOperationsResponse) Reset

func (x *ListOperationsResponse) Reset()

func (*ListOperationsResponse) String

func (x *ListOperationsResponse) String() string

type MetadataRequest

type MetadataRequest struct {
	Properties map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

Base metadata request for all components

func (*MetadataRequest) Descriptor deprecated

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

Deprecated: Use MetadataRequest.ProtoReflect.Descriptor instead.

func (*MetadataRequest) GetProperties

func (x *MetadataRequest) GetProperties() map[string]string

func (*MetadataRequest) ProtoMessage

func (*MetadataRequest) ProtoMessage()

func (*MetadataRequest) ProtoReflect

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

func (*MetadataRequest) Reset

func (x *MetadataRequest) Reset()

func (*MetadataRequest) String

func (x *MetadataRequest) String() string

type MultiMaxSizeRequest added in v1.13.0

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

MultiMaxSizeRequest is the request for MultiMaxSize. It is empty because there are no parameters.

func (*MultiMaxSizeRequest) Descriptor deprecated added in v1.13.0

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

Deprecated: Use MultiMaxSizeRequest.ProtoReflect.Descriptor instead.

func (*MultiMaxSizeRequest) ProtoMessage added in v1.13.0

func (*MultiMaxSizeRequest) ProtoMessage()

func (*MultiMaxSizeRequest) ProtoReflect added in v1.13.0

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

func (*MultiMaxSizeRequest) Reset added in v1.13.0

func (x *MultiMaxSizeRequest) Reset()

func (*MultiMaxSizeRequest) String added in v1.13.0

func (x *MultiMaxSizeRequest) String() string

type MultiMaxSizeResponse added in v1.13.0

type MultiMaxSizeResponse struct {

	// The maximum number of operations that can be performed in a single
	// transaction.
	MaxSize int64 `protobuf:"varint,1,opt,name=max_size,json=maxSize,proto3" json:"max_size,omitempty"`
	// contains filtered or unexported fields
}

MultiMaxSizeResponse is the response for MultiMaxSize.

func (*MultiMaxSizeResponse) Descriptor deprecated added in v1.13.0

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

Deprecated: Use MultiMaxSizeResponse.ProtoReflect.Descriptor instead.

func (*MultiMaxSizeResponse) GetMaxSize added in v1.13.0

func (x *MultiMaxSizeResponse) GetMaxSize() int64

func (*MultiMaxSizeResponse) ProtoMessage added in v1.13.0

func (*MultiMaxSizeResponse) ProtoMessage()

func (*MultiMaxSizeResponse) ProtoReflect added in v1.13.0

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

func (*MultiMaxSizeResponse) Reset added in v1.13.0

func (x *MultiMaxSizeResponse) Reset()

func (*MultiMaxSizeResponse) String added in v1.13.0

func (x *MultiMaxSizeResponse) String() string

type OutputBindingClient

type OutputBindingClient interface {
	// Initializes the outputbinding component component with the given metadata.
	Init(ctx context.Context, in *OutputBindingInitRequest, opts ...grpc.CallOption) (*OutputBindingInitResponse, error)
	// Invoke remote systems with optional payloads.
	Invoke(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (*InvokeResponse, error)
	// ListOperations list system supported operations.
	ListOperations(ctx context.Context, in *ListOperationsRequest, opts ...grpc.CallOption) (*ListOperationsResponse, error)
	// Ping the OutputBinding. Used for liveness porpuses.
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
}

OutputBindingClient is the client API for OutputBinding 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.

type OutputBindingInitRequest

type OutputBindingInitRequest struct {

	// The metadata request.
	Metadata *MetadataRequest `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

OutputBindingInitRequest is the request for initializing the output binding component.

func (*OutputBindingInitRequest) Descriptor deprecated

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

Deprecated: Use OutputBindingInitRequest.ProtoReflect.Descriptor instead.

func (*OutputBindingInitRequest) GetMetadata

func (x *OutputBindingInitRequest) GetMetadata() *MetadataRequest

func (*OutputBindingInitRequest) ProtoMessage

func (*OutputBindingInitRequest) ProtoMessage()

func (*OutputBindingInitRequest) ProtoReflect

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

func (*OutputBindingInitRequest) Reset

func (x *OutputBindingInitRequest) Reset()

func (*OutputBindingInitRequest) String

func (x *OutputBindingInitRequest) String() string

type OutputBindingInitResponse

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

reserved for future-proof extensibility

func (*OutputBindingInitResponse) Descriptor deprecated

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

Deprecated: Use OutputBindingInitResponse.ProtoReflect.Descriptor instead.

func (*OutputBindingInitResponse) ProtoMessage

func (*OutputBindingInitResponse) ProtoMessage()

func (*OutputBindingInitResponse) ProtoReflect

func (*OutputBindingInitResponse) Reset

func (x *OutputBindingInitResponse) Reset()

func (*OutputBindingInitResponse) String

func (x *OutputBindingInitResponse) String() string

type OutputBindingServer

type OutputBindingServer interface {
	// Initializes the outputbinding component component with the given metadata.
	Init(context.Context, *OutputBindingInitRequest) (*OutputBindingInitResponse, error)
	// Invoke remote systems with optional payloads.
	Invoke(context.Context, *InvokeRequest) (*InvokeResponse, error)
	// ListOperations list system supported operations.
	ListOperations(context.Context, *ListOperationsRequest) (*ListOperationsResponse, error)
	// Ping the OutputBinding. Used for liveness porpuses.
	Ping(context.Context, *PingRequest) (*PingResponse, error)
}

OutputBindingServer is the server API for OutputBinding service. All implementations should embed UnimplementedOutputBindingServer for forward compatibility

type Pagination

type Pagination struct {

	// Maximum of results that should be returned.
	Limit int64 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// The pagination token.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*Pagination) Descriptor deprecated

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

Deprecated: Use Pagination.ProtoReflect.Descriptor instead.

func (*Pagination) GetLimit

func (x *Pagination) GetLimit() int64

func (*Pagination) GetToken

func (x *Pagination) GetToken() string

func (*Pagination) ProtoMessage

func (*Pagination) ProtoMessage()

func (*Pagination) ProtoReflect

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

func (*Pagination) Reset

func (x *Pagination) Reset()

func (*Pagination) String

func (x *Pagination) String() string

type PingRequest

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

reserved for future-proof extensibility

func (*PingRequest) Descriptor deprecated

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect

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

func (*PingRequest) Reset

func (x *PingRequest) Reset()

func (*PingRequest) String

func (x *PingRequest) String() string

type PingResponse

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

reserved for future-proof extensibility

func (*PingResponse) Descriptor deprecated

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) ProtoMessage

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect

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

func (*PingResponse) Reset

func (x *PingResponse) Reset()

func (*PingResponse) String

func (x *PingResponse) String() string

type PubSubClient

type PubSubClient interface {
	// Initializes the pubsub component with the given metadata.
	Init(ctx context.Context, in *PubSubInitRequest, opts ...grpc.CallOption) (*PubSubInitResponse, error)
	// Returns a list of implemented pubsub features.
	Features(ctx context.Context, in *FeaturesRequest, opts ...grpc.CallOption) (*FeaturesResponse, error)
	// Publish publishes a new message for the given topic.
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	BulkPublish(ctx context.Context, in *BulkPublishRequest, opts ...grpc.CallOption) (*BulkPublishResponse, error)
	// Establishes a stream with the server (PubSub component), which sends
	// messages down to the client (daprd). The client streams acknowledgements
	// back to the server. The server will close the stream and return the status
	// on any error. In case of closed connection, the client should re-establish
	// the stream. The first message MUST contain a `topic` attribute on it that
	// should be used for the entire streaming pull.
	PullMessages(ctx context.Context, opts ...grpc.CallOption) (PubSub_PullMessagesClient, error)
	// Ping the pubsub. Used for liveness porpuses.
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
}

PubSubClient is the client API for PubSub 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 NewPubSubClient

func NewPubSubClient(cc grpc.ClientConnInterface) PubSubClient

type PubSubInitRequest

type PubSubInitRequest struct {

	// The metadata request.
	Metadata *MetadataRequest `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

PubSubInitRequest is the request for initializing the pubsub component.

func (*PubSubInitRequest) Descriptor deprecated

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

Deprecated: Use PubSubInitRequest.ProtoReflect.Descriptor instead.

func (*PubSubInitRequest) GetMetadata

func (x *PubSubInitRequest) GetMetadata() *MetadataRequest

func (*PubSubInitRequest) ProtoMessage

func (*PubSubInitRequest) ProtoMessage()

func (*PubSubInitRequest) ProtoReflect

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

func (*PubSubInitRequest) Reset

func (x *PubSubInitRequest) Reset()

func (*PubSubInitRequest) String

func (x *PubSubInitRequest) String() string

type PubSubInitResponse

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

reserved for future-proof extensibility

func (*PubSubInitResponse) Descriptor deprecated

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

Deprecated: Use PubSubInitResponse.ProtoReflect.Descriptor instead.

func (*PubSubInitResponse) ProtoMessage

func (*PubSubInitResponse) ProtoMessage()

func (*PubSubInitResponse) ProtoReflect

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

func (*PubSubInitResponse) Reset

func (x *PubSubInitResponse) Reset()

func (*PubSubInitResponse) String

func (x *PubSubInitResponse) String() string

type PubSubServer

type PubSubServer interface {
	// Initializes the pubsub component with the given metadata.
	Init(context.Context, *PubSubInitRequest) (*PubSubInitResponse, error)
	// Returns a list of implemented pubsub features.
	Features(context.Context, *FeaturesRequest) (*FeaturesResponse, error)
	// Publish publishes a new message for the given topic.
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	BulkPublish(context.Context, *BulkPublishRequest) (*BulkPublishResponse, error)
	// Establishes a stream with the server (PubSub component), which sends
	// messages down to the client (daprd). The client streams acknowledgements
	// back to the server. The server will close the stream and return the status
	// on any error. In case of closed connection, the client should re-establish
	// the stream. The first message MUST contain a `topic` attribute on it that
	// should be used for the entire streaming pull.
	PullMessages(PubSub_PullMessagesServer) error
	// Ping the pubsub. Used for liveness porpuses.
	Ping(context.Context, *PingRequest) (*PingResponse, error)
}

PubSubServer is the server API for PubSub service. All implementations should embed UnimplementedPubSubServer for forward compatibility

type PubSub_PullMessagesClient

type PubSub_PullMessagesClient interface {
	Send(*PullMessagesRequest) error
	Recv() (*PullMessagesResponse, error)
	grpc.ClientStream
}

type PubSub_PullMessagesServer

type PubSub_PullMessagesServer interface {
	Send(*PullMessagesResponse) error
	Recv() (*PullMessagesRequest, error)
	grpc.ServerStream
}

type PublishRequest

type PublishRequest struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The pubsub name.
	PubsubName string `protobuf:"bytes,2,opt,name=pubsub_name,json=pubsubName,proto3" json:"pubsub_name,omitempty"`
	// The publishing topic.
	Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	// Message metadata.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The data content type.
	ContentType string `protobuf:"bytes,5,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequest) Descriptor deprecated

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetContentType

func (x *PublishRequest) GetContentType() string

func (*PublishRequest) GetData

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

func (*PublishRequest) GetMetadata

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

func (*PublishRequest) GetPubsubName

func (x *PublishRequest) GetPubsubName() string

func (*PublishRequest) GetTopic

func (x *PublishRequest) GetTopic() string

func (*PublishRequest) ProtoMessage

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect

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

func (*PublishRequest) Reset

func (x *PublishRequest) Reset()

func (*PublishRequest) String

func (x *PublishRequest) String() string

type PublishResponse

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

reserved for future-proof extensibility

func (*PublishResponse) Descriptor deprecated

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

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) ProtoMessage

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect

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

func (*PublishResponse) Reset

func (x *PublishResponse) Reset()

func (*PublishResponse) String

func (x *PublishResponse) String() string

type PullMessagesRequest

type PullMessagesRequest struct {

	// Required. The subscribed topic for which to initialize the new stream. This
	// must be provided in the first request on the stream, and must not be set in
	// subsequent requests from client to server.
	Topic *Topic `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// The unique message ID.
	AckMessageId string `protobuf:"bytes,2,opt,name=ack_message_id,json=ackMessageId,proto3" json:"ack_message_id,omitempty"`
	// Optional, should not be fulfilled when the message was successfully
	// handled.
	AckError *AckMessageError `protobuf:"bytes,3,opt,name=ack_error,json=ackError,proto3" json:"ack_error,omitempty"`
	// contains filtered or unexported fields
}

Used for acknowledge a message.

func (*PullMessagesRequest) Descriptor deprecated

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

Deprecated: Use PullMessagesRequest.ProtoReflect.Descriptor instead.

func (*PullMessagesRequest) GetAckError

func (x *PullMessagesRequest) GetAckError() *AckMessageError

func (*PullMessagesRequest) GetAckMessageId

func (x *PullMessagesRequest) GetAckMessageId() string

func (*PullMessagesRequest) GetTopic

func (x *PullMessagesRequest) GetTopic() *Topic

func (*PullMessagesRequest) ProtoMessage

func (*PullMessagesRequest) ProtoMessage()

func (*PullMessagesRequest) ProtoReflect

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

func (*PullMessagesRequest) Reset

func (x *PullMessagesRequest) Reset()

func (*PullMessagesRequest) String

func (x *PullMessagesRequest) String() string

type PullMessagesResponse

type PullMessagesResponse struct {

	// The message content.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The topic where the message come from.
	TopicName string `protobuf:"bytes,2,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"`
	// The message related metadata.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The message content type.
	ContentType string `protobuf:"bytes,4,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// The message {transient} ID. Its used for ack'ing it later.
	Id string `protobuf:"bytes,5,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*PullMessagesResponse) Descriptor deprecated

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

Deprecated: Use PullMessagesResponse.ProtoReflect.Descriptor instead.

func (*PullMessagesResponse) GetContentType

func (x *PullMessagesResponse) GetContentType() string

func (*PullMessagesResponse) GetData

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

func (*PullMessagesResponse) GetId

func (x *PullMessagesResponse) GetId() string

func (*PullMessagesResponse) GetMetadata

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

func (*PullMessagesResponse) GetTopicName

func (x *PullMessagesResponse) GetTopicName() string

func (*PullMessagesResponse) ProtoMessage

func (*PullMessagesResponse) ProtoMessage()

func (*PullMessagesResponse) ProtoReflect

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

func (*PullMessagesResponse) Reset

func (x *PullMessagesResponse) Reset()

func (*PullMessagesResponse) String

func (x *PullMessagesResponse) String() string

type QueriableStateStoreClient

type QueriableStateStoreClient interface {
	// Query performs a query request on the statestore.
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
}

QueriableStateStoreClient is the client API for QueriableStateStore 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.

type QueriableStateStoreServer

type QueriableStateStoreServer interface {
	// Query performs a query request on the statestore.
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
}

QueriableStateStoreServer is the server API for QueriableStateStore service. All implementations should embed UnimplementedQueriableStateStoreServer for forward compatibility

type Query

type Query struct {

	// Filters that should be applied.
	Filter map[string]*anypb.Any `` /* 153-byte string literal not displayed */
	// The sort order.
	Sort []*Sorting `protobuf:"bytes,2,rep,name=sort,proto3" json:"sort,omitempty"`
	// The query pagination params.
	Pagination *Pagination `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*Query) Descriptor deprecated

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

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetFilter

func (x *Query) GetFilter() map[string]*anypb.Any

func (*Query) GetPagination

func (x *Query) GetPagination() *Pagination

func (*Query) GetSort

func (x *Query) GetSort() []*Sorting

func (*Query) ProtoMessage

func (*Query) ProtoMessage()

func (*Query) ProtoReflect

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

func (*Query) Reset

func (x *Query) Reset()

func (*Query) String

func (x *Query) String() string

type QueryItem

type QueryItem struct {

	// The returned item Key.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The returned item Data.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// The returned item ETag
	Etag *Etag `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// The returned error string.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// The returned contenttype
	ContentType string `protobuf:"bytes,5,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// contains filtered or unexported fields
}

QueryItem is an object representing a single entry in query results.

func (*QueryItem) Descriptor deprecated

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

Deprecated: Use QueryItem.ProtoReflect.Descriptor instead.

func (*QueryItem) GetContentType

func (x *QueryItem) GetContentType() string

func (*QueryItem) GetData

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

func (*QueryItem) GetError

func (x *QueryItem) GetError() string

func (*QueryItem) GetEtag

func (x *QueryItem) GetEtag() *Etag

func (*QueryItem) GetKey

func (x *QueryItem) GetKey() string

func (*QueryItem) ProtoMessage

func (*QueryItem) ProtoMessage()

func (*QueryItem) ProtoReflect

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

func (*QueryItem) Reset

func (x *QueryItem) Reset()

func (*QueryItem) String

func (x *QueryItem) String() string

type QueryRequest

type QueryRequest struct {

	// The query to be performed.
	Query *Query `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// Request associated metadata.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

QueryRequest is for querying state store.

func (*QueryRequest) Descriptor deprecated

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetMetadata

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

func (*QueryRequest) GetQuery

func (x *QueryRequest) GetQuery() *Query

func (*QueryRequest) ProtoMessage

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect

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

func (*QueryRequest) Reset

func (x *QueryRequest) Reset()

func (*QueryRequest) String

func (x *QueryRequest) String() string

type QueryResponse

type QueryResponse struct {

	// The query response items.
	Items []*QueryItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// The response token.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// Response associated metadata.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

QueryResponse is the query response.

func (*QueryResponse) Descriptor deprecated

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

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetItems

func (x *QueryResponse) GetItems() []*QueryItem

func (*QueryResponse) GetMetadata

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

func (*QueryResponse) GetToken

func (x *QueryResponse) GetToken() string

func (*QueryResponse) ProtoMessage

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect

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

func (*QueryResponse) Reset

func (x *QueryResponse) Reset()

func (*QueryResponse) String

func (x *QueryResponse) String() string

type ReadRequest

type ReadRequest struct {

	// The handle response.
	ResponseData []byte `protobuf:"bytes,1,opt,name=response_data,json=responseData,proto3" json:"response_data,omitempty"`
	// The unique message ID.
	MessageId string `protobuf:"bytes,2,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// Optional, should not be fulfilled when the message was successfully
	// handled.
	ResponseError *AckResponseError `protobuf:"bytes,3,opt,name=response_error,json=responseError,proto3" json:"response_error,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadRequest) Descriptor deprecated

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

Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.

func (*ReadRequest) GetMessageId

func (x *ReadRequest) GetMessageId() string

func (*ReadRequest) GetResponseData

func (x *ReadRequest) GetResponseData() []byte

func (*ReadRequest) GetResponseError

func (x *ReadRequest) GetResponseError() *AckResponseError

func (*ReadRequest) ProtoMessage

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoReflect

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

func (*ReadRequest) Reset

func (x *ReadRequest) Reset()

func (*ReadRequest) String

func (x *ReadRequest) String() string

type ReadResponse

type ReadResponse struct {

	// The Read binding Data.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// The message metadata
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The message content type.
	ContentType string `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// The {transient} message ID used for ACK-ing it later.
	MessageId string `protobuf:"bytes,4,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse) Descriptor deprecated

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

Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.

func (*ReadResponse) GetContentType

func (x *ReadResponse) GetContentType() string

func (*ReadResponse) GetData

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

func (*ReadResponse) GetMessageId

func (x *ReadResponse) GetMessageId() string

func (*ReadResponse) GetMetadata

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

func (*ReadResponse) ProtoMessage

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) ProtoReflect

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

func (*ReadResponse) Reset

func (x *ReadResponse) Reset()

func (*ReadResponse) String

func (x *ReadResponse) String() string

type SecretResponse added in v1.12.0

type SecretResponse struct {
	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 added in v1.12.0

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

Deprecated: Use SecretResponse.ProtoReflect.Descriptor instead.

func (*SecretResponse) GetSecrets added in v1.12.0

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

func (*SecretResponse) ProtoMessage added in v1.12.0

func (*SecretResponse) ProtoMessage()

func (*SecretResponse) ProtoReflect added in v1.12.0

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

func (*SecretResponse) Reset added in v1.12.0

func (x *SecretResponse) Reset()

func (*SecretResponse) String added in v1.12.0

func (x *SecretResponse) String() string

type SecretStoreClient added in v1.12.0

type SecretStoreClient interface {
	// Initializes the secret store with the given metadata.
	Init(ctx context.Context, in *SecretStoreInitRequest, opts ...grpc.CallOption) (*SecretStoreInitResponse, error)
	// Returns a list of implemented secret store features.
	Features(ctx context.Context, in *FeaturesRequest, opts ...grpc.CallOption) (*FeaturesResponse, error)
	// Get an individual secret from the store.
	Get(ctx context.Context, in *GetSecretRequest, opts ...grpc.CallOption) (*GetSecretResponse, error)
	// Get all secrets from the store.
	BulkGet(ctx context.Context, in *BulkGetSecretRequest, opts ...grpc.CallOption) (*BulkGetSecretResponse, error)
	// Ping the pubsub. Used for liveness porpuses.
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
}

SecretStoreClient is the client API for SecretStore 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 NewSecretStoreClient added in v1.12.0

func NewSecretStoreClient(cc grpc.ClientConnInterface) SecretStoreClient

type SecretStoreInitRequest added in v1.12.0

type SecretStoreInitRequest struct {
	Metadata *MetadataRequest `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Request to initialize the secret store.

func (*SecretStoreInitRequest) Descriptor deprecated added in v1.12.0

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

Deprecated: Use SecretStoreInitRequest.ProtoReflect.Descriptor instead.

func (*SecretStoreInitRequest) GetMetadata added in v1.12.0

func (x *SecretStoreInitRequest) GetMetadata() *MetadataRequest

func (*SecretStoreInitRequest) ProtoMessage added in v1.12.0

func (*SecretStoreInitRequest) ProtoMessage()

func (*SecretStoreInitRequest) ProtoReflect added in v1.12.0

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

func (*SecretStoreInitRequest) Reset added in v1.12.0

func (x *SecretStoreInitRequest) Reset()

func (*SecretStoreInitRequest) String added in v1.12.0

func (x *SecretStoreInitRequest) String() string

type SecretStoreInitResponse added in v1.12.0

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

Response from initialization.

func (*SecretStoreInitResponse) Descriptor deprecated added in v1.12.0

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

Deprecated: Use SecretStoreInitResponse.ProtoReflect.Descriptor instead.

func (*SecretStoreInitResponse) ProtoMessage added in v1.12.0

func (*SecretStoreInitResponse) ProtoMessage()

func (*SecretStoreInitResponse) ProtoReflect added in v1.12.0

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

func (*SecretStoreInitResponse) Reset added in v1.12.0

func (x *SecretStoreInitResponse) Reset()

func (*SecretStoreInitResponse) String added in v1.12.0

func (x *SecretStoreInitResponse) String() string

type SecretStoreServer added in v1.12.0

type SecretStoreServer interface {
	// Initializes the secret store with the given metadata.
	Init(context.Context, *SecretStoreInitRequest) (*SecretStoreInitResponse, error)
	// Returns a list of implemented secret store features.
	Features(context.Context, *FeaturesRequest) (*FeaturesResponse, error)
	// Get an individual secret from the store.
	Get(context.Context, *GetSecretRequest) (*GetSecretResponse, error)
	// Get all secrets from the store.
	BulkGet(context.Context, *BulkGetSecretRequest) (*BulkGetSecretResponse, error)
	// Ping the pubsub. Used for liveness porpuses.
	Ping(context.Context, *PingRequest) (*PingResponse, error)
}

SecretStoreServer is the server API for SecretStore service. All implementations should embed UnimplementedSecretStoreServer for forward compatibility

type SetRequest

type SetRequest struct {

	// The key that should be set.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Value is the desired content of the given key.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// The etag is used as a If-Match header, to allow certain levels of
	// consistency.
	Etag *Etag `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// The request metadata.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// The Set request options.
	Options *StateOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	// The data contenttype
	ContentType string `protobuf:"bytes,6,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// contains filtered or unexported fields
}

func (*SetRequest) Descriptor deprecated

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

Deprecated: Use SetRequest.ProtoReflect.Descriptor instead.

func (*SetRequest) GetContentType

func (x *SetRequest) GetContentType() string

func (*SetRequest) GetEtag

func (x *SetRequest) GetEtag() *Etag

func (*SetRequest) GetKey

func (x *SetRequest) GetKey() string

func (*SetRequest) GetMetadata

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

func (*SetRequest) GetOptions

func (x *SetRequest) GetOptions() *StateOptions

func (*SetRequest) GetValue

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

func (*SetRequest) ProtoMessage

func (*SetRequest) ProtoMessage()

func (*SetRequest) ProtoReflect

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

func (*SetRequest) Reset

func (x *SetRequest) Reset()

func (*SetRequest) String

func (x *SetRequest) String() string

type SetResponse

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

reserved for future-proof extensibility

func (*SetResponse) Descriptor deprecated

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

Deprecated: Use SetResponse.ProtoReflect.Descriptor instead.

func (*SetResponse) ProtoMessage

func (*SetResponse) ProtoMessage()

func (*SetResponse) ProtoReflect

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

func (*SetResponse) Reset

func (x *SetResponse) Reset()

func (*SetResponse) String

func (x *SetResponse) String() string

type Sorting

type Sorting struct {

	// The key that should be used for sorting.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The order that should be used.
	Order Sorting_Order `protobuf:"varint,2,opt,name=order,proto3,enum=dapr.proto.components.v1.Sorting_Order" json:"order,omitempty"`
	// contains filtered or unexported fields
}

func (*Sorting) Descriptor deprecated

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

Deprecated: Use Sorting.ProtoReflect.Descriptor instead.

func (*Sorting) GetKey

func (x *Sorting) GetKey() string

func (*Sorting) GetOrder

func (x *Sorting) GetOrder() Sorting_Order

func (*Sorting) ProtoMessage

func (*Sorting) ProtoMessage()

func (*Sorting) ProtoReflect

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

func (*Sorting) Reset

func (x *Sorting) Reset()

func (*Sorting) String

func (x *Sorting) String() string

type Sorting_Order

type Sorting_Order int32
const (
	Sorting_ASC  Sorting_Order = 0
	Sorting_DESC Sorting_Order = 1
)

func (Sorting_Order) Descriptor

func (Sorting_Order) Enum

func (x Sorting_Order) Enum() *Sorting_Order

func (Sorting_Order) EnumDescriptor deprecated

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

Deprecated: Use Sorting_Order.Descriptor instead.

func (Sorting_Order) Number

func (Sorting_Order) String

func (x Sorting_Order) String() string

func (Sorting_Order) Type

type StateOptions

type StateOptions struct {
	Concurrency StateOptions_StateConcurrency `` /* 136-byte string literal not displayed */
	Consistency StateOptions_StateConsistency `` /* 136-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.

const (
	StateOptions_CONCURRENCY_UNSPECIFIED StateOptions_StateConcurrency = 0
	StateOptions_CONCURRENCY_FIRST_WRITE StateOptions_StateConcurrency = 1
	StateOptions_CONCURRENCY_LAST_WRITE  StateOptions_StateConcurrency = 2
)

func (StateOptions_StateConcurrency) Descriptor

func (StateOptions_StateConcurrency) Enum

func (StateOptions_StateConcurrency) EnumDescriptor deprecated

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

Deprecated: Use StateOptions_StateConcurrency.Descriptor instead.

func (StateOptions_StateConcurrency) Number

func (StateOptions_StateConcurrency) String

func (StateOptions_StateConcurrency) Type

type StateOptions_StateConsistency

type StateOptions_StateConsistency int32

Enum describing the supported consistency for state.

const (
	StateOptions_CONSISTENCY_UNSPECIFIED StateOptions_StateConsistency = 0
	StateOptions_CONSISTENCY_EVENTUAL    StateOptions_StateConsistency = 1
	StateOptions_CONSISTENCY_STRONG      StateOptions_StateConsistency = 2
)

func (StateOptions_StateConsistency) Descriptor

func (StateOptions_StateConsistency) Enum

func (StateOptions_StateConsistency) EnumDescriptor deprecated

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

Deprecated: Use StateOptions_StateConsistency.Descriptor instead.

func (StateOptions_StateConsistency) Number

func (StateOptions_StateConsistency) String

func (StateOptions_StateConsistency) Type

type StateStoreClient

type StateStoreClient interface {
	// Initializes the state store component with the given metadata.
	Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error)
	// Returns a list of implemented state store features.
	Features(ctx context.Context, in *FeaturesRequest, opts ...grpc.CallOption) (*FeaturesResponse, error)
	// Deletes the specified key from the state store.
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Get data from the given key.
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Sets the value of the specified key.
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	// Ping the state store. Used for liveness porpuses.
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	// Deletes many keys at once.
	BulkDelete(ctx context.Context, in *BulkDeleteRequest, opts ...grpc.CallOption) (*BulkDeleteResponse, error)
	// Retrieves many keys at once.
	BulkGet(ctx context.Context, in *BulkGetRequest, opts ...grpc.CallOption) (*BulkGetResponse, error)
	// Set the value of many keys at once.
	BulkSet(ctx context.Context, in *BulkSetRequest, opts ...grpc.CallOption) (*BulkSetResponse, error)
}

StateStoreClient is the client API for StateStore 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 NewStateStoreClient

func NewStateStoreClient(cc grpc.ClientConnInterface) StateStoreClient

type StateStoreServer

type StateStoreServer interface {
	// Initializes the state store component with the given metadata.
	Init(context.Context, *InitRequest) (*InitResponse, error)
	// Returns a list of implemented state store features.
	Features(context.Context, *FeaturesRequest) (*FeaturesResponse, error)
	// Deletes the specified key from the state store.
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// Get data from the given key.
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Sets the value of the specified key.
	Set(context.Context, *SetRequest) (*SetResponse, error)
	// Ping the state store. Used for liveness porpuses.
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// Deletes many keys at once.
	BulkDelete(context.Context, *BulkDeleteRequest) (*BulkDeleteResponse, error)
	// Retrieves many keys at once.
	BulkGet(context.Context, *BulkGetRequest) (*BulkGetResponse, error)
	// Set the value of many keys at once.
	BulkSet(context.Context, *BulkSetRequest) (*BulkSetResponse, error)
}

StateStoreServer is the server API for StateStore service. All implementations should embed UnimplementedStateStoreServer for forward compatibility

type Topic

type Topic struct {

	// The topic name desired to be subscribed
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Metadata related subscribe request.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Topic) Descriptor deprecated

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetMetadata

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

func (*Topic) GetName

func (x *Topic) GetName() string

func (*Topic) ProtoMessage

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect

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

func (*Topic) Reset

func (x *Topic) Reset()

func (*Topic) String

func (x *Topic) String() string

type TransactionalStateOperation

type TransactionalStateOperation struct {

	// request is either delete or set.
	//
	// Types that are assignable to Request:
	//
	//	*TransactionalStateOperation_Delete
	//	*TransactionalStateOperation_Set
	Request isTransactionalStateOperation_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

TransactionalStateOperation describes operation type, key, and value for transactional operation.

func (*TransactionalStateOperation) Descriptor deprecated

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

Deprecated: Use TransactionalStateOperation.ProtoReflect.Descriptor instead.

func (*TransactionalStateOperation) GetDelete

func (*TransactionalStateOperation) GetRequest

func (m *TransactionalStateOperation) GetRequest() isTransactionalStateOperation_Request

func (*TransactionalStateOperation) GetSet

func (*TransactionalStateOperation) ProtoMessage

func (*TransactionalStateOperation) ProtoMessage()

func (*TransactionalStateOperation) ProtoReflect

func (*TransactionalStateOperation) Reset

func (x *TransactionalStateOperation) Reset()

func (*TransactionalStateOperation) String

func (x *TransactionalStateOperation) String() string

type TransactionalStateOperation_Delete

type TransactionalStateOperation_Delete struct {
	Delete *DeleteRequest `protobuf:"bytes,1,opt,name=delete,proto3,oneof"`
}

type TransactionalStateOperation_Set

type TransactionalStateOperation_Set struct {
	Set *SetRequest `protobuf:"bytes,2,opt,name=set,proto3,oneof"`
}

type TransactionalStateRequest

type TransactionalStateRequest struct {

	// Operations that should be performed.
	Operations []*TransactionalStateOperation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// Request associated metadata.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

TransactionalStateRequest describes a transactional operation against a state store that comprises multiple types of operations The Request field is either a DeleteRequest or SetRequest.

func (*TransactionalStateRequest) Descriptor deprecated

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

Deprecated: Use TransactionalStateRequest.ProtoReflect.Descriptor instead.

func (*TransactionalStateRequest) GetMetadata

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

func (*TransactionalStateRequest) GetOperations

func (*TransactionalStateRequest) ProtoMessage

func (*TransactionalStateRequest) ProtoMessage()

func (*TransactionalStateRequest) ProtoReflect

func (*TransactionalStateRequest) Reset

func (x *TransactionalStateRequest) Reset()

func (*TransactionalStateRequest) String

func (x *TransactionalStateRequest) String() string

type TransactionalStateResponse

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

reserved for future-proof extensibility

func (*TransactionalStateResponse) Descriptor deprecated

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

Deprecated: Use TransactionalStateResponse.ProtoReflect.Descriptor instead.

func (*TransactionalStateResponse) ProtoMessage

func (*TransactionalStateResponse) ProtoMessage()

func (*TransactionalStateResponse) ProtoReflect

func (*TransactionalStateResponse) Reset

func (x *TransactionalStateResponse) Reset()

func (*TransactionalStateResponse) String

func (x *TransactionalStateResponse) String() string

type TransactionalStateStoreClient

type TransactionalStateStoreClient interface {
	// Transact executes multiples operation in a transactional environment.
	Transact(ctx context.Context, in *TransactionalStateRequest, opts ...grpc.CallOption) (*TransactionalStateResponse, error)
}

TransactionalStateStoreClient is the client API for TransactionalStateStore 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.

type TransactionalStateStoreServer

type TransactionalStateStoreServer interface {
	// Transact executes multiples operation in a transactional environment.
	Transact(context.Context, *TransactionalStateRequest) (*TransactionalStateResponse, error)
}

TransactionalStateStoreServer is the server API for TransactionalStateStore service. All implementations should embed UnimplementedTransactionalStateStoreServer for forward compatibility

type TransactionalStoreMultiMaxSizeClient added in v1.13.0

type TransactionalStoreMultiMaxSizeClient interface {
	// MultiMaxSize returns the maximum number of operations that can be performed
	// in a single transaction.
	MultiMaxSize(ctx context.Context, in *MultiMaxSizeRequest, opts ...grpc.CallOption) (*MultiMaxSizeResponse, error)
}

TransactionalStoreMultiMaxSizeClient is the client API for TransactionalStoreMultiMaxSize 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 NewTransactionalStoreMultiMaxSizeClient added in v1.13.0

func NewTransactionalStoreMultiMaxSizeClient(cc grpc.ClientConnInterface) TransactionalStoreMultiMaxSizeClient

type TransactionalStoreMultiMaxSizeServer added in v1.13.0

type TransactionalStoreMultiMaxSizeServer interface {
	// MultiMaxSize returns the maximum number of operations that can be performed
	// in a single transaction.
	MultiMaxSize(context.Context, *MultiMaxSizeRequest) (*MultiMaxSizeResponse, error)
}

TransactionalStoreMultiMaxSizeServer is the server API for TransactionalStoreMultiMaxSize service. All implementations should embed UnimplementedTransactionalStoreMultiMaxSizeServer for forward compatibility

type UnimplementedInputBindingServer

type UnimplementedInputBindingServer struct {
}

UnimplementedInputBindingServer should be embedded to have forward compatible implementations.

func (UnimplementedInputBindingServer) Ping

func (UnimplementedInputBindingServer) Read

type UnimplementedOutputBindingServer

type UnimplementedOutputBindingServer struct {
}

UnimplementedOutputBindingServer should be embedded to have forward compatible implementations.

func (UnimplementedOutputBindingServer) Invoke

func (UnimplementedOutputBindingServer) ListOperations

func (UnimplementedOutputBindingServer) Ping

type UnimplementedPubSubServer

type UnimplementedPubSubServer struct {
}

UnimplementedPubSubServer should be embedded to have forward compatible implementations.

func (UnimplementedPubSubServer) BulkPublish added in v1.12.0

func (UnimplementedPubSubServer) Features

func (UnimplementedPubSubServer) Init

func (UnimplementedPubSubServer) Ping

func (UnimplementedPubSubServer) Publish

func (UnimplementedPubSubServer) PullMessages

type UnimplementedQueriableStateStoreServer

type UnimplementedQueriableStateStoreServer struct {
}

UnimplementedQueriableStateStoreServer should be embedded to have forward compatible implementations.

func (UnimplementedQueriableStateStoreServer) Query

type UnimplementedSecretStoreServer added in v1.12.0

type UnimplementedSecretStoreServer struct {
}

UnimplementedSecretStoreServer should be embedded to have forward compatible implementations.

func (UnimplementedSecretStoreServer) BulkGet added in v1.12.0

func (UnimplementedSecretStoreServer) Features added in v1.12.0

func (UnimplementedSecretStoreServer) Get added in v1.12.0

func (UnimplementedSecretStoreServer) Init added in v1.12.0

func (UnimplementedSecretStoreServer) Ping added in v1.12.0

type UnimplementedStateStoreServer

type UnimplementedStateStoreServer struct {
}

UnimplementedStateStoreServer should be embedded to have forward compatible implementations.

func (UnimplementedStateStoreServer) BulkDelete

func (UnimplementedStateStoreServer) BulkGet

func (UnimplementedStateStoreServer) BulkSet

func (UnimplementedStateStoreServer) Delete

func (UnimplementedStateStoreServer) Features

func (UnimplementedStateStoreServer) Get

func (UnimplementedStateStoreServer) Init

func (UnimplementedStateStoreServer) Ping

func (UnimplementedStateStoreServer) Set

type UnimplementedTransactionalStateStoreServer

type UnimplementedTransactionalStateStoreServer struct {
}

UnimplementedTransactionalStateStoreServer should be embedded to have forward compatible implementations.

func (UnimplementedTransactionalStateStoreServer) Transact

type UnimplementedTransactionalStoreMultiMaxSizeServer added in v1.13.0

type UnimplementedTransactionalStoreMultiMaxSizeServer struct {
}

UnimplementedTransactionalStoreMultiMaxSizeServer should be embedded to have forward compatible implementations.

func (UnimplementedTransactionalStoreMultiMaxSizeServer) MultiMaxSize added in v1.13.0

type UnsafeInputBindingServer

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

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

type UnsafeOutputBindingServer

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

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

type UnsafePubSubServer

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

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

type UnsafeQueriableStateStoreServer

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

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

type UnsafeSecretStoreServer added in v1.12.0

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

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

type UnsafeStateStoreServer

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

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

type UnsafeTransactionalStateStoreServer

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

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

type UnsafeTransactionalStoreMultiMaxSizeServer added in v1.13.0

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

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

Jump to

Keyboard shortcuts

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