Documentation
¶
Index ¶
- Variables
- func RegisterStateServiceServer(s grpc.ServiceRegistrar, srv StateServiceServer)
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRequest) GetKey() string
- func (x *DeleteRequest) GetLastRevision() uint64
- func (x *DeleteRequest) GetStore() string
- func (m *DeleteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *DeleteRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *DeleteRequest) MarshalVT() (dAtA []byte, err error)
- func (*DeleteRequest) ProtoMessage()
- func (x *DeleteRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRequest) Reset()
- func (m *DeleteRequest) SizeVT() (n int)
- func (x *DeleteRequest) String() string
- func (m *DeleteRequest) UnmarshalVT(dAtA []byte) error
- type DeleteResponse
- func (*DeleteResponse) Descriptor() ([]byte, []int)deprecated
- func (m *DeleteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *DeleteResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *DeleteResponse) MarshalVT() (dAtA []byte, err error)
- func (*DeleteResponse) ProtoMessage()
- func (x *DeleteResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteResponse) Reset()
- func (m *DeleteResponse) SizeVT() (n int)
- func (x *DeleteResponse) String() string
- func (m *DeleteResponse) UnmarshalVT(dAtA []byte) error
- type EnsureStoreRequest
- func (*EnsureStoreRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EnsureStoreRequest) GetStore() string
- func (m *EnsureStoreRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *EnsureStoreRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *EnsureStoreRequest) MarshalVT() (dAtA []byte, err error)
- func (*EnsureStoreRequest) ProtoMessage()
- func (x *EnsureStoreRequest) ProtoReflect() protoreflect.Message
- func (x *EnsureStoreRequest) Reset()
- func (m *EnsureStoreRequest) SizeVT() (n int)
- func (x *EnsureStoreRequest) String() string
- func (m *EnsureStoreRequest) UnmarshalVT(dAtA []byte) error
- type EnsureStoreResponse
- func (*EnsureStoreResponse) Descriptor() ([]byte, []int)deprecated
- func (m *EnsureStoreResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *EnsureStoreResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *EnsureStoreResponse) MarshalVT() (dAtA []byte, err error)
- func (*EnsureStoreResponse) ProtoMessage()
- func (x *EnsureStoreResponse) ProtoReflect() protoreflect.Message
- func (x *EnsureStoreResponse) Reset()
- func (m *EnsureStoreResponse) SizeVT() (n int)
- func (x *EnsureStoreResponse) String() string
- func (m *EnsureStoreResponse) UnmarshalVT(dAtA []byte) error
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRequest) GetKey() string
- func (x *GetRequest) GetStore() string
- func (m *GetRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetRequest) MarshalVT() (dAtA []byte, err error)
- func (*GetRequest) ProtoMessage()
- func (x *GetRequest) ProtoReflect() protoreflect.Message
- func (x *GetRequest) Reset()
- func (m *GetRequest) SizeVT() (n int)
- func (x *GetRequest) String() string
- func (m *GetRequest) UnmarshalVT(dAtA []byte) error
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetResponse) GetLastUpdated() *timestamppb.Timestamp
- func (x *GetResponse) GetRevision() uint64
- func (x *GetResponse) GetValue() *anypb.Any
- func (m *GetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetResponse) MarshalVT() (dAtA []byte, err error)
- func (*GetResponse) ProtoMessage()
- func (x *GetResponse) ProtoReflect() protoreflect.Message
- func (x *GetResponse) Reset()
- func (m *GetResponse) SizeVT() (n int)
- func (x *GetResponse) String() string
- func (m *GetResponse) UnmarshalVT(dAtA []byte) error
- type SetRequest
- func (*SetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetRequest) GetCreateOnly() bool
- func (x *SetRequest) GetKey() string
- func (x *SetRequest) GetLastRevision() uint64
- func (x *SetRequest) GetStore() string
- func (x *SetRequest) GetValue() *anypb.Any
- func (m *SetRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SetRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *SetRequest) MarshalVT() (dAtA []byte, err error)
- func (*SetRequest) ProtoMessage()
- func (x *SetRequest) ProtoReflect() protoreflect.Message
- func (x *SetRequest) Reset()
- func (m *SetRequest) SizeVT() (n int)
- func (x *SetRequest) String() string
- func (m *SetRequest) UnmarshalVT(dAtA []byte) error
- type SetResponse
- func (*SetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SetResponse) GetRevision() uint64
- func (m *SetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *SetResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *SetResponse) MarshalVT() (dAtA []byte, err error)
- func (*SetResponse) ProtoMessage()
- func (x *SetResponse) ProtoReflect() protoreflect.Message
- func (x *SetResponse) Reset()
- func (m *SetResponse) SizeVT() (n int)
- func (x *SetResponse) String() string
- func (m *SetResponse) UnmarshalVT(dAtA []byte) error
- type StateServiceClient
- type StateServiceServer
- type UnimplementedStateServiceServer
- func (UnimplementedStateServiceServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
- func (UnimplementedStateServiceServer) EnsureStore(context.Context, *EnsureStoreRequest) (*EnsureStoreResponse, error)
- func (UnimplementedStateServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error)
- func (UnimplementedStateServiceServer) Set(context.Context, *SetRequest) (*SetResponse, error)
- type UnsafeStateServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflow = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") )
var File_windshift_state_v1alpha1_service_proto protoreflect.FileDescriptor
var StateService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "windshift.state.v1alpha1.StateService", HandlerType: (*StateServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "EnsureStore", Handler: _StateService_EnsureStore_Handler, }, { MethodName: "Get", Handler: _StateService_Get_Handler, }, { MethodName: "Set", Handler: _StateService_Set_Handler, }, { MethodName: "Delete", Handler: _StateService_Delete_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "windshift/state/v1alpha1/service.proto", }
StateService_ServiceDesc is the grpc.ServiceDesc for StateService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterStateServiceServer ¶
func RegisterStateServiceServer(s grpc.ServiceRegistrar, srv StateServiceServer)
Types ¶
type DeleteRequest ¶
type DeleteRequest struct {
// Store to delete the key from.
Store string `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
// Key to delete.
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
// If set the operation will only succeed if the current revision of the
// key matches the given revision.
LastRevision *uint64 `protobuf:"varint,3,opt,name=last_revision,json=lastRevision,proto3,oneof" json:"last_revision,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteRequest) Descriptor
deprecated
func (*DeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) GetKey ¶
func (x *DeleteRequest) GetKey() string
func (*DeleteRequest) GetLastRevision ¶
func (x *DeleteRequest) GetLastRevision() uint64
func (*DeleteRequest) GetStore ¶
func (x *DeleteRequest) GetStore() string
func (*DeleteRequest) MarshalToSizedBufferVT ¶
func (m *DeleteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*DeleteRequest) MarshalToVT ¶
func (m *DeleteRequest) MarshalToVT(dAtA []byte) (int, error)
func (*DeleteRequest) MarshalVT ¶
func (m *DeleteRequest) MarshalVT() (dAtA []byte, err error)
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) ProtoReflect ¶
func (x *DeleteRequest) ProtoReflect() protoreflect.Message
func (*DeleteRequest) Reset ¶
func (x *DeleteRequest) Reset()
func (*DeleteRequest) SizeVT ¶
func (m *DeleteRequest) SizeVT() (n int)
func (*DeleteRequest) String ¶
func (x *DeleteRequest) String() string
func (*DeleteRequest) UnmarshalVT ¶
func (m *DeleteRequest) UnmarshalVT(dAtA []byte) error
type DeleteResponse ¶
type DeleteResponse struct {
// contains filtered or unexported fields
}
func (*DeleteResponse) Descriptor
deprecated
func (*DeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.
func (*DeleteResponse) MarshalToSizedBufferVT ¶
func (m *DeleteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*DeleteResponse) MarshalToVT ¶
func (m *DeleteResponse) MarshalToVT(dAtA []byte) (int, error)
func (*DeleteResponse) MarshalVT ¶
func (m *DeleteResponse) MarshalVT() (dAtA []byte, err error)
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) ProtoReflect ¶
func (x *DeleteResponse) ProtoReflect() protoreflect.Message
func (*DeleteResponse) Reset ¶
func (x *DeleteResponse) Reset()
func (*DeleteResponse) SizeVT ¶
func (m *DeleteResponse) SizeVT() (n int)
func (*DeleteResponse) String ¶
func (x *DeleteResponse) String() string
func (*DeleteResponse) UnmarshalVT ¶
func (m *DeleteResponse) UnmarshalVT(dAtA []byte) error
type EnsureStoreRequest ¶
type EnsureStoreRequest struct {
// The name of the store to create or update. Store names are case-sensitive
// and should only contain the following characters:
//
// - `a` to `z`, `A` to `Z` and `0` to `9` are allowed.
// - `_` and `-` are allowed for separating words.
Store string `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
// contains filtered or unexported fields
}
EnsureStoreRequest creates or updates a state store.
func (*EnsureStoreRequest) Descriptor
deprecated
func (*EnsureStoreRequest) Descriptor() ([]byte, []int)
Deprecated: Use EnsureStoreRequest.ProtoReflect.Descriptor instead.
func (*EnsureStoreRequest) GetStore ¶
func (x *EnsureStoreRequest) GetStore() string
func (*EnsureStoreRequest) MarshalToSizedBufferVT ¶
func (m *EnsureStoreRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*EnsureStoreRequest) MarshalToVT ¶
func (m *EnsureStoreRequest) MarshalToVT(dAtA []byte) (int, error)
func (*EnsureStoreRequest) MarshalVT ¶
func (m *EnsureStoreRequest) MarshalVT() (dAtA []byte, err error)
func (*EnsureStoreRequest) ProtoMessage ¶
func (*EnsureStoreRequest) ProtoMessage()
func (*EnsureStoreRequest) ProtoReflect ¶
func (x *EnsureStoreRequest) ProtoReflect() protoreflect.Message
func (*EnsureStoreRequest) Reset ¶
func (x *EnsureStoreRequest) Reset()
func (*EnsureStoreRequest) SizeVT ¶
func (m *EnsureStoreRequest) SizeVT() (n int)
func (*EnsureStoreRequest) String ¶
func (x *EnsureStoreRequest) String() string
func (*EnsureStoreRequest) UnmarshalVT ¶
func (m *EnsureStoreRequest) UnmarshalVT(dAtA []byte) error
type EnsureStoreResponse ¶
type EnsureStoreResponse struct {
// contains filtered or unexported fields
}
func (*EnsureStoreResponse) Descriptor
deprecated
func (*EnsureStoreResponse) Descriptor() ([]byte, []int)
Deprecated: Use EnsureStoreResponse.ProtoReflect.Descriptor instead.
func (*EnsureStoreResponse) MarshalToSizedBufferVT ¶
func (m *EnsureStoreResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*EnsureStoreResponse) MarshalToVT ¶
func (m *EnsureStoreResponse) MarshalToVT(dAtA []byte) (int, error)
func (*EnsureStoreResponse) MarshalVT ¶
func (m *EnsureStoreResponse) MarshalVT() (dAtA []byte, err error)
func (*EnsureStoreResponse) ProtoMessage ¶
func (*EnsureStoreResponse) ProtoMessage()
func (*EnsureStoreResponse) ProtoReflect ¶
func (x *EnsureStoreResponse) ProtoReflect() protoreflect.Message
func (*EnsureStoreResponse) Reset ¶
func (x *EnsureStoreResponse) Reset()
func (*EnsureStoreResponse) SizeVT ¶
func (m *EnsureStoreResponse) SizeVT() (n int)
func (*EnsureStoreResponse) String ¶
func (x *EnsureStoreResponse) String() string
func (*EnsureStoreResponse) UnmarshalVT ¶
func (m *EnsureStoreResponse) UnmarshalVT(dAtA []byte) error
type GetRequest ¶
type GetRequest struct {
// Store to retrieve the value from.
Store string `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
// Key to retrieve the value for.
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
GetRequest is the message sent to retrieve a value from a store.
func (*GetRequest) Descriptor
deprecated
func (*GetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.
func (*GetRequest) GetKey ¶
func (x *GetRequest) GetKey() string
func (*GetRequest) GetStore ¶
func (x *GetRequest) GetStore() string
func (*GetRequest) MarshalToSizedBufferVT ¶
func (m *GetRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*GetRequest) MarshalToVT ¶
func (m *GetRequest) MarshalToVT(dAtA []byte) (int, error)
func (*GetRequest) MarshalVT ¶
func (m *GetRequest) MarshalVT() (dAtA []byte, err error)
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) ProtoReflect ¶
func (x *GetRequest) ProtoReflect() protoreflect.Message
func (*GetRequest) Reset ¶
func (x *GetRequest) Reset()
func (*GetRequest) SizeVT ¶
func (m *GetRequest) SizeVT() (n int)
func (*GetRequest) String ¶
func (x *GetRequest) String() string
func (*GetRequest) UnmarshalVT ¶
func (m *GetRequest) UnmarshalVT(dAtA []byte) error
type GetResponse ¶
type GetResponse struct {
// *
// Timestamp of the last update to the key.
LastUpdated *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=last_updated,json=lastUpdated,proto3,oneof" json:"last_updated,omitempty"`
// *
// The revision of the key.
Revision uint64 `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"`
// *
// The value of the key.
Value *anypb.Any `protobuf:"bytes,3,opt,name=value,proto3,oneof" json:"value,omitempty"`
// contains filtered or unexported fields
}
GetResponse is the message returned when retrieving a value from a store.
func (*GetResponse) Descriptor
deprecated
func (*GetResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.
func (*GetResponse) GetLastUpdated ¶
func (x *GetResponse) GetLastUpdated() *timestamppb.Timestamp
func (*GetResponse) GetRevision ¶
func (x *GetResponse) GetRevision() uint64
func (*GetResponse) GetValue ¶
func (x *GetResponse) GetValue() *anypb.Any
func (*GetResponse) MarshalToSizedBufferVT ¶
func (m *GetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*GetResponse) MarshalToVT ¶
func (m *GetResponse) MarshalToVT(dAtA []byte) (int, error)
func (*GetResponse) MarshalVT ¶
func (m *GetResponse) MarshalVT() (dAtA []byte, err error)
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) ProtoReflect ¶
func (x *GetResponse) ProtoReflect() protoreflect.Message
func (*GetResponse) Reset ¶
func (x *GetResponse) Reset()
func (*GetResponse) SizeVT ¶
func (m *GetResponse) SizeVT() (n int)
func (*GetResponse) String ¶
func (x *GetResponse) String() string
func (*GetResponse) UnmarshalVT ¶
func (m *GetResponse) UnmarshalVT(dAtA []byte) error
type SetRequest ¶
type SetRequest struct {
// Store to set the value in.
Store string `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
// Key to set the value for. Keys are case-sensitive and should only contain
// the following characters:
//
// - `a` to `z`, `A` to `Z` and `0` to `9` are allowed.
// - `_` and `-` are allowed for separating words, but the use of camelCase
// is recommended.
// - `.` is allowed and used a hierarchy separator.
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
// Value to set.
Value *anypb.Any `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
// If set the operation will only succeed if the key does not already
// exist in the store.
CreateOnly *bool `protobuf:"varint,4,opt,name=create_only,json=createOnly,proto3,oneof" json:"create_only,omitempty"`
// If set the operation will only succeed if the current revision of the
// key matches the given revision.
LastRevision *uint64 `protobuf:"varint,5,opt,name=last_revision,json=lastRevision,proto3,oneof" json:"last_revision,omitempty"`
// contains filtered or unexported fields
}
func (*SetRequest) Descriptor
deprecated
func (*SetRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetRequest.ProtoReflect.Descriptor instead.
func (*SetRequest) GetCreateOnly ¶
func (x *SetRequest) GetCreateOnly() bool
func (*SetRequest) GetKey ¶
func (x *SetRequest) GetKey() string
func (*SetRequest) GetLastRevision ¶
func (x *SetRequest) GetLastRevision() uint64
func (*SetRequest) GetStore ¶
func (x *SetRequest) GetStore() string
func (*SetRequest) GetValue ¶
func (x *SetRequest) GetValue() *anypb.Any
func (*SetRequest) MarshalToSizedBufferVT ¶
func (m *SetRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*SetRequest) MarshalToVT ¶
func (m *SetRequest) MarshalToVT(dAtA []byte) (int, error)
func (*SetRequest) MarshalVT ¶
func (m *SetRequest) MarshalVT() (dAtA []byte, err error)
func (*SetRequest) ProtoMessage ¶
func (*SetRequest) ProtoMessage()
func (*SetRequest) ProtoReflect ¶
func (x *SetRequest) ProtoReflect() protoreflect.Message
func (*SetRequest) Reset ¶
func (x *SetRequest) Reset()
func (*SetRequest) SizeVT ¶
func (m *SetRequest) SizeVT() (n int)
func (*SetRequest) String ¶
func (x *SetRequest) String() string
func (*SetRequest) UnmarshalVT ¶
func (m *SetRequest) UnmarshalVT(dAtA []byte) error
type SetResponse ¶
type SetResponse struct {
// The revision of the key.
Revision uint64 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
// contains filtered or unexported fields
}
func (*SetResponse) Descriptor
deprecated
func (*SetResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetResponse.ProtoReflect.Descriptor instead.
func (*SetResponse) GetRevision ¶
func (x *SetResponse) GetRevision() uint64
func (*SetResponse) MarshalToSizedBufferVT ¶
func (m *SetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*SetResponse) MarshalToVT ¶
func (m *SetResponse) MarshalToVT(dAtA []byte) (int, error)
func (*SetResponse) MarshalVT ¶
func (m *SetResponse) MarshalVT() (dAtA []byte, err error)
func (*SetResponse) ProtoMessage ¶
func (*SetResponse) ProtoMessage()
func (*SetResponse) ProtoReflect ¶
func (x *SetResponse) ProtoReflect() protoreflect.Message
func (*SetResponse) Reset ¶
func (x *SetResponse) Reset()
func (*SetResponse) SizeVT ¶
func (m *SetResponse) SizeVT() (n int)
func (*SetResponse) String ¶
func (x *SetResponse) String() string
func (*SetResponse) UnmarshalVT ¶
func (m *SetResponse) UnmarshalVT(dAtA []byte) error
type StateServiceClient ¶
type StateServiceClient interface {
// EnsureStore ensures that a store exists. If the store does not exist, it
// will be created.
//
// Stores are used to collect related data. For example, a store could be
// used to store the state of a single application.
EnsureStore(ctx context.Context, in *EnsureStoreRequest, opts ...grpc.CallOption) (*EnsureStoreResponse, error)
// Get retrieves the value of a key in a store.
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
// Set sets the value of a key in a store.
Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
// Delete deletes a key from a store.
Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
}
StateServiceClient is the client API for StateService 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 NewStateServiceClient ¶
func NewStateServiceClient(cc grpc.ClientConnInterface) StateServiceClient
type StateServiceServer ¶
type StateServiceServer interface {
// EnsureStore ensures that a store exists. If the store does not exist, it
// will be created.
//
// Stores are used to collect related data. For example, a store could be
// used to store the state of a single application.
EnsureStore(context.Context, *EnsureStoreRequest) (*EnsureStoreResponse, error)
// Get retrieves the value of a key in a store.
Get(context.Context, *GetRequest) (*GetResponse, error)
// Set sets the value of a key in a store.
Set(context.Context, *SetRequest) (*SetResponse, error)
// Delete deletes a key from a store.
Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
// contains filtered or unexported methods
}
StateServiceServer is the server API for StateService service. All implementations must embed UnimplementedStateServiceServer for forward compatibility
type UnimplementedStateServiceServer ¶
type UnimplementedStateServiceServer struct {
}
UnimplementedStateServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedStateServiceServer) Delete ¶
func (UnimplementedStateServiceServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
func (UnimplementedStateServiceServer) EnsureStore ¶
func (UnimplementedStateServiceServer) EnsureStore(context.Context, *EnsureStoreRequest) (*EnsureStoreResponse, error)
func (UnimplementedStateServiceServer) Get ¶
func (UnimplementedStateServiceServer) Get(context.Context, *GetRequest) (*GetResponse, error)
func (UnimplementedStateServiceServer) Set ¶
func (UnimplementedStateServiceServer) Set(context.Context, *SetRequest) (*SetResponse, error)
type UnsafeStateServiceServer ¶
type UnsafeStateServiceServer interface {
// contains filtered or unexported methods
}
UnsafeStateServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StateServiceServer will result in compilation errors.