cassandra

Documentation

Index

• Constants
• Variables
• func BaseLogWithOrgName(orgName string) string
• func KeyspaceWithOrgName(orgName string) string
• type LogMeta
• type SavedLog
  • func (l *SavedLog) String() string

Constants

const LogMetaTableName = "spot_prod.base_log_meta"

LogMetaTableName .

Variables

var DefaultBaseLogTable = "spot_prod.base_log"

DefaultBaseLogTable .

Functions

func BaseLogWithOrgName

func BaseLogWithOrgName(orgName string) string

BaseLogWithOrgName .

func KeyspaceWithOrgName

func KeyspaceWithOrgName(orgName string) string

KeyspaceWithOrgName orgName must match ^([A-Za-z0-9][-A-Za-z0-9_.]*)?[A-Za-z0-9]$ refer https://stackoverflow.com/questions/29569443/cassandra-keyspace-name-with-hyphen

Types

type LogMeta

type LogMeta struct {
	Source string
	ID     string
	Tags   map[string]string
}

LogMeta .

type SavedLog

type SavedLog struct {
	Source     string
	ID         string
	Stream     string
	TimeBucket int64 `db:"time_bucket"`
	Timestamp  int64
	Offset     int64
	Content    []byte
	Level      string
	RequestID  string `db:"request_id"`
}

SavedLog Cassandra查询的结构

func (*SavedLog) String

func (l *SavedLog) String() string

String .