pools

package

v1.9.0 Latest Latest Go to latest Published: Jul 27, 2023 License: BSD-3-Clause Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/brimdata/zed

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Config
- func NewConfig(name string, sortKey order.SortKey, thresh int64, seekStride int) *Config
- func (p *Config) Key() string
- func (p *Config) Path(root *storage.URI) *storage.URI
type Store
- func CreateStore(ctx context.Context, engine storage.Engine, logger *zap.Logger, ...) (*Store, error)
- func OpenStore(ctx context.Context, engine storage.Engine, logger *zap.Logger, ...) (*Store, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrExists   = errors.New("pool already exists")
	ErrNotFound = errors.New("pool not found")
)

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	Ts         nano.Ts       `zed:"ts"`
	Name       string        `zed:"name"`
	ID         ksuid.KSUID   `zed:"id"`
	SortKey    order.SortKey `zed:"layout"`
	SeekStride int           `zed:"seek_stride"`
	Threshold  int64         `zed:"threshold"`
}

func NewConfig ¶

func NewConfig(name string, sortKey order.SortKey, thresh int64, seekStride int) *Config

func (*Config) Key ¶

func (p *Config) Key() string

func (*Config) Path ¶

func (p *Config) Path(root *storage.URI) *storage.URI

type Store ¶

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

func CreateStore ¶

func CreateStore(ctx context.Context, engine storage.Engine, logger *zap.Logger, path *storage.URI) (*Store, error)

func OpenStore ¶

func OpenStore(ctx context.Context, engine storage.Engine, logger *zap.Logger, path *storage.URI) (*Store, error)

func (*Store) Add ¶

func (s *Store) Add(ctx context.Context, config *Config) error

func (*Store) All ¶

func (s *Store) All(ctx context.Context) ([]Config, error)

func (*Store) LookupByID ¶

func (s *Store) LookupByID(ctx context.Context, id ksuid.KSUID) (*Config, error)

func (*Store) LookupByName ¶

func (s *Store) LookupByName(ctx context.Context, name string) *Config

func (*Store) Remove ¶

func (s *Store) Remove(ctx context.Context, config Config) error

Remove deletes a pool from the configuration journal.

func (*Store) Rename ¶

func (s *Store) Rename(ctx context.Context, id ksuid.KSUID, newName string) error

Source Files ¶

View all Source files

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