storeapi

package
v0.62.1 Latest Latest
Warning

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

Go to latest
Published: Oct 13, 2025 License: Apache-2.0 Imports: 44 Imported by: 0

Documentation

Index

Constants

View Source
const (
	StoreModeHot  = "hot"
	StoreModeCold = "cold"
)

Variables

This section is empty.

Functions

func NewClient

func NewClient(store *Store) storeapi.StoreApiClient

Types

type APIConfig

type APIConfig struct {
	StoreMode string
	Bulk      BulkConfig
	Search    SearchConfig
	Fetch     FetchConfig
	Filter    FilterConfig
}

type BulkConfig

type BulkConfig struct {
	RequestsLimit uint64
	LogThreshold  time.Duration
}

type FetchConfig

type FetchConfig struct {
	LogThreshold time.Duration
}

type FilterConfig added in v0.61.0

type FilterConfig struct {
	Query string    `config:"query"`
	From  time.Time `config:"from"`
	To    time.Time `config:"to"`
}

type GrpcV1

type GrpcV1 struct {
	storeapi.UnimplementedStoreApiServer
	// contains filtered or unexported fields
}

func NewGrpcV1

func NewGrpcV1(cfg APIConfig, fracManager *fracmanager.FracManager, mappingProvider MappingProvider) *GrpcV1

func (*GrpcV1) Bulk

func (g *GrpcV1) Bulk(ctx context.Context, req *storeapi.BulkRequest) (*emptypb.Empty, error)

func (*GrpcV1) CancelAsyncSearch added in v0.59.0

func (*GrpcV1) DeleteAsyncSearch added in v0.59.0

func (*GrpcV1) Fetch

func (*GrpcV1) GetAsyncSearchesList added in v0.59.0

func (*GrpcV1) Search

func (*GrpcV1) Status

type MappingProvider

type MappingProvider interface {
	GetMapping() seq.Mapping
}

type SearchConfig

type SearchConfig struct {
	WorkersCount          int
	MaxFractionHits       int
	FractionsPerIteration int
	RequestsLimit         uint64
	LogThreshold          time.Duration
	Async                 fracmanager.AsyncSearcherConfig
}

type Store

type Store struct {
	Config StoreConfig

	FracManager *fracmanager.FracManager
	// contains filtered or unexported fields
}

func NewStore

func NewStore(ctx context.Context, c StoreConfig, s3cli *s3.Client, mappingProvider MappingProvider) (*Store, error)

func (*Store) GrpcAddr

func (s *Store) GrpcAddr() string

func (*Store) GrpcV1

func (s *Store) GrpcV1() *GrpcV1

func (*Store) OffloadAll added in v0.60.0

func (s *Store) OffloadAll()

func (*Store) ResetCache

func (s *Store) ResetCache()

func (*Store) SealAll

func (s *Store) SealAll()

func (*Store) Start

func (s *Store) Start(lis net.Listener)

func (*Store) Stop

func (s *Store) Stop()

func (*Store) WaitIdle

func (s *Store) WaitIdle()

type StoreConfig

type StoreConfig struct {
	API         APIConfig
	FracManager fracmanager.Config
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL