proto

package
v0.0.0-...-1ddc73e Latest Latest
Warning

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

 Go to latest Published: Apr 6, 2023 License: MIT Imports: 11 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	FeaturesResponse_Feature_name = map[int32]string{
		0: "DATASTORE",
		1: "BATCHING",
		2: "CHECKED",
		3: "SCRUBBED",
		4: "GC",
		5: "PERSISTENT",
		6: "TTL",
		7: "TRANSACTION",
	}
	FeaturesResponse_Feature_value = map[string]int32{
		"DATASTORE":   0,
		"BATCHING":    1,
		"CHECKED":     2,
		"SCRUBBED":    3,
		"GC":          4,
		"PERSISTENT":  5,
		"TTL":         6,
		"TRANSACTION": 7,
	}
)

Enum value maps for FeaturesResponse_Feature.

View Source 
var (
	BatchRequest_OpCode_name = map[int32]string{
		0: "PUT",
		1: "DELETE",
	}
	BatchRequest_OpCode_value = map[string]int32{
		"PUT":    0,
		"DELETE": 1,
	}
)

Enum value maps for BatchRequest_OpCode.

View Source 
var Datastore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Datastore",
	HandlerType: (*DatastoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Features",
			Handler:    _Datastore_Features_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _Datastore_Get_Handler,
		},
		{
			MethodName: "Has",
			Handler:    _Datastore_Has_Handler,
		},
		{
			MethodName: "GetSize",
			Handler:    _Datastore_GetSize_Handler,
		},
		{
			MethodName: "Put",
			Handler:    _Datastore_Put_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Datastore_Delete_Handler,
		},
		{
			MethodName: "Sync",
			Handler:    _Datastore_Sync_Handler,
		},
		{
			MethodName: "Batch",
			Handler:    _Datastore_Batch_Handler,
		},
		{
			MethodName: "Check",
			Handler:    _Datastore_Check_Handler,
		},
		{
			MethodName: "Scrub",
			Handler:    _Datastore_Scrub_Handler,
		},
		{
			MethodName: "CollectGarbage",
			Handler:    _Datastore_CollectGarbage_Handler,
		},
		{
			MethodName: "DiskUsage",
			Handler:    _Datastore_DiskUsage_Handler,
		},
		{
			MethodName: "PutWithTTL",
			Handler:    _Datastore_PutWithTTL_Handler,
		},
		{
			MethodName: "SetTTL",
			Handler:    _Datastore_SetTTL_Handler,
		},
		{
			MethodName: "GetExpiration",
			Handler:    _Datastore_GetExpiration_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Query",
			Handler:       _Datastore_Query_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "ds.proto",
}

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

View Source 
var File_ds_proto protoreflect.FileDescriptor

Functions

func RegisterDatastoreServer 

func RegisterDatastoreServer(s grpc.ServiceRegistrar, srv DatastoreServer)

Types

type BatchRequest 

type BatchRequest struct {
	Ops []*BatchRequest_Op `protobuf:"bytes,1,rep,name=ops,proto3" json:"ops,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchRequest) Descriptor deprecated 

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

Deprecated: Use BatchRequest.ProtoReflect.Descriptor instead.

func (*BatchRequest) GetOps 

func (x *BatchRequest) GetOps() []*BatchRequest_Op

func (*BatchRequest) ProtoMessage 

func (*BatchRequest) ProtoMessage()

func (*BatchRequest) ProtoReflect 

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

func (*BatchRequest) Reset 

func (x *BatchRequest) Reset()

func (*BatchRequest) String 

func (x *BatchRequest) String() string

type BatchRequest_Op 

type BatchRequest_Op struct {
	OpCode BatchRequest_OpCode `protobuf:"varint,1,opt,name=opCode,proto3,enum=BatchRequest_OpCode" json:"opCode,omitempty"`
	Key    string              `protobuf:"bytes,2,opt,name=Key,proto3" json:"Key,omitempty"`
	Value  []byte              `protobuf:"bytes,3,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchRequest_Op) Descriptor deprecated 

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

Deprecated: Use BatchRequest_Op.ProtoReflect.Descriptor instead.

func (*BatchRequest_Op) GetKey 

func (x *BatchRequest_Op) GetKey() string

func (*BatchRequest_Op) GetOpCode 

func (x *BatchRequest_Op) GetOpCode() BatchRequest_OpCode

func (*BatchRequest_Op) GetValue 

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

func (*BatchRequest_Op) ProtoMessage 

func (*BatchRequest_Op) ProtoMessage()

func (*BatchRequest_Op) ProtoReflect 

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

func (*BatchRequest_Op) Reset 

func (x *BatchRequest_Op) Reset()

func (*BatchRequest_Op) String 

func (x *BatchRequest_Op) String() string

type BatchRequest_OpCode 

type BatchRequest_OpCode int32
const (
	BatchRequest_PUT    BatchRequest_OpCode = 0
	BatchRequest_DELETE BatchRequest_OpCode = 1
)

func (BatchRequest_OpCode) Descriptor 

func (BatchRequest_OpCode) Descriptor() protoreflect.EnumDescriptor

func (BatchRequest_OpCode) Enum 

func (x BatchRequest_OpCode) Enum() *BatchRequest_OpCode

func (BatchRequest_OpCode) EnumDescriptor deprecated 

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

Deprecated: Use BatchRequest_OpCode.Descriptor instead.

func (BatchRequest_OpCode) Number 

func (x BatchRequest_OpCode) Number() protoreflect.EnumNumber

func (BatchRequest_OpCode) String 

func (x BatchRequest_OpCode) String() string

func (BatchRequest_OpCode) Type 

func (BatchRequest_OpCode) Type() protoreflect.EnumType

type BatchResponse 

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

func (*BatchResponse) Descriptor deprecated 

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

Deprecated: Use BatchResponse.ProtoReflect.Descriptor instead.

func (*BatchResponse) ProtoMessage 

func (*BatchResponse) ProtoMessage()

func (*BatchResponse) ProtoReflect 

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

func (*BatchResponse) Reset 

func (x *BatchResponse) Reset()

func (*BatchResponse) String 

func (x *BatchResponse) String() string

type CheckRequest 

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

func (*CheckRequest) Descriptor deprecated 

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

Deprecated: Use CheckRequest.ProtoReflect.Descriptor instead.

func (*CheckRequest) ProtoMessage 

func (*CheckRequest) ProtoMessage()

func (*CheckRequest) ProtoReflect 

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

func (*CheckRequest) Reset 

func (x *CheckRequest) Reset()

func (*CheckRequest) String 

func (x *CheckRequest) String() string

type CheckResponse 

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

func (*CheckResponse) Descriptor deprecated 

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

Deprecated: Use CheckResponse.ProtoReflect.Descriptor instead.

func (*CheckResponse) ProtoMessage 

func (*CheckResponse) ProtoMessage()

func (*CheckResponse) ProtoReflect 

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

func (*CheckResponse) Reset 

func (x *CheckResponse) Reset()

func (*CheckResponse) String 

func (x *CheckResponse) String() string

type CollectGarbageRequest 

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

func (*CollectGarbageRequest) Descriptor deprecated 

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

Deprecated: Use CollectGarbageRequest.ProtoReflect.Descriptor instead.

func (*CollectGarbageRequest) ProtoMessage 

func (*CollectGarbageRequest) ProtoMessage()

func (*CollectGarbageRequest) ProtoReflect 

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

func (*CollectGarbageRequest) Reset 

func (x *CollectGarbageRequest) Reset()

func (*CollectGarbageRequest) String 

func (x *CollectGarbageRequest) String() string

type CollectGarbageResponse 

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

func (*CollectGarbageResponse) Descriptor deprecated 

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

Deprecated: Use CollectGarbageResponse.ProtoReflect.Descriptor instead.

func (*CollectGarbageResponse) ProtoMessage 

func (*CollectGarbageResponse) ProtoMessage()

func (*CollectGarbageResponse) ProtoReflect 

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

func (*CollectGarbageResponse) Reset 

func (x *CollectGarbageResponse) Reset()

func (*CollectGarbageResponse) String 

func (x *CollectGarbageResponse) String() string

type DatastoreClient 

type DatastoreClient interface {
	Features(ctx context.Context, in *FeaturesRequest, opts ...grpc.CallOption) (*FeaturesResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Has(ctx context.Context, in *HasRequest, opts ...grpc.CallOption) (*HasResponse, error)
	GetSize(ctx context.Context, in *GetSizeRequest, opts ...grpc.CallOption) (*GetSizeResponse, error)
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncResponse, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (Datastore_QueryClient, error)
	Batch(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)
	Check(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error)
	Scrub(ctx context.Context, in *ScrubRequest, opts ...grpc.CallOption) (*ScrubResponse, error)
	CollectGarbage(ctx context.Context, in *CollectGarbageRequest, opts ...grpc.CallOption) (*CollectGarbageResponse, error)
	DiskUsage(ctx context.Context, in *DiskUsageRequest, opts ...grpc.CallOption) (*DiskUsageResponse, error)
	PutWithTTL(ctx context.Context, in *PutWithTTLRequest, opts ...grpc.CallOption) (*PutWithTTLResponse, error)
	SetTTL(ctx context.Context, in *SetTTLRequest, opts ...grpc.CallOption) (*SetTTLResponse, error)
	GetExpiration(ctx context.Context, in *GetExpirationRequest, opts ...grpc.CallOption) (*GetExpirationResponse, error)
}

DatastoreClient is the client API for Datastore 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 NewDatastoreClient 

func NewDatastoreClient(cc grpc.ClientConnInterface) DatastoreClient

type DatastoreServer 

type DatastoreServer interface {
	Features(context.Context, *FeaturesRequest) (*FeaturesResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Has(context.Context, *HasRequest) (*HasResponse, error)
	GetSize(context.Context, *GetSizeRequest) (*GetSizeResponse, error)
	Put(context.Context, *PutRequest) (*PutResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Sync(context.Context, *SyncRequest) (*SyncResponse, error)
	Query(*QueryRequest, Datastore_QueryServer) error
	Batch(context.Context, *BatchRequest) (*BatchResponse, error)
	Check(context.Context, *CheckRequest) (*CheckResponse, error)
	Scrub(context.Context, *ScrubRequest) (*ScrubResponse, error)
	CollectGarbage(context.Context, *CollectGarbageRequest) (*CollectGarbageResponse, error)
	DiskUsage(context.Context, *DiskUsageRequest) (*DiskUsageResponse, error)
	PutWithTTL(context.Context, *PutWithTTLRequest) (*PutWithTTLResponse, error)
	SetTTL(context.Context, *SetTTLRequest) (*SetTTLResponse, error)
	GetExpiration(context.Context, *GetExpirationRequest) (*GetExpirationResponse, error)
	// contains filtered or unexported methods
}

DatastoreServer is the server API for Datastore service. All implementations must embed UnimplementedDatastoreServer for forward compatibility

type Datastore_QueryClient 

type Datastore_QueryClient interface {
	Recv() (*QueryResult, error)
	grpc.ClientStream
}

type Datastore_QueryServer 

type Datastore_QueryServer interface {
	Send(*QueryResult) error
	grpc.ServerStream
}

type DeleteRequest 

type DeleteRequest struct {
	Key string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,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) 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
}

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 DiskUsageRequest 

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

func (*DiskUsageRequest) Descriptor deprecated 

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

Deprecated: Use DiskUsageRequest.ProtoReflect.Descriptor instead.

func (*DiskUsageRequest) ProtoMessage 

func (*DiskUsageRequest) ProtoMessage()

func (*DiskUsageRequest) ProtoReflect 

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

func (*DiskUsageRequest) Reset 

func (x *DiskUsageRequest) Reset()

func (*DiskUsageRequest) String 

func (x *DiskUsageRequest) String() string

type DiskUsageResponse 

type DiskUsageResponse struct {
	Size uint64 `protobuf:"varint,1,opt,name=Size,proto3" json:"Size,omitempty"`
	// contains filtered or unexported fields
}

func (*DiskUsageResponse) Descriptor deprecated 

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

Deprecated: Use DiskUsageResponse.ProtoReflect.Descriptor instead.

func (*DiskUsageResponse) GetSize 

func (x *DiskUsageResponse) GetSize() uint64

func (*DiskUsageResponse) ProtoMessage 

func (*DiskUsageResponse) ProtoMessage()

func (*DiskUsageResponse) ProtoReflect 

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

func (*DiskUsageResponse) Reset 

func (x *DiskUsageResponse) Reset()

func (*DiskUsageResponse) String 

func (x *DiskUsageResponse) String() string

type FeaturesRequest 

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

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 []FeaturesResponse_Feature `protobuf:"varint,1,rep,packed,name=features,proto3,enum=FeaturesResponse_Feature" 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() []FeaturesResponse_Feature

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 FeaturesResponse_Feature 

type FeaturesResponse_Feature int32
const (
	FeaturesResponse_DATASTORE   FeaturesResponse_Feature = 0
	FeaturesResponse_BATCHING    FeaturesResponse_Feature = 1
	FeaturesResponse_CHECKED     FeaturesResponse_Feature = 2
	FeaturesResponse_SCRUBBED    FeaturesResponse_Feature = 3
	FeaturesResponse_GC          FeaturesResponse_Feature = 4
	FeaturesResponse_PERSISTENT  FeaturesResponse_Feature = 5
	FeaturesResponse_TTL         FeaturesResponse_Feature = 6
	FeaturesResponse_TRANSACTION FeaturesResponse_Feature = 7
)

func (FeaturesResponse_Feature) Descriptor 

func (FeaturesResponse_Feature) Descriptor() protoreflect.EnumDescriptor

func (FeaturesResponse_Feature) Enum 

func (x FeaturesResponse_Feature) Enum() *FeaturesResponse_Feature

func (FeaturesResponse_Feature) EnumDescriptor deprecated 

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

Deprecated: Use FeaturesResponse_Feature.Descriptor instead.

func (FeaturesResponse_Feature) Number 

func (x FeaturesResponse_Feature) Number() protoreflect.EnumNumber

func (FeaturesResponse_Feature) String 

func (x FeaturesResponse_Feature) String() string

func (FeaturesResponse_Feature) Type 

func (FeaturesResponse_Feature) Type() protoreflect.EnumType

type GetExpirationRequest 

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

func (*GetExpirationRequest) Descriptor deprecated 

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

Deprecated: Use GetExpirationRequest.ProtoReflect.Descriptor instead.

func (*GetExpirationRequest) GetKey 

func (x *GetExpirationRequest) GetKey() string

func (*GetExpirationRequest) ProtoMessage 

func (*GetExpirationRequest) ProtoMessage()

func (*GetExpirationRequest) ProtoReflect 

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

func (*GetExpirationRequest) Reset 

func (x *GetExpirationRequest) Reset()

func (*GetExpirationRequest) String 

func (x *GetExpirationRequest) String() string

type GetExpirationResponse 

type GetExpirationResponse struct {
	Expiration *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=Expiration,proto3" json:"Expiration,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExpirationResponse) Descriptor deprecated 

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

Deprecated: Use GetExpirationResponse.ProtoReflect.Descriptor instead.

func (*GetExpirationResponse) GetExpiration 

func (x *GetExpirationResponse) GetExpiration() *timestamppb.Timestamp

func (*GetExpirationResponse) ProtoMessage 

func (*GetExpirationResponse) ProtoMessage()

func (*GetExpirationResponse) ProtoReflect 

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

func (*GetExpirationResponse) Reset 

func (x *GetExpirationResponse) Reset()

func (*GetExpirationResponse) String 

func (x *GetExpirationResponse) String() string

type GetRequest 

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

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) 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 {
	Value []byte `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetValue 

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

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 GetSizeRequest 

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

func (*GetSizeRequest) Descriptor deprecated 

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

Deprecated: Use GetSizeRequest.ProtoReflect.Descriptor instead.

func (*GetSizeRequest) GetKey 

func (x *GetSizeRequest) GetKey() string

func (*GetSizeRequest) ProtoMessage 

func (*GetSizeRequest) ProtoMessage()

func (*GetSizeRequest) ProtoReflect 

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

func (*GetSizeRequest) Reset 

func (x *GetSizeRequest) Reset()

func (*GetSizeRequest) String 

func (x *GetSizeRequest) String() string

type GetSizeResponse 

type GetSizeResponse struct {
	Size uint64 `protobuf:"varint,1,opt,name=Size,proto3" json:"Size,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSizeResponse) Descriptor deprecated 

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

Deprecated: Use GetSizeResponse.ProtoReflect.Descriptor instead.

func (*GetSizeResponse) GetSize 

func (x *GetSizeResponse) GetSize() uint64

func (*GetSizeResponse) ProtoMessage 

func (*GetSizeResponse) ProtoMessage()

func (*GetSizeResponse) ProtoReflect 

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

func (*GetSizeResponse) Reset 

func (x *GetSizeResponse) Reset()

func (*GetSizeResponse) String 

func (x *GetSizeResponse) String() string

type HasRequest 

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

func (*HasRequest) Descriptor deprecated 

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

Deprecated: Use HasRequest.ProtoReflect.Descriptor instead.

func (*HasRequest) GetKey 

func (x *HasRequest) GetKey() string

func (*HasRequest) ProtoMessage 

func (*HasRequest) ProtoMessage()

func (*HasRequest) ProtoReflect 

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

func (*HasRequest) Reset 

func (x *HasRequest) Reset()

func (*HasRequest) String 

func (x *HasRequest) String() string

type HasResponse 

type HasResponse struct {
	Has bool `protobuf:"varint,1,opt,name=Has,proto3" json:"Has,omitempty"`
	// contains filtered or unexported fields
}

func (*HasResponse) Descriptor deprecated 

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

Deprecated: Use HasResponse.ProtoReflect.Descriptor instead.

func (*HasResponse) GetHas 

func (x *HasResponse) GetHas() bool

func (*HasResponse) ProtoMessage 

func (*HasResponse) ProtoMessage()

func (*HasResponse) ProtoReflect 

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

func (*HasResponse) Reset 

func (x *HasResponse) Reset()

func (*HasResponse) String 

func (x *HasResponse) String() string

type PutRequest 

type PutRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetKey 

func (x *PutRequest) GetKey() string

func (*PutRequest) GetValue 

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

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

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

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) String 

func (x *PutRequest) String() string

type PutResponse 

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

func (*PutResponse) Descriptor deprecated 

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect 

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

func (*PutResponse) Reset 

func (x *PutResponse) Reset()

func (*PutResponse) String 

func (x *PutResponse) String() string

type PutWithTTLRequest 

type PutWithTTLRequest struct {
	Key   string               `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Value []byte               `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	TTL   *durationpb.Duration `protobuf:"bytes,3,opt,name=TTL,proto3" json:"TTL,omitempty"`
	// contains filtered or unexported fields
}

func (*PutWithTTLRequest) Descriptor deprecated 

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

Deprecated: Use PutWithTTLRequest.ProtoReflect.Descriptor instead.

func (*PutWithTTLRequest) GetKey 

func (x *PutWithTTLRequest) GetKey() string

func (*PutWithTTLRequest) GetTTL 

func (x *PutWithTTLRequest) GetTTL() *durationpb.Duration

func (*PutWithTTLRequest) GetValue 

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

func (*PutWithTTLRequest) ProtoMessage 

func (*PutWithTTLRequest) ProtoMessage()

func (*PutWithTTLRequest) ProtoReflect 

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

func (*PutWithTTLRequest) Reset 

func (x *PutWithTTLRequest) Reset()

func (*PutWithTTLRequest) String 

func (x *PutWithTTLRequest) String() string

type PutWithTTLResponse 

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

func (*PutWithTTLResponse) Descriptor deprecated 

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

Deprecated: Use PutWithTTLResponse.ProtoReflect.Descriptor instead.

func (*PutWithTTLResponse) ProtoMessage 

func (*PutWithTTLResponse) ProtoMessage()

func (*PutWithTTLResponse) ProtoReflect 

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

func (*PutWithTTLResponse) Reset 

func (x *PutWithTTLResponse) Reset()

func (*PutWithTTLResponse) String 

func (x *PutWithTTLResponse) String() string

type QueryFilterKeyCompare 

type QueryFilterKeyCompare struct {
	Op  string `protobuf:"bytes,1,opt,name=Op,proto3" json:"Op,omitempty"`
	Key string `protobuf:"bytes,2,opt,name=Key,proto3" json:"Key,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryFilterKeyCompare) Descriptor deprecated 

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

Deprecated: Use QueryFilterKeyCompare.ProtoReflect.Descriptor instead.

func (*QueryFilterKeyCompare) GetKey 

func (x *QueryFilterKeyCompare) GetKey() string

func (*QueryFilterKeyCompare) GetOp 

func (x *QueryFilterKeyCompare) GetOp() string

func (*QueryFilterKeyCompare) ProtoMessage 

func (*QueryFilterKeyCompare) ProtoMessage()

func (*QueryFilterKeyCompare) ProtoReflect 

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

func (*QueryFilterKeyCompare) Reset 

func (x *QueryFilterKeyCompare) Reset()

func (*QueryFilterKeyCompare) String 

func (x *QueryFilterKeyCompare) String() string

type QueryFilterKeyPrefix 

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

func (*QueryFilterKeyPrefix) Descriptor deprecated 

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

Deprecated: Use QueryFilterKeyPrefix.ProtoReflect.Descriptor instead.

func (*QueryFilterKeyPrefix) GetPrefix 

func (x *QueryFilterKeyPrefix) GetPrefix() string

func (*QueryFilterKeyPrefix) ProtoMessage 

func (*QueryFilterKeyPrefix) ProtoMessage()

func (*QueryFilterKeyPrefix) ProtoReflect 

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

func (*QueryFilterKeyPrefix) Reset 

func (x *QueryFilterKeyPrefix) Reset()

func (*QueryFilterKeyPrefix) String 

func (x *QueryFilterKeyPrefix) String() string

type QueryFilterValueCompare 

type QueryFilterValueCompare struct {
	Op    string `protobuf:"bytes,1,opt,name=Op,proto3" json:"Op,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryFilterValueCompare) Descriptor deprecated 

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

Deprecated: Use QueryFilterValueCompare.ProtoReflect.Descriptor instead.

func (*QueryFilterValueCompare) GetOp 

func (x *QueryFilterValueCompare) GetOp() string

func (*QueryFilterValueCompare) GetValue 

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

func (*QueryFilterValueCompare) ProtoMessage 

func (*QueryFilterValueCompare) ProtoMessage()

func (*QueryFilterValueCompare) ProtoReflect 

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

func (*QueryFilterValueCompare) Reset 

func (x *QueryFilterValueCompare) Reset()

func (*QueryFilterValueCompare) String 

func (x *QueryFilterValueCompare) String() string

type QueryRequest 

type QueryRequest struct {
	Prefix            string            `protobuf:"bytes,1,opt,name=Prefix,proto3" json:"Prefix,omitempty"`
	Filters           map[string][]byte `` /* 155-byte string literal not displayed */
	Orders            map[string][]byte `` /* 153-byte string literal not displayed */
	Limit             uint64            `protobuf:"varint,4,opt,name=Limit,proto3" json:"Limit,omitempty"`
	Offset            uint64            `protobuf:"varint,5,opt,name=Offset,proto3" json:"Offset,omitempty"`
	KeysOnly          bool              `protobuf:"varint,6,opt,name=KeysOnly,proto3" json:"KeysOnly,omitempty"`
	ReturnExpirations bool              `protobuf:"varint,7,opt,name=ReturnExpirations,proto3" json:"ReturnExpirations,omitempty"`
	ReturnSizes       bool              `protobuf:"varint,8,opt,name=ReturnSizes,proto3" json:"ReturnSizes,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetFilters 

func (x *QueryRequest) GetFilters() map[string][]byte

func (*QueryRequest) GetKeysOnly 

func (x *QueryRequest) GetKeysOnly() bool

func (*QueryRequest) GetLimit 

func (x *QueryRequest) GetLimit() uint64

func (*QueryRequest) GetOffset 

func (x *QueryRequest) GetOffset() uint64

func (*QueryRequest) GetOrders 

func (x *QueryRequest) GetOrders() map[string][]byte

func (*QueryRequest) GetPrefix 

func (x *QueryRequest) GetPrefix() string

func (*QueryRequest) GetReturnExpirations 

func (x *QueryRequest) GetReturnExpirations() bool

func (*QueryRequest) GetReturnSizes 

func (x *QueryRequest) GetReturnSizes() bool

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 QueryResult 

type QueryResult struct {
	Key        string     `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Value      []byte     `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	Expiration uint64     `protobuf:"varint,3,opt,name=Expiration,proto3" json:"Expiration,omitempty"`
	Size       uint64     `protobuf:"varint,4,opt,name=Size,proto3" json:"Size,omitempty"`
	Error      *anypb.Any `protobuf:"bytes,5,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryResult) Descriptor deprecated 

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

Deprecated: Use QueryResult.ProtoReflect.Descriptor instead.

func (*QueryResult) GetError 

func (x *QueryResult) GetError() *anypb.Any

func (*QueryResult) GetExpiration 

func (x *QueryResult) GetExpiration() uint64

func (*QueryResult) GetKey 

func (x *QueryResult) GetKey() string

func (*QueryResult) GetSize 

func (x *QueryResult) GetSize() uint64

func (*QueryResult) GetValue 

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

func (*QueryResult) ProtoMessage 

func (*QueryResult) ProtoMessage()

func (*QueryResult) ProtoReflect 

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

func (*QueryResult) Reset 

func (x *QueryResult) Reset()

func (*QueryResult) String 

func (x *QueryResult) String() string

type ScrubRequest 

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

func (*ScrubRequest) Descriptor deprecated 

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

Deprecated: Use ScrubRequest.ProtoReflect.Descriptor instead.

func (*ScrubRequest) ProtoMessage 

func (*ScrubRequest) ProtoMessage()

func (*ScrubRequest) ProtoReflect 

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

func (*ScrubRequest) Reset 

func (x *ScrubRequest) Reset()

func (*ScrubRequest) String 

func (x *ScrubRequest) String() string

type ScrubResponse 

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

func (*ScrubResponse) Descriptor deprecated 

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

Deprecated: Use ScrubResponse.ProtoReflect.Descriptor instead.

func (*ScrubResponse) ProtoMessage 

func (*ScrubResponse) ProtoMessage()

func (*ScrubResponse) ProtoReflect 

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

func (*ScrubResponse) Reset 

func (x *ScrubResponse) Reset()

func (*ScrubResponse) String 

func (x *ScrubResponse) String() string

type SetTTLRequest 

type SetTTLRequest struct {
	Key string               `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	TTL *durationpb.Duration `protobuf:"bytes,2,opt,name=TTL,proto3" json:"TTL,omitempty"`
	// contains filtered or unexported fields
}

func (*SetTTLRequest) Descriptor deprecated 

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

Deprecated: Use SetTTLRequest.ProtoReflect.Descriptor instead.

func (*SetTTLRequest) GetKey 

func (x *SetTTLRequest) GetKey() string

func (*SetTTLRequest) GetTTL 

func (x *SetTTLRequest) GetTTL() *durationpb.Duration

func (*SetTTLRequest) ProtoMessage 

func (*SetTTLRequest) ProtoMessage()

func (*SetTTLRequest) ProtoReflect 

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

func (*SetTTLRequest) Reset 

func (x *SetTTLRequest) Reset()

func (*SetTTLRequest) String 

func (x *SetTTLRequest) String() string

type SetTTLResponse 

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

func (*SetTTLResponse) Descriptor deprecated 

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

Deprecated: Use SetTTLResponse.ProtoReflect.Descriptor instead.

func (*SetTTLResponse) ProtoMessage 

func (*SetTTLResponse) ProtoMessage()

func (*SetTTLResponse) ProtoReflect 

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

func (*SetTTLResponse) Reset 

func (x *SetTTLResponse) Reset()

func (*SetTTLResponse) String 

func (x *SetTTLResponse) String() string

type SyncRequest 

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

func (*SyncRequest) Descriptor deprecated 

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

Deprecated: Use SyncRequest.ProtoReflect.Descriptor instead.

func (*SyncRequest) GetPrefix 

func (x *SyncRequest) GetPrefix() string

func (*SyncRequest) ProtoMessage 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) ProtoReflect 

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

func (*SyncRequest) Reset 

func (x *SyncRequest) Reset()

func (*SyncRequest) String 

func (x *SyncRequest) String() string

type SyncResponse 

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

func (*SyncResponse) Descriptor deprecated 

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

Deprecated: Use SyncResponse.ProtoReflect.Descriptor instead.

func (*SyncResponse) ProtoMessage 

func (*SyncResponse) ProtoMessage()

func (*SyncResponse) ProtoReflect 

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

func (*SyncResponse) Reset 

func (x *SyncResponse) Reset()

func (*SyncResponse) String 

func (x *SyncResponse) String() string

type UnimplementedDatastoreServer 

type UnimplementedDatastoreServer struct {
}

UnimplementedDatastoreServer must be embedded to have forward compatible implementations.

func (UnimplementedDatastoreServer) Batch 

func (UnimplementedDatastoreServer) Batch(context.Context, *BatchRequest) (*BatchResponse, error)

func (UnimplementedDatastoreServer) Check 

func (UnimplementedDatastoreServer) Check(context.Context, *CheckRequest) (*CheckResponse, error)

func (UnimplementedDatastoreServer) CollectGarbage 

func (UnimplementedDatastoreServer) CollectGarbage(context.Context, *CollectGarbageRequest) (*CollectGarbageResponse, error)

func (UnimplementedDatastoreServer) Delete 

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

func (UnimplementedDatastoreServer) DiskUsage 

func (UnimplementedDatastoreServer) DiskUsage(context.Context, *DiskUsageRequest) (*DiskUsageResponse, error)

func (UnimplementedDatastoreServer) Features 

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

func (UnimplementedDatastoreServer) Get 

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

func (UnimplementedDatastoreServer) GetExpiration 

func (UnimplementedDatastoreServer) GetExpiration(context.Context, *GetExpirationRequest) (*GetExpirationResponse, error)

func (UnimplementedDatastoreServer) GetSize 

func (UnimplementedDatastoreServer) GetSize(context.Context, *GetSizeRequest) (*GetSizeResponse, error)

func (UnimplementedDatastoreServer) Has 

func (UnimplementedDatastoreServer) Has(context.Context, *HasRequest) (*HasResponse, error)

func (UnimplementedDatastoreServer) Put 

func (UnimplementedDatastoreServer) Put(context.Context, *PutRequest) (*PutResponse, error)

func (UnimplementedDatastoreServer) PutWithTTL 

func (UnimplementedDatastoreServer) PutWithTTL(context.Context, *PutWithTTLRequest) (*PutWithTTLResponse, error)

func (UnimplementedDatastoreServer) Query 

func (UnimplementedDatastoreServer) Query(*QueryRequest, Datastore_QueryServer) error

func (UnimplementedDatastoreServer) Scrub 

func (UnimplementedDatastoreServer) Scrub(context.Context, *ScrubRequest) (*ScrubResponse, error)

func (UnimplementedDatastoreServer) SetTTL 

func (UnimplementedDatastoreServer) SetTTL(context.Context, *SetTTLRequest) (*SetTTLResponse, error)

func (UnimplementedDatastoreServer) Sync 

func (UnimplementedDatastoreServer) Sync(context.Context, *SyncRequest) (*SyncResponse, error)

type UnsafeDatastoreServer 

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

UnsafeDatastoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DatastoreServer 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.