components

package
v1.10.8 Latest Latest
Warning

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

 Go to latest Published: Jun 21, 2023 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_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: "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 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)

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 RegisterStateStoreServer 

func RegisterStateStoreServer(s grpc.ServiceRegistrar, srv StateStoreServer)

func RegisterTransactionalStateStoreServer 

func RegisterTransactionalStateStoreServer(s grpc.ServiceRegistrar, srv TransactionalStateStoreServer)

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"`
	// 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) 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 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"`
	// 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) 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 BulkGetResponse 

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

func (*BulkGetResponse) Descriptor deprecated 

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

Deprecated: Use BulkGetResponse.ProtoReflect.Descriptor instead.

func (*BulkGetResponse) GetGot 

func (x *BulkGetResponse) GetGot() bool

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 BulkSetRequest 

type BulkSetRequest struct {
	Items []*SetRequest `protobuf:"bytes,1,rep,name=items,proto3" json:"items,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) 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 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 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.

func NewInputBindingClient 

func NewInputBindingClient(cc grpc.ClientConnInterface) InputBindingClient

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 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.

func NewOutputBindingClient 

func NewOutputBindingClient(cc grpc.ClientConnInterface) OutputBindingClient

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 (x *OutputBindingInitResponse) ProtoReflect() protoreflect.Message

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)
	// 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)
	// 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.

func NewQueriableStateStoreClient 

func NewQueriableStateStoreClient(cc grpc.ClientConnInterface) QueriableStateStoreClient

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 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) Descriptor() protoreflect.EnumDescriptor

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 (x Sorting_Order) Number() protoreflect.EnumNumber

func (Sorting_Order) String 

func (x Sorting_Order) String() string

func (Sorting_Order) Type 

func (Sorting_Order) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

func (StateOptions_StateConcurrency) Enum 

func (x StateOptions_StateConcurrency) Enum() *StateOptions_StateConcurrency

func (StateOptions_StateConcurrency) EnumDescriptor deprecated 

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

Deprecated: Use StateOptions_StateConcurrency.Descriptor instead.

func (StateOptions_StateConcurrency) Number 

func (x StateOptions_StateConcurrency) Number() protoreflect.EnumNumber

func (StateOptions_StateConcurrency) String 

func (x StateOptions_StateConcurrency) String() string

func (StateOptions_StateConcurrency) Type 

func (StateOptions_StateConcurrency) Type() protoreflect.EnumType

type StateOptions_StateConsistency 

type StateOptions_StateConsistency int32

Enum describing the supported consistency for state. 

const (
	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) Descriptor() protoreflect.EnumDescriptor

func (StateOptions_StateConsistency) Enum 

func (x StateOptions_StateConsistency) Enum() *StateOptions_StateConsistency

func (StateOptions_StateConsistency) EnumDescriptor deprecated 

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

Deprecated: Use StateOptions_StateConsistency.Descriptor instead.

func (StateOptions_StateConsistency) Number 

func (x StateOptions_StateConsistency) Number() protoreflect.EnumNumber

func (StateOptions_StateConsistency) String 

func (x StateOptions_StateConsistency) String() string

func (StateOptions_StateConsistency) Type 

func (StateOptions_StateConsistency) Type() protoreflect.EnumType

type 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 (x *TransactionalStateOperation) GetDelete() *DeleteRequest

func (*TransactionalStateOperation) GetRequest 

func (m *TransactionalStateOperation) GetRequest() isTransactionalStateOperation_Request

func (*TransactionalStateOperation) GetSet 

func (x *TransactionalStateOperation) GetSet() *SetRequest

func (*TransactionalStateOperation) ProtoMessage 

func (*TransactionalStateOperation) ProtoMessage()

func (*TransactionalStateOperation) ProtoReflect 

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

func (*TransactionalStateOperation) Reset 

func (x *TransactionalStateOperation) Reset()

func (*TransactionalStateOperation) String 

func (x *TransactionalStateOperation) String() string

type 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 (x *TransactionalStateRequest) GetOperations() []*TransactionalStateOperation

func (*TransactionalStateRequest) ProtoMessage 

func (*TransactionalStateRequest) ProtoMessage()

func (*TransactionalStateRequest) ProtoReflect 

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

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 (x *TransactionalStateResponse) ProtoReflect() protoreflect.Message

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.

func NewTransactionalStateStoreClient 

func NewTransactionalStateStoreClient(cc grpc.ClientConnInterface) TransactionalStateStoreClient

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 UnimplementedInputBindingServer 

type UnimplementedInputBindingServer struct {
}

UnimplementedInputBindingServer should be embedded to have forward compatible implementations.

func (UnimplementedInputBindingServer) Init 

func (UnimplementedInputBindingServer) Init(context.Context, *InputBindingInitRequest) (*InputBindingInitResponse, error)

func (UnimplementedInputBindingServer) Ping 

func (UnimplementedInputBindingServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

func (UnimplementedInputBindingServer) Read 

func (UnimplementedInputBindingServer) Read(InputBinding_ReadServer) error

type UnimplementedOutputBindingServer 

type UnimplementedOutputBindingServer struct {
}

UnimplementedOutputBindingServer should be embedded to have forward compatible implementations.

func (UnimplementedOutputBindingServer) Init 

func (UnimplementedOutputBindingServer) Init(context.Context, *OutputBindingInitRequest) (*OutputBindingInitResponse, error)

func (UnimplementedOutputBindingServer) Invoke 

func (UnimplementedOutputBindingServer) Invoke(context.Context, *InvokeRequest) (*InvokeResponse, error)

func (UnimplementedOutputBindingServer) ListOperations 

func (UnimplementedOutputBindingServer) ListOperations(context.Context, *ListOperationsRequest) (*ListOperationsResponse, error)

func (UnimplementedOutputBindingServer) Ping 

func (UnimplementedOutputBindingServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

type UnimplementedPubSubServer 

type UnimplementedPubSubServer struct {
}

UnimplementedPubSubServer should be embedded to have forward compatible implementations.

func (UnimplementedPubSubServer) Features 

func (UnimplementedPubSubServer) Features(context.Context, *FeaturesRequest) (*FeaturesResponse, error)

func (UnimplementedPubSubServer) Init 

func (UnimplementedPubSubServer) Init(context.Context, *PubSubInitRequest) (*PubSubInitResponse, error)

func (UnimplementedPubSubServer) Ping 

func (UnimplementedPubSubServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

func (UnimplementedPubSubServer) Publish 

func (UnimplementedPubSubServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)

func (UnimplementedPubSubServer) PullMessages 

func (UnimplementedPubSubServer) PullMessages(PubSub_PullMessagesServer) error

type UnimplementedQueriableStateStoreServer 

type UnimplementedQueriableStateStoreServer struct {
}

UnimplementedQueriableStateStoreServer should be embedded to have forward compatible implementations.

func (UnimplementedQueriableStateStoreServer) Query 

func (UnimplementedQueriableStateStoreServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)

type UnimplementedStateStoreServer 

type UnimplementedStateStoreServer struct {
}

UnimplementedStateStoreServer should be embedded to have forward compatible implementations.

func (UnimplementedStateStoreServer) BulkDelete 

func (UnimplementedStateStoreServer) BulkDelete(context.Context, *BulkDeleteRequest) (*BulkDeleteResponse, error)

func (UnimplementedStateStoreServer) BulkGet 

func (UnimplementedStateStoreServer) BulkGet(context.Context, *BulkGetRequest) (*BulkGetResponse, error)

func (UnimplementedStateStoreServer) BulkSet 

func (UnimplementedStateStoreServer) BulkSet(context.Context, *BulkSetRequest) (*BulkSetResponse, error)

func (UnimplementedStateStoreServer) Delete 

func (UnimplementedStateStoreServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedStateStoreServer) Features 

func (UnimplementedStateStoreServer) Features(context.Context, *FeaturesRequest) (*FeaturesResponse, error)

func (UnimplementedStateStoreServer) Get 

func (UnimplementedStateStoreServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedStateStoreServer) Init 

func (UnimplementedStateStoreServer) Init(context.Context, *InitRequest) (*InitResponse, error)

func (UnimplementedStateStoreServer) Ping 

func (UnimplementedStateStoreServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

func (UnimplementedStateStoreServer) Set 

func (UnimplementedStateStoreServer) Set(context.Context, *SetRequest) (*SetResponse, error)

type UnimplementedTransactionalStateStoreServer 

type UnimplementedTransactionalStateStoreServer struct {
}

UnimplementedTransactionalStateStoreServer should be embedded to have forward compatible implementations.

func (UnimplementedTransactionalStateStoreServer) Transact 

func (UnimplementedTransactionalStateStoreServer) Transact(context.Context, *TransactionalStateRequest) (*TransactionalStateResponse, error)

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 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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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