Documentation
¶
Index ¶
- Variables
- func RegisterFetcherServer(s grpc.ServiceRegistrar, srv FetcherServer)
- type Content
- func (*Content) Descriptor() ([]byte, []int)deprecated
- func (x *Content) GetAppName() string
- func (x *Content) GetContent() string
- func (x *Content) GetContributor() string
- func (x *Content) GetFrom() string
- func (x *Content) GetHeight() int64
- func (x *Content) GetId() int64
- func (x *Content) GetOriginalDigest() string
- func (x *Content) GetTitle() string
- func (x *Content) GetTo() string
- func (x *Content) GetTs() int64
- func (x *Content) GetTxHash() string
- func (*Content) ProtoMessage()
- func (x *Content) ProtoReflect() protoreflect.Message
- func (x *Content) Reset()
- func (x *Content) String() string
- type FetcherClient
- type FetcherServer
- type GetAuthorCountRequest
- func (*GetAuthorCountRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetAuthorCountRequest) GetAppName() string
- func (x *GetAuthorCountRequest) GetFrom() int64
- func (x *GetAuthorCountRequest) GetTo() int64
- func (*GetAuthorCountRequest) ProtoMessage()
- func (x *GetAuthorCountRequest) ProtoReflect() protoreflect.Message
- func (x *GetAuthorCountRequest) Reset()
- func (x *GetAuthorCountRequest) String() string
- type GetAuthorCountResponse
- func (*GetAuthorCountResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetAuthorCountResponse) GetCount() int64
- func (x *GetAuthorCountResponse) GetStatus() InternalFetcherStatus
- func (*GetAuthorCountResponse) ProtoMessage()
- func (x *GetAuthorCountResponse) ProtoReflect() protoreflect.Message
- func (x *GetAuthorCountResponse) Reset()
- func (x *GetAuthorCountResponse) String() string
- type GetContentByHashRequest
- func (*GetContentByHashRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetContentByHashRequest) GetHash() string
- func (*GetContentByHashRequest) ProtoMessage()
- func (x *GetContentByHashRequest) ProtoReflect() protoreflect.Message
- func (x *GetContentByHashRequest) Reset()
- func (x *GetContentByHashRequest) String() string
- type GetContentByHashResponse
- func (*GetContentByHashResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetContentByHashResponse) GetContent() *Content
- func (x *GetContentByHashResponse) GetStatus() InternalFetcherStatus
- func (*GetContentByHashResponse) ProtoMessage()
- func (x *GetContentByHashResponse) ProtoReflect() protoreflect.Message
- func (x *GetContentByHashResponse) Reset()
- func (x *GetContentByHashResponse) String() string
- type GetContentCountRequest
- func (*GetContentCountRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetContentCountRequest) GetAppName() string
- func (x *GetContentCountRequest) GetFrom() int64
- func (x *GetContentCountRequest) GetTo() int64
- func (*GetContentCountRequest) ProtoMessage()
- func (x *GetContentCountRequest) ProtoReflect() protoreflect.Message
- func (x *GetContentCountRequest) Reset()
- func (x *GetContentCountRequest) String() string
- type GetContentCountResponse
- func (*GetContentCountResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetContentCountResponse) GetCount() int64
- func (x *GetContentCountResponse) GetStatus() InternalFetcherStatus
- func (*GetContentCountResponse) ProtoMessage()
- func (x *GetContentCountResponse) ProtoReflect() protoreflect.Message
- func (x *GetContentCountResponse) Reset()
- func (x *GetContentCountResponse) String() string
- type GetContentsInfoRequest
- func (*GetContentsInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetContentsInfoRequest) GetAppName() string
- func (x *GetContentsInfoRequest) GetContributor() string
- func (x *GetContentsInfoRequest) GetFrom() string
- func (x *GetContentsInfoRequest) GetHeight() int64
- func (x *GetContentsInfoRequest) GetLimit() int64
- func (x *GetContentsInfoRequest) GetOffset() int64
- func (x *GetContentsInfoRequest) GetTo() string
- func (x *GetContentsInfoRequest) GetTs() int64
- func (*GetContentsInfoRequest) ProtoMessage()
- func (x *GetContentsInfoRequest) ProtoReflect() protoreflect.Message
- func (x *GetContentsInfoRequest) Reset()
- func (x *GetContentsInfoRequest) String() string
- type GetContentsInfoResponse
- func (*GetContentsInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetContentsInfoResponse) GetContents() []*Content
- func (x *GetContentsInfoResponse) GetStatus() InternalFetcherStatus
- func (x *GetContentsInfoResponse) GetTotal() int64
- func (*GetContentsInfoResponse) ProtoMessage()
- func (x *GetContentsInfoResponse) ProtoReflect() protoreflect.Message
- func (x *GetContentsInfoResponse) Reset()
- func (x *GetContentsInfoResponse) String() string
- type GetTopArticlesRequest
- func (*GetTopArticlesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTopArticlesRequest) GetAppName() string
- func (x *GetTopArticlesRequest) GetTop() int64
- func (*GetTopArticlesRequest) ProtoMessage()
- func (x *GetTopArticlesRequest) ProtoReflect() protoreflect.Message
- func (x *GetTopArticlesRequest) Reset()
- func (x *GetTopArticlesRequest) String() string
- type GetTopArticlesResponse
- func (*GetTopArticlesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTopArticlesResponse) GetContents() []*Content
- func (x *GetTopArticlesResponse) GetStatus() InternalFetcherStatus
- func (x *GetTopArticlesResponse) GetTotal() int64
- func (*GetTopArticlesResponse) ProtoMessage()
- func (x *GetTopArticlesResponse) ProtoReflect() protoreflect.Message
- func (x *GetTopArticlesResponse) Reset()
- func (x *GetTopArticlesResponse) String() string
- type InternalFetcherStatus
- func (InternalFetcherStatus) Descriptor() protoreflect.EnumDescriptor
- func (x InternalFetcherStatus) Enum() *InternalFetcherStatus
- func (InternalFetcherStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x InternalFetcherStatus) Number() protoreflect.EnumNumber
- func (x InternalFetcherStatus) String() string
- func (InternalFetcherStatus) Type() protoreflect.EnumType
- type SearchRequest
- func (*SearchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SearchRequest) GetAppName() string
- func (x *SearchRequest) GetLimit() int64
- func (x *SearchRequest) GetOffset() int64
- func (x *SearchRequest) GetSearchStr() string
- func (*SearchRequest) ProtoMessage()
- func (x *SearchRequest) ProtoReflect() protoreflect.Message
- func (x *SearchRequest) Reset()
- func (x *SearchRequest) String() string
- type SearchResponse
- func (*SearchResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SearchResponse) GetContents() []*Content
- func (x *SearchResponse) GetStatus() InternalFetcherStatus
- func (x *SearchResponse) GetTotal() int64
- func (*SearchResponse) ProtoMessage()
- func (x *SearchResponse) ProtoReflect() protoreflect.Message
- func (x *SearchResponse) Reset()
- func (x *SearchResponse) String() string
- type UnimplementedFetcherServer
- func (UnimplementedFetcherServer) GetAuthorCount(context.Context, *GetAuthorCountRequest) (*GetAuthorCountResponse, error)
- func (UnimplementedFetcherServer) GetContentByHash(context.Context, *GetContentByHashRequest) (*GetContentByHashResponse, error)
- func (UnimplementedFetcherServer) GetContentCount(context.Context, *GetContentCountRequest) (*GetContentCountResponse, error)
- func (UnimplementedFetcherServer) GetContentsInfo(context.Context, *GetContentsInfoRequest) (*GetContentsInfoResponse, error)
- func (UnimplementedFetcherServer) GetTopArticles(context.Context, *GetTopArticlesRequest) (*GetTopArticlesResponse, error)
- func (UnimplementedFetcherServer) Search(context.Context, *SearchRequest) (*SearchResponse, error)
- type UnsafeFetcherServer
Constants ¶
This section is empty.
Variables ¶
var ( InternalFetcherStatus_name = map[int32]string{ 0: "INTERNAL_FETCHER__SUCCESS", 1: "INTERNAL_FETCHER__ERROR", } InternalFetcherStatus_value = map[string]int32{ "INTERNAL_FETCHER__SUCCESS": 0, "INTERNAL_FETCHER__ERROR": 1, } )
Enum value maps for InternalFetcherStatus.
var Fetcher_ServiceDesc = grpc.ServiceDesc{ ServiceName: "fetcher.api.Fetcher", HandlerType: (*FetcherServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetContentsInfo", Handler: _Fetcher_GetContentsInfo_Handler, }, { MethodName: "GetContentByHash", Handler: _Fetcher_GetContentByHash_Handler, }, { MethodName: "GetAuthorCount", Handler: _Fetcher_GetAuthorCount_Handler, }, { MethodName: "GetContentCount", Handler: _Fetcher_GetContentCount_Handler, }, { MethodName: "Search", Handler: _Fetcher_Search_Handler, }, { MethodName: "GetTopArticles", Handler: _Fetcher_GetTopArticles_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "fetcher.proto", }
Fetcher_ServiceDesc is the grpc.ServiceDesc for Fetcher service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_fetcher_proto protoreflect.FileDescriptor
Functions ¶
func RegisterFetcherServer ¶
func RegisterFetcherServer(s grpc.ServiceRegistrar, srv FetcherServer)
Types ¶
type Content ¶
type Content struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Ts int64 `protobuf:"varint,2,opt,name=ts,proto3" json:"ts,omitempty"` Height int64 `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"` TxHash string `protobuf:"bytes,4,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"` From string `protobuf:"bytes,5,opt,name=from,proto3" json:"from,omitempty"` To string `protobuf:"bytes,6,opt,name=to,proto3" json:"to,omitempty"` Content string `protobuf:"bytes,7,opt,name=content,proto3" json:"content,omitempty"` Contributor string `protobuf:"bytes,8,opt,name=contributor,proto3" json:"contributor,omitempty"` AppName string `protobuf:"bytes,9,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"` Title string `protobuf:"bytes,10,opt,name=title,proto3" json:"title,omitempty"` OriginalDigest string `protobuf:"bytes,11,opt,name=original_digest,json=originalDigest,proto3" json:"original_digest,omitempty"` // contains filtered or unexported fields }
func (*Content) Descriptor
deprecated
func (*Content) GetAppName ¶
func (*Content) GetContent ¶
func (*Content) GetContributor ¶
func (*Content) GetOriginalDigest ¶
func (*Content) ProtoMessage ¶
func (*Content) ProtoMessage()
func (*Content) ProtoReflect ¶
func (x *Content) ProtoReflect() protoreflect.Message
type FetcherClient ¶
type FetcherClient interface { GetContentsInfo(ctx context.Context, in *GetContentsInfoRequest, opts ...grpc.CallOption) (*GetContentsInfoResponse, error) GetContentByHash(ctx context.Context, in *GetContentByHashRequest, opts ...grpc.CallOption) (*GetContentByHashResponse, error) GetAuthorCount(ctx context.Context, in *GetAuthorCountRequest, opts ...grpc.CallOption) (*GetAuthorCountResponse, error) GetContentCount(ctx context.Context, in *GetContentCountRequest, opts ...grpc.CallOption) (*GetContentCountResponse, error) Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error) GetTopArticles(ctx context.Context, in *GetTopArticlesRequest, opts ...grpc.CallOption) (*GetTopArticlesResponse, error) }
FetcherClient is the client API for Fetcher service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewFetcherClient ¶
func NewFetcherClient(cc grpc.ClientConnInterface) FetcherClient
type FetcherServer ¶
type FetcherServer interface { GetContentsInfo(context.Context, *GetContentsInfoRequest) (*GetContentsInfoResponse, error) GetContentByHash(context.Context, *GetContentByHashRequest) (*GetContentByHashResponse, error) GetAuthorCount(context.Context, *GetAuthorCountRequest) (*GetAuthorCountResponse, error) GetContentCount(context.Context, *GetContentCountRequest) (*GetContentCountResponse, error) Search(context.Context, *SearchRequest) (*SearchResponse, error) GetTopArticles(context.Context, *GetTopArticlesRequest) (*GetTopArticlesResponse, error) // contains filtered or unexported methods }
FetcherServer is the server API for Fetcher service. All implementations must embed UnimplementedFetcherServer for forward compatibility
type GetAuthorCountRequest ¶
type GetAuthorCountRequest struct { From int64 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"` To int64 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"` AppName string `protobuf:"bytes,3,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"` // contains filtered or unexported fields }
func (*GetAuthorCountRequest) Descriptor
deprecated
func (*GetAuthorCountRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetAuthorCountRequest.ProtoReflect.Descriptor instead.
func (*GetAuthorCountRequest) GetAppName ¶
func (x *GetAuthorCountRequest) GetAppName() string
func (*GetAuthorCountRequest) GetFrom ¶
func (x *GetAuthorCountRequest) GetFrom() int64
func (*GetAuthorCountRequest) GetTo ¶
func (x *GetAuthorCountRequest) GetTo() int64
func (*GetAuthorCountRequest) ProtoMessage ¶
func (*GetAuthorCountRequest) ProtoMessage()
func (*GetAuthorCountRequest) ProtoReflect ¶
func (x *GetAuthorCountRequest) ProtoReflect() protoreflect.Message
func (*GetAuthorCountRequest) Reset ¶
func (x *GetAuthorCountRequest) Reset()
func (*GetAuthorCountRequest) String ¶
func (x *GetAuthorCountRequest) String() string
type GetAuthorCountResponse ¶
type GetAuthorCountResponse struct { Status InternalFetcherStatus `protobuf:"varint,1,opt,name=status,proto3,enum=fetcher.api.InternalFetcherStatus" json:"status,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*GetAuthorCountResponse) Descriptor
deprecated
func (*GetAuthorCountResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetAuthorCountResponse.ProtoReflect.Descriptor instead.
func (*GetAuthorCountResponse) GetCount ¶
func (x *GetAuthorCountResponse) GetCount() int64
func (*GetAuthorCountResponse) GetStatus ¶
func (x *GetAuthorCountResponse) GetStatus() InternalFetcherStatus
func (*GetAuthorCountResponse) ProtoMessage ¶
func (*GetAuthorCountResponse) ProtoMessage()
func (*GetAuthorCountResponse) ProtoReflect ¶
func (x *GetAuthorCountResponse) ProtoReflect() protoreflect.Message
func (*GetAuthorCountResponse) Reset ¶
func (x *GetAuthorCountResponse) Reset()
func (*GetAuthorCountResponse) String ¶
func (x *GetAuthorCountResponse) String() string
type GetContentByHashRequest ¶
type GetContentByHashRequest struct { Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"` // contains filtered or unexported fields }
func (*GetContentByHashRequest) Descriptor
deprecated
func (*GetContentByHashRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetContentByHashRequest.ProtoReflect.Descriptor instead.
func (*GetContentByHashRequest) GetHash ¶
func (x *GetContentByHashRequest) GetHash() string
func (*GetContentByHashRequest) ProtoMessage ¶
func (*GetContentByHashRequest) ProtoMessage()
func (*GetContentByHashRequest) ProtoReflect ¶
func (x *GetContentByHashRequest) ProtoReflect() protoreflect.Message
func (*GetContentByHashRequest) Reset ¶
func (x *GetContentByHashRequest) Reset()
func (*GetContentByHashRequest) String ¶
func (x *GetContentByHashRequest) String() string
type GetContentByHashResponse ¶
type GetContentByHashResponse struct { Status InternalFetcherStatus `protobuf:"varint,1,opt,name=status,proto3,enum=fetcher.api.InternalFetcherStatus" json:"status,omitempty"` Content *Content `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*GetContentByHashResponse) Descriptor
deprecated
func (*GetContentByHashResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetContentByHashResponse.ProtoReflect.Descriptor instead.
func (*GetContentByHashResponse) GetContent ¶
func (x *GetContentByHashResponse) GetContent() *Content
func (*GetContentByHashResponse) GetStatus ¶
func (x *GetContentByHashResponse) GetStatus() InternalFetcherStatus
func (*GetContentByHashResponse) ProtoMessage ¶
func (*GetContentByHashResponse) ProtoMessage()
func (*GetContentByHashResponse) ProtoReflect ¶
func (x *GetContentByHashResponse) ProtoReflect() protoreflect.Message
func (*GetContentByHashResponse) Reset ¶
func (x *GetContentByHashResponse) Reset()
func (*GetContentByHashResponse) String ¶
func (x *GetContentByHashResponse) String() string
type GetContentCountRequest ¶
type GetContentCountRequest struct { From int64 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"` To int64 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"` AppName string `protobuf:"bytes,3,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"` // contains filtered or unexported fields }
func (*GetContentCountRequest) Descriptor
deprecated
func (*GetContentCountRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetContentCountRequest.ProtoReflect.Descriptor instead.
func (*GetContentCountRequest) GetAppName ¶
func (x *GetContentCountRequest) GetAppName() string
func (*GetContentCountRequest) GetFrom ¶
func (x *GetContentCountRequest) GetFrom() int64
func (*GetContentCountRequest) GetTo ¶
func (x *GetContentCountRequest) GetTo() int64
func (*GetContentCountRequest) ProtoMessage ¶
func (*GetContentCountRequest) ProtoMessage()
func (*GetContentCountRequest) ProtoReflect ¶
func (x *GetContentCountRequest) ProtoReflect() protoreflect.Message
func (*GetContentCountRequest) Reset ¶
func (x *GetContentCountRequest) Reset()
func (*GetContentCountRequest) String ¶
func (x *GetContentCountRequest) String() string
type GetContentCountResponse ¶
type GetContentCountResponse struct { Status InternalFetcherStatus `protobuf:"varint,1,opt,name=status,proto3,enum=fetcher.api.InternalFetcherStatus" json:"status,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*GetContentCountResponse) Descriptor
deprecated
func (*GetContentCountResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetContentCountResponse.ProtoReflect.Descriptor instead.
func (*GetContentCountResponse) GetCount ¶
func (x *GetContentCountResponse) GetCount() int64
func (*GetContentCountResponse) GetStatus ¶
func (x *GetContentCountResponse) GetStatus() InternalFetcherStatus
func (*GetContentCountResponse) ProtoMessage ¶
func (*GetContentCountResponse) ProtoMessage()
func (*GetContentCountResponse) ProtoReflect ¶
func (x *GetContentCountResponse) ProtoReflect() protoreflect.Message
func (*GetContentCountResponse) Reset ¶
func (x *GetContentCountResponse) Reset()
func (*GetContentCountResponse) String ¶
func (x *GetContentCountResponse) String() string
type GetContentsInfoRequest ¶
type GetContentsInfoRequest struct { Ts int64 `protobuf:"varint,1,opt,name=ts,proto3" json:"ts,omitempty"` Height int64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"` From string `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"` To string `protobuf:"bytes,4,opt,name=to,proto3" json:"to,omitempty"` Contributor string `protobuf:"bytes,5,opt,name=contributor,proto3" json:"contributor,omitempty"` AppName string `protobuf:"bytes,6,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"` Offset int64 `protobuf:"varint,7,opt,name=offset,proto3" json:"offset,omitempty"` Limit int64 `protobuf:"varint,8,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*GetContentsInfoRequest) Descriptor
deprecated
func (*GetContentsInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetContentsInfoRequest.ProtoReflect.Descriptor instead.
func (*GetContentsInfoRequest) GetAppName ¶
func (x *GetContentsInfoRequest) GetAppName() string
func (*GetContentsInfoRequest) GetContributor ¶
func (x *GetContentsInfoRequest) GetContributor() string
func (*GetContentsInfoRequest) GetFrom ¶
func (x *GetContentsInfoRequest) GetFrom() string
func (*GetContentsInfoRequest) GetHeight ¶
func (x *GetContentsInfoRequest) GetHeight() int64
func (*GetContentsInfoRequest) GetLimit ¶
func (x *GetContentsInfoRequest) GetLimit() int64
func (*GetContentsInfoRequest) GetOffset ¶
func (x *GetContentsInfoRequest) GetOffset() int64
func (*GetContentsInfoRequest) GetTo ¶
func (x *GetContentsInfoRequest) GetTo() string
func (*GetContentsInfoRequest) GetTs ¶
func (x *GetContentsInfoRequest) GetTs() int64
func (*GetContentsInfoRequest) ProtoMessage ¶
func (*GetContentsInfoRequest) ProtoMessage()
func (*GetContentsInfoRequest) ProtoReflect ¶
func (x *GetContentsInfoRequest) ProtoReflect() protoreflect.Message
func (*GetContentsInfoRequest) Reset ¶
func (x *GetContentsInfoRequest) Reset()
func (*GetContentsInfoRequest) String ¶
func (x *GetContentsInfoRequest) String() string
type GetContentsInfoResponse ¶
type GetContentsInfoResponse struct { Status InternalFetcherStatus `protobuf:"varint,1,opt,name=status,proto3,enum=fetcher.api.InternalFetcherStatus" json:"status,omitempty"` Contents []*Content `protobuf:"bytes,2,rep,name=contents,proto3" json:"contents,omitempty"` Total int64 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"` // contains filtered or unexported fields }
func (*GetContentsInfoResponse) Descriptor
deprecated
func (*GetContentsInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetContentsInfoResponse.ProtoReflect.Descriptor instead.
func (*GetContentsInfoResponse) GetContents ¶
func (x *GetContentsInfoResponse) GetContents() []*Content
func (*GetContentsInfoResponse) GetStatus ¶
func (x *GetContentsInfoResponse) GetStatus() InternalFetcherStatus
func (*GetContentsInfoResponse) GetTotal ¶
func (x *GetContentsInfoResponse) GetTotal() int64
func (*GetContentsInfoResponse) ProtoMessage ¶
func (*GetContentsInfoResponse) ProtoMessage()
func (*GetContentsInfoResponse) ProtoReflect ¶
func (x *GetContentsInfoResponse) ProtoReflect() protoreflect.Message
func (*GetContentsInfoResponse) Reset ¶
func (x *GetContentsInfoResponse) Reset()
func (*GetContentsInfoResponse) String ¶
func (x *GetContentsInfoResponse) String() string
type GetTopArticlesRequest ¶
type GetTopArticlesRequest struct { Top int64 `protobuf:"varint,1,opt,name=top,proto3" json:"top,omitempty"` AppName string `protobuf:"bytes,2,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"` // contains filtered or unexported fields }
func (*GetTopArticlesRequest) Descriptor
deprecated
func (*GetTopArticlesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTopArticlesRequest.ProtoReflect.Descriptor instead.
func (*GetTopArticlesRequest) GetAppName ¶
func (x *GetTopArticlesRequest) GetAppName() string
func (*GetTopArticlesRequest) GetTop ¶
func (x *GetTopArticlesRequest) GetTop() int64
func (*GetTopArticlesRequest) ProtoMessage ¶
func (*GetTopArticlesRequest) ProtoMessage()
func (*GetTopArticlesRequest) ProtoReflect ¶
func (x *GetTopArticlesRequest) ProtoReflect() protoreflect.Message
func (*GetTopArticlesRequest) Reset ¶
func (x *GetTopArticlesRequest) Reset()
func (*GetTopArticlesRequest) String ¶
func (x *GetTopArticlesRequest) String() string
type GetTopArticlesResponse ¶
type GetTopArticlesResponse struct { Status InternalFetcherStatus `protobuf:"varint,1,opt,name=status,proto3,enum=fetcher.api.InternalFetcherStatus" json:"status,omitempty"` Contents []*Content `protobuf:"bytes,2,rep,name=contents,proto3" json:"contents,omitempty"` Total int64 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"` // contains filtered or unexported fields }
func (*GetTopArticlesResponse) Descriptor
deprecated
func (*GetTopArticlesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTopArticlesResponse.ProtoReflect.Descriptor instead.
func (*GetTopArticlesResponse) GetContents ¶
func (x *GetTopArticlesResponse) GetContents() []*Content
func (*GetTopArticlesResponse) GetStatus ¶
func (x *GetTopArticlesResponse) GetStatus() InternalFetcherStatus
func (*GetTopArticlesResponse) GetTotal ¶
func (x *GetTopArticlesResponse) GetTotal() int64
func (*GetTopArticlesResponse) ProtoMessage ¶
func (*GetTopArticlesResponse) ProtoMessage()
func (*GetTopArticlesResponse) ProtoReflect ¶
func (x *GetTopArticlesResponse) ProtoReflect() protoreflect.Message
func (*GetTopArticlesResponse) Reset ¶
func (x *GetTopArticlesResponse) Reset()
func (*GetTopArticlesResponse) String ¶
func (x *GetTopArticlesResponse) String() string
type InternalFetcherStatus ¶
type InternalFetcherStatus int32
const ( InternalFetcherStatus_INTERNAL_FETCHER__SUCCESS InternalFetcherStatus = 0 InternalFetcherStatus_INTERNAL_FETCHER__ERROR InternalFetcherStatus = 1 )
func (InternalFetcherStatus) Descriptor ¶
func (InternalFetcherStatus) Descriptor() protoreflect.EnumDescriptor
func (InternalFetcherStatus) Enum ¶
func (x InternalFetcherStatus) Enum() *InternalFetcherStatus
func (InternalFetcherStatus) EnumDescriptor
deprecated
func (InternalFetcherStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use InternalFetcherStatus.Descriptor instead.
func (InternalFetcherStatus) Number ¶
func (x InternalFetcherStatus) Number() protoreflect.EnumNumber
func (InternalFetcherStatus) String ¶
func (x InternalFetcherStatus) String() string
func (InternalFetcherStatus) Type ¶
func (InternalFetcherStatus) Type() protoreflect.EnumType
type SearchRequest ¶
type SearchRequest struct { SearchStr string `protobuf:"bytes,1,opt,name=search_str,json=searchStr,proto3" json:"search_str,omitempty"` Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` Limit int64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"` AppName string `protobuf:"bytes,4,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"` // contains filtered or unexported fields }
func (*SearchRequest) Descriptor
deprecated
func (*SearchRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.
func (*SearchRequest) GetAppName ¶
func (x *SearchRequest) GetAppName() string
func (*SearchRequest) GetLimit ¶
func (x *SearchRequest) GetLimit() int64
func (*SearchRequest) GetOffset ¶
func (x *SearchRequest) GetOffset() int64
func (*SearchRequest) GetSearchStr ¶
func (x *SearchRequest) GetSearchStr() string
func (*SearchRequest) ProtoMessage ¶
func (*SearchRequest) ProtoMessage()
func (*SearchRequest) ProtoReflect ¶
func (x *SearchRequest) ProtoReflect() protoreflect.Message
func (*SearchRequest) Reset ¶
func (x *SearchRequest) Reset()
func (*SearchRequest) String ¶
func (x *SearchRequest) String() string
type SearchResponse ¶
type SearchResponse struct { Status InternalFetcherStatus `protobuf:"varint,1,opt,name=status,proto3,enum=fetcher.api.InternalFetcherStatus" json:"status,omitempty"` Contents []*Content `protobuf:"bytes,2,rep,name=contents,proto3" json:"contents,omitempty"` Total int64 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"` // contains filtered or unexported fields }
func (*SearchResponse) Descriptor
deprecated
func (*SearchResponse) Descriptor() ([]byte, []int)
Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.
func (*SearchResponse) GetContents ¶
func (x *SearchResponse) GetContents() []*Content
func (*SearchResponse) GetStatus ¶
func (x *SearchResponse) GetStatus() InternalFetcherStatus
func (*SearchResponse) GetTotal ¶
func (x *SearchResponse) GetTotal() int64
func (*SearchResponse) ProtoMessage ¶
func (*SearchResponse) ProtoMessage()
func (*SearchResponse) ProtoReflect ¶
func (x *SearchResponse) ProtoReflect() protoreflect.Message
func (*SearchResponse) Reset ¶
func (x *SearchResponse) Reset()
func (*SearchResponse) String ¶
func (x *SearchResponse) String() string
type UnimplementedFetcherServer ¶
type UnimplementedFetcherServer struct { }
UnimplementedFetcherServer must be embedded to have forward compatible implementations.
func (UnimplementedFetcherServer) GetAuthorCount ¶
func (UnimplementedFetcherServer) GetAuthorCount(context.Context, *GetAuthorCountRequest) (*GetAuthorCountResponse, error)
func (UnimplementedFetcherServer) GetContentByHash ¶
func (UnimplementedFetcherServer) GetContentByHash(context.Context, *GetContentByHashRequest) (*GetContentByHashResponse, error)
func (UnimplementedFetcherServer) GetContentCount ¶
func (UnimplementedFetcherServer) GetContentCount(context.Context, *GetContentCountRequest) (*GetContentCountResponse, error)
func (UnimplementedFetcherServer) GetContentsInfo ¶
func (UnimplementedFetcherServer) GetContentsInfo(context.Context, *GetContentsInfoRequest) (*GetContentsInfoResponse, error)
func (UnimplementedFetcherServer) GetTopArticles ¶
func (UnimplementedFetcherServer) GetTopArticles(context.Context, *GetTopArticlesRequest) (*GetTopArticlesResponse, error)
func (UnimplementedFetcherServer) Search ¶
func (UnimplementedFetcherServer) Search(context.Context, *SearchRequest) (*SearchResponse, error)
type UnsafeFetcherServer ¶
type UnsafeFetcherServer interface {
// contains filtered or unexported methods
}
UnsafeFetcherServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FetcherServer will result in compilation errors.