pools

Documentation

Index

• Variables
• type Config
  • func NewConfig(name string, sortKeys order.SortKeys, thresh int64, seekStride int) *Config
  • func (p *Config) Key() string
  • func (p Config) MarshalZNG(ctx *zson.MarshalZNGContext) (zed.Type, error)
  • func (p *Config) Path(root *storage.URI) *storage.URI
  • func (p *Config) UnmarshalZNG(ctx *zson.UnmarshalZNGContext, val zed.Value) error
• 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)
  • func (s *Store) Add(ctx context.Context, config *Config) error
  • func (s *Store) All(ctx context.Context) ([]Config, error)
  • func (s *Store) LookupByID(ctx context.Context, id ksuid.KSUID) (*Config, error)
  • func (s *Store) LookupByName(ctx context.Context, name string) *Config
  • func (s *Store) Remove(ctx context.Context, config Config) error
  • func (s *Store) Rename(ctx context.Context, id ksuid.KSUID, newName string) error

Variables

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

Types

type Config

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

func NewConfig

func NewConfig(name string, sortKeys order.SortKeys, thresh int64, seekStride int) *Config

func (*Config) Key

func (p *Config) Key() string

func (Config) MarshalZNG

func (p Config) MarshalZNG(ctx *zson.MarshalZNGContext) (zed.Type, error)

func (*Config) Path

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

func (*Config) UnmarshalZNG

func (p *Config) UnmarshalZNG(ctx *zson.UnmarshalZNGContext, val zed.Value) error

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