client

Documentation

Index

• Variables
• func NewPorterClient() (porter.LibrarianPorterServiceClient, error)
• func WithPorterAddress(ctx context.Context, address string) context.Context
• func WithPorterFastFail(ctx context.Context) context.Context
• func WithPorterName(ctx context.Context, name string) context.Context
• type Porter
  • func NewPorter(client porter.LibrarianPorterServiceClient) (*Porter, error)
  • func (p *Porter) GetServiceAddresses(ctx context.Context) ([]string, error)
• type Searcher
  • func NewSearcher(client searcher.LibrarianSearcherServiceClient) *Searcher
  • func (s *Searcher) DescribeID(ctx context.Context, id model.InternalID, desc interface{}, ...) error
  • func (s *Searcher) NewBatchIDs(ctx context.Context, num int) ([]model.InternalID, error)
  • func (s *Searcher) NewID(ctx context.Context) (model.InternalID, error)
  • func (s *Searcher) SearchID(ctx context.Context, paging model.Paging, keyword string, index searcher.Index) ([]model.InternalID, error)

Variables

var ProviderSet = wire.NewSet(NewSearcher, NewPorter, NewPorterClient)

Functions

func NewPorterClient

func NewPorterClient() (porter.LibrarianPorterServiceClient, error)

func WithPorterAddress

func WithPorterAddress(ctx context.Context, address string) context.Context

func WithPorterFastFail

func WithPorterFastFail(ctx context.Context) context.Context

func WithPorterName

func WithPorterName(ctx context.Context, name string) context.Context

Types

type Porter

type Porter struct {
	porter.LibrarianPorterServiceClient
	// contains filtered or unexported fields
}

func NewPorter

func NewPorter(
	client porter.LibrarianPorterServiceClient,
) (*Porter, error)

func (*Porter) GetServiceAddresses

func (p *Porter) GetServiceAddresses(ctx context.Context) ([]string, error)

type Searcher

type Searcher struct {
	// contains filtered or unexported fields
}

func NewSearcher

func NewSearcher(
	client searcher.LibrarianSearcherServiceClient,
) *Searcher

func (*Searcher) DescribeID

func (s *Searcher) DescribeID(
	ctx context.Context,
	id model.InternalID,
	desc interface{},
	mode searcher.DescribeIDRequest_DescribeMode,
	index searcher.Index,
) error

func (*Searcher) NewBatchIDs

func (s *Searcher) NewBatchIDs(ctx context.Context, num int) ([]model.InternalID, error)

func (*Searcher) NewID

func (s *Searcher) NewID(ctx context.Context) (model.InternalID, error)

func (*Searcher) SearchID

func (s *Searcher) SearchID(
	ctx context.Context, paging model.Paging, keyword string, index searcher.Index,
) ([]model.InternalID, error)