service

Documentation

Index

• Variables
• func NewLibrarianPorterServiceService(feed *bizfeed.FeedUseCase, steam *bizsteam.SteamUseCase, s3 *bizs3.S3) pb.LibrarianPorterServiceServer
• func ToBizBucket(t pb.DataSource) bizs3.Bucket
• func ToBizFeedDestination(t pb.FeedDestination) bizfeed.FeedDestination
• func ToPBAppType(t bizsteam.AppType) librarian.AppType
• type LibrarianPorterServiceService
  • func (s *LibrarianPorterServiceService) PullAccount(ctx context.Context, req *pb.PullAccountRequest) (*pb.PullAccountResponse, error)
  • func (s *LibrarianPorterServiceService) PullAccountAppRelation(ctx context.Context, req *pb.PullAccountAppRelationRequest) (*pb.PullAccountAppRelationResponse, error)
  • func (s *LibrarianPorterServiceService) PullApp(ctx context.Context, req *pb.PullAppRequest) (*pb.PullAppResponse, error)
  • func (s *LibrarianPorterServiceService) PullFeed(ctx context.Context, req *pb.PullFeedRequest) (*pb.PullFeedResponse, error)
  • func (s *LibrarianPorterServiceService) PushData(conn pb.LibrarianPorterService_PushDataServer) error
  • func (s *LibrarianPorterServiceService) PushFeedItems(ctx context.Context, req *pb.PushFeedItemsRequest) (*pb.PushFeedItemsResponse, error)

Variables

var ProviderSet = wire.NewSet(NewLibrarianPorterServiceService)

ProviderSet is service providers.

Functions

func NewLibrarianPorterServiceService

func NewLibrarianPorterServiceService(
	feed *bizfeed.FeedUseCase,
	steam *bizsteam.SteamUseCase,
	s3 *bizs3.S3,
) pb.LibrarianPorterServiceServer

func ToBizBucket

func ToBizBucket(t pb.DataSource) bizs3.Bucket

func ToBizFeedDestination

func ToBizFeedDestination(t pb.FeedDestination) bizfeed.FeedDestination

func ToPBAppType

func ToPBAppType(t bizsteam.AppType) librarian.AppType

Types

type LibrarianPorterServiceService

type LibrarianPorterServiceService struct {
	pb.UnimplementedLibrarianPorterServiceServer
	// contains filtered or unexported fields
}

func (*LibrarianPorterServiceService) PullAccount

func (s *LibrarianPorterServiceService) PullAccount(
	ctx context.Context,
	req *pb.PullAccountRequest,
) (*pb.PullAccountResponse, error)

func (*LibrarianPorterServiceService) PullAccountAppRelation

func (s *LibrarianPorterServiceService) PullAccountAppRelation(
	ctx context.Context,
	req *pb.PullAccountAppRelationRequest,
) (*pb.PullAccountAppRelationResponse, error)

func (*LibrarianPorterServiceService) PullApp

func (s *LibrarianPorterServiceService) PullApp(
	ctx context.Context,
	req *pb.PullAppRequest,
) (*pb.PullAppResponse, error)

func (*LibrarianPorterServiceService) PullFeed

func (s *LibrarianPorterServiceService) PullFeed(
	ctx context.Context,
	req *pb.PullFeedRequest,
) (*pb.PullFeedResponse, error)

func (*LibrarianPorterServiceService) PushData

func (s *LibrarianPorterServiceService) PushData(conn pb.LibrarianPorterService_PushDataServer) error

func (*LibrarianPorterServiceService) PushFeedItems

func (s *LibrarianPorterServiceService) PushFeedItems(ctx context.Context, req *pb.PushFeedItemsRequest) (
	*pb.PushFeedItemsResponse, error)