client

Documentation

Index

• type Connector
• type ConnectorConfig
  • func (cfg ConnectorConfig) NewConnector(logger bark.Logger, metricScope tally.Scope) (Connector, error)
• type Row

Types

type Connector

type Connector interface {
	// Insert inserts rows to ares
	// returns number of rows inserted and error.
	// updateModes are optional, if ignored for all columns, no need to set
	// if set, then all columns needs to be set
	Insert(tableName string, columnNames []string, rows []Row, updateModes ...memCom.ColumnUpdateMode) (int, error)
}

Connector is the connector interface for ares.

type ConnectorConfig

type ConnectorConfig struct {
	// Address is in the format of host:port
	Address string `yaml:"address"`
	// DeviceChoosingTimeout value is the request timeout in seconds for http calls
	// if <= 0, will use default
	Timeout int `yaml:"timeout"`
	// SchemaRefreshInterval is the interval in seconds for the connector to
	// fetch and refresh schema from ares
	// if <= 0, will use default
	SchemaRefreshInterval int `yaml:"schemaRefreshInterval"`
}

ConnectorConfig holds the configurations for ares Connector.

func (ConnectorConfig) NewConnector

func (cfg ConnectorConfig) NewConnector(logger bark.Logger, metricScope tally.Scope) (Connector, error)

NewConnector returns a new ares Connector

type Row

type Row []interface{}

Row represents a row of insert data.