storage

Documentation

Index

• Constants
• type YDB
  • func New(cfg *config.Config) (*YDB, error)
  • func (s *YDB) AppendColumn(name string, in interface{}, rowbytes int, columns []types.StructValueOption) ([]types.StructValueOption, int, error)
  • func (s *YDB) AppendColumnPlain(cref options.Column, in interface{}, rowbytes int, ...) ([]types.StructValueOption, int, error)
  • func (s *YDB) BuildColumnUsageMap() map[string]bool
  • func (s *YDB) ConvertRows(events []*model.Event) ([]types.Value, int, error)
  • func (s *YDB) Exit() error
  • func (s *YDB) Write(events []*model.Event) error

Constants

const (
	Sz8   = 8
	Sz16  = 16
	Sz32  = 32
	Sz64  = 64
	Sz30M = 30 * 1024 * 1024
)

const (
	// Number of numerical characters after dot may be different.
	// The longest one is probably this: 2024-05-02T12:36:13.395105207Z
	LenTimestamp3339 = 22
)

Types

type YDB

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

func New

func New(cfg *config.Config) (*YDB, error)

func (*YDB) AppendColumn

func (s *YDB) AppendColumn(name string, in interface{}, rowbytes int, columns []types.StructValueOption) (
	[]types.StructValueOption, int, error,
)

func (*YDB) AppendColumnPlain

func (s *YDB) AppendColumnPlain(cref options.Column, in interface{}, rowbytes int, columns []types.StructValueOption) (
	[]types.StructValueOption, int, error,
)

func (*YDB) BuildColumnUsageMap

func (s *YDB) BuildColumnUsageMap() map[string]bool

func (*YDB) ConvertRows

func (s *YDB) ConvertRows(events []*model.Event) ([]types.Value, int, error)

func (*YDB) Exit

func (s *YDB) Exit() error

func (*YDB) Write

func (s *YDB) Write(events []*model.Event) error