Documentation ¶
Index ¶
- type CollapsingMergeTreeBuffer
- func (c *CollapsingMergeTreeBuffer) Close()
- func (c *CollapsingMergeTreeBuffer) Delete(queries ...table_buffer.Query) error
- func (c *CollapsingMergeTreeBuffer) Errors() <-chan error
- func (c *CollapsingMergeTreeBuffer) Flush()
- func (c *CollapsingMergeTreeBuffer) Insert(queries ...table_buffer.Query) error
- func (c *CollapsingMergeTreeBuffer) InsertOrUpdate(queries ...table_buffer.Query) error
- func (c *CollapsingMergeTreeBuffer) Update(queries ...table_buffer.Query) error
- type MergeTreeBuffer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CollapsingMergeTreeBuffer ¶
type CollapsingMergeTreeBuffer struct {
// contains filtered or unexported fields
}
func (*CollapsingMergeTreeBuffer) Close ¶
func (c *CollapsingMergeTreeBuffer) Close()
func (*CollapsingMergeTreeBuffer) Delete ¶
func (c *CollapsingMergeTreeBuffer) Delete(queries ...table_buffer.Query) error
func (*CollapsingMergeTreeBuffer) Errors ¶
func (c *CollapsingMergeTreeBuffer) Errors() <-chan error
func (*CollapsingMergeTreeBuffer) Flush ¶
func (c *CollapsingMergeTreeBuffer) Flush()
func (*CollapsingMergeTreeBuffer) Insert ¶
func (c *CollapsingMergeTreeBuffer) Insert(queries ...table_buffer.Query) error
func (*CollapsingMergeTreeBuffer) InsertOrUpdate ¶
func (c *CollapsingMergeTreeBuffer) InsertOrUpdate(queries ...table_buffer.Query) error
func (*CollapsingMergeTreeBuffer) Update ¶
func (c *CollapsingMergeTreeBuffer) Update(queries ...table_buffer.Query) error
type MergeTreeBuffer ¶
type MergeTreeBuffer struct {
// contains filtered or unexported fields
}
func NewMergeTreeBuffer ¶
func (*MergeTreeBuffer) Close ¶
func (m *MergeTreeBuffer) Close()
func (*MergeTreeBuffer) Errors ¶
func (m *MergeTreeBuffer) Errors() <-chan error
func (*MergeTreeBuffer) Flush ¶
func (m *MergeTreeBuffer) Flush()
func (*MergeTreeBuffer) Insert ¶
func (m *MergeTreeBuffer) Insert(queries ...table_buffer.Query) error
Click to show internal directories.
Click to hide internal directories.