common

Documentation

Index

• func ValidateOption(option *GraphOption) error
• type CSVReader
  • func NewCsvReader(path, delimiter string, withHeader bool, limit int) *CSVReader
  • func (c *CSVReader) ReadForever(dataCh chan<- Data) error
• type CSVWriter
  • func NewCsvWriter(path, delimiter string, header []string, dataCh <-chan []string) *CSVWriter
  • func (c *CSVWriter) WriteForever() error
• type CsvOption
• type Data
• type GraphOption
  • func MakeDefaultOption(opt *GraphOption) *GraphOption
• type IClient
• type IClientPool
• type ICsvReader
• type IGraphClient
• type IGraphClientPool
• type IGraphResponse
• type OutputOption
• type PoolOption
• type PoolPolicy
• type RetryOption
• type SSLOption

Functions

func ValidateOption

func ValidateOption(option *GraphOption) error

Types

type CSVReader

type CSVReader struct {
	Path       string
	Delimiter  string
	WithHeader bool
	// contains filtered or unexported fields
}

func NewCsvReader

func NewCsvReader(path, delimiter string, withHeader bool, limit int) *CSVReader

func (*CSVReader) ReadForever

func (c *CSVReader) ReadForever(dataCh chan<- Data) error

ReadForever read the csv in slice first, and send to the data channel forever.

type CSVWriter

type CSVWriter struct {
	Path      string
	Header    []string
	Delimiter string
	DataCh    <-chan []string
}

func NewCsvWriter

func NewCsvWriter(path, delimiter string, header []string, dataCh <-chan []string) *CSVWriter

func (*CSVWriter) WriteForever

func (c *CSVWriter) WriteForever() error

type CsvOption

type CsvOption struct {
	CsvPath        string `json:"csv_path"`
	CsvDelimiter   string `json:"csv_delimiter"`
	CsvWithHeader  bool   `json:"csv_with_header"`
	CsvChannelSize int    `json:"csv_channel_size"`
	CsvDataLimit   int    `json:"csv_data_limit"`
}

type Data

type Data []string

Data data in csv file

type GraphOption

type GraphOption struct {
	PoolOption   `json:",inline"`
	OutputOption `json:",inline"`
	CsvOption    `json:",inline"`
	RetryOption  `json:",inline"`
	SSLOption    `json:",inline"`
}

func MakeDefaultOption

func MakeDefaultOption(opt *GraphOption) *GraphOption

type IClient

type IClient interface {
	Open() error
	Close() error
}

IClient common client

type IClientPool

type IClientPool interface {
	Close() error
}

IClientPool common client pool

type ICsvReader

type ICsvReader interface {
	ReadForever(dataCh chan<- Data) error
}

type IGraphClient

type IGraphClient interface {
	IClient
	GetData() (Data, error)
	Execute(stmt string) (IGraphResponse, error)
}

IGraphClient graph client

type IGraphClientPool

type IGraphClientPool interface {
	IClientPool
	GetSession() (IGraphClient, error)
	// Init initialize the poop with default channel bufferSize
	Init() (IGraphClientPool, error)
	SetOption(*GraphOption) error
}

IGraphClientPool graph client pool.

type IGraphResponse

type IGraphResponse interface {
	IsSucceed() bool
	GetLatency() int64
	GetResponseTime() int32
	GetRowSize() int32
}

IGraphResponse graph response, just support some functions to user.

type OutputOption

type OutputOption struct {
	Output            string `json:"output"`
	OutputChannelSize int    `json:"output_channel_size"`
}

type PoolOption

type PoolOption struct {
	PoolPolicy string `json:"pool_policy"`
	Address    string `json:"address"`
	TimeoutUs  int    `json:"timeout_us"`
	IdleTimeUs int    `json:"idletime_us"`
	MaxSize    int    `json:"max_size"`
	MinSize    int    `json:"min_size"`
	Username   string `json:"username"`
	Password   string `json:"password"`
	Space      string `json:"space"`
	UseHttp    bool   `json:"use_http"`
}

type PoolPolicy

type PoolPolicy string

pool policy

const (
	ConnectionPool PoolPolicy = "connection"
	SessionPool    PoolPolicy = "session"
)

type RetryOption

type RetryOption struct {
	RetryTimes      int `json:"retry_times"`
	RetryIntervalUs int `json:"retry_interval_us"`
	RetryTimeoutUs  int `json:"retry_timeout_us"`
}

type SSLOption

type SSLOption struct {
	SslCaPemPath     string `json:"ssl_ca_pem_path"`
	SslClientPemPath string `json:"ssl_client_pem_path"`
	SslClientKeyPath string `json:"ssl_client_key_path"`
}