fetcherpb

package
v0.0.0-...-47f881f Latest Latest
Warning

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

Go to latest
Published: May 23, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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)

View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Content.ProtoReflect.Descriptor instead.

func (*Content) GetAppName

func (x *Content) GetAppName() string

func (*Content) GetContent

func (x *Content) GetContent() string

func (*Content) GetContributor

func (x *Content) GetContributor() string

func (*Content) GetFrom

func (x *Content) GetFrom() string

func (*Content) GetHeight

func (x *Content) GetHeight() int64

func (*Content) GetId

func (x *Content) GetId() int64

func (*Content) GetOriginalDigest

func (x *Content) GetOriginalDigest() string

func (*Content) GetTitle

func (x *Content) GetTitle() string

func (*Content) GetTo

func (x *Content) GetTo() string

func (*Content) GetTs

func (x *Content) GetTs() int64

func (*Content) GetTxHash

func (x *Content) GetTxHash() string

func (*Content) ProtoMessage

func (*Content) ProtoMessage()

func (*Content) ProtoReflect

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

func (*Content) Reset

func (x *Content) Reset()

func (*Content) String

func (x *Content) String() string

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

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 (*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 (*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 (*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 (*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 (*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) Enum

func (InternalFetcherStatus) EnumDescriptor deprecated

func (InternalFetcherStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use InternalFetcherStatus.Descriptor instead.

func (InternalFetcherStatus) Number

func (InternalFetcherStatus) String

func (x InternalFetcherStatus) String() string

func (InternalFetcherStatus) Type

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) GetContentByHash

func (UnimplementedFetcherServer) GetContentCount

func (UnimplementedFetcherServer) GetContentsInfo

func (UnimplementedFetcherServer) GetTopArticles

func (UnimplementedFetcherServer) Search

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL