handlers

package
v0.0.0-...-3bd2bae Latest Latest
Warning

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

 Go to latest Published: Jan 17, 2025 License: GPL-3.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ArticlesHandler 

type ArticlesHandler struct {

	// Embed the unimplemented server
	articlesv2connect.UnimplementedArticlesServiceHandler
	// contains filtered or unexported fields
}

ArticlesHandler handles operations related to articles, leveraging MongoDB, Elastic, Neo4j, JWT authentication, and Redis for caching.

func NewArticlesHandler 

func NewArticlesHandler(cfg *config.Config, log *zap.SugaredLogger, mg *db.MongoDB, elastic *es.Elastic, neo *neo.Neo, authenticator *auth.JWTAuthenticator, rdb *redis.RedisClient) *ArticlesHandler

NewArticlesHandler initializes and returns a new ArticlesHandler instance. It takes a configuration, logger, MongoDB, ElasticSearch, Neo4j, JWT authenticator, and Redis client as arguments.

func (*ArticlesHandler) Consume 

func (h *ArticlesHandler) Consume()

Consume processes messages from the articles channel and handles them accordingly.

func (*ArticlesHandler) GetArticle 

func (h *ArticlesHandler) GetArticle(ctx context.Context, req *connect.Request[articlesv2.QueryArticle]) (*connect.Response[articlesv2.Article], error)

GetArticle retrieves an article by its ID from Elasticsearch and optionally counts similar articles if requested.

func (*ArticlesHandler) GetArticles 

func (h *ArticlesHandler) GetArticles(ctx context.Context, req *connect.Request[articlesv2.QueryArticle]) (*connect.Response[articlesv2.ArticleList], error)

GetArticles retrieves a list of articles matching the specified query criteria.

func (*ArticlesHandler) StreamArticles 

func (h *ArticlesHandler) StreamArticles(ctx context.Context, req *connect.Request[articlesv2.QueryArticle], stream *connect.ServerStream[articlesv2.ArticleList]) error

StreamArticles streams articles in real-time to the client.

func (*ArticlesHandler) StreamRelatedArticles 

func (h *ArticlesHandler) StreamRelatedArticles(ctx context.Context, req *connect.Request[articlesv2.QueryArticle], stream *connect.ServerStream[articlesv2.ArticleList]) error

StreamRelatedArticles streams related articles based on the given query parameters.

type FeedsHandler 

type FeedsHandler struct {

	// Embed the unimplemented server
	feedsv2connect.UnimplementedFeedServiceHandler
	// contains filtered or unexported fields
}

FeedsHandler implements feeds connect service

func NewFeedsHandler 

func NewFeedsHandler(cfg *config.Config, log *zap.SugaredLogger, mg *db.MongoDB, elastic *es.Elastic, authenticator *auth.JWTAuthenticator, rdb *redis.RedisClient) (*FeedsHandler, error)

NewFeedsHandler returns a new FeedsHandler service.

func (*FeedsHandler) CreateFeed 

func (h *FeedsHandler) CreateFeed(ctx context.Context, req *connect.Request[feedsv2.Feed]) (*connect.Response[feedsv2.Feed], error)

CreateFeed creates a new feed.

func (*FeedsHandler) DeleteFeed 

func (h *FeedsHandler) DeleteFeed(ctx context.Context, req *connect.Request[feedsv2.Feed]) (*connect.Response[commonv2.ResponseWithMessage], error)

DeleteFeed deletes a single article.

func (*FeedsHandler) GetFeed 

func (h *FeedsHandler) GetFeed(ctx context.Context, req *connect.Request[feedsv2.QueryFeed]) (*connect.Response[feedsv2.Feed], error)

GetFeed returns a single feed.

func (*FeedsHandler) GetFeeds 

func (h *FeedsHandler) GetFeeds(ctx context.Context, req *connect.Request[feedsv2.QueryFeed]) (*connect.Response[feedsv2.FeedList], error)

GetFeeds return a list of feeds.

func (*FeedsHandler) GetFeedsStreamList 

func (h *FeedsHandler) GetFeedsStreamList(ctx context.Context, req *connect.Request[feedsv2.QueryFeed]) (*connect.Response[feedsv2.FeedList], error)

GetFeedsStreamList returns a stream list.

func (*FeedsHandler) TestFeed 

func (h *FeedsHandler) TestFeed(ctx context.Context, req *connect.Request[feedsv2.Feed]) (*connect.Response[feedsv2.FeedTest], error)

TestFeed tests a feed.

func (*FeedsHandler) UpdateFeed 

func (h *FeedsHandler) UpdateFeed(ctx context.Context, req *connect.Request[feedsv2.Feed]) (*connect.Response[commonv2.ResponseWithMessage], error)

UpdateFeed updates a single feed.

type PassagesHandler 

type PassagesHandler struct {

	// Embed the unimplemented server
	passagesv2connect.UnimplementedPassageServiceHandler
	// contains filtered or unexported fields
}

func NewPassagesHandler 

func NewPassagesHandler(cfg *config.Config, log *zap.SugaredLogger, mg *db.MongoDB, elastic *es.Elastic, authenticator *auth.JWTAuthenticator, rdb *redis.RedisClient) (*PassagesHandler, error)

NewPassagesHandler returns a new PassagesHandler service.

func (*PassagesHandler) CreatePassage 

func (h *PassagesHandler) CreatePassage(ctx context.Context, req *connect.Request[passagesv2.Passage]) (*connect.Response[passagesv2.Passage], error)

CreateFeed creates a new feed.

func (*PassagesHandler) DeletePassage 

func (h *PassagesHandler) DeletePassage(ctx context.Context, req *connect.Request[passagesv2.Passage]) (*connect.Response[commonv2.ResponseWithMessage], error)

DeletePassage deletes a passage.

func (*PassagesHandler) GetPassages 

func (h *PassagesHandler) GetPassages(ctx context.Context, req *connect.Request[passagesv2.QueryPassage]) (*connect.Response[passagesv2.PassageList], error)

GetPassages return a list of passages.

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.