generate

package
v0.0.8 Latest Latest
Warning

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

 Go to latest Published: Dec 31, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_stele_proto protoreflect.FileDescriptor

Functions

func RegisterSteleServer 

func RegisterSteleServer(s *grpc.Server, srv SteleServer)

Types

type BatchSetKVs 

type BatchSetKVs struct {
	Kvs []*SteleKV `protobuf:"bytes,1,rep,name=kvs,proto3" json:"kvs,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchSetKVs) Descriptor deprecated 

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

Deprecated: Use BatchSetKVs.ProtoReflect.Descriptor instead.

func (*BatchSetKVs) GetKvs 

func (x *BatchSetKVs) GetKvs() []*SteleKV

func (*BatchSetKVs) ProtoMessage 

func (*BatchSetKVs) ProtoMessage()

func (*BatchSetKVs) ProtoReflect 

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

func (*BatchSetKVs) Reset 

func (x *BatchSetKVs) Reset()

func (*BatchSetKVs) String 

func (x *BatchSetKVs) String() string

type Prefix 

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

func (*Prefix) Descriptor deprecated 

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

Deprecated: Use Prefix.ProtoReflect.Descriptor instead.

func (*Prefix) GetPrefix 

func (x *Prefix) GetPrefix() []byte

func (*Prefix) ProtoMessage 

func (*Prefix) ProtoMessage()

func (*Prefix) ProtoReflect 

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

func (*Prefix) Reset 

func (x *Prefix) Reset()

func (*Prefix) String 

func (x *Prefix) String() string

type SteleClient 

type SteleClient interface {
	Set(ctx context.Context, in *SteleKV, opts ...grpc.CallOption) (*SteleStatus, error)
	Get(ctx context.Context, in *SteleK, opts ...grpc.CallOption) (*SteleVal, error)
	Delete(ctx context.Context, in *SteleK, opts ...grpc.CallOption) (*SteleStatus, error)
	// Batch Insertion Failure Rollback. 批量插入 失败 回滚
	BatchSet(ctx context.Context, in *BatchSetKVs, opts ...grpc.CallOption) (*SteleStatus, error)
	// Batch Get. 批量查询
	BatchGet(ctx context.Context, in *SteleKS, opts ...grpc.CallOption) (*BatchSetKVs, error)
	// Iterate over all keys. 遍历所有Key
	IterateKeys(ctx context.Context, in *SteleRequest, opts ...grpc.CallOption) (*SteleKS, error)
	// Iterate over keys and values. 遍历Key和value
	IterateKeysAndValues(ctx context.Context, in *SteleRequest, opts ...grpc.CallOption) (*BatchSetKVs, error)
	// Prefix Scan. 前缀扫描
	PrefixScan(ctx context.Context, in *Prefix, opts ...grpc.CallOption) (*BatchSetKVs, error)
}

SteleClient is the client API for Stele service.

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

func NewSteleClient 

func NewSteleClient(cc grpc.ClientConnInterface) SteleClient

type SteleK 

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

func (*SteleK) Descriptor deprecated 

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

Deprecated: Use SteleK.ProtoReflect.Descriptor instead.

func (*SteleK) GetKey 

func (x *SteleK) GetKey() []byte

func (*SteleK) ProtoMessage 

func (*SteleK) ProtoMessage()

func (*SteleK) ProtoReflect 

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

func (*SteleK) Reset 

func (x *SteleK) Reset()

func (*SteleK) String 

func (x *SteleK) String() string

type SteleKS 

type SteleKS struct {
	Keys [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*SteleKS) Descriptor deprecated 

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

Deprecated: Use SteleKS.ProtoReflect.Descriptor instead.

func (*SteleKS) GetKeys 

func (x *SteleKS) GetKeys() [][]byte

func (*SteleKS) ProtoMessage 

func (*SteleKS) ProtoMessage()

func (*SteleKS) ProtoReflect 

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

func (*SteleKS) Reset 

func (x *SteleKS) Reset()

func (*SteleKS) String 

func (x *SteleKS) String() string

type SteleKV 

type SteleKV struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Val []byte `protobuf:"bytes,2,opt,name=val,proto3" json:"val,omitempty"`
	Ttl int64  `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*SteleKV) Descriptor deprecated 

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

Deprecated: Use SteleKV.ProtoReflect.Descriptor instead.

func (*SteleKV) GetKey 

func (x *SteleKV) GetKey() []byte

func (*SteleKV) GetTtl 

func (x *SteleKV) GetTtl() int64

func (*SteleKV) GetVal 

func (x *SteleKV) GetVal() []byte

func (*SteleKV) ProtoMessage 

func (*SteleKV) ProtoMessage()

func (*SteleKV) ProtoReflect 

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

func (*SteleKV) Reset 

func (x *SteleKV) Reset()

func (*SteleKV) String 

func (x *SteleKV) String() string

type SteleRequest 

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

func (*SteleRequest) Descriptor deprecated 

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

Deprecated: Use SteleRequest.ProtoReflect.Descriptor instead.

func (*SteleRequest) ProtoMessage 

func (*SteleRequest) ProtoMessage()

func (*SteleRequest) ProtoReflect 

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

func (*SteleRequest) Reset 

func (x *SteleRequest) Reset()

func (*SteleRequest) String 

func (x *SteleRequest) String() string

type SteleServer 

type SteleServer interface {
	Set(context.Context, *SteleKV) (*SteleStatus, error)
	Get(context.Context, *SteleK) (*SteleVal, error)
	Delete(context.Context, *SteleK) (*SteleStatus, error)
	// Batch Insertion Failure Rollback. 批量插入 失败 回滚
	BatchSet(context.Context, *BatchSetKVs) (*SteleStatus, error)
	// Batch Get. 批量查询
	BatchGet(context.Context, *SteleKS) (*BatchSetKVs, error)
	// Iterate over all keys. 遍历所有Key
	IterateKeys(context.Context, *SteleRequest) (*SteleKS, error)
	// Iterate over keys and values. 遍历Key和value
	IterateKeysAndValues(context.Context, *SteleRequest) (*BatchSetKVs, error)
	// Prefix Scan. 前缀扫描
	PrefixScan(context.Context, *Prefix) (*BatchSetKVs, error)
}

SteleServer is the server API for Stele service.

type SteleStatus 

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

func (*SteleStatus) Descriptor deprecated 

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

Deprecated: Use SteleStatus.ProtoReflect.Descriptor instead.

func (*SteleStatus) ProtoMessage 

func (*SteleStatus) ProtoMessage()

func (*SteleStatus) ProtoReflect 

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

func (*SteleStatus) Reset 

func (x *SteleStatus) Reset()

func (*SteleStatus) String 

func (x *SteleStatus) String() string

type SteleVal 

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

func (*SteleVal) Descriptor deprecated 

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

Deprecated: Use SteleVal.ProtoReflect.Descriptor instead.

func (*SteleVal) GetVal 

func (x *SteleVal) GetVal() []byte

func (*SteleVal) ProtoMessage 

func (*SteleVal) ProtoMessage()

func (*SteleVal) ProtoReflect 

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

func (*SteleVal) Reset 

func (x *SteleVal) Reset()

func (*SteleVal) String 

func (x *SteleVal) String() string

type UnimplementedSteleServer 

type UnimplementedSteleServer struct {
}

UnimplementedSteleServer can be embedded to have forward compatible implementations.

func (*UnimplementedSteleServer) BatchGet 

func (*UnimplementedSteleServer) BatchGet(context.Context, *SteleKS) (*BatchSetKVs, error)

func (*UnimplementedSteleServer) BatchSet 

func (*UnimplementedSteleServer) BatchSet(context.Context, *BatchSetKVs) (*SteleStatus, error)

func (*UnimplementedSteleServer) Delete added in v0.0.5 

func (*UnimplementedSteleServer) Delete(context.Context, *SteleK) (*SteleStatus, error)

func (*UnimplementedSteleServer) Get 

func (*UnimplementedSteleServer) Get(context.Context, *SteleK) (*SteleVal, error)

func (*UnimplementedSteleServer) IterateKeys 

func (*UnimplementedSteleServer) IterateKeys(context.Context, *SteleRequest) (*SteleKS, error)

func (*UnimplementedSteleServer) IterateKeysAndValues 

func (*UnimplementedSteleServer) IterateKeysAndValues(context.Context, *SteleRequest) (*BatchSetKVs, error)

func (*UnimplementedSteleServer) PrefixScan 

func (*UnimplementedSteleServer) PrefixScan(context.Context, *Prefix) (*BatchSetKVs, error)

func (*UnimplementedSteleServer) Set 

func (*UnimplementedSteleServer) Set(context.Context, *SteleKV) (*SteleStatus, 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.