db_buffer

Documentation

Index

• Constants
• func ParallelCopyTxsToDB(transactions interface{}, tableName string) error
• type Buffer
  • func NewDBBuffer(db *gorm.DB, cfg Config) *Buffer
  • func (b *Buffer) ClearBuffer(dataType string)
  • func (b *Buffer) GetBufferSize(dataType string) int
  • func (b *Buffer) GetData(dataType string) (map[string]interface{}, error)
  • func (b *Buffer) InsertData(key string, height int64, data interface{}, notify bool) error
  • func (b *Buffer) SetSyncFunc(cb SyncCB)
  • func (b *Buffer) Start()
  • func (b *Buffer) Stop()
• type BufferMetrics
• type Config
• type SyncCB
• type SyncResult

Constants

const DefaultSyncPeriod = 30 * time.Second

Functions

func ParallelCopyTxsToDB

func ParallelCopyTxsToDB(transactions interface{}, tableName string) error

Types

type Buffer

type Buffer struct {
	SyncComplete chan SyncResult
	// contains filtered or unexported fields
}

func NewDBBuffer

func NewDBBuffer(db *gorm.DB, cfg Config) *Buffer

func (*Buffer) ClearBuffer

func (b *Buffer) ClearBuffer(dataType string)

func (*Buffer) GetBufferSize

func (b *Buffer) GetBufferSize(dataType string) int

func (*Buffer) GetData

func (b *Buffer) GetData(dataType string) (map[string]interface{}, error)

func (*Buffer) InsertData

func (b *Buffer) InsertData(key string, height int64, data interface{}, notify bool) error

InsertData inserts 'data' into the buffer under the key 'key' if notify is set to true, the condition 'SyncBlockThreshold' will be tested for that specific key

func (*Buffer) SetSyncFunc

func (b *Buffer) SetSyncFunc(cb SyncCB)

SetSyncFunc sets the syncing callback function

func (*Buffer) Start

func (b *Buffer) Start()

Start starts listening for syncing triggering events

func (*Buffer) Stop

func (b *Buffer) Stop()

Stop stops listening for syncing triggering events

type BufferMetrics

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

type Config

type Config struct {
	SyncTimePeriod     time.Duration
	SyncBlockThreshold uint
}

type SyncCB

type SyncCB func() SyncResult

type SyncResult

type SyncResult struct {
	Id            string
	SyncedHeights *[]uint64 // Synced heights
	Error         error     // Error in db insertion process
}