client

Documentation

Index

• Variables
• func NewPorterClient(c *conf.Consul, p *conf.Porter, app *libapp.Settings) (porter.LibrarianPorterServiceClient, error)
• func WithPorterAddress(ctx context.Context, addresses []string) context.Context
• func WithPorterFastFail(ctx context.Context) context.Context
• type Porter
  • func NewPorter(client porter.LibrarianPorterServiceClient, consul *conf.Consul, ...) (*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, query string, index searcher.Index) ([]model.InternalID, error)

Variables

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

Functions

func NewPorterClient

func NewPorterClient(c *conf.Consul, p *conf.Porter, app *libapp.Settings) (porter.LibrarianPorterServiceClient, error)

func WithPorterAddress

func WithPorterAddress(ctx context.Context, addresses []string) context.Context

func WithPorterFastFail

func WithPorterFastFail(ctx context.Context) context.Context

Types

type Porter

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

func NewPorter

func NewPorter(
	client porter.LibrarianPorterServiceClient,
	consul *conf.Consul,
	porter *conf.Porter,
) (*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, query string, index searcher.Index,
) ([]model.InternalID, error)