proxypb

package
v0.0.0-...-9c7057b Latest Latest
Warning

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

 Go to latest Published: Dec 10, 2018 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AdminGrpcServiceDesc = &adminGrpcServiceDesc{&_Admin_serviceDesc}
View Source 
var AdminHttpServiceDesc = &adminHttpServiceDesc{&_Admin_Http_serviceDesc}
View Source 
var ProxyGrpcServiceDesc = &proxyGrpcServiceDesc{&_Proxy_serviceDesc}
View Source 
var ProxyHttpServiceDesc = &proxyHttpServiceDesc{&_Proxy_Http_serviceDesc}

Functions

func RegisterAdminServer 

func RegisterAdminServer(s *grpc1.Server, srv AdminServer)

func RegisterProxyServer 

func RegisterProxyServer(s *grpc1.Server, srv ProxyServer)

Types

type AdminClient 

type AdminClient interface {
	Info(ctx context2.Context, in *InfoReq, opts ...grpc1.CallOption) (*InfoRsp, error)
}

AdminClient is the client API for Admin service.

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

func NewAdminClient 

func NewAdminClient(cc *grpc1.ClientConn) AdminClient

type AdminGrpcClient 

type AdminGrpcClient interface {
	Info(ctx context.Context, in *InfoReq, opts ...tropt.CallOption) (*InfoRsp, error)
}

func NewAdminGrpcClient 

func NewAdminGrpcClient(cc tr.ClientConn) AdminGrpcClient

type AdminHttpClient 

type AdminHttpClient interface {
	Info(ctx context1.Context, in *InfoReq, opts ...tropt1.CallOption) (*InfoRsp, error)
}

func NewAdminHttpClient 

func NewAdminHttpClient(cc tr1.ClientConn) AdminHttpClient

type AdminServer 

type AdminServer interface {
	Info(context2.Context, *InfoReq) (*InfoRsp, error)
}

AdminServer is the server API for Admin service.

type IndexDocReq 

type IndexDocReq struct {
	TraceID              string       `protobuf:"bytes,1,opt,name=traceID,proto3" json:"traceID,omitempty"`
	Namespace            string       `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Doc                  *pb.Document `protobuf:"bytes,3,opt,name=doc,proto3" json:"doc,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*IndexDocReq) Descriptor 

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

func (*IndexDocReq) GetDoc 

func (m *IndexDocReq) GetDoc() *pb.Document

func (*IndexDocReq) GetNamespace 

func (m *IndexDocReq) GetNamespace() string

func (*IndexDocReq) GetTraceID 

func (m *IndexDocReq) GetTraceID() string

func (*IndexDocReq) ProtoMessage 

func (*IndexDocReq) ProtoMessage()

func (*IndexDocReq) Reset 

func (m *IndexDocReq) Reset()

func (*IndexDocReq) String 

func (m *IndexDocReq) String() string

func (*IndexDocReq) XXX_DiscardUnknown 

func (m *IndexDocReq) XXX_DiscardUnknown()

func (*IndexDocReq) XXX_Marshal 

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

func (*IndexDocReq) XXX_Merge 

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

func (*IndexDocReq) XXX_Size 

func (m *IndexDocReq) XXX_Size() int

func (*IndexDocReq) XXX_Unmarshal 

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

type IndexDocRsp 

type IndexDocRsp struct {
	TraceID              string   `protobuf:"bytes,1,opt,name=traceID,proto3" json:"traceID,omitempty"`
	DocID                string   `protobuf:"bytes,2,opt,name=docID,proto3" json:"docID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexDocRsp) Descriptor 

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

func (*IndexDocRsp) GetDocID 

func (m *IndexDocRsp) GetDocID() string

func (*IndexDocRsp) GetTraceID 

func (m *IndexDocRsp) GetTraceID() string

func (*IndexDocRsp) ProtoMessage 

func (*IndexDocRsp) ProtoMessage()

func (*IndexDocRsp) Reset 

func (m *IndexDocRsp) Reset()

func (*IndexDocRsp) String 

func (m *IndexDocRsp) String() string

func (*IndexDocRsp) XXX_DiscardUnknown 

func (m *IndexDocRsp) XXX_DiscardUnknown()

func (*IndexDocRsp) XXX_Marshal 

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

func (*IndexDocRsp) XXX_Merge 

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

func (*IndexDocRsp) XXX_Size 

func (m *IndexDocRsp) XXX_Size() int

func (*IndexDocRsp) XXX_Unmarshal 

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

type InfoReq 

type InfoReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InfoReq) Descriptor 

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

func (*InfoReq) ProtoMessage 

func (*InfoReq) ProtoMessage()

func (*InfoReq) Reset 

func (m *InfoReq) Reset()

func (*InfoReq) String 

func (m *InfoReq) String() string

func (*InfoReq) XXX_DiscardUnknown 

func (m *InfoReq) XXX_DiscardUnknown()

func (*InfoReq) XXX_Marshal 

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

func (*InfoReq) XXX_Merge 

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

func (*InfoReq) XXX_Size 

func (m *InfoReq) XXX_Size() int

func (*InfoReq) XXX_Unmarshal 

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

type InfoRsp 

type InfoRsp struct {
	Tables               map[string]*InfoRsp_Table `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*InfoRsp) Descriptor 

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

func (*InfoRsp) GetTables 

func (m *InfoRsp) GetTables() map[string]*InfoRsp_Table

func (*InfoRsp) ProtoMessage 

func (*InfoRsp) ProtoMessage()

func (*InfoRsp) Reset 

func (m *InfoRsp) Reset()

func (*InfoRsp) String 

func (m *InfoRsp) String() string

func (*InfoRsp) XXX_DiscardUnknown 

func (m *InfoRsp) XXX_DiscardUnknown()

func (*InfoRsp) XXX_Marshal 

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

func (*InfoRsp) XXX_Merge 

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

func (*InfoRsp) XXX_Size 

func (m *InfoRsp) XXX_Size() int

func (*InfoRsp) XXX_Unmarshal 

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

type InfoRsp_Shard 

type InfoRsp_Shard struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Node                 string   `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InfoRsp_Shard) Descriptor 

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

func (*InfoRsp_Shard) GetID 

func (m *InfoRsp_Shard) GetID() string

func (*InfoRsp_Shard) GetNode 

func (m *InfoRsp_Shard) GetNode() string

func (*InfoRsp_Shard) ProtoMessage 

func (*InfoRsp_Shard) ProtoMessage()

func (*InfoRsp_Shard) Reset 

func (m *InfoRsp_Shard) Reset()

func (*InfoRsp_Shard) String 

func (m *InfoRsp_Shard) String() string

func (*InfoRsp_Shard) XXX_DiscardUnknown 

func (m *InfoRsp_Shard) XXX_DiscardUnknown()

func (*InfoRsp_Shard) XXX_Marshal 

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

func (*InfoRsp_Shard) XXX_Merge 

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

func (*InfoRsp_Shard) XXX_Size 

func (m *InfoRsp_Shard) XXX_Size() int

func (*InfoRsp_Shard) XXX_Unmarshal 

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

type InfoRsp_Table 

type InfoRsp_Table struct {
	Namespace            string           `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ShardNum             uint32           `protobuf:"varint,2,opt,name=shardNum,proto3" json:"shardNum,omitempty"`
	ReplicaFactor        uint32           `protobuf:"varint,3,opt,name=replicaFactor,proto3" json:"replicaFactor,omitempty"`
	Shards               []*InfoRsp_Shard `protobuf:"bytes,4,rep,name=shards,proto3" json:"shards,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*InfoRsp_Table) Descriptor 

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

func (*InfoRsp_Table) GetNamespace 

func (m *InfoRsp_Table) GetNamespace() string

func (*InfoRsp_Table) GetReplicaFactor 

func (m *InfoRsp_Table) GetReplicaFactor() uint32

func (*InfoRsp_Table) GetShardNum 

func (m *InfoRsp_Table) GetShardNum() uint32

func (*InfoRsp_Table) GetShards 

func (m *InfoRsp_Table) GetShards() []*InfoRsp_Shard

func (*InfoRsp_Table) ProtoMessage 

func (*InfoRsp_Table) ProtoMessage()

func (*InfoRsp_Table) Reset 

func (m *InfoRsp_Table) Reset()

func (*InfoRsp_Table) String 

func (m *InfoRsp_Table) String() string

func (*InfoRsp_Table) XXX_DiscardUnknown 

func (m *InfoRsp_Table) XXX_DiscardUnknown()

func (*InfoRsp_Table) XXX_Marshal 

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

func (*InfoRsp_Table) XXX_Merge 

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

func (*InfoRsp_Table) XXX_Size 

func (m *InfoRsp_Table) XXX_Size() int

func (*InfoRsp_Table) XXX_Unmarshal 

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

type ProxyClient 

type ProxyClient interface {
	IndexDoc(ctx context2.Context, in *IndexDocReq, opts ...grpc1.CallOption) (*IndexDocRsp, error)
	RemoveDoc(ctx context2.Context, in *RemoveDocReq, opts ...grpc1.CallOption) (*RemoveDocRsp, error)
	Search(ctx context2.Context, in *SearchReq, opts ...grpc1.CallOption) (*SearchRsp, error)
}

ProxyClient is the client API for Proxy service.

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

func NewProxyClient 

func NewProxyClient(cc *grpc1.ClientConn) ProxyClient

type ProxyGrpcClient 

type ProxyGrpcClient interface {
	IndexDoc(ctx context.Context, in *IndexDocReq, opts ...tropt.CallOption) (*IndexDocRsp, error)
	RemoveDoc(ctx context.Context, in *RemoveDocReq, opts ...tropt.CallOption) (*RemoveDocRsp, error)
	Search(ctx context.Context, in *SearchReq, opts ...tropt.CallOption) (*SearchRsp, error)
}

func NewProxyGrpcClient 

func NewProxyGrpcClient(cc tr.ClientConn) ProxyGrpcClient

type ProxyHttpClient 

type ProxyHttpClient interface {
	IndexDoc(ctx context1.Context, in *IndexDocReq, opts ...tropt1.CallOption) (*IndexDocRsp, error)
	RemoveDoc(ctx context1.Context, in *RemoveDocReq, opts ...tropt1.CallOption) (*RemoveDocRsp, error)
	Search(ctx context1.Context, in *SearchReq, opts ...tropt1.CallOption) (*SearchRsp, error)
}

func NewProxyHttpClient 

func NewProxyHttpClient(cc tr1.ClientConn) ProxyHttpClient

type ProxyServer 

type ProxyServer interface {
	IndexDoc(context2.Context, *IndexDocReq) (*IndexDocRsp, error)
	RemoveDoc(context2.Context, *RemoveDocReq) (*RemoveDocRsp, error)
	Search(context2.Context, *SearchReq) (*SearchRsp, error)
}

ProxyServer is the server API for Proxy service.

type RemoveDocReq 

type RemoveDocReq struct {
	TraceID              string   `protobuf:"bytes,1,opt,name=traceID,proto3" json:"traceID,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	DocID                string   `protobuf:"bytes,3,opt,name=docID,proto3" json:"docID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveDocReq) Descriptor 

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

func (*RemoveDocReq) GetDocID 

func (m *RemoveDocReq) GetDocID() string

func (*RemoveDocReq) GetNamespace 

func (m *RemoveDocReq) GetNamespace() string

func (*RemoveDocReq) GetTraceID 

func (m *RemoveDocReq) GetTraceID() string

func (*RemoveDocReq) ProtoMessage 

func (*RemoveDocReq) ProtoMessage()

func (*RemoveDocReq) Reset 

func (m *RemoveDocReq) Reset()

func (*RemoveDocReq) String 

func (m *RemoveDocReq) String() string

func (*RemoveDocReq) XXX_DiscardUnknown 

func (m *RemoveDocReq) XXX_DiscardUnknown()

func (*RemoveDocReq) XXX_Marshal 

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

func (*RemoveDocReq) XXX_Merge 

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

func (*RemoveDocReq) XXX_Size 

func (m *RemoveDocReq) XXX_Size() int

func (*RemoveDocReq) XXX_Unmarshal 

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

type RemoveDocRsp 

type RemoveDocRsp struct {
	TraceID              string   `protobuf:"bytes,1,opt,name=traceID,proto3" json:"traceID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveDocRsp) Descriptor 

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

func (*RemoveDocRsp) GetTraceID 

func (m *RemoveDocRsp) GetTraceID() string

func (*RemoveDocRsp) ProtoMessage 

func (*RemoveDocRsp) ProtoMessage()

func (*RemoveDocRsp) Reset 

func (m *RemoveDocRsp) Reset()

func (*RemoveDocRsp) String 

func (m *RemoveDocRsp) String() string

func (*RemoveDocRsp) XXX_DiscardUnknown 

func (m *RemoveDocRsp) XXX_DiscardUnknown()

func (*RemoveDocRsp) XXX_Marshal 

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

func (*RemoveDocRsp) XXX_Merge 

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

func (*RemoveDocRsp) XXX_Size 

func (m *RemoveDocRsp) XXX_Size() int

func (*RemoveDocRsp) XXX_Unmarshal 

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

type SearchReq 

type SearchReq struct {
	TraceID              string    `protobuf:"bytes,1,opt,name=traceID,proto3" json:"traceID,omitempty"`
	Namespace            string    `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Query                *pb.Query `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	Start                uint64    `protobuf:"varint,4,opt,name=start,proto3" json:"start,omitempty"`
	Count                uint32    `protobuf:"varint,5,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*SearchReq) Descriptor 

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

func (*SearchReq) GetCount 

func (m *SearchReq) GetCount() uint32

func (*SearchReq) GetNamespace 

func (m *SearchReq) GetNamespace() string

func (*SearchReq) GetQuery 

func (m *SearchReq) GetQuery() *pb.Query

func (*SearchReq) GetStart 

func (m *SearchReq) GetStart() uint64

func (*SearchReq) GetTraceID 

func (m *SearchReq) GetTraceID() string

func (*SearchReq) ProtoMessage 

func (*SearchReq) ProtoMessage()

func (*SearchReq) Reset 

func (m *SearchReq) Reset()

func (*SearchReq) String 

func (m *SearchReq) String() string

func (*SearchReq) XXX_DiscardUnknown 

func (m *SearchReq) XXX_DiscardUnknown()

func (*SearchReq) XXX_Marshal 

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

func (*SearchReq) XXX_Merge 

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

func (*SearchReq) XXX_Size 

func (m *SearchReq) XXX_Size() int

func (*SearchReq) XXX_Unmarshal 

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

type SearchRsp 

type SearchRsp struct {
	TraceID              string         `protobuf:"bytes,1,opt,name=traceID,proto3" json:"traceID,omitempty"`
	Query                *pb.Query      `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	Docs                 []*pb.Document `protobuf:"bytes,3,rep,name=docs,proto3" json:"docs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*SearchRsp) Descriptor 

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

func (*SearchRsp) GetDocs 

func (m *SearchRsp) GetDocs() []*pb.Document

func (*SearchRsp) GetQuery 

func (m *SearchRsp) GetQuery() *pb.Query

func (*SearchRsp) GetTraceID 

func (m *SearchRsp) GetTraceID() string

func (*SearchRsp) ProtoMessage 

func (*SearchRsp) ProtoMessage()

func (*SearchRsp) Reset 

func (m *SearchRsp) Reset()

func (*SearchRsp) String 

func (m *SearchRsp) String() string

func (*SearchRsp) XXX_DiscardUnknown 

func (m *SearchRsp) XXX_DiscardUnknown()

func (*SearchRsp) XXX_Marshal 

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

func (*SearchRsp) XXX_Merge 

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

func (*SearchRsp) XXX_Size 

func (m *SearchRsp) XXX_Size() int

func (*SearchRsp) XXX_Unmarshal 

func (m *SearchRsp) 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.