Documentation
¶
Overview ¶
Package streaming provides a ResourceStore implementation that sends records directly to a remote_write endpoint instead of persisting them. Designed for the backfill job where the SQLite store is unnecessary overhead.
Index ¶
- type Store
- func (s *Store) Count(_ context.Context) (int, error)
- func (s *Store) Create(_ context.Context, record *types.ResourceTags) error
- func (s *Store) Delete(_ context.Context, _ string) error
- func (s *Store) DeleteAll(_ context.Context) error
- func (s *Store) FindAllBy(_ context.Context, _ ...interface{}) ([]*types.ResourceTags, error)
- func (s *Store) FindFirstBy(_ context.Context, _ ...interface{}) (*types.ResourceTags, error)
- func (s *Store) Flush() error
- func (s *Store) Get(_ context.Context, _ string) (*types.ResourceTags, error)
- func (s *Store) Tx(_ context.Context, block func(context.Context) error) error
- func (s *Store) Update(ctx context.Context, record *types.ResourceTags) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
func New ¶
func New(settings *config.Settings, clock types.TimeProvider) *Store
New creates a streaming store that sends records directly to the collector endpoint configured in settings.RemoteWrite. The clock stamps record timestamps.
func (*Store) FindFirstBy ¶
Source Files
Click to show internal directories.
Click to hide internal directories.