proto

package
v0.0.0-...-dae3534 Latest Latest
Warning

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

 Go to latest Published: May 25, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_proto_data_proto protoreflect.FileDescriptor

Functions

func RegisterCacheRpcServiceServer 

func RegisterCacheRpcServiceServer(s *grpc.Server, srv CacheRpcServiceServer)

Types

type AddCacheReq 

type AddCacheReq struct {
	TableName string     `protobuf:"bytes,1,opt,name=tableName,proto3" json:"tableName,omitempty"`
	Data      *CacheInfo `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*AddCacheReq) Descriptor deprecated 

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

Deprecated: Use AddCacheReq.ProtoReflect.Descriptor instead.

func (*AddCacheReq) GetData 

func (x *AddCacheReq) GetData() *CacheInfo

func (*AddCacheReq) GetTableName 

func (x *AddCacheReq) GetTableName() string

func (*AddCacheReq) MarshalJSON 

func (msg *AddCacheReq) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*AddCacheReq) ProtoMessage 

func (*AddCacheReq) ProtoMessage()

func (*AddCacheReq) ProtoReflect 

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

func (*AddCacheReq) Reset 

func (x *AddCacheReq) Reset()

func (*AddCacheReq) String 

func (x *AddCacheReq) String() string

func (*AddCacheReq) UnmarshalJSON 

func (msg *AddCacheReq) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type CacheInfo 

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

func (*CacheInfo) Descriptor deprecated 

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

Deprecated: Use CacheInfo.ProtoReflect.Descriptor instead.

func (*CacheInfo) GetKey 

func (x *CacheInfo) GetKey() string

func (*CacheInfo) GetValue 

func (x *CacheInfo) GetValue() string

func (*CacheInfo) MarshalJSON 

func (msg *CacheInfo) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*CacheInfo) ProtoMessage 

func (*CacheInfo) ProtoMessage()

func (*CacheInfo) ProtoReflect 

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

func (*CacheInfo) Reset 

func (x *CacheInfo) Reset()

func (*CacheInfo) String 

func (x *CacheInfo) String() string

func (*CacheInfo) UnmarshalJSON 

func (msg *CacheInfo) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type CacheRpcServiceClient 

type CacheRpcServiceClient interface {
	RegisterTable(ctx context.Context, in *RegisterTableReq, opts ...grpc.CallOption) (*RegisterTableResp, error)
	ListTable(ctx context.Context, in *ListTableReq, opts ...grpc.CallOption) (*ListTableResp, error)
	DropTable(ctx context.Context, in *DropTableReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	AddCache(ctx context.Context, in *AddCacheReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetCache(ctx context.Context, in *GetCacheReq, opts ...grpc.CallOption) (*GetCacheResp, error)
	ListCache(ctx context.Context, in *ListCacheReq, opts ...grpc.CallOption) (*ListCacheResp, error)
	DeleteCache(ctx context.Context, in *DeleteCacheReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

CacheRpcServiceClient is the client API for CacheRpcService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCacheRpcServiceClient 

func NewCacheRpcServiceClient(cc grpc.ClientConnInterface) CacheRpcServiceClient

type CacheRpcServiceServer 

type CacheRpcServiceServer interface {
	RegisterTable(context.Context, *RegisterTableReq) (*RegisterTableResp, error)
	ListTable(context.Context, *ListTableReq) (*ListTableResp, error)
	DropTable(context.Context, *DropTableReq) (*emptypb.Empty, error)
	AddCache(context.Context, *AddCacheReq) (*emptypb.Empty, error)
	GetCache(context.Context, *GetCacheReq) (*GetCacheResp, error)
	ListCache(context.Context, *ListCacheReq) (*ListCacheResp, error)
	DeleteCache(context.Context, *DeleteCacheReq) (*emptypb.Empty, error)
}

CacheRpcServiceServer is the server API for CacheRpcService service.

type CacheTable 

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

func (*CacheTable) Descriptor deprecated 

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

Deprecated: Use CacheTable.ProtoReflect.Descriptor instead.

func (*CacheTable) GetExpireTime 

func (x *CacheTable) GetExpireTime() *durationpb.Duration

func (*CacheTable) GetName 

func (x *CacheTable) GetName() string

func (*CacheTable) MarshalJSON 

func (msg *CacheTable) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*CacheTable) ProtoMessage 

func (*CacheTable) ProtoMessage()

func (*CacheTable) ProtoReflect 

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

func (*CacheTable) Reset 

func (x *CacheTable) Reset()

func (*CacheTable) String 

func (x *CacheTable) String() string

func (*CacheTable) UnmarshalJSON 

func (msg *CacheTable) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type DeleteCacheReq 

type DeleteCacheReq struct {
	TableName string `protobuf:"bytes,1,opt,name=tableName,proto3" json:"tableName,omitempty"`
	CacheName string `protobuf:"bytes,2,opt,name=cacheName,proto3" json:"cacheName,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteCacheReq) Descriptor deprecated 

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

Deprecated: Use DeleteCacheReq.ProtoReflect.Descriptor instead.

func (*DeleteCacheReq) GetCacheName 

func (x *DeleteCacheReq) GetCacheName() string

func (*DeleteCacheReq) GetTableName 

func (x *DeleteCacheReq) GetTableName() string

func (*DeleteCacheReq) MarshalJSON 

func (msg *DeleteCacheReq) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*DeleteCacheReq) ProtoMessage 

func (*DeleteCacheReq) ProtoMessage()

func (*DeleteCacheReq) ProtoReflect 

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

func (*DeleteCacheReq) Reset 

func (x *DeleteCacheReq) Reset()

func (*DeleteCacheReq) String 

func (x *DeleteCacheReq) String() string

func (*DeleteCacheReq) UnmarshalJSON 

func (msg *DeleteCacheReq) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type DropTableReq 

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

func (*DropTableReq) Descriptor deprecated 

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

Deprecated: Use DropTableReq.ProtoReflect.Descriptor instead.

func (*DropTableReq) GetName 

func (x *DropTableReq) GetName() string

func (*DropTableReq) MarshalJSON 

func (msg *DropTableReq) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*DropTableReq) ProtoMessage 

func (*DropTableReq) ProtoMessage()

func (*DropTableReq) ProtoReflect 

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

func (*DropTableReq) Reset 

func (x *DropTableReq) Reset()

func (*DropTableReq) String 

func (x *DropTableReq) String() string

func (*DropTableReq) UnmarshalJSON 

func (msg *DropTableReq) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type GetCacheReq 

type GetCacheReq struct {
	TableName string `protobuf:"bytes,1,opt,name=tableName,proto3" json:"tableName,omitempty"`
	CacheName string `protobuf:"bytes,2,opt,name=cacheName,proto3" json:"cacheName,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCacheReq) Descriptor deprecated 

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

Deprecated: Use GetCacheReq.ProtoReflect.Descriptor instead.

func (*GetCacheReq) GetCacheName 

func (x *GetCacheReq) GetCacheName() string

func (*GetCacheReq) GetTableName 

func (x *GetCacheReq) GetTableName() string

func (*GetCacheReq) MarshalJSON 

func (msg *GetCacheReq) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*GetCacheReq) ProtoMessage 

func (*GetCacheReq) ProtoMessage()

func (*GetCacheReq) ProtoReflect 

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

func (*GetCacheReq) Reset 

func (x *GetCacheReq) Reset()

func (*GetCacheReq) String 

func (x *GetCacheReq) String() string

func (*GetCacheReq) UnmarshalJSON 

func (msg *GetCacheReq) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type GetCacheResp 

type GetCacheResp struct {
	Data *CacheInfo `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCacheResp) Descriptor deprecated 

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

Deprecated: Use GetCacheResp.ProtoReflect.Descriptor instead.

func (*GetCacheResp) GetData 

func (x *GetCacheResp) GetData() *CacheInfo

func (*GetCacheResp) MarshalJSON 

func (msg *GetCacheResp) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*GetCacheResp) ProtoMessage 

func (*GetCacheResp) ProtoMessage()

func (*GetCacheResp) ProtoReflect 

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

func (*GetCacheResp) Reset 

func (x *GetCacheResp) Reset()

func (*GetCacheResp) String 

func (x *GetCacheResp) String() string

func (*GetCacheResp) UnmarshalJSON 

func (msg *GetCacheResp) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type ListCacheReq 

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

func (*ListCacheReq) Descriptor deprecated 

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

Deprecated: Use ListCacheReq.ProtoReflect.Descriptor instead.

func (*ListCacheReq) GetTableName 

func (x *ListCacheReq) GetTableName() string

func (*ListCacheReq) MarshalJSON 

func (msg *ListCacheReq) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ListCacheReq) ProtoMessage 

func (*ListCacheReq) ProtoMessage()

func (*ListCacheReq) ProtoReflect 

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

func (*ListCacheReq) Reset 

func (x *ListCacheReq) Reset()

func (*ListCacheReq) String 

func (x *ListCacheReq) String() string

func (*ListCacheReq) UnmarshalJSON 

func (msg *ListCacheReq) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type ListCacheResp 

type ListCacheResp struct {
	List []*CacheInfo `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

func (*ListCacheResp) Descriptor deprecated 

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

Deprecated: Use ListCacheResp.ProtoReflect.Descriptor instead.

func (*ListCacheResp) GetList 

func (x *ListCacheResp) GetList() []*CacheInfo

func (*ListCacheResp) MarshalJSON 

func (msg *ListCacheResp) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ListCacheResp) ProtoMessage 

func (*ListCacheResp) ProtoMessage()

func (*ListCacheResp) ProtoReflect 

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

func (*ListCacheResp) Reset 

func (x *ListCacheResp) Reset()

func (*ListCacheResp) String 

func (x *ListCacheResp) String() string

func (*ListCacheResp) UnmarshalJSON 

func (msg *ListCacheResp) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type ListTableReq 

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

func (*ListTableReq) Descriptor deprecated 

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

Deprecated: Use ListTableReq.ProtoReflect.Descriptor instead.

func (*ListTableReq) GetTableName 

func (x *ListTableReq) GetTableName() string

func (*ListTableReq) MarshalJSON 

func (msg *ListTableReq) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ListTableReq) ProtoMessage 

func (*ListTableReq) ProtoMessage()

func (*ListTableReq) ProtoReflect 

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

func (*ListTableReq) Reset 

func (x *ListTableReq) Reset()

func (*ListTableReq) String 

func (x *ListTableReq) String() string

func (*ListTableReq) UnmarshalJSON 

func (msg *ListTableReq) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type ListTableResp 

type ListTableResp struct {
	TableList []string `protobuf:"bytes,1,rep,name=tableList,proto3" json:"tableList,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTableResp) Descriptor deprecated 

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

Deprecated: Use ListTableResp.ProtoReflect.Descriptor instead.

func (*ListTableResp) GetTableList 

func (x *ListTableResp) GetTableList() []string

func (*ListTableResp) MarshalJSON 

func (msg *ListTableResp) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ListTableResp) ProtoMessage 

func (*ListTableResp) ProtoMessage()

func (*ListTableResp) ProtoReflect 

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

func (*ListTableResp) Reset 

func (x *ListTableResp) Reset()

func (*ListTableResp) String 

func (x *ListTableResp) String() string

func (*ListTableResp) UnmarshalJSON 

func (msg *ListTableResp) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type RegisterTableReq 

type RegisterTableReq struct {
	Data *CacheTable `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterTableReq) Descriptor deprecated 

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

Deprecated: Use RegisterTableReq.ProtoReflect.Descriptor instead.

func (*RegisterTableReq) GetData 

func (x *RegisterTableReq) GetData() *CacheTable

func (*RegisterTableReq) MarshalJSON 

func (msg *RegisterTableReq) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*RegisterTableReq) ProtoMessage 

func (*RegisterTableReq) ProtoMessage()

func (*RegisterTableReq) ProtoReflect 

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

func (*RegisterTableReq) Reset 

func (x *RegisterTableReq) Reset()

func (*RegisterTableReq) String 

func (x *RegisterTableReq) String() string

func (*RegisterTableReq) UnmarshalJSON 

func (msg *RegisterTableReq) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type RegisterTableResp 

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

func (*RegisterTableResp) Descriptor deprecated 

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

Deprecated: Use RegisterTableResp.ProtoReflect.Descriptor instead.

func (*RegisterTableResp) GetName 

func (x *RegisterTableResp) GetName() string

func (*RegisterTableResp) MarshalJSON 

func (msg *RegisterTableResp) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*RegisterTableResp) ProtoMessage 

func (*RegisterTableResp) ProtoMessage()

func (*RegisterTableResp) ProtoReflect 

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

func (*RegisterTableResp) Reset 

func (x *RegisterTableResp) Reset()

func (*RegisterTableResp) String 

func (x *RegisterTableResp) String() string

func (*RegisterTableResp) UnmarshalJSON 

func (msg *RegisterTableResp) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

type UnimplementedCacheRpcServiceServer 

type UnimplementedCacheRpcServiceServer struct {
}

UnimplementedCacheRpcServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCacheRpcServiceServer) AddCache 

func (*UnimplementedCacheRpcServiceServer) AddCache(context.Context, *AddCacheReq) (*emptypb.Empty, error)

func (*UnimplementedCacheRpcServiceServer) DeleteCache 

func (*UnimplementedCacheRpcServiceServer) DeleteCache(context.Context, *DeleteCacheReq) (*emptypb.Empty, error)

func (*UnimplementedCacheRpcServiceServer) DropTable 

func (*UnimplementedCacheRpcServiceServer) DropTable(context.Context, *DropTableReq) (*emptypb.Empty, error)

func (*UnimplementedCacheRpcServiceServer) GetCache 

func (*UnimplementedCacheRpcServiceServer) GetCache(context.Context, *GetCacheReq) (*GetCacheResp, error)

func (*UnimplementedCacheRpcServiceServer) ListCache 

func (*UnimplementedCacheRpcServiceServer) ListCache(context.Context, *ListCacheReq) (*ListCacheResp, error)

func (*UnimplementedCacheRpcServiceServer) ListTable 

func (*UnimplementedCacheRpcServiceServer) ListTable(context.Context, *ListTableReq) (*ListTableResp, error)

func (*UnimplementedCacheRpcServiceServer) RegisterTable 

func (*UnimplementedCacheRpcServiceServer) RegisterTable(context.Context, *RegisterTableReq) (*RegisterTableResp, error)

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.