ankadbpb

package
v0.2.4 Latest Latest
Warning

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

 Go to latest Published: Oct 29, 2018 License: Apache-2.0 Imports: 5 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterAnkaDBServServer 

func RegisterAnkaDBServServer(s *grpc.Server, srv AnkaDBServServer)

Types

type AnkaDBServClient 

type AnkaDBServClient interface {
	Query(ctx context.Context, in *Query, opts ...grpc.CallOption) (*ReplyQuery, error)
	QueryStream(ctx context.Context, in *Query, opts ...grpc.CallOption) (AnkaDBServ_QueryStreamClient, error)
}

AnkaDBServClient is the client API for AnkaDBServ service.

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

func NewAnkaDBServClient 

func NewAnkaDBServClient(cc *grpc.ClientConn) AnkaDBServClient

type AnkaDBServServer 

type AnkaDBServServer interface {
	Query(context.Context, *Query) (*ReplyQuery, error)
	QueryStream(*Query, AnkaDBServ_QueryStreamServer) error
}

AnkaDBServServer is the server API for AnkaDBServ service.

type AnkaDBServ_QueryStreamClient 

type AnkaDBServ_QueryStreamClient interface {
	Recv() (*ReplyQuery, error)
	grpc.ClientStream
}

type AnkaDBServ_QueryStreamServer 

type AnkaDBServ_QueryStreamServer interface {
	Send(*ReplyQuery) error
	grpc.ServerStream
}

type Query 

type Query struct {
	QueryData            string   `protobuf:"bytes,1,opt,name=queryData,proto3" json:"queryData,omitempty"`
	VarData              string   `protobuf:"bytes,2,opt,name=varData,proto3" json:"varData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Query) Descriptor 

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

func (*Query) GetQueryData 

func (m *Query) GetQueryData() string

func (*Query) GetVarData 

func (m *Query) GetVarData() string

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) String 

func (m *Query) String() string

func (*Query) XXX_DiscardUnknown 

func (m *Query) XXX_DiscardUnknown()

func (*Query) XXX_Marshal 

func (m *Query) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Query) XXX_Merge 

func (dst *Query) XXX_Merge(src proto.Message)

func (*Query) XXX_Size 

func (m *Query) XXX_Size() int

func (*Query) XXX_Unmarshal 

func (m *Query) XXX_Unmarshal(b []byte) error

type ReplyQuery 

type ReplyQuery struct {
	Err                  string   `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Result               string   `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplyQuery) Descriptor 

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

func (*ReplyQuery) GetErr 

func (m *ReplyQuery) GetErr() string

func (*ReplyQuery) GetResult 

func (m *ReplyQuery) GetResult() string

func (*ReplyQuery) ProtoMessage 

func (*ReplyQuery) ProtoMessage()

func (*ReplyQuery) Reset 

func (m *ReplyQuery) Reset()

func (*ReplyQuery) String 

func (m *ReplyQuery) String() string

func (*ReplyQuery) XXX_DiscardUnknown 

func (m *ReplyQuery) XXX_DiscardUnknown()

func (*ReplyQuery) XXX_Marshal 

func (m *ReplyQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplyQuery) XXX_Merge 

func (dst *ReplyQuery) XXX_Merge(src proto.Message)

func (*ReplyQuery) XXX_Size 

func (m *ReplyQuery) XXX_Size() int

func (*ReplyQuery) XXX_Unmarshal 

func (m *ReplyQuery) XXX_Unmarshal(b []byte) error

type Snapshot 

type Snapshot struct {
	SnapshotID           int64    `protobuf:"varint,1,opt,name=snapshotID,proto3" json:"snapshotID,omitempty"`
	Keys                 []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	CreateTime           int64    `protobuf:"varint,3,opt,name=createTime,proto3" json:"createTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Snapshot) Descriptor 

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

func (*Snapshot) GetCreateTime 

func (m *Snapshot) GetCreateTime() int64

func (*Snapshot) GetKeys 

func (m *Snapshot) GetKeys() []string

func (*Snapshot) GetSnapshotID 

func (m *Snapshot) GetSnapshotID() int64

func (*Snapshot) ProtoMessage 

func (*Snapshot) ProtoMessage()

func (*Snapshot) Reset 

func (m *Snapshot) Reset()

func (*Snapshot) String 

func (m *Snapshot) String() string

func (*Snapshot) XXX_DiscardUnknown 

func (m *Snapshot) XXX_DiscardUnknown()

func (*Snapshot) XXX_Marshal 

func (m *Snapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Snapshot) XXX_Merge 

func (dst *Snapshot) XXX_Merge(src proto.Message)

func (*Snapshot) XXX_Size 

func (m *Snapshot) XXX_Size() int

func (*Snapshot) XXX_Unmarshal 

func (m *Snapshot) XXX_Unmarshal(b []byte) error

type SnapshotMgr 

type SnapshotMgr struct {
	MaxSnapshotID        int64    `protobuf:"varint,1,opt,name=maxSnapshotID,proto3" json:"maxSnapshotID,omitempty"`
	Snapshots            []int64  `protobuf:"varint,2,rep,packed,name=snapshots,proto3" json:"snapshots,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SnapshotMgr) Descriptor 

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

func (*SnapshotMgr) GetMaxSnapshotID 

func (m *SnapshotMgr) GetMaxSnapshotID() int64

func (*SnapshotMgr) GetSnapshots 

func (m *SnapshotMgr) GetSnapshots() []int64

func (*SnapshotMgr) ProtoMessage 

func (*SnapshotMgr) ProtoMessage()

func (*SnapshotMgr) Reset 

func (m *SnapshotMgr) Reset()

func (*SnapshotMgr) String 

func (m *SnapshotMgr) String() string

func (*SnapshotMgr) XXX_DiscardUnknown 

func (m *SnapshotMgr) XXX_DiscardUnknown()

func (*SnapshotMgr) XXX_Marshal 

func (m *SnapshotMgr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SnapshotMgr) XXX_Merge 

func (dst *SnapshotMgr) XXX_Merge(src proto.Message)

func (*SnapshotMgr) XXX_Size 

func (m *SnapshotMgr) XXX_Size() int

func (*SnapshotMgr) XXX_Unmarshal 

func (m *SnapshotMgr) XXX_Unmarshal(b []byte) 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.