proto

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

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
}

type BatchRequest_OpCode int32

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

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

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

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

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

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

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
}

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

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

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

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

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

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

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

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
}

type FeaturesResponse_Feature int32

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

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

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

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

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

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

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

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

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
}

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

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
}

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

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
}

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

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
}

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
}

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
}

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

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

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
}

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

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

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

type UnimplementedDatastoreServer struct {
}

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