storages

Documentation

Index

• type MemoryStorage
  • func NewMemoryStorage(ctx *MemoryStorageContext, cols []*columns.Column) *MemoryStorage
  • func (storage *MemoryStorage) Close()
  • func (storage *MemoryStorage) Columns() []*columns.Column
  • func (storage *MemoryStorage) GetInputStream(session *sessions.Session) (datastreams.IDataBlockInputStream, error)
  • func (storage *MemoryStorage) GetOutputStream(session *sessions.Session) (datastreams.IDataBlockOutputStream, error)
  • func (storage *MemoryStorage) Name() string
• type MemoryStorageContext
  • func NewMemoryStorageContext(log *xlog.Log, conf *config.Config) *MemoryStorageContext
• type NativeBlockOutputStream
  • func NewNativeBlockOutputStream(header *datablocks.DataBlock) *NativeBlockOutputStream
  • func (stream *NativeBlockOutputStream) Close()
  • func (stream *NativeBlockOutputStream) Finalize() error
  • func (stream *NativeBlockOutputStream) Name() string
  • func (stream *NativeBlockOutputStream) SampleBlock() *datablocks.DataBlock
  • func (stream *NativeBlockOutputStream) Write(block *datablocks.DataBlock) error

Types

type MemoryStorage

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

func NewMemoryStorage

func NewMemoryStorage(ctx *MemoryStorageContext, cols []*columns.Column) *MemoryStorage

func (*MemoryStorage) Close

func (storage *MemoryStorage) Close()

func (*MemoryStorage) Columns

func (storage *MemoryStorage) Columns() []*columns.Column

func (*MemoryStorage) GetInputStream

func (storage *MemoryStorage) GetInputStream(session *sessions.Session) (datastreams.IDataBlockInputStream, error)

func (*MemoryStorage) GetOutputStream

func (storage *MemoryStorage) GetOutputStream(session *sessions.Session) (datastreams.IDataBlockOutputStream, error)

func (*MemoryStorage) Name

func (storage *MemoryStorage) Name() string

type MemoryStorageContext

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

func NewMemoryStorageContext

func NewMemoryStorageContext(log *xlog.Log, conf *config.Config) *MemoryStorageContext

type NativeBlockOutputStream

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

func NewNativeBlockOutputStream

func NewNativeBlockOutputStream(header *datablocks.DataBlock) *NativeBlockOutputStream

func (*NativeBlockOutputStream) Close

func (stream *NativeBlockOutputStream) Close()

func (*NativeBlockOutputStream) Finalize

func (stream *NativeBlockOutputStream) Finalize() error

func (*NativeBlockOutputStream) Name

func (stream *NativeBlockOutputStream) Name() string

func (*NativeBlockOutputStream) SampleBlock

func (stream *NativeBlockOutputStream) SampleBlock() *datablocks.DataBlock

func (*NativeBlockOutputStream) Write

func (stream *NativeBlockOutputStream) Write(block *datablocks.DataBlock) error