mysql

Documentation

Index

• Constants
• type MysqlKubeEventPoint
• type MysqlService
  • func NewMysqlClient(uri *url.URL) (*MysqlService, error)
  • func (mySvc MysqlService) CloseDB() error
  • func (mySvc MysqlService) CreateDatabase(name string) error
  • func (mySvc MysqlService) FlushData() error
  • func (mySvc MysqlService) SaveData(sinkData []interface{}) error

Constants

const (
	DEFAULT_TABLE = "k8s-event"
)

Types

type MysqlKubeEventPoint

type MysqlKubeEventPoint struct {
	Namespace                string
	Kind                     string
	Name                     string
	Type                     string
	Reason                   string
	Message                  string
	EventID                  string
	FirstOccurrenceTimestamp string
	LastOccurrenceTimestamp  string
}

type MysqlService

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

func NewMysqlClient

func NewMysqlClient(uri *url.URL) (*MysqlService, error)

func (MysqlService) CloseDB

func (mySvc MysqlService) CloseDB() error

func (MysqlService) CreateDatabase

func (mySvc MysqlService) CreateDatabase(name string) error

func (MysqlService) FlushData

func (mySvc MysqlService) FlushData() error

func (MysqlService) SaveData

func (mySvc MysqlService) SaveData(sinkData []interface{}) error