kvdbserver

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Apr 4, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DatabaseService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kvdbserverapi.DatabaseService",
	HandlerType: (*DatabaseServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateDatabase",
			Handler:    _DatabaseService_CreateDatabase_Handler,
		},
		{
			MethodName: "GetAllDatabases",
			Handler:    _DatabaseService_GetAllDatabases_Handler,
		},
		{
			MethodName: "GetDatabaseInfo",
			Handler:    _DatabaseService_GetDatabaseInfo_Handler,
		},
		{
			MethodName: "DeleteDatabase",
			Handler:    _DatabaseService_DeleteDatabase_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/kvdbserver/db.proto",
}

DatabaseService_ServiceDesc is the grpc.ServiceDesc for DatabaseService 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_proto_kvdbserver_db_proto protoreflect.FileDescriptor
View Source 
var File_proto_kvdbserver_server_proto protoreflect.FileDescriptor
View Source 
var File_proto_kvdbserver_storage_proto protoreflect.FileDescriptor
View Source 
var ServerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kvdbserverapi.ServerService",
	HandlerType: (*ServerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetServerInfo",
			Handler:    _ServerService_GetServerInfo_Handler,
		},
		{
			MethodName: "GetLogs",
			Handler:    _ServerService_GetLogs_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/kvdbserver/server.proto",
}

ServerService_ServiceDesc is the grpc.ServiceDesc for ServerService 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 StorageService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "kvdbserverapi.StorageService",
	HandlerType: (*StorageServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetTypeOfKey",
			Handler:    _StorageService_GetTypeOfKey_Handler,
		},
		{
			MethodName: "SetString",
			Handler:    _StorageService_SetString_Handler,
		},
		{
			MethodName: "GetString",
			Handler:    _StorageService_GetString_Handler,
		},
		{
			MethodName: "DeleteKey",
			Handler:    _StorageService_DeleteKey_Handler,
		},
		{
			MethodName: "DeleteAllKeys",
			Handler:    _StorageService_DeleteAllKeys_Handler,
		},
		{
			MethodName: "GetKeys",
			Handler:    _StorageService_GetKeys_Handler,
		},
		{
			MethodName: "SetHashMap",
			Handler:    _StorageService_SetHashMap_Handler,
		},
		{
			MethodName: "GetHashMapFieldValue",
			Handler:    _StorageService_GetHashMapFieldValue_Handler,
		},
		{
			MethodName: "DeleteHashMapFields",
			Handler:    _StorageService_DeleteHashMapFields_Handler,
		},
		{
			MethodName: "GetAllHashMapFieldsAndValues",
			Handler:    _StorageService_GetAllHashMapFieldsAndValues_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/kvdbserver/storage.proto",
}

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

Functions

func RegisterDatabaseServiceServer 

func RegisterDatabaseServiceServer(s grpc.ServiceRegistrar, srv DatabaseServiceServer)

func RegisterServerServiceServer 

func RegisterServerServiceServer(s grpc.ServiceRegistrar, srv ServerServiceServer)

func RegisterStorageServiceServer 

func RegisterStorageServiceServer(s grpc.ServiceRegistrar, srv StorageServiceServer)

Types

type CreateDatabaseRequest 

type CreateDatabaseRequest struct {

	// Name of the database to create.
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDatabaseRequest) Descriptor deprecated 

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

Deprecated: Use CreateDatabaseRequest.ProtoReflect.Descriptor instead.

func (*CreateDatabaseRequest) GetDbName 

func (x *CreateDatabaseRequest) GetDbName() string

func (*CreateDatabaseRequest) ProtoMessage 

func (*CreateDatabaseRequest) ProtoMessage()

func (*CreateDatabaseRequest) ProtoReflect 

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

func (*CreateDatabaseRequest) Reset 

func (x *CreateDatabaseRequest) Reset()

func (*CreateDatabaseRequest) String 

func (x *CreateDatabaseRequest) String() string

type CreateDatabaseResponse 

type CreateDatabaseResponse struct {

	// Name of the created database.
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDatabaseResponse) Descriptor deprecated 

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

Deprecated: Use CreateDatabaseResponse.ProtoReflect.Descriptor instead.

func (*CreateDatabaseResponse) GetDbName 

func (x *CreateDatabaseResponse) GetDbName() string

func (*CreateDatabaseResponse) ProtoMessage 

func (*CreateDatabaseResponse) ProtoMessage()

func (*CreateDatabaseResponse) ProtoReflect 

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

func (*CreateDatabaseResponse) Reset 

func (x *CreateDatabaseResponse) Reset()

func (*CreateDatabaseResponse) String 

func (x *CreateDatabaseResponse) String() string

type DatabaseInfo 

type DatabaseInfo struct {

	// Name of the database.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// UTC timestamp when the database was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// UTC timestamp when the database was updated.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Size of the data in bytes.
	DataSize uint64 `protobuf:"varint,4,opt,name=data_size,json=dataSize,proto3" json:"data_size,omitempty"`
	// Number of keys in the database.
	KeyCount uint32 `protobuf:"varint,5,opt,name=key_count,json=keyCount,proto3" json:"key_count,omitempty"`
	// contains filtered or unexported fields
}

DatabaseInfo represents information about a database.

func (*DatabaseInfo) Descriptor deprecated 

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

Deprecated: Use DatabaseInfo.ProtoReflect.Descriptor instead.

func (*DatabaseInfo) GetCreatedAt 

func (x *DatabaseInfo) GetCreatedAt() *timestamppb.Timestamp

func (*DatabaseInfo) GetDataSize 

func (x *DatabaseInfo) GetDataSize() uint64

func (*DatabaseInfo) GetKeyCount 

func (x *DatabaseInfo) GetKeyCount() uint32

func (*DatabaseInfo) GetName 

func (x *DatabaseInfo) GetName() string

func (*DatabaseInfo) GetUpdatedAt 

func (x *DatabaseInfo) GetUpdatedAt() *timestamppb.Timestamp

func (*DatabaseInfo) ProtoMessage 

func (*DatabaseInfo) ProtoMessage()

func (*DatabaseInfo) ProtoReflect 

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

func (*DatabaseInfo) Reset 

func (x *DatabaseInfo) Reset()

func (*DatabaseInfo) String 

func (x *DatabaseInfo) String() string

type DatabaseServiceClient 

type DatabaseServiceClient interface {
	// CreateDatabase creates a new database.
	CreateDatabase(ctx context.Context, in *CreateDatabaseRequest, opts ...grpc.CallOption) (*CreateDatabaseResponse, error)
	// GetAllDatabases returns the names of all databases.
	GetAllDatabases(ctx context.Context, in *GetAllDatabasesRequest, opts ...grpc.CallOption) (*GetAllDatabasesResponse, error)
	// GetDatabaseInfo returns information about a database.
	GetDatabaseInfo(ctx context.Context, in *GetDatabaseInfoRequest, opts ...grpc.CallOption) (*GetDatabaseInfoResponse, error)
	// DeleteDatabase deletes a database.
	DeleteDatabase(ctx context.Context, in *DeleteDatabaseRequest, opts ...grpc.CallOption) (*DeleteDatabaseResponse, error)
}

DatabaseServiceClient is the client API for DatabaseService 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 NewDatabaseServiceClient 

func NewDatabaseServiceClient(cc grpc.ClientConnInterface) DatabaseServiceClient

type DatabaseServiceServer 

type DatabaseServiceServer interface {
	// CreateDatabase creates a new database.
	CreateDatabase(context.Context, *CreateDatabaseRequest) (*CreateDatabaseResponse, error)
	// GetAllDatabases returns the names of all databases.
	GetAllDatabases(context.Context, *GetAllDatabasesRequest) (*GetAllDatabasesResponse, error)
	// GetDatabaseInfo returns information about a database.
	GetDatabaseInfo(context.Context, *GetDatabaseInfoRequest) (*GetDatabaseInfoResponse, error)
	// DeleteDatabase deletes a database.
	DeleteDatabase(context.Context, *DeleteDatabaseRequest) (*DeleteDatabaseResponse, error)
	// contains filtered or unexported methods
}

DatabaseServiceServer is the server API for DatabaseService service. All implementations must embed UnimplementedDatabaseServiceServer for forward compatibility

type DeleteAllKeysRequest added in v0.5.0 

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

func (*DeleteAllKeysRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use DeleteAllKeysRequest.ProtoReflect.Descriptor instead.

func (*DeleteAllKeysRequest) ProtoMessage added in v0.5.0 

func (*DeleteAllKeysRequest) ProtoMessage()

func (*DeleteAllKeysRequest) ProtoReflect added in v0.5.0 

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

func (*DeleteAllKeysRequest) Reset added in v0.5.0 

func (x *DeleteAllKeysRequest) Reset()

func (*DeleteAllKeysRequest) String added in v0.5.0 

func (x *DeleteAllKeysRequest) String() string

type DeleteAllKeysResponse added in v0.5.0 

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

func (*DeleteAllKeysResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use DeleteAllKeysResponse.ProtoReflect.Descriptor instead.

func (*DeleteAllKeysResponse) ProtoMessage added in v0.5.0 

func (*DeleteAllKeysResponse) ProtoMessage()

func (*DeleteAllKeysResponse) ProtoReflect added in v0.5.0 

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

func (*DeleteAllKeysResponse) Reset added in v0.5.0 

func (x *DeleteAllKeysResponse) Reset()

func (*DeleteAllKeysResponse) String added in v0.5.0 

func (x *DeleteAllKeysResponse) String() string

type DeleteDatabaseRequest added in v0.4.0 

type DeleteDatabaseRequest struct {

	// Name of the database.
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDatabaseRequest) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use DeleteDatabaseRequest.ProtoReflect.Descriptor instead.

func (*DeleteDatabaseRequest) GetDbName added in v0.4.0 

func (x *DeleteDatabaseRequest) GetDbName() string

func (*DeleteDatabaseRequest) ProtoMessage added in v0.4.0 

func (*DeleteDatabaseRequest) ProtoMessage()

func (*DeleteDatabaseRequest) ProtoReflect added in v0.4.0 

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

func (*DeleteDatabaseRequest) Reset added in v0.4.0 

func (x *DeleteDatabaseRequest) Reset()

func (*DeleteDatabaseRequest) String added in v0.4.0 

func (x *DeleteDatabaseRequest) String() string

type DeleteDatabaseResponse added in v0.4.0 

type DeleteDatabaseResponse struct {

	// Name of the deleted database.
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDatabaseResponse) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use DeleteDatabaseResponse.ProtoReflect.Descriptor instead.

func (*DeleteDatabaseResponse) GetDbName added in v0.4.0 

func (x *DeleteDatabaseResponse) GetDbName() string

func (*DeleteDatabaseResponse) ProtoMessage added in v0.4.0 

func (*DeleteDatabaseResponse) ProtoMessage()

func (*DeleteDatabaseResponse) ProtoReflect added in v0.4.0 

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

func (*DeleteDatabaseResponse) Reset added in v0.4.0 

func (x *DeleteDatabaseResponse) Reset()

func (*DeleteDatabaseResponse) String added in v0.4.0 

func (x *DeleteDatabaseResponse) String() string

type DeleteHashMapFieldsRequest added in v0.8.0 

type DeleteHashMapFieldsRequest struct {

	// The key to use.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The fields to remove from the HashMap.
	Fields []string `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteHashMapFieldsRequest) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use DeleteHashMapFieldsRequest.ProtoReflect.Descriptor instead.

func (*DeleteHashMapFieldsRequest) GetFields added in v0.8.0 

func (x *DeleteHashMapFieldsRequest) GetFields() []string

func (*DeleteHashMapFieldsRequest) GetKey added in v0.8.0 

func (x *DeleteHashMapFieldsRequest) GetKey() string

func (*DeleteHashMapFieldsRequest) ProtoMessage added in v0.8.0 

func (*DeleteHashMapFieldsRequest) ProtoMessage()

func (*DeleteHashMapFieldsRequest) ProtoReflect added in v0.8.0 

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

func (*DeleteHashMapFieldsRequest) Reset added in v0.8.0 

func (x *DeleteHashMapFieldsRequest) Reset()

func (*DeleteHashMapFieldsRequest) String added in v0.8.0 

func (x *DeleteHashMapFieldsRequest) String() string

type DeleteHashMapFieldsResponse added in v0.8.0 

type DeleteHashMapFieldsResponse struct {

	// The number of fields removed.
	FieldsRemoved uint32 `protobuf:"varint,1,opt,name=fields_removed,json=fieldsRemoved,proto3" json:"fields_removed,omitempty"`
	// True if the key exists. False if it doesn't exist.
	Ok bool `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteHashMapFieldsResponse) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use DeleteHashMapFieldsResponse.ProtoReflect.Descriptor instead.

func (*DeleteHashMapFieldsResponse) GetFieldsRemoved added in v0.8.0 

func (x *DeleteHashMapFieldsResponse) GetFieldsRemoved() uint32

func (*DeleteHashMapFieldsResponse) GetOk added in v0.8.0 

func (x *DeleteHashMapFieldsResponse) GetOk() bool

func (*DeleteHashMapFieldsResponse) ProtoMessage added in v0.8.0 

func (*DeleteHashMapFieldsResponse) ProtoMessage()

func (*DeleteHashMapFieldsResponse) ProtoReflect added in v0.8.0 

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

func (*DeleteHashMapFieldsResponse) Reset added in v0.8.0 

func (x *DeleteHashMapFieldsResponse) Reset()

func (*DeleteHashMapFieldsResponse) String added in v0.8.0 

func (x *DeleteHashMapFieldsResponse) String() string

type DeleteKeyRequest 

type DeleteKeyRequest struct {

	// The key to delete.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeyRequest) Descriptor deprecated 

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

Deprecated: Use DeleteKeyRequest.ProtoReflect.Descriptor instead.

func (*DeleteKeyRequest) GetKey 

func (x *DeleteKeyRequest) GetKey() string

func (*DeleteKeyRequest) ProtoMessage 

func (*DeleteKeyRequest) ProtoMessage()

func (*DeleteKeyRequest) ProtoReflect 

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

func (*DeleteKeyRequest) Reset 

func (x *DeleteKeyRequest) Reset()

func (*DeleteKeyRequest) String 

func (x *DeleteKeyRequest) String() string

type DeleteKeyResponse 

type DeleteKeyResponse struct {

	// True if the key was deleted. False if it doesn't exist.
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeyResponse) Descriptor deprecated 

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

Deprecated: Use DeleteKeyResponse.ProtoReflect.Descriptor instead.

func (*DeleteKeyResponse) GetOk added in v0.6.1 

func (x *DeleteKeyResponse) GetOk() bool

func (*DeleteKeyResponse) ProtoMessage 

func (*DeleteKeyResponse) ProtoMessage()

func (*DeleteKeyResponse) ProtoReflect 

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

func (*DeleteKeyResponse) Reset 

func (x *DeleteKeyResponse) Reset()

func (*DeleteKeyResponse) String 

func (x *DeleteKeyResponse) String() string

type GetAllDatabasesRequest 

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

func (*GetAllDatabasesRequest) Descriptor deprecated 

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

Deprecated: Use GetAllDatabasesRequest.ProtoReflect.Descriptor instead.

func (*GetAllDatabasesRequest) ProtoMessage 

func (*GetAllDatabasesRequest) ProtoMessage()

func (*GetAllDatabasesRequest) ProtoReflect 

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

func (*GetAllDatabasesRequest) Reset 

func (x *GetAllDatabasesRequest) Reset()

func (*GetAllDatabasesRequest) String 

func (x *GetAllDatabasesRequest) String() string

type GetAllDatabasesResponse 

type GetAllDatabasesResponse struct {

	// List of returned database names.
	DbNames []string `protobuf:"bytes,1,rep,name=db_names,json=dbNames,proto3" json:"db_names,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAllDatabasesResponse) Descriptor deprecated 

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

Deprecated: Use GetAllDatabasesResponse.ProtoReflect.Descriptor instead.

func (*GetAllDatabasesResponse) GetDbNames 

func (x *GetAllDatabasesResponse) GetDbNames() []string

func (*GetAllDatabasesResponse) ProtoMessage 

func (*GetAllDatabasesResponse) ProtoMessage()

func (*GetAllDatabasesResponse) ProtoReflect 

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

func (*GetAllDatabasesResponse) Reset 

func (x *GetAllDatabasesResponse) Reset()

func (*GetAllDatabasesResponse) String 

func (x *GetAllDatabasesResponse) String() string

type GetAllHashMapFieldsAndValuesRequest added in v0.9.0 

type GetAllHashMapFieldsAndValuesRequest struct {

	// The key to use.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAllHashMapFieldsAndValuesRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use GetAllHashMapFieldsAndValuesRequest.ProtoReflect.Descriptor instead.

func (*GetAllHashMapFieldsAndValuesRequest) GetKey added in v0.9.0 

func (x *GetAllHashMapFieldsAndValuesRequest) GetKey() string

func (*GetAllHashMapFieldsAndValuesRequest) ProtoMessage added in v0.9.0 

func (*GetAllHashMapFieldsAndValuesRequest) ProtoMessage()

func (*GetAllHashMapFieldsAndValuesRequest) ProtoReflect added in v0.9.0 

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

func (*GetAllHashMapFieldsAndValuesRequest) Reset added in v0.9.0 

func (x *GetAllHashMapFieldsAndValuesRequest) Reset()

func (*GetAllHashMapFieldsAndValuesRequest) String added in v0.9.0 

func (x *GetAllHashMapFieldsAndValuesRequest) String() string

type GetAllHashMapFieldsAndValuesResponse added in v0.9.0 

type GetAllHashMapFieldsAndValuesResponse struct {

	// The returned fields and their corresponding values.
	FieldValueMap map[string]string `` /* 190-byte string literal not displayed */
	// True if the key exists. False if it doesn't exist.
	Ok bool `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAllHashMapFieldsAndValuesResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use GetAllHashMapFieldsAndValuesResponse.ProtoReflect.Descriptor instead.

func (*GetAllHashMapFieldsAndValuesResponse) GetFieldValueMap added in v0.9.0 

func (x *GetAllHashMapFieldsAndValuesResponse) GetFieldValueMap() map[string]string

func (*GetAllHashMapFieldsAndValuesResponse) GetOk added in v0.9.0 

func (x *GetAllHashMapFieldsAndValuesResponse) GetOk() bool

func (*GetAllHashMapFieldsAndValuesResponse) ProtoMessage added in v0.9.0 

func (*GetAllHashMapFieldsAndValuesResponse) ProtoMessage()

func (*GetAllHashMapFieldsAndValuesResponse) ProtoReflect added in v0.9.0 

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

func (*GetAllHashMapFieldsAndValuesResponse) Reset added in v0.9.0 

func (x *GetAllHashMapFieldsAndValuesResponse) Reset()

func (*GetAllHashMapFieldsAndValuesResponse) String added in v0.9.0 

func (x *GetAllHashMapFieldsAndValuesResponse) String() string

type GetDatabaseInfoRequest 

type GetDatabaseInfoRequest struct {

	// Name of the database.
	DbName string `protobuf:"bytes,1,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDatabaseInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetDatabaseInfoRequest.ProtoReflect.Descriptor instead.

func (*GetDatabaseInfoRequest) GetDbName 

func (x *GetDatabaseInfoRequest) GetDbName() string

func (*GetDatabaseInfoRequest) ProtoMessage 

func (*GetDatabaseInfoRequest) ProtoMessage()

func (*GetDatabaseInfoRequest) ProtoReflect 

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

func (*GetDatabaseInfoRequest) Reset 

func (x *GetDatabaseInfoRequest) Reset()

func (*GetDatabaseInfoRequest) String 

func (x *GetDatabaseInfoRequest) String() string

type GetDatabaseInfoResponse 

type GetDatabaseInfoResponse struct {

	// Information about the database.
	Data *DatabaseInfo `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDatabaseInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetDatabaseInfoResponse.ProtoReflect.Descriptor instead.

func (*GetDatabaseInfoResponse) GetData 

func (x *GetDatabaseInfoResponse) GetData() *DatabaseInfo

func (*GetDatabaseInfoResponse) ProtoMessage 

func (*GetDatabaseInfoResponse) ProtoMessage()

func (*GetDatabaseInfoResponse) ProtoReflect 

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

func (*GetDatabaseInfoResponse) Reset 

func (x *GetDatabaseInfoResponse) Reset()

func (*GetDatabaseInfoResponse) String 

func (x *GetDatabaseInfoResponse) String() string

type GetHashMapFieldValueRequest added in v0.7.0 

type GetHashMapFieldValueRequest struct {

	// The key to use.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The field whose value should be returned.
	Field string `protobuf:"bytes,2,opt,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHashMapFieldValueRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use GetHashMapFieldValueRequest.ProtoReflect.Descriptor instead.

func (*GetHashMapFieldValueRequest) GetField added in v0.7.0 

func (x *GetHashMapFieldValueRequest) GetField() string

func (*GetHashMapFieldValueRequest) GetKey added in v0.7.0 

func (x *GetHashMapFieldValueRequest) GetKey() string

func (*GetHashMapFieldValueRequest) ProtoMessage added in v0.7.0 

func (*GetHashMapFieldValueRequest) ProtoMessage()

func (*GetHashMapFieldValueRequest) ProtoReflect added in v0.7.0 

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

func (*GetHashMapFieldValueRequest) Reset added in v0.7.0 

func (x *GetHashMapFieldValueRequest) Reset()

func (*GetHashMapFieldValueRequest) String added in v0.7.0 

func (x *GetHashMapFieldValueRequest) String() string

type GetHashMapFieldValueResponse added in v0.7.0 

type GetHashMapFieldValueResponse struct {

	// The returned value.
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// True if the field exists. False if the key or field doesn't exist.
	Ok bool `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHashMapFieldValueResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use GetHashMapFieldValueResponse.ProtoReflect.Descriptor instead.

func (*GetHashMapFieldValueResponse) GetOk added in v0.7.0 

func (x *GetHashMapFieldValueResponse) GetOk() bool

func (*GetHashMapFieldValueResponse) GetValue added in v0.7.0 

func (x *GetHashMapFieldValueResponse) GetValue() string

func (*GetHashMapFieldValueResponse) ProtoMessage added in v0.7.0 

func (*GetHashMapFieldValueResponse) ProtoMessage()

func (*GetHashMapFieldValueResponse) ProtoReflect added in v0.7.0 

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

func (*GetHashMapFieldValueResponse) Reset added in v0.7.0 

func (x *GetHashMapFieldValueResponse) Reset()

func (*GetHashMapFieldValueResponse) String added in v0.7.0 

func (x *GetHashMapFieldValueResponse) String() string

type GetKeysRequest added in v0.5.0 

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

func (*GetKeysRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use GetKeysRequest.ProtoReflect.Descriptor instead.

func (*GetKeysRequest) ProtoMessage added in v0.5.0 

func (*GetKeysRequest) ProtoMessage()

func (*GetKeysRequest) ProtoReflect added in v0.5.0 

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

func (*GetKeysRequest) Reset added in v0.5.0 

func (x *GetKeysRequest) Reset()

func (*GetKeysRequest) String added in v0.5.0 

func (x *GetKeysRequest) String() string

type GetKeysResponse added in v0.5.0 

type GetKeysResponse struct {

	// List of returned keys.
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKeysResponse) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use GetKeysResponse.ProtoReflect.Descriptor instead.

func (*GetKeysResponse) GetKeys added in v0.5.0 

func (x *GetKeysResponse) GetKeys() []string

func (*GetKeysResponse) ProtoMessage added in v0.5.0 

func (*GetKeysResponse) ProtoMessage()

func (*GetKeysResponse) ProtoReflect added in v0.5.0 

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

func (*GetKeysResponse) Reset added in v0.5.0 

func (x *GetKeysResponse) Reset()

func (*GetKeysResponse) String added in v0.5.0 

func (x *GetKeysResponse) String() string

type GetLogsRequest added in v0.6.0 

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

This will have fields in the future to do filtering. For example to return only the latest 10 logs.

func (*GetLogsRequest) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use GetLogsRequest.ProtoReflect.Descriptor instead.

func (*GetLogsRequest) ProtoMessage added in v0.6.0 

func (*GetLogsRequest) ProtoMessage()

func (*GetLogsRequest) ProtoReflect added in v0.6.0 

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

func (*GetLogsRequest) Reset added in v0.6.0 

func (x *GetLogsRequest) Reset()

func (*GetLogsRequest) String added in v0.6.0 

func (x *GetLogsRequest) String() string

type GetLogsResponse added in v0.6.0 

type GetLogsResponse struct {

	// List of returned logs.
	Logs []string `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// True if log file is enabled. Otherwise false.
	LogfileEnabled bool `protobuf:"varint,2,opt,name=logfile_enabled,json=logfileEnabled,proto3" json:"logfile_enabled,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogsResponse) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use GetLogsResponse.ProtoReflect.Descriptor instead.

func (*GetLogsResponse) GetLogfileEnabled added in v0.6.0 

func (x *GetLogsResponse) GetLogfileEnabled() bool

func (*GetLogsResponse) GetLogs added in v0.6.0 

func (x *GetLogsResponse) GetLogs() []string

func (*GetLogsResponse) ProtoMessage added in v0.6.0 

func (*GetLogsResponse) ProtoMessage()

func (*GetLogsResponse) ProtoReflect added in v0.6.0 

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

func (*GetLogsResponse) Reset added in v0.6.0 

func (x *GetLogsResponse) Reset()

func (*GetLogsResponse) String added in v0.6.0 

func (x *GetLogsResponse) String() string

type GetServerInfoRequest 

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

func (*GetServerInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetServerInfoRequest.ProtoReflect.Descriptor instead.

func (*GetServerInfoRequest) ProtoMessage 

func (*GetServerInfoRequest) ProtoMessage()

func (*GetServerInfoRequest) ProtoReflect 

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

func (*GetServerInfoRequest) Reset 

func (x *GetServerInfoRequest) Reset()

func (*GetServerInfoRequest) String 

func (x *GetServerInfoRequest) String() string

type GetServerInfoResponse 

type GetServerInfoResponse struct {

	// Information about the server.
	Data *ServerInfo `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServerInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetServerInfoResponse.ProtoReflect.Descriptor instead.

func (*GetServerInfoResponse) GetData 

func (x *GetServerInfoResponse) GetData() *ServerInfo

func (*GetServerInfoResponse) ProtoMessage 

func (*GetServerInfoResponse) ProtoMessage()

func (*GetServerInfoResponse) ProtoReflect 

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

func (*GetServerInfoResponse) Reset 

func (x *GetServerInfoResponse) Reset()

func (*GetServerInfoResponse) String 

func (x *GetServerInfoResponse) String() string

type GetStringRequest 

type GetStringRequest struct {

	// The key to use.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStringRequest) Descriptor deprecated 

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

Deprecated: Use GetStringRequest.ProtoReflect.Descriptor instead.

func (*GetStringRequest) GetKey 

func (x *GetStringRequest) GetKey() string

func (*GetStringRequest) ProtoMessage 

func (*GetStringRequest) ProtoMessage()

func (*GetStringRequest) ProtoReflect 

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

func (*GetStringRequest) Reset 

func (x *GetStringRequest) Reset()

func (*GetStringRequest) String 

func (x *GetStringRequest) String() string

type GetStringResponse 

type GetStringResponse struct {

	// The returned value.
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// True if the key exists. False if it doesn't exist.
	Ok bool `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStringResponse) Descriptor deprecated 

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

Deprecated: Use GetStringResponse.ProtoReflect.Descriptor instead.

func (*GetStringResponse) GetOk added in v0.8.0 

func (x *GetStringResponse) GetOk() bool

func (*GetStringResponse) GetValue 

func (x *GetStringResponse) GetValue() string

func (*GetStringResponse) ProtoMessage 

func (*GetStringResponse) ProtoMessage()

func (*GetStringResponse) ProtoReflect 

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

func (*GetStringResponse) Reset 

func (x *GetStringResponse) Reset()

func (*GetStringResponse) String 

func (x *GetStringResponse) String() string

type GetTypeOfKeyRequest added in v0.8.0 

type GetTypeOfKeyRequest struct {

	// The key whose data type should be returned.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTypeOfKeyRequest) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use GetTypeOfKeyRequest.ProtoReflect.Descriptor instead.

func (*GetTypeOfKeyRequest) GetKey added in v0.8.0 

func (x *GetTypeOfKeyRequest) GetKey() string

func (*GetTypeOfKeyRequest) ProtoMessage added in v0.8.0 

func (*GetTypeOfKeyRequest) ProtoMessage()

func (*GetTypeOfKeyRequest) ProtoReflect added in v0.8.0 

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

func (*GetTypeOfKeyRequest) Reset added in v0.8.0 

func (x *GetTypeOfKeyRequest) Reset()

func (*GetTypeOfKeyRequest) String added in v0.8.0 

func (x *GetTypeOfKeyRequest) String() string

type GetTypeOfKeyResponse added in v0.8.0 

type GetTypeOfKeyResponse struct {

	// The data type of the key.
	KeyType string `protobuf:"bytes,1,opt,name=key_type,json=keyType,proto3" json:"key_type,omitempty"`
	// True if the key exists. False if it doesn't exist.
	Ok bool `protobuf:"varint,2,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTypeOfKeyResponse) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use GetTypeOfKeyResponse.ProtoReflect.Descriptor instead.

func (*GetTypeOfKeyResponse) GetKeyType added in v0.8.0 

func (x *GetTypeOfKeyResponse) GetKeyType() string

func (*GetTypeOfKeyResponse) GetOk added in v0.8.0 

func (x *GetTypeOfKeyResponse) GetOk() bool

func (*GetTypeOfKeyResponse) ProtoMessage added in v0.8.0 

func (*GetTypeOfKeyResponse) ProtoMessage()

func (*GetTypeOfKeyResponse) ProtoReflect added in v0.8.0 

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

func (*GetTypeOfKeyResponse) Reset added in v0.8.0 

func (x *GetTypeOfKeyResponse) Reset()

func (*GetTypeOfKeyResponse) String added in v0.8.0 

func (x *GetTypeOfKeyResponse) String() string

type ServerInfo 

type ServerInfo struct {

	// Version of kvdb.
	KvdbVersion string `protobuf:"bytes,1,opt,name=kvdb_version,json=kvdbVersion,proto3" json:"kvdb_version,omitempty"`
	// Version of go used to compile the server.
	GoVersion string `protobuf:"bytes,2,opt,name=go_version,json=goVersion,proto3" json:"go_version,omitempty"`
	// Number of databases.
	DbCount uint32 `protobuf:"varint,3,opt,name=db_count,json=dbCount,proto3" json:"db_count,omitempty"`
	// Total amount of stored data in bytes.
	TotalDataSize uint64 `protobuf:"varint,4,opt,name=total_data_size,json=totalDataSize,proto3" json:"total_data_size,omitempty"`
	// Server operating system.
	Os string `protobuf:"bytes,5,opt,name=os,proto3" json:"os,omitempty"`
	// Architecture which can be 32 or 64 bits.
	Arch string `protobuf:"bytes,6,opt,name=arch,proto3" json:"arch,omitempty"`
	// PID of the server process.
	ProcessId uint32 `protobuf:"varint,7,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	// Server process uptime in seconds.
	UptimeSeconds uint64 `protobuf:"varint,8,opt,name=uptime_seconds,json=uptimeSeconds,proto3" json:"uptime_seconds,omitempty"`
	// Server TCP/IP port.
	TcpPort uint32 `protobuf:"varint,9,opt,name=tcp_port,json=tcpPort,proto3" json:"tcp_port,omitempty"`
	// contains filtered or unexported fields
}

ServerInfo represents information about the server. Will have more fields in future versions.

func (*ServerInfo) Descriptor deprecated 

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

Deprecated: Use ServerInfo.ProtoReflect.Descriptor instead.

func (*ServerInfo) GetArch 

func (x *ServerInfo) GetArch() string

func (*ServerInfo) GetDbCount 

func (x *ServerInfo) GetDbCount() uint32

func (*ServerInfo) GetGoVersion 

func (x *ServerInfo) GetGoVersion() string

func (*ServerInfo) GetKvdbVersion added in v0.1.2 

func (x *ServerInfo) GetKvdbVersion() string

func (*ServerInfo) GetOs 

func (x *ServerInfo) GetOs() string

func (*ServerInfo) GetProcessId 

func (x *ServerInfo) GetProcessId() uint32

func (*ServerInfo) GetTcpPort 

func (x *ServerInfo) GetTcpPort() uint32

func (*ServerInfo) GetTotalDataSize 

func (x *ServerInfo) GetTotalDataSize() uint64

func (*ServerInfo) GetUptimeSeconds 

func (x *ServerInfo) GetUptimeSeconds() uint64

func (*ServerInfo) ProtoMessage 

func (*ServerInfo) ProtoMessage()

func (*ServerInfo) ProtoReflect 

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

func (*ServerInfo) Reset 

func (x *ServerInfo) Reset()

func (*ServerInfo) String 

func (x *ServerInfo) String() string

type ServerServiceClient 

type ServerServiceClient interface {
	// GetServerInfo returns information about the server.
	GetServerInfo(ctx context.Context, in *GetServerInfoRequest, opts ...grpc.CallOption) (*GetServerInfoResponse, error)
	// GetLogs returns the server logs if the log file is enabled.
	GetLogs(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (*GetLogsResponse, error)
}

ServerServiceClient is the client API for ServerService 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 NewServerServiceClient 

func NewServerServiceClient(cc grpc.ClientConnInterface) ServerServiceClient

type ServerServiceServer 

type ServerServiceServer interface {
	// GetServerInfo returns information about the server.
	GetServerInfo(context.Context, *GetServerInfoRequest) (*GetServerInfoResponse, error)
	// GetLogs returns the server logs if the log file is enabled.
	GetLogs(context.Context, *GetLogsRequest) (*GetLogsResponse, error)
	// contains filtered or unexported methods
}

ServerServiceServer is the server API for ServerService service. All implementations must embed UnimplementedServerServiceServer for forward compatibility

type SetHashMapRequest added in v0.7.0 

type SetHashMapRequest struct {

	// The key to use.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The fields to be set and their corresponding values.
	Fields map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SetHashMapRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use SetHashMapRequest.ProtoReflect.Descriptor instead.

func (*SetHashMapRequest) GetFields added in v0.7.0 

func (x *SetHashMapRequest) GetFields() map[string]string

func (*SetHashMapRequest) GetKey added in v0.7.0 

func (x *SetHashMapRequest) GetKey() string

func (*SetHashMapRequest) ProtoMessage added in v0.7.0 

func (*SetHashMapRequest) ProtoMessage()

func (*SetHashMapRequest) ProtoReflect added in v0.7.0 

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

func (*SetHashMapRequest) Reset added in v0.7.0 

func (x *SetHashMapRequest) Reset()

func (*SetHashMapRequest) String added in v0.7.0 

func (x *SetHashMapRequest) String() string

type SetHashMapResponse added in v0.7.0 

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

func (*SetHashMapResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use SetHashMapResponse.ProtoReflect.Descriptor instead.

func (*SetHashMapResponse) ProtoMessage added in v0.7.0 

func (*SetHashMapResponse) ProtoMessage()

func (*SetHashMapResponse) ProtoReflect added in v0.7.0 

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

func (*SetHashMapResponse) Reset added in v0.7.0 

func (x *SetHashMapResponse) Reset()

func (*SetHashMapResponse) String added in v0.7.0 

func (x *SetHashMapResponse) String() string

type SetStringRequest 

type SetStringRequest struct {

	// The key to use.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The value to store.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SetStringRequest) Descriptor deprecated 

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

Deprecated: Use SetStringRequest.ProtoReflect.Descriptor instead.

func (*SetStringRequest) GetKey 

func (x *SetStringRequest) GetKey() string

func (*SetStringRequest) GetValue 

func (x *SetStringRequest) GetValue() string

func (*SetStringRequest) ProtoMessage 

func (*SetStringRequest) ProtoMessage()

func (*SetStringRequest) ProtoReflect 

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

func (*SetStringRequest) Reset 

func (x *SetStringRequest) Reset()

func (*SetStringRequest) String 

func (x *SetStringRequest) String() string

type SetStringResponse 

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

func (*SetStringResponse) Descriptor deprecated 

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

Deprecated: Use SetStringResponse.ProtoReflect.Descriptor instead.

func (*SetStringResponse) ProtoMessage 

func (*SetStringResponse) ProtoMessage()

func (*SetStringResponse) ProtoReflect 

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

func (*SetStringResponse) Reset 

func (x *SetStringResponse) Reset()

func (*SetStringResponse) String 

func (x *SetStringResponse) String() string

type StorageServiceClient 

type StorageServiceClient interface {
	// GetTypeOfKey returns the data type of a key.
	GetTypeOfKey(ctx context.Context, in *GetTypeOfKeyRequest, opts ...grpc.CallOption) (*GetTypeOfKeyResponse, error)
	// SetString sets a String value using a key. Creates the key if it doesn't exist.
	// Overwrites the key if it is holding a value of another data type.
	SetString(ctx context.Context, in *SetStringRequest, opts ...grpc.CallOption) (*SetStringResponse, error)
	// GetString returns a String value using a key.
	GetString(ctx context.Context, in *GetStringRequest, opts ...grpc.CallOption) (*GetStringResponse, error)
	// DeleteKey deletes a key and its value.
	DeleteKey(ctx context.Context, in *DeleteKeyRequest, opts ...grpc.CallOption) (*DeleteKeyResponse, error)
	// DeleteAllKeys deletes all the keys of a database.
	DeleteAllKeys(ctx context.Context, in *DeleteAllKeysRequest, opts ...grpc.CallOption) (*DeleteAllKeysResponse, error)
	// GetKeys returns all the keys of a database.
	GetKeys(ctx context.Context, in *GetKeysRequest, opts ...grpc.CallOption) (*GetKeysResponse, error)
	// SetHashMap sets fields in a HashMap using a key.
	// Previous fields are overwritten. Creates the key if it doesn't exist.
	// Overwrites the key if it is holding a value of another data type.
	SetHashMap(ctx context.Context, in *SetHashMapRequest, opts ...grpc.CallOption) (*SetHashMapResponse, error)
	// GetHashMapFieldValue returns a single HashMap field value using a key.
	GetHashMapFieldValue(ctx context.Context, in *GetHashMapFieldValueRequest, opts ...grpc.CallOption) (*GetHashMapFieldValueResponse, error)
	// DeleteHashMapFields removes fields from a HashMap using a key.
	DeleteHashMapFields(ctx context.Context, in *DeleteHashMapFieldsRequest, opts ...grpc.CallOption) (*DeleteHashMapFieldsResponse, error)
	// GetAllHashMapFieldsAndValues returns all the fields and values of a HashMap using a key.
	GetAllHashMapFieldsAndValues(ctx context.Context, in *GetAllHashMapFieldsAndValuesRequest, opts ...grpc.CallOption) (*GetAllHashMapFieldsAndValuesResponse, error)
}

StorageServiceClient is the client API for StorageService 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 NewStorageServiceClient 

func NewStorageServiceClient(cc grpc.ClientConnInterface) StorageServiceClient

type StorageServiceServer 

type StorageServiceServer interface {
	// GetTypeOfKey returns the data type of a key.
	GetTypeOfKey(context.Context, *GetTypeOfKeyRequest) (*GetTypeOfKeyResponse, error)
	// SetString sets a String value using a key. Creates the key if it doesn't exist.
	// Overwrites the key if it is holding a value of another data type.
	SetString(context.Context, *SetStringRequest) (*SetStringResponse, error)
	// GetString returns a String value using a key.
	GetString(context.Context, *GetStringRequest) (*GetStringResponse, error)
	// DeleteKey deletes a key and its value.
	DeleteKey(context.Context, *DeleteKeyRequest) (*DeleteKeyResponse, error)
	// DeleteAllKeys deletes all the keys of a database.
	DeleteAllKeys(context.Context, *DeleteAllKeysRequest) (*DeleteAllKeysResponse, error)
	// GetKeys returns all the keys of a database.
	GetKeys(context.Context, *GetKeysRequest) (*GetKeysResponse, error)
	// SetHashMap sets fields in a HashMap using a key.
	// Previous fields are overwritten. Creates the key if it doesn't exist.
	// Overwrites the key if it is holding a value of another data type.
	SetHashMap(context.Context, *SetHashMapRequest) (*SetHashMapResponse, error)
	// GetHashMapFieldValue returns a single HashMap field value using a key.
	GetHashMapFieldValue(context.Context, *GetHashMapFieldValueRequest) (*GetHashMapFieldValueResponse, error)
	// DeleteHashMapFields removes fields from a HashMap using a key.
	DeleteHashMapFields(context.Context, *DeleteHashMapFieldsRequest) (*DeleteHashMapFieldsResponse, error)
	// GetAllHashMapFieldsAndValues returns all the fields and values of a HashMap using a key.
	GetAllHashMapFieldsAndValues(context.Context, *GetAllHashMapFieldsAndValuesRequest) (*GetAllHashMapFieldsAndValuesResponse, error)
	// contains filtered or unexported methods
}

StorageServiceServer is the server API for StorageService service. All implementations must embed UnimplementedStorageServiceServer for forward compatibility

type UnimplementedDatabaseServiceServer 

type UnimplementedDatabaseServiceServer struct {
}

UnimplementedDatabaseServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDatabaseServiceServer) CreateDatabase 

func (UnimplementedDatabaseServiceServer) CreateDatabase(context.Context, *CreateDatabaseRequest) (*CreateDatabaseResponse, error)

func (UnimplementedDatabaseServiceServer) DeleteDatabase added in v0.4.0 

func (UnimplementedDatabaseServiceServer) DeleteDatabase(context.Context, *DeleteDatabaseRequest) (*DeleteDatabaseResponse, error)

func (UnimplementedDatabaseServiceServer) GetAllDatabases 

func (UnimplementedDatabaseServiceServer) GetAllDatabases(context.Context, *GetAllDatabasesRequest) (*GetAllDatabasesResponse, error)

func (UnimplementedDatabaseServiceServer) GetDatabaseInfo 

func (UnimplementedDatabaseServiceServer) GetDatabaseInfo(context.Context, *GetDatabaseInfoRequest) (*GetDatabaseInfoResponse, error)

type UnimplementedServerServiceServer 

type UnimplementedServerServiceServer struct {
}

UnimplementedServerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedServerServiceServer) GetLogs added in v0.6.0 

func (UnimplementedServerServiceServer) GetLogs(context.Context, *GetLogsRequest) (*GetLogsResponse, error)

func (UnimplementedServerServiceServer) GetServerInfo 

func (UnimplementedServerServiceServer) GetServerInfo(context.Context, *GetServerInfoRequest) (*GetServerInfoResponse, error)

type UnimplementedStorageServiceServer 

type UnimplementedStorageServiceServer struct {
}

UnimplementedStorageServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedStorageServiceServer) DeleteAllKeys added in v0.5.0 

func (UnimplementedStorageServiceServer) DeleteAllKeys(context.Context, *DeleteAllKeysRequest) (*DeleteAllKeysResponse, error)

func (UnimplementedStorageServiceServer) DeleteHashMapFields added in v0.8.0 

func (UnimplementedStorageServiceServer) DeleteHashMapFields(context.Context, *DeleteHashMapFieldsRequest) (*DeleteHashMapFieldsResponse, error)

func (UnimplementedStorageServiceServer) DeleteKey 

func (UnimplementedStorageServiceServer) DeleteKey(context.Context, *DeleteKeyRequest) (*DeleteKeyResponse, error)

func (UnimplementedStorageServiceServer) GetAllHashMapFieldsAndValues added in v0.9.0 

func (UnimplementedStorageServiceServer) GetAllHashMapFieldsAndValues(context.Context, *GetAllHashMapFieldsAndValuesRequest) (*GetAllHashMapFieldsAndValuesResponse, error)

func (UnimplementedStorageServiceServer) GetHashMapFieldValue added in v0.7.0 

func (UnimplementedStorageServiceServer) GetHashMapFieldValue(context.Context, *GetHashMapFieldValueRequest) (*GetHashMapFieldValueResponse, error)

func (UnimplementedStorageServiceServer) GetKeys added in v0.5.0 

func (UnimplementedStorageServiceServer) GetKeys(context.Context, *GetKeysRequest) (*GetKeysResponse, error)

func (UnimplementedStorageServiceServer) GetString 

func (UnimplementedStorageServiceServer) GetString(context.Context, *GetStringRequest) (*GetStringResponse, error)

func (UnimplementedStorageServiceServer) GetTypeOfKey added in v0.8.0 

func (UnimplementedStorageServiceServer) GetTypeOfKey(context.Context, *GetTypeOfKeyRequest) (*GetTypeOfKeyResponse, error)

func (UnimplementedStorageServiceServer) SetHashMap added in v0.7.0 

func (UnimplementedStorageServiceServer) SetHashMap(context.Context, *SetHashMapRequest) (*SetHashMapResponse, error)

func (UnimplementedStorageServiceServer) SetString 

func (UnimplementedStorageServiceServer) SetString(context.Context, *SetStringRequest) (*SetStringResponse, error)

type UnsafeDatabaseServiceServer 

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

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

type UnsafeServerServiceServer 

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

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

type UnsafeStorageServiceServer 

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

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