utils

Documentation

Index

• Constants
• func AppendColumn(col frames.Column, value interface{}) error
• func AppendNil(col frames.Column) error
• func AppendValue(data interface{}, value interface{}) (interface{}, error)
• func ColAt(col frames.Column, i int) (interface{}, error)
• func NewColumn(value interface{}, size int) (interface{}, error)
• func NewColumnFromType(t string, size int) (interface{}, error)
• func RemoveColumn(name string, columns []frames.Column) []frames.Column
• type HistoryEntry
• type HistoryServer
  • func NewHistoryServer(logger logger.Logger, cfg *frames.Config) (*HistoryServer, error)
  • func (m *HistoryServer) AddCreateLog(createRequest *frames.CreateRequest, duration time.Duration, ...)
  • func (m *HistoryServer) AddDeleteLog(deleteRequest *frames.DeleteRequest, duration time.Duration, ...)
  • func (m *HistoryServer) AddExecuteLog(execRequest *frames.ExecRequest, duration time.Duration, startTime time.Time)
  • func (m *HistoryServer) AddReadLog(readRequest *frames.ReadRequest, duration time.Duration, startTime time.Time)
  • func (m *HistoryServer) AddWriteLog(writeRequest *frames.WriteRequest, duration time.Duration, startTime time.Time)
  • func (m *HistoryServer) GetLogs(request *frames.HistoryRequest, out chan frames.Frame) error
  • func (m *HistoryServer) Start()
  • func (m *HistoryServer) StartEvictionTask()

Constants

const (
	WriteType = "write"
)

Functions

func AppendColumn

func AppendColumn(col frames.Column, value interface{}) error

AppendColumn appends a value to a column

func AppendNil

func AppendNil(col frames.Column) error

AppendNil appends an empty value to data

func AppendValue

func AppendValue(data interface{}, value interface{}) (interface{}, error)

AppendValue appends a value to data

func ColAt

func ColAt(col frames.Column, i int) (interface{}, error)

ColAt return value at index i in column as interface{} This is a slightly different use case than col.ValueAt, also we don't want to use defer/recover due to performance overhead

func NewColumn

func NewColumn(value interface{}, size int) (interface{}, error)

NewColumn creates a new column from type of value

func NewColumnFromType

func NewColumnFromType(t string, size int) (interface{}, error)

NewColumn creates a new column from type of value

func RemoveColumn

func RemoveColumn(name string, columns []frames.Column) []frames.Column

RemoveColumn removes the first column that matches name from columns If the column is not found, columns is unchanged

Types

type HistoryEntry

type HistoryEntry struct {
	ActionType     string
	UserName       string
	BackendName    string
	TableName      string
	Container      string
	ActionDuration time.Duration
	StartTime      time.Time

	AdditionalData map[string]string
}

type HistoryServer

type HistoryServer struct {
	WriteMonitoringLogsTimeout     time.Duration
	PendingLogsBatchSize           int
	LogsFolderPath                 string
	LogsContainer                  string
	MaxBytesInNginxRequest         int
	HistoryFileDurationSecondSpans int64
	HistoryFileNum                 int
	// contains filtered or unexported fields
}

func NewHistoryServer

func NewHistoryServer(logger logger.Logger, cfg *frames.Config) (*HistoryServer, error)

func (*HistoryServer) AddCreateLog

func (m *HistoryServer) AddCreateLog(createRequest *frames.CreateRequest, duration time.Duration, startTime time.Time)

func (*HistoryServer) AddDeleteLog

func (m *HistoryServer) AddDeleteLog(deleteRequest *frames.DeleteRequest, duration time.Duration, startTime time.Time)

func (*HistoryServer) AddExecuteLog

func (m *HistoryServer) AddExecuteLog(execRequest *frames.ExecRequest, duration time.Duration, startTime time.Time)

func (*HistoryServer) AddReadLog

func (m *HistoryServer) AddReadLog(readRequest *frames.ReadRequest, duration time.Duration, startTime time.Time)

func (*HistoryServer) AddWriteLog

func (m *HistoryServer) AddWriteLog(writeRequest *frames.WriteRequest, duration time.Duration, startTime time.Time)

func (*HistoryServer) GetLogs

func (m *HistoryServer) GetLogs(request *frames.HistoryRequest, out chan frames.Frame) error

func (*HistoryServer) Start

func (m *HistoryServer) Start()

func (*HistoryServer) StartEvictionTask

func (m *HistoryServer) StartEvictionTask()