schemaless

Documentation

Index

• Constants
• Variables
• func SetAutoReconnect(reconnect bool) func(*Config)
• func SetDb(db string) func(*Config)
• func SetEnableCompression(enableCompression bool) func(*Config)
• func SetErrorHandler(errorHandler func(error)) func(*Config)
• func SetPassword(password string) func(*Config)
• func SetReadTimeout(readTimeout time.Duration) func(*Config)
• func SetReconnectIntervalMs(reconnectIntervalMs int) func(*Config)
• func SetReconnectRetryCount(reconnectRetryCount int) func(*Config)
• func SetUser(user string) func(*Config)
• func SetWriteTimeout(writeTimeout time.Duration) func(*Config)
• type Config
  • func NewConfig(url string, chanLength uint, opts ...func(*Config)) *Config
• type IndexedChan
• type Schemaless
  • func NewSchemaless(config *Config) (*Schemaless, error)
  • func (s *Schemaless) Close()
  • func (s *Schemaless) Insert(lines string, protocol int, precision string, ttl int, reqID int64) error

Constants

const (
	InfluxDBLineProtocol       = 1
	OpenTSDBTelnetLineProtocol = 2
	OpenTSDBJsonFormatProtocol = 3
)

Variables

var (
	ConnectTimeoutErr = errors.New("schemaless connect timeout")
)

Functions

func SetAutoReconnect

func SetAutoReconnect(reconnect bool) func(*Config)

func SetDb

func SetDb(db string) func(*Config)

func SetEnableCompression

func SetEnableCompression(enableCompression bool) func(*Config)

func SetErrorHandler

func SetErrorHandler(errorHandler func(error)) func(*Config)

func SetPassword

func SetPassword(password string) func(*Config)

func SetReadTimeout

func SetReadTimeout(readTimeout time.Duration) func(*Config)

func SetReconnectIntervalMs

func SetReconnectIntervalMs(reconnectIntervalMs int) func(*Config)

func SetReconnectRetryCount

func SetReconnectRetryCount(reconnectRetryCount int) func(*Config)

func SetUser

func SetUser(user string) func(*Config)

func SetWriteTimeout

func SetWriteTimeout(writeTimeout time.Duration) func(*Config)

Types

type Config

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

func NewConfig

func NewConfig(url string, chanLength uint, opts ...func(*Config)) *Config

type IndexedChan

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

type Schemaless

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

func NewSchemaless

func NewSchemaless(config *Config) (*Schemaless, error)

func (*Schemaless) Close

func (s *Schemaless) Close()

func (*Schemaless) Insert

func (s *Schemaless) Insert(lines string, protocol int, precision string, ttl int, reqID int64) error