Documentation ¶
Index ¶
- func RegisterAPIServer(s *grpc.Server, srv APIServer)
- type APIClient
- type APIServer
- type GetThreadReply
- func (*GetThreadReply) Descriptor() ([]byte, []int)
- func (m *GetThreadReply) GetID() []byte
- func (m *GetThreadReply) GetIsDB() bool
- func (m *GetThreadReply) GetName() string
- func (*GetThreadReply) ProtoMessage()
- func (m *GetThreadReply) Reset()
- func (m *GetThreadReply) String() string
- func (m *GetThreadReply) XXX_DiscardUnknown()
- func (m *GetThreadReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetThreadReply) XXX_Merge(src proto.Message)
- func (m *GetThreadReply) XXX_Size() int
- func (m *GetThreadReply) XXX_Unmarshal(b []byte) error
- type GetThreadRequest
- func (*GetThreadRequest) Descriptor() ([]byte, []int)
- func (m *GetThreadRequest) GetName() string
- func (*GetThreadRequest) ProtoMessage()
- func (m *GetThreadRequest) Reset()
- func (m *GetThreadRequest) String() string
- func (m *GetThreadRequest) XXX_DiscardUnknown()
- func (m *GetThreadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetThreadRequest) XXX_Merge(src proto.Message)
- func (m *GetThreadRequest) XXX_Size() int
- func (m *GetThreadRequest) XXX_Unmarshal(b []byte) error
- type ListThreadsReply
- func (*ListThreadsReply) Descriptor() ([]byte, []int)
- func (m *ListThreadsReply) GetList() []*GetThreadReply
- func (*ListThreadsReply) ProtoMessage()
- func (m *ListThreadsReply) Reset()
- func (m *ListThreadsReply) String() string
- func (m *ListThreadsReply) XXX_DiscardUnknown()
- func (m *ListThreadsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListThreadsReply) XXX_Merge(src proto.Message)
- func (m *ListThreadsReply) XXX_Size() int
- func (m *ListThreadsReply) XXX_Unmarshal(b []byte) error
- type ListThreadsRequest
- func (*ListThreadsRequest) Descriptor() ([]byte, []int)
- func (*ListThreadsRequest) ProtoMessage()
- func (m *ListThreadsRequest) Reset()
- func (m *ListThreadsRequest) String() string
- func (m *ListThreadsRequest) XXX_DiscardUnknown()
- func (m *ListThreadsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListThreadsRequest) XXX_Merge(src proto.Message)
- func (m *ListThreadsRequest) XXX_Size() int
- func (m *ListThreadsRequest) XXX_Unmarshal(b []byte) error
- type UnimplementedAPIServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterAPIServer ¶
Types ¶
type APIClient ¶
type APIClient interface { GetThread(ctx context.Context, in *GetThreadRequest, opts ...grpc.CallOption) (*GetThreadReply, error) ListThreads(ctx context.Context, in *ListThreadsRequest, opts ...grpc.CallOption) (*ListThreadsReply, error) }
APIClient is the client API for API service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAPIClient ¶
func NewAPIClient(cc *grpc.ClientConn) APIClient
type APIServer ¶
type APIServer interface { GetThread(context.Context, *GetThreadRequest) (*GetThreadReply, error) ListThreads(context.Context, *ListThreadsRequest) (*ListThreadsReply, error) }
APIServer is the server API for API service.
type GetThreadReply ¶
type GetThreadReply struct { ID []byte `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` IsDB bool `protobuf:"varint,3,opt,name=isDB,proto3" json:"isDB,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetThreadReply) Descriptor ¶
func (*GetThreadReply) Descriptor() ([]byte, []int)
func (*GetThreadReply) GetID ¶
func (m *GetThreadReply) GetID() []byte
func (*GetThreadReply) GetIsDB ¶ added in v1.0.2
func (m *GetThreadReply) GetIsDB() bool
func (*GetThreadReply) GetName ¶
func (m *GetThreadReply) GetName() string
func (*GetThreadReply) ProtoMessage ¶
func (*GetThreadReply) ProtoMessage()
func (*GetThreadReply) Reset ¶
func (m *GetThreadReply) Reset()
func (*GetThreadReply) String ¶
func (m *GetThreadReply) String() string
func (*GetThreadReply) XXX_DiscardUnknown ¶
func (m *GetThreadReply) XXX_DiscardUnknown()
func (*GetThreadReply) XXX_Marshal ¶
func (m *GetThreadReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetThreadReply) XXX_Merge ¶
func (m *GetThreadReply) XXX_Merge(src proto.Message)
func (*GetThreadReply) XXX_Size ¶
func (m *GetThreadReply) XXX_Size() int
func (*GetThreadReply) XXX_Unmarshal ¶
func (m *GetThreadReply) XXX_Unmarshal(b []byte) error
type GetThreadRequest ¶
type GetThreadRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetThreadRequest) Descriptor ¶
func (*GetThreadRequest) Descriptor() ([]byte, []int)
func (*GetThreadRequest) GetName ¶
func (m *GetThreadRequest) GetName() string
func (*GetThreadRequest) ProtoMessage ¶
func (*GetThreadRequest) ProtoMessage()
func (*GetThreadRequest) Reset ¶
func (m *GetThreadRequest) Reset()
func (*GetThreadRequest) String ¶
func (m *GetThreadRequest) String() string
func (*GetThreadRequest) XXX_DiscardUnknown ¶
func (m *GetThreadRequest) XXX_DiscardUnknown()
func (*GetThreadRequest) XXX_Marshal ¶
func (m *GetThreadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetThreadRequest) XXX_Merge ¶
func (m *GetThreadRequest) XXX_Merge(src proto.Message)
func (*GetThreadRequest) XXX_Size ¶
func (m *GetThreadRequest) XXX_Size() int
func (*GetThreadRequest) XXX_Unmarshal ¶
func (m *GetThreadRequest) XXX_Unmarshal(b []byte) error
type ListThreadsReply ¶
type ListThreadsReply struct { List []*GetThreadReply `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListThreadsReply) Descriptor ¶
func (*ListThreadsReply) Descriptor() ([]byte, []int)
func (*ListThreadsReply) GetList ¶
func (m *ListThreadsReply) GetList() []*GetThreadReply
func (*ListThreadsReply) ProtoMessage ¶
func (*ListThreadsReply) ProtoMessage()
func (*ListThreadsReply) Reset ¶
func (m *ListThreadsReply) Reset()
func (*ListThreadsReply) String ¶
func (m *ListThreadsReply) String() string
func (*ListThreadsReply) XXX_DiscardUnknown ¶
func (m *ListThreadsReply) XXX_DiscardUnknown()
func (*ListThreadsReply) XXX_Marshal ¶
func (m *ListThreadsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListThreadsReply) XXX_Merge ¶
func (m *ListThreadsReply) XXX_Merge(src proto.Message)
func (*ListThreadsReply) XXX_Size ¶
func (m *ListThreadsReply) XXX_Size() int
func (*ListThreadsReply) XXX_Unmarshal ¶
func (m *ListThreadsReply) XXX_Unmarshal(b []byte) error
type ListThreadsRequest ¶
type ListThreadsRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListThreadsRequest) Descriptor ¶
func (*ListThreadsRequest) Descriptor() ([]byte, []int)
func (*ListThreadsRequest) ProtoMessage ¶
func (*ListThreadsRequest) ProtoMessage()
func (*ListThreadsRequest) Reset ¶
func (m *ListThreadsRequest) Reset()
func (*ListThreadsRequest) String ¶
func (m *ListThreadsRequest) String() string
func (*ListThreadsRequest) XXX_DiscardUnknown ¶
func (m *ListThreadsRequest) XXX_DiscardUnknown()
func (*ListThreadsRequest) XXX_Marshal ¶
func (m *ListThreadsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListThreadsRequest) XXX_Merge ¶
func (m *ListThreadsRequest) XXX_Merge(src proto.Message)
func (*ListThreadsRequest) XXX_Size ¶
func (m *ListThreadsRequest) XXX_Size() int
func (*ListThreadsRequest) XXX_Unmarshal ¶
func (m *ListThreadsRequest) XXX_Unmarshal(b []byte) error
type UnimplementedAPIServer ¶
type UnimplementedAPIServer struct { }
UnimplementedAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedAPIServer) GetThread ¶
func (*UnimplementedAPIServer) GetThread(ctx context.Context, req *GetThreadRequest) (*GetThreadReply, error)
func (*UnimplementedAPIServer) ListThreads ¶
func (*UnimplementedAPIServer) ListThreads(ctx context.Context, req *ListThreadsRequest) (*ListThreadsReply, error)
Click to show internal directories.
Click to hide internal directories.