pb

package
v0.3.0-alpha1 Latest Latest
Warning

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

Go to latest
Published: Oct 23, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Data_Set_FullMethodName              = "/hb.Data/Set"
	Data_Get_FullMethodName              = "/hb.Data/Get"
	Data_Delete_FullMethodName           = "/hb.Data/Delete"
	Data_DeleteByPrefix_FullMethodName   = "/hb.Data/DeleteByPrefix"
	Data_CreateReadStream_FullMethodName = "/hb.Data/CreateReadStream"
	Data_CreateSendStream_FullMethodName = "/hb.Data/CreateSendStream"
)
View Source
const (
	Db_Create_FullMethodName   = "/hb.Db/Create"
	Db_Drop_FullMethodName     = "/hb.Db/Drop"
	Db_Exists_FullMethodName   = "/hb.Db/Exists"
	Db_EnsureDb_FullMethodName = "/hb.Db/EnsureDb"
)
View Source
const (
	Sys_Ping_FullMethodName = "/hb.Sys/Ping"
)

Variables

View Source
var Data_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "hb.Data",
	HandlerType: (*DataServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Set",
			Handler:    _Data_Set_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _Data_Get_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Data_Delete_Handler,
		},
		{
			MethodName: "DeleteByPrefix",
			Handler:    _Data_DeleteByPrefix_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CreateReadStream",
			Handler:       _Data_CreateReadStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "CreateSendStream",
			Handler:       _Data_CreateSendStream_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "honey_badger.proto",
}

Data_ServiceDesc is the grpc.ServiceDesc for Data 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 Db_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "hb.Db",
	HandlerType: (*DbServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _Db_Create_Handler,
		},
		{
			MethodName: "Drop",
			Handler:    _Db_Drop_Handler,
		},
		{
			MethodName: "Exists",
			Handler:    _Db_Exists_Handler,
		},
		{
			MethodName: "EnsureDb",
			Handler:    _Db_EnsureDb_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "honey_badger.proto",
}

Db_ServiceDesc is the grpc.ServiceDesc for Db 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_honey_badger_proto protoreflect.FileDescriptor
View Source
var Sys_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "hb.Sys",
	HandlerType: (*SysServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Sys_Ping_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "honey_badger.proto",
}

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

Functions

func RegisterDataServer

func RegisterDataServer(s grpc.ServiceRegistrar, srv DataServer)

func RegisterDbServer

func RegisterDbServer(s grpc.ServiceRegistrar, srv DbServer)

func RegisterSysServer

func RegisterSysServer(s grpc.ServiceRegistrar, srv SysServer)

Types

type CreateDbOpt

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

func (*CreateDbOpt) Descriptor deprecated

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

Deprecated: Use CreateDbOpt.ProtoReflect.Descriptor instead.

func (*CreateDbOpt) GetInMemory

func (x *CreateDbOpt) GetInMemory() bool

func (*CreateDbOpt) ProtoMessage

func (*CreateDbOpt) ProtoMessage()

func (*CreateDbOpt) ProtoReflect

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

func (*CreateDbOpt) Reset

func (x *CreateDbOpt) Reset()

func (*CreateDbOpt) String

func (x *CreateDbOpt) String() string

type CreateDbReq

type CreateDbReq struct {
	Name string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Opt  *CreateDbOpt `protobuf:"bytes,2,opt,name=opt,proto3" json:"opt,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDbReq) Descriptor deprecated

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

Deprecated: Use CreateDbReq.ProtoReflect.Descriptor instead.

func (*CreateDbReq) GetName

func (x *CreateDbReq) GetName() string

func (*CreateDbReq) GetOpt

func (x *CreateDbReq) GetOpt() *CreateDbOpt

func (*CreateDbReq) ProtoMessage

func (*CreateDbReq) ProtoMessage()

func (*CreateDbReq) ProtoReflect

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

func (*CreateDbReq) Reset

func (x *CreateDbReq) Reset()

func (*CreateDbReq) String

func (x *CreateDbReq) String() string

type DataClient

type DataClient interface {
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Get(ctx context.Context, in *KeyRequest, opts ...grpc.CallOption) (*GetResult, error)
	Delete(ctx context.Context, in *KeyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteByPrefix(ctx context.Context, in *PrefixRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CreateReadStream(ctx context.Context, in *ReadStreamReq, opts ...grpc.CallOption) (Data_CreateReadStreamClient, error)
	CreateSendStream(ctx context.Context, opts ...grpc.CallOption) (Data_CreateSendStreamClient, error)
}

DataClient is the client API for Data 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 NewDataClient

func NewDataClient(cc grpc.ClientConnInterface) DataClient

type DataItem

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

func (*DataItem) Descriptor deprecated

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

Deprecated: Use DataItem.ProtoReflect.Descriptor instead.

func (*DataItem) GetData

func (x *DataItem) GetData() []byte

func (*DataItem) GetKey

func (x *DataItem) GetKey() string

func (*DataItem) ProtoMessage

func (*DataItem) ProtoMessage()

func (*DataItem) ProtoReflect

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

func (*DataItem) Reset

func (x *DataItem) Reset()

func (*DataItem) String

func (x *DataItem) String() string

type DataServer

type DataServer interface {
	Set(context.Context, *SetRequest) (*emptypb.Empty, error)
	Get(context.Context, *KeyRequest) (*GetResult, error)
	Delete(context.Context, *KeyRequest) (*emptypb.Empty, error)
	DeleteByPrefix(context.Context, *PrefixRequest) (*emptypb.Empty, error)
	CreateReadStream(*ReadStreamReq, Data_CreateReadStreamServer) error
	CreateSendStream(Data_CreateSendStreamServer) error
	// contains filtered or unexported methods
}

DataServer is the server API for Data service. All implementations must embed UnimplementedDataServer for forward compatibility

type Data_CreateReadStreamClient

type Data_CreateReadStreamClient interface {
	Recv() (*DataItem, error)
	grpc.ClientStream
}

type Data_CreateReadStreamServer

type Data_CreateReadStreamServer interface {
	Send(*DataItem) error
	grpc.ServerStream
}

type Data_CreateSendStreamClient

type Data_CreateSendStreamClient interface {
	Send(*SendStreamReq) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type Data_CreateSendStreamServer

type Data_CreateSendStreamServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*SendStreamReq, error)
	grpc.ServerStream
}

type DbClient

type DbClient interface {
	Create(ctx context.Context, in *CreateDbReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Drop(ctx context.Context, in *DropDbRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Exists(ctx context.Context, in *ExistsDbReq, opts ...grpc.CallOption) (*ExistsDbRes, error)
	EnsureDb(ctx context.Context, in *CreateDbReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DbClient is the client API for Db 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 NewDbClient

func NewDbClient(cc grpc.ClientConnInterface) DbClient

type DbServer

type DbServer interface {
	Create(context.Context, *CreateDbReq) (*emptypb.Empty, error)
	Drop(context.Context, *DropDbRequest) (*emptypb.Empty, error)
	Exists(context.Context, *ExistsDbReq) (*ExistsDbRes, error)
	EnsureDb(context.Context, *CreateDbReq) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

DbServer is the server API for Db service. All implementations must embed UnimplementedDbServer for forward compatibility

type DropDbRequest

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

func (*DropDbRequest) Descriptor deprecated

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

Deprecated: Use DropDbRequest.ProtoReflect.Descriptor instead.

func (*DropDbRequest) GetName

func (x *DropDbRequest) GetName() string

func (*DropDbRequest) ProtoMessage

func (*DropDbRequest) ProtoMessage()

func (*DropDbRequest) ProtoReflect

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

func (*DropDbRequest) Reset

func (x *DropDbRequest) Reset()

func (*DropDbRequest) String

func (x *DropDbRequest) String() string

type ExistsDbReq

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

func (*ExistsDbReq) Descriptor deprecated

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

Deprecated: Use ExistsDbReq.ProtoReflect.Descriptor instead.

func (*ExistsDbReq) GetName

func (x *ExistsDbReq) GetName() string

func (*ExistsDbReq) ProtoMessage

func (*ExistsDbReq) ProtoMessage()

func (*ExistsDbReq) ProtoReflect

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

func (*ExistsDbReq) Reset

func (x *ExistsDbReq) Reset()

func (*ExistsDbReq) String

func (x *ExistsDbReq) String() string

type ExistsDbRes

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

func (*ExistsDbRes) Descriptor deprecated

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

Deprecated: Use ExistsDbRes.ProtoReflect.Descriptor instead.

func (*ExistsDbRes) GetExists

func (x *ExistsDbRes) GetExists() bool

func (*ExistsDbRes) ProtoMessage

func (*ExistsDbRes) ProtoMessage()

func (*ExistsDbRes) ProtoReflect

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

func (*ExistsDbRes) Reset

func (x *ExistsDbRes) Reset()

func (*ExistsDbRes) String

func (x *ExistsDbRes) String() string

type GetResult

type GetResult struct {
	Hit  bool   `protobuf:"varint,1,opt,name=hit,proto3" json:"hit,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResult) Descriptor deprecated

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

Deprecated: Use GetResult.ProtoReflect.Descriptor instead.

func (*GetResult) GetData

func (x *GetResult) GetData() []byte

func (*GetResult) GetHit

func (x *GetResult) GetHit() bool

func (*GetResult) ProtoMessage

func (*GetResult) ProtoMessage()

func (*GetResult) ProtoReflect

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

func (*GetResult) Reset

func (x *GetResult) Reset()

func (*GetResult) String

func (x *GetResult) String() string

type KeyRequest

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

func (*KeyRequest) Descriptor deprecated

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

Deprecated: Use KeyRequest.ProtoReflect.Descriptor instead.

func (*KeyRequest) GetDb

func (x *KeyRequest) GetDb() string

func (*KeyRequest) GetKey

func (x *KeyRequest) GetKey() string

func (*KeyRequest) ProtoMessage

func (*KeyRequest) ProtoMessage()

func (*KeyRequest) ProtoReflect

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

func (*KeyRequest) Reset

func (x *KeyRequest) Reset()

func (*KeyRequest) String

func (x *KeyRequest) String() string

type PingRequest

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

func (*PingRequest) Descriptor deprecated

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect

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

func (*PingRequest) Reset

func (x *PingRequest) Reset()

func (*PingRequest) String

func (x *PingRequest) String() string

type PingResult

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

func (*PingResult) Descriptor deprecated

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

Deprecated: Use PingResult.ProtoReflect.Descriptor instead.

func (*PingResult) GetMesage

func (x *PingResult) GetMesage() string

func (*PingResult) ProtoMessage

func (*PingResult) ProtoMessage()

func (*PingResult) ProtoReflect

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

func (*PingResult) Reset

func (x *PingResult) Reset()

func (*PingResult) String

func (x *PingResult) String() string

type PrefixRequest

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

func (*PrefixRequest) Descriptor deprecated

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

Deprecated: Use PrefixRequest.ProtoReflect.Descriptor instead.

func (*PrefixRequest) GetDb

func (x *PrefixRequest) GetDb() string

func (*PrefixRequest) GetPrefix

func (x *PrefixRequest) GetPrefix() string

func (*PrefixRequest) ProtoMessage

func (*PrefixRequest) ProtoMessage()

func (*PrefixRequest) ProtoReflect

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

func (*PrefixRequest) Reset

func (x *PrefixRequest) Reset()

func (*PrefixRequest) String

func (x *PrefixRequest) String() string

type ReadStreamReq

type ReadStreamReq struct {
	Db     string  `protobuf:"bytes,1,opt,name=db,proto3" json:"db,omitempty"`
	Prefix *string `protobuf:"bytes,2,opt,name=prefix,proto3,oneof" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadStreamReq) Descriptor deprecated

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

Deprecated: Use ReadStreamReq.ProtoReflect.Descriptor instead.

func (*ReadStreamReq) GetDb

func (x *ReadStreamReq) GetDb() string

func (*ReadStreamReq) GetPrefix

func (x *ReadStreamReq) GetPrefix() string

func (*ReadStreamReq) ProtoMessage

func (*ReadStreamReq) ProtoMessage()

func (*ReadStreamReq) ProtoReflect

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

func (*ReadStreamReq) Reset

func (x *ReadStreamReq) Reset()

func (*ReadStreamReq) String

func (x *ReadStreamReq) String() string

type SendStreamReq

type SendStreamReq struct {
	Item *DataItem `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	Db   string    `protobuf:"bytes,2,opt,name=db,proto3" json:"db,omitempty"`
	// contains filtered or unexported fields
}

func (*SendStreamReq) Descriptor deprecated

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

Deprecated: Use SendStreamReq.ProtoReflect.Descriptor instead.

func (*SendStreamReq) GetDb

func (x *SendStreamReq) GetDb() string

func (*SendStreamReq) GetItem

func (x *SendStreamReq) GetItem() *DataItem

func (*SendStreamReq) ProtoMessage

func (*SendStreamReq) ProtoMessage()

func (*SendStreamReq) ProtoReflect

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

func (*SendStreamReq) Reset

func (x *SendStreamReq) Reset()

func (*SendStreamReq) String

func (x *SendStreamReq) String() string

type SetRequest

type SetRequest struct {
	Db   string `protobuf:"bytes,1,opt,name=db,proto3" json:"db,omitempty"`
	Key  string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Ttl  *int32 `protobuf:"varint,4,opt,name=ttl,proto3,oneof" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*SetRequest) Descriptor deprecated

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

Deprecated: Use SetRequest.ProtoReflect.Descriptor instead.

func (*SetRequest) GetData

func (x *SetRequest) GetData() []byte

func (*SetRequest) GetDb

func (x *SetRequest) GetDb() string

func (*SetRequest) GetKey

func (x *SetRequest) GetKey() string

func (*SetRequest) GetTtl

func (x *SetRequest) GetTtl() int32

func (*SetRequest) ProtoMessage

func (*SetRequest) ProtoMessage()

func (*SetRequest) ProtoReflect

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

func (*SetRequest) Reset

func (x *SetRequest) Reset()

func (*SetRequest) String

func (x *SetRequest) String() string

type SysClient

type SysClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResult, error)
}

SysClient is the client API for Sys 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 NewSysClient

func NewSysClient(cc grpc.ClientConnInterface) SysClient

type SysServer

type SysServer interface {
	Ping(context.Context, *PingRequest) (*PingResult, error)
	// contains filtered or unexported methods
}

SysServer is the server API for Sys service. All implementations must embed UnimplementedSysServer for forward compatibility

type UnimplementedDataServer

type UnimplementedDataServer struct {
}

UnimplementedDataServer must be embedded to have forward compatible implementations.

func (UnimplementedDataServer) CreateReadStream

func (UnimplementedDataServer) CreateSendStream

func (UnimplementedDataServer) Delete

func (UnimplementedDataServer) DeleteByPrefix

func (UnimplementedDataServer) Get

func (UnimplementedDataServer) Set

type UnimplementedDbServer

type UnimplementedDbServer struct {
}

UnimplementedDbServer must be embedded to have forward compatible implementations.

func (UnimplementedDbServer) Create

func (UnimplementedDbServer) Drop

func (UnimplementedDbServer) EnsureDb

func (UnimplementedDbServer) Exists

type UnimplementedSysServer

type UnimplementedSysServer struct {
}

UnimplementedSysServer must be embedded to have forward compatible implementations.

func (UnimplementedSysServer) Ping

type UnsafeDataServer

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

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

type UnsafeDbServer

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

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

type UnsafeSysServer

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL