server

Documentation

Index

• Constants
• func StartGRPCServer(port string, cert string, keyFile string, f func(grpcServer *grpc.Server)) error
• type FetcherApiSever
  • func CreateFetcherApiServer(cfg *conf.FetcherApiConf, db *xorm.Engine) (*FetcherApiSever, error)
  • func (s *FetcherApiSever) GetAuthorCount(ctx context.Context, request *pb.GetAuthorCountRequest) (response *pb.GetAuthorCountResponse, err error)
  • func (s *FetcherApiSever) GetContentByHash(ctx context.Context, request *pb.GetContentByHashRequest) (response *pb.GetContentByHashResponse, err error)
  • func (s *FetcherApiSever) GetContentCount(ctx context.Context, request *pb.GetContentCountRequest) (response *pb.GetContentCountResponse, err error)
  • func (s *FetcherApiSever) GetContentsInfo(ctx context.Context, request *pb.GetContentsInfoRequest) (response *pb.GetContentsInfoResponse, err error)
  • func (s *FetcherApiSever) GetTopArticles(ctx context.Context, request *pb.GetTopArticlesRequest) (response *pb.GetTopArticlesResponse, err error)
  • func (s *FetcherApiSever) Search(ctx context.Context, request *pb.SearchRequest) (response *pb.SearchResponse, err error)
  • func (s *FetcherApiSever) StartGRPCServer() error

Constants

const (
	NETWORK string = "tcp"
)

Functions

func StartGRPCServer

func StartGRPCServer(port string, cert string, keyFile string, f func(grpcServer *grpc.Server)) error

Types

type FetcherApiSever

type FetcherApiSever struct {
	pb.UnimplementedFetcherServer
	// contains filtered or unexported fields
}

func CreateFetcherApiServer

func CreateFetcherApiServer(cfg *conf.FetcherApiConf, db *xorm.Engine) (*FetcherApiSever, error)

func (*FetcherApiSever) GetAuthorCount

func (s *FetcherApiSever) GetAuthorCount(ctx context.Context, request *pb.GetAuthorCountRequest) (response *pb.GetAuthorCountResponse, err error)

func (*FetcherApiSever) GetContentByHash

func (s *FetcherApiSever) GetContentByHash(ctx context.Context, request *pb.GetContentByHashRequest) (response *pb.GetContentByHashResponse, err error)

func (*FetcherApiSever) GetContentCount

func (s *FetcherApiSever) GetContentCount(ctx context.Context, request *pb.GetContentCountRequest) (response *pb.GetContentCountResponse, err error)

func (*FetcherApiSever) GetContentsInfo

func (s *FetcherApiSever) GetContentsInfo(ctx context.Context, request *pb.GetContentsInfoRequest) (response *pb.GetContentsInfoResponse, err error)

func (*FetcherApiSever) GetTopArticles

func (s *FetcherApiSever) GetTopArticles(ctx context.Context, request *pb.GetTopArticlesRequest) (response *pb.GetTopArticlesResponse, err error)

func (*FetcherApiSever) Search

func (s *FetcherApiSever) Search(ctx context.Context, request *pb.SearchRequest) (response *pb.SearchResponse, err error)

func (*FetcherApiSever) StartGRPCServer

func (s *FetcherApiSever) StartGRPCServer() error