system

Documentation

Index

• type DatabasesFillFunc
• type SystemDatabasesStorage
  • func NewSystemDatabasesStorage(ctx *SystemStorageContext) *SystemDatabasesStorage
  • func (storage *SystemDatabasesStorage) Close()
  • func (storage *SystemDatabasesStorage) Columns() []*columns.Column
  • func (storage *SystemDatabasesStorage) GetInputStream(session *sessions.Session) (datastreams.IDataBlockInputStream, error)
  • func (storage *SystemDatabasesStorage) GetOutputStream(session *sessions.Session) (datastreams.IDataBlockOutputStream, error)
  • func (storage *SystemDatabasesStorage) Name() string
• type SystemNumbersBlockIntputStream
  • func NewSystemNumbersBlockInputStream(storage *SystemNumbersStorage) *SystemNumbersBlockIntputStream
  • func (stream *SystemNumbersBlockIntputStream) Close()
  • func (stream *SystemNumbersBlockIntputStream) Name() string
  • func (stream *SystemNumbersBlockIntputStream) Read() (*datablocks.DataBlock, error)
• type SystemNumbersStorage
  • func NewSystemNumbersStorage(ctx *SystemStorageContext) *SystemNumbersStorage
  • func (storage *SystemNumbersStorage) Close()
  • func (storage *SystemNumbersStorage) Columns() []*columns.Column
  • func (storage *SystemNumbersStorage) GetInputStream(session *sessions.Session) (datastreams.IDataBlockInputStream, error)
  • func (storage *SystemNumbersStorage) GetOutputStream(session *sessions.Session) (datastreams.IDataBlockOutputStream, error)
  • func (storage *SystemNumbersStorage) Name() string
• type SystemStorageContext
  • func NewSystemStorageContext(log *xlog.Log, conf *config.Config, tablesFillFunc TablesFillFunc, ...) *SystemStorageContext
• type SystemTablesStorage
  • func NewSystemTablesStorage(ctx *SystemStorageContext) *SystemTablesStorage
  • func (storage *SystemTablesStorage) Close()
  • func (storage *SystemTablesStorage) Columns() []*columns.Column
  • func (storage *SystemTablesStorage) GetInputStream(session *sessions.Session) (datastreams.IDataBlockInputStream, error)
  • func (storage *SystemTablesStorage) GetOutputStream(session *sessions.Session) (datastreams.IDataBlockOutputStream, error)
  • func (storage *SystemTablesStorage) Name() string
• type TablesFillFunc

Types

type DatabasesFillFunc

type DatabasesFillFunc func(*datablocks.DataBlock) error

type SystemDatabasesStorage

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

func NewSystemDatabasesStorage

func NewSystemDatabasesStorage(ctx *SystemStorageContext) *SystemDatabasesStorage

func (*SystemDatabasesStorage) Close

func (storage *SystemDatabasesStorage) Close()

func (*SystemDatabasesStorage) Columns

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

func (*SystemDatabasesStorage) GetInputStream

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

func (*SystemDatabasesStorage) GetOutputStream

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

func (*SystemDatabasesStorage) Name

func (storage *SystemDatabasesStorage) Name() string

type SystemNumbersBlockIntputStream

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

func NewSystemNumbersBlockInputStream

func NewSystemNumbersBlockInputStream(storage *SystemNumbersStorage) *SystemNumbersBlockIntputStream

func (*SystemNumbersBlockIntputStream) Close

func (stream *SystemNumbersBlockIntputStream) Close()

func (*SystemNumbersBlockIntputStream) Name

func (stream *SystemNumbersBlockIntputStream) Name() string

func (*SystemNumbersBlockIntputStream) Read

func (stream *SystemNumbersBlockIntputStream) Read() (*datablocks.DataBlock, error)

type SystemNumbersStorage

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

func NewSystemNumbersStorage

func NewSystemNumbersStorage(ctx *SystemStorageContext) *SystemNumbersStorage

func (*SystemNumbersStorage) Close

func (storage *SystemNumbersStorage) Close()

func (*SystemNumbersStorage) Columns

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

func (*SystemNumbersStorage) GetInputStream

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

func (*SystemNumbersStorage) GetOutputStream

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

func (*SystemNumbersStorage) Name

func (storage *SystemNumbersStorage) Name() string

type SystemStorageContext

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

func NewSystemStorageContext

func NewSystemStorageContext(log *xlog.Log, conf *config.Config, tablesFillFunc TablesFillFunc, databasesFillFunc DatabasesFillFunc) *SystemStorageContext

type SystemTablesStorage

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

func NewSystemTablesStorage

func NewSystemTablesStorage(ctx *SystemStorageContext) *SystemTablesStorage

func (*SystemTablesStorage) Close

func (storage *SystemTablesStorage) Close()

func (*SystemTablesStorage) Columns

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

func (*SystemTablesStorage) GetInputStream

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

func (*SystemTablesStorage) GetOutputStream

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

func (*SystemTablesStorage) Name

func (storage *SystemTablesStorage) Name() string

type TablesFillFunc

type TablesFillFunc func(*datablocks.DataBlock) error