query

Documentation

Index

• Constants
• Variables
• type CQLQueryInf
• type LogMeta
• type Logs
  • func (l Logs) Len() int
  • func (l Logs) Less(i, j int) bool
  • func (l Logs) Swap(i, j int)
• type RequestCtx
  • func (rc *RequestCtx) PatternMode() bool
• type SaveLogMeta
• type SavedLog

Constants

const (
	LogMetaTableName = "spot_prod.base_log_meta"
)

LogTableName .

Variables

var ErrEmptyLogMeta = errors.New("empty log meta record")

Types

type CQLQueryInf

type CQLQueryInf interface {
	Query(builder *qb.SelectBuilder, binding qb.M, dest interface{}) error
}

type LogMeta

type LogMeta struct {
	Source string            `json:"source"`
	ID     string            `json:"id"`
	Tags   map[string]string `json:"tags"`
}

type Logs

type Logs []*pb.LogItem

Logs .

func (Logs) Len

func (l Logs) Len() int

func (Logs) Less

func (l Logs) Less(i, j int) bool

func (Logs) Swap

func (l Logs) Swap(i, j int)

type RequestCtx

type RequestCtx struct {
	RequestID     string `form:"requestId"`
	LogID         string `form:"requestId"`
	Source        string `form:"source"`
	ID            string `form:"id"`
	Stream        string `form:"stream" default:"stdout"`
	Start         int64  `form:"start"`
	End           int64  `form:"end"`
	Count         int64  `form:"count"`
	ApplicationID string `from:"applicationId"`
	ClusterName   string `from:"clusterName"`

	// match mode
	Pattern string
	// contains filtered or unexported fields
}

Request .

func (*RequestCtx) PatternMode

func (rc *RequestCtx) PatternMode() bool

type SaveLogMeta

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

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查询的结构