db

Documentation

Index

• Constants
• func InitDb(dbType, indexName, configPath string) error
• func InitElasticDb(indexName, configPath string) error
• func IsValidDBDriver(dbDriver string) bool
• type Db
  • func NewConn(indexName, configPath string) (Db, error)
  • func NewConnOf(dbType string, indexName string, configPath string) (Db, error)
• type EContainer
• type ENetworkInterface
• type ENetworkStat
• type ENode
• type LogConn
  • func NewConnTo(elasticIP, elasticPort, logstashIP, logstashPort, indexName, configPath string) (LogConn, error)
  • func NewElasticConn(indexName string, configPath string) (LogConn, error)
  • func (c LogConn) Close()
  • func (c LogConn) CreateCluster() error
  • func (c LogConn) CreateNode(node *uc.Node) error
  • func (c LogConn) UpdateNode(node *uc.Node) error

Constants

const (
	ContainersTableName        = "containers"
	NetworkInterfacesTableName = "network_interfaces"
	NetworkStatsTableName      = "network_stats"
	NodeTableName              = "node_stats"
	DBDrivers                  = "elasticsearch"
)

const DEFAULT_DB = "elasticsearch"

Functions

func InitDb

func InitDb(dbType, indexName, configPath string) error

func InitElasticDb

func InitElasticDb(indexName, configPath string) error

func IsValidDBDriver

func IsValidDBDriver(dbDriver string) bool

Types

type Db

type Db interface {
	Close()
	UpdateNode(*uc.Node) error
	CreateNode(*uc.Node) error
	CreateCluster() error
}

func NewConn

func NewConn(indexName, configPath string) (Db, error)

func NewConnOf

func NewConnOf(dbType string, indexName string, configPath string) (Db, error)

type EContainer

type EContainer struct {
	IsActive  bool
	DockerID  string
	Name      string
	NodeName  string
	CreatedAt time.Time
	UpdatedAt time.Time
	DeletedAt *time.Time
}

type ENetworkInterface

type ENetworkInterface struct {
	Name string
}

type ENetworkStat

type ENetworkStat struct {
	Value                int64
	Name                 string
	ContainerDockerID    string
	ContainerName        string
	NodeName             string
	NetworkInterfaceName string
	UpdatedAt            time.Time
}

type ENode

type ENode struct {
	Name      string
	CreatedAt time.Time
	UpdatedAt time.Time
	DeletedAt *time.Time
}

type LogConn

type LogConn struct {
	*elastic.Client
	// contains filtered or unexported fields
}

func NewConnTo

func NewConnTo(elasticIP, elasticPort, logstashIP, logstashPort, indexName, configPath string) (LogConn, error)

func NewElasticConn

func NewElasticConn(indexName string, configPath string) (LogConn, error)

func (LogConn) Close

func (c LogConn) Close()

func (LogConn) CreateCluster

func (c LogConn) CreateCluster() error

func (LogConn) CreateNode

func (c LogConn) CreateNode(node *uc.Node) error

func (LogConn) UpdateNode

func (c LogConn) UpdateNode(node *uc.Node) error