teadb

package
v0.1.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 1, 2019 License: MIT Imports: 26 Imported by: 24

Documentation

Index

Constants

View Source 
const (
	SortAsc  = "asc"
	SortDesc = "desc"
)

Variables

View Source 
var ErrorDBUnavailable = errors.New("database is not available")

Functions

func SetupDB 

func SetupDB()

Types

type AccessLogDAOInterface 

type AccessLogDAOInterface interface {
	// 初始化
	Init()

	// 获取表名
	TableName(day string) string

	// 写入一条日志
	InsertOne(accessLog *accesslogs.AccessLog) error

	// 写入一组日志
	InsertAccessLogs(accessLogList []interface{}) error

	// 查找某条访问日志的cookie信息
	FindAccessLogCookie(day string, logId string) (*accesslogs.AccessLog, error)

	// 查找某条访问日志的请求信息
	FindRequestHeaderAndBody(day string, logId string) (*accesslogs.AccessLog, error)

	// 查找某条访问日志的响应信息
	FindResponseHeaderAndBody(day string, logId string) (*accesslogs.AccessLog, error)

	// 列出日志
	ListAccessLogs(day string, serverId string, fromId string, onlyErrors bool, searchIP string, offset int, size int) ([]*accesslogs.AccessLog, error)

	// 检查是否有下一条日志
	HasNextAccessLog(day string, serverId string, fromId string, onlyErrors bool, searchIP string) (bool, error)

	// 判断某个代理服务是否有日志
	HasAccessLog(day string, serverId string) (bool, error)

	// 列出最近的某些日志
	ListLatestAccessLogs(day string, serverId string, fromId string, onlyErrors bool, size int) ([]*accesslogs.AccessLog, error)

	// 列出某天的一些日志
	ListTopAccessLogs(day string, size int) ([]*accesslogs.AccessLog, error)

	// 根据查询条件来查找日志
	QueryAccessLogs(day string, serverId string, query *Query) ([]*accesslogs.AccessLog, error)
}

func AccessLogDAO 

func AccessLogDAO() AccessLogDAOInterface

type AgentLogDAOInterface 

type AgentLogDAOInterface interface {
	Init()

	// 插入一条数据
	InsertOne(agentId string, log *agents.ProcessLog) error

	// 获取最新任务的日志
	FindLatestTaskLogs(agentId string, taskId string, fromId string, size int) ([]*agents.ProcessLog, error)

	// 获取任务最后一次的执行日志
	FindLatestTaskLog(agentId string, taskId string) (*agents.ProcessLog, error)
}

func AgentLogDAO 

func AgentLogDAO() AgentLogDAOInterface

type AgentValueDAOInterface 

type AgentValueDAOInterface interface {
	Init()
	TableName(agentId string) string
	Insert(agentId string, value *agents.Value) error
	ClearItemValues(agentId string, appId string, itemId string, level notices.NoticeLevel) error
	FindLatestItemValue(agentId string, appId string, itemId string) (*agents.Value, error)
	FindLatestItemValueNoError(agentId string, appId string, itemId string) (*agents.Value, error)

	// 取得最近的数值记录
	FindLatestItemValues(agentId string, appId string, itemId string, noticeLevel notices.NoticeLevel, lastId string, size int) ([]*agents.Value, error)

	ListItemValues(agentId string, appId string, itemId string, noticeLevel notices.NoticeLevel, lastId string, offset int, size int) ([]*agents.Value, error)
	QueryValues(query *Query) ([]*agents.Value, error)
	GroupValuesByTime(query *Query, timeField string, result map[string]Expr) ([]*agents.Value, error)
	DropAgentTable(agentId string) error
}

func AgentValueDAO 

func AgentValueDAO() AgentValueDAOInterface

type AuditLogDAOInterface 

type AuditLogDAOInterface interface {
	Init()
	CountAllAuditLogs() (int64, error)
	ListAuditLogs(offset int, size int) ([]*audits.Log, error)
	InsertOne(auditLog *audits.Log) error
}

func AuditLogDAO 

func AuditLogDAO() AuditLogDAOInterface

type AvgExpr 

type AvgExpr struct {
	Field string
}

func NewAvgExpr 

func NewAvgExpr(field string) *AvgExpr

type BaseDriver 

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

func (*BaseDriver) IsAvailable 

func (this *BaseDriver) IsAvailable() bool

func (*BaseDriver) SetIsAvailable 

func (this *BaseDriver) SetIsAvailable(b bool)

type DriverInterface 

type DriverInterface interface {
	// 初始化
	Init()

	// 设置是否可用
	SetIsAvailable(b bool)

	// 取得是否可用
	IsAvailable() bool

	// 查找单条记录
	FindOne(query *Query, modelPtr interface{}) (interface{}, error)

	// 查找多条记录
	FindOnes(query *Query, modelPtr interface{}) ([]interface{}, error)

	// 插入一条记录
	InsertOne(table string, modelPtr interface{}) error

	// 插入多条记录
	InsertOnes(table string, modelPtrSlice interface{}) error

	// 删除多条记录
	DeleteOnes(query *Query) error

	// 计算总数量
	Count(query *Query) (int64, error)

	// 计算总和
	Sum(query *Query, field string) (float64, error)

	// 计算平均值
	Avg(query *Query, field string) (float64, error)

	// 计算最小值
	Min(query *Query, field string) (float64, error)

	// 计算最大值
	Max(query *Query, field string) (float64, error)

	// 对数据进行分组统计
	Group(query *Query, field string, result map[string]Expr) ([]maps.Map, error)

	// 测试数据库连接
	Test() error
}

func SharedDB 

func SharedDB() DriverInterface

type Expr 

type Expr interface {
}

type MaxExpr 

type MaxExpr struct {
	Field string
}

func NewMaxExpr 

func NewMaxExpr(field string) *MaxExpr

type MinExpr 

type MinExpr struct {
	Field string
}

func NewMinExpr 

func NewMinExpr(field string) *MinExpr

type MongoAccessLogDAO 

type MongoAccessLogDAO struct {
}

func (*MongoAccessLogDAO) FindAccessLogCookie 

func (this *MongoAccessLogDAO) FindAccessLogCookie(day string, logId string) (*accesslogs.AccessLog, error)

func (*MongoAccessLogDAO) FindRequestHeaderAndBody 

func (this *MongoAccessLogDAO) FindRequestHeaderAndBody(day string, logId string) (*accesslogs.AccessLog, error)

func (*MongoAccessLogDAO) FindResponseHeaderAndBody 

func (this *MongoAccessLogDAO) FindResponseHeaderAndBody(day string, logId string) (*accesslogs.AccessLog, error)

func (*MongoAccessLogDAO) HasAccessLog 

func (this *MongoAccessLogDAO) HasAccessLog(day string, serverId string) (bool, error)

func (*MongoAccessLogDAO) HasNextAccessLog 

func (this *MongoAccessLogDAO) HasNextAccessLog(day string, serverId string, fromId string, onlyErrors bool, searchIP string) (bool, error)

func (*MongoAccessLogDAO) Init 

func (this *MongoAccessLogDAO) Init()

func (*MongoAccessLogDAO) InsertAccessLogs 

func (this *MongoAccessLogDAO) InsertAccessLogs(accessLogList []interface{}) error

写入一组日志

func (*MongoAccessLogDAO) InsertOne 

func (this *MongoAccessLogDAO) InsertOne(accessLog *accesslogs.AccessLog) error

写入一条日志

func (*MongoAccessLogDAO) ListAccessLogs 

func (this *MongoAccessLogDAO) ListAccessLogs(day string, serverId string, fromId string, onlyErrors bool, searchIP string, offset int, size int) ([]*accesslogs.AccessLog, error)

func (*MongoAccessLogDAO) ListLatestAccessLogs 

func (this *MongoAccessLogDAO) ListLatestAccessLogs(day string, serverId string, fromId string, onlyErrors bool, size int) ([]*accesslogs.AccessLog, error)

func (*MongoAccessLogDAO) ListTopAccessLogs 

func (this *MongoAccessLogDAO) ListTopAccessLogs(day string, size int) ([]*accesslogs.AccessLog, error)

func (*MongoAccessLogDAO) QueryAccessLogs 

func (this *MongoAccessLogDAO) QueryAccessLogs(day string, serverId string, query *Query) ([]*accesslogs.AccessLog, error)

func (*MongoAccessLogDAO) TableName 

func (this *MongoAccessLogDAO) TableName(day string) string

type MongoAgentLogDAO 

type MongoAgentLogDAO struct {
}

func (*MongoAgentLogDAO) FindLatestTaskLog 

func (this *MongoAgentLogDAO) FindLatestTaskLog(agentId string, taskId string) (*agents.ProcessLog, error)

获取任务最后一次的执行日志

func (*MongoAgentLogDAO) FindLatestTaskLogs 

func (this *MongoAgentLogDAO) FindLatestTaskLogs(agentId string, taskId string, fromId string, size int) ([]*agents.ProcessLog, error)

获取任务的日志

func (*MongoAgentLogDAO) Init 

func (this *MongoAgentLogDAO) Init()

func (*MongoAgentLogDAO) InsertOne 

func (this *MongoAgentLogDAO) InsertOne(agentId string, log *agents.ProcessLog) error

插入一条数据

func (*MongoAgentLogDAO) TableName 

func (this *MongoAgentLogDAO) TableName(agentId string) string

type MongoAgentValueDAO 

type MongoAgentValueDAO struct {
}

func (*MongoAgentValueDAO) ClearItemValues 

func (this *MongoAgentValueDAO) ClearItemValues(agentId string, appId string, itemId string, level notices.NoticeLevel) error

func (*MongoAgentValueDAO) DropAgentTable 

func (this *MongoAgentValueDAO) DropAgentTable(agentId string) error

func (*MongoAgentValueDAO) FindLatestItemValue 

func (this *MongoAgentValueDAO) FindLatestItemValue(agentId string, appId string, itemId string) (*agents.Value, error)

func (*MongoAgentValueDAO) FindLatestItemValueNoError 

func (this *MongoAgentValueDAO) FindLatestItemValueNoError(agentId string, appId string, itemId string) (*agents.Value, error)

func (*MongoAgentValueDAO) FindLatestItemValues 

func (this *MongoAgentValueDAO) FindLatestItemValues(agentId string, appId string, itemId string, noticeLevel notices.NoticeLevel, lastId string, size int) ([]*agents.Value, error)

取得最近的数值记录

func (*MongoAgentValueDAO) GroupValuesByTime 

func (this *MongoAgentValueDAO) GroupValuesByTime(query *Query, timeField string, result map[string]Expr) ([]*agents.Value, error)

func (*MongoAgentValueDAO) Init 

func (this *MongoAgentValueDAO) Init()

func (*MongoAgentValueDAO) Insert 

func (this *MongoAgentValueDAO) Insert(agentId string, value *agents.Value) error

func (*MongoAgentValueDAO) ListItemValues 

func (this *MongoAgentValueDAO) ListItemValues(agentId string, appId string, itemId string, noticeLevel notices.NoticeLevel, lastId string, offset int, size int) ([]*agents.Value, error)

func (*MongoAgentValueDAO) QueryValues 

func (this *MongoAgentValueDAO) QueryValues(query *Query) ([]*agents.Value, error)

func (*MongoAgentValueDAO) TableName 

func (this *MongoAgentValueDAO) TableName(agentId string) string

type MongoAuditLogDAO 

type MongoAuditLogDAO struct {
}

func (*MongoAuditLogDAO) CountAllAuditLogs 

func (this *MongoAuditLogDAO) CountAllAuditLogs() (int64, error)

func (*MongoAuditLogDAO) Init 

func (this *MongoAuditLogDAO) Init()

func (*MongoAuditLogDAO) InsertOne 

func (this *MongoAuditLogDAO) InsertOne(auditLog *audits.Log) error

func (*MongoAuditLogDAO) ListAuditLogs 

func (this *MongoAuditLogDAO) ListAuditLogs(offset int, size int) ([]*audits.Log, error)

type MongoDriver 

type MongoDriver struct {
	BaseDriver
}

func (*MongoDriver) Avg 

func (this *MongoDriver) Avg(query *Query, field string) (float64, error)

func (*MongoDriver) Count 

func (this *MongoDriver) Count(query *Query) (int64, error)

func (*MongoDriver) DeleteOnes 

func (this *MongoDriver) DeleteOnes(query *Query) error

func (*MongoDriver) FindOne 

func (this *MongoDriver) FindOne(query *Query, modelPtr interface{}) (interface{}, error)

func (*MongoDriver) FindOnes 

func (this *MongoDriver) FindOnes(query *Query, modelPtr interface{}) ([]interface{}, error)

func (*MongoDriver) Group 

func (this *MongoDriver) Group(query *Query, field string, result map[string]Expr) ([]maps.Map, error)

func (*MongoDriver) Init 

func (this *MongoDriver) Init()

func (*MongoDriver) InsertOne 

func (this *MongoDriver) InsertOne(table string, modelPtr interface{}) error

func (*MongoDriver) InsertOnes 

func (this *MongoDriver) InsertOnes(table string, modelPtrSlice interface{}) error

func (*MongoDriver) Max 

func (this *MongoDriver) Max(query *Query, field string) (float64, error)

func (*MongoDriver) Min 

func (this *MongoDriver) Min(query *Query, field string) (float64, error)

func (*MongoDriver) Sum 

func (this *MongoDriver) Sum(query *Query, field string) (float64, error)

func (*MongoDriver) Test 

func (this *MongoDriver) Test() error

测试数据库连接

type MongoNoticeDAO 

type MongoNoticeDAO struct {
}

func (*MongoNoticeDAO) CountAllReadNotices 

func (this *MongoNoticeDAO) CountAllReadNotices() (int, error)

func (*MongoNoticeDAO) CountAllUnreadNotices 

func (this *MongoNoticeDAO) CountAllUnreadNotices() (int, error)

func (*MongoNoticeDAO) CountReadNoticesForAgent 

func (this *MongoNoticeDAO) CountReadNoticesForAgent(agentId string) (int, error)

func (*MongoNoticeDAO) CountReceivedNotices 

func (this *MongoNoticeDAO) CountReceivedNotices(receiverId string, cond map[string]interface{}, minutes int) (int, error)

func (*MongoNoticeDAO) CountUnreadNoticesForAgent 

func (this *MongoNoticeDAO) CountUnreadNoticesForAgent(agentId string) (int, error)

func (*MongoNoticeDAO) DeleteNoticesForAgent 

func (this *MongoNoticeDAO) DeleteNoticesForAgent(agentId string) error

func (*MongoNoticeDAO) ExistNoticesWithHash 

func (this *MongoNoticeDAO) ExistNoticesWithHash(hash string, cond map[string]interface{}, duration time.Duration) (bool, error)

func (*MongoNoticeDAO) Init 

func (this *MongoNoticeDAO) Init()

func (*MongoNoticeDAO) InsertOne 

func (this *MongoNoticeDAO) InsertOne(notice *notices.Notice) error

func (*MongoNoticeDAO) ListAgentNotices 

func (this *MongoNoticeDAO) ListAgentNotices(agentId string, isRead bool, offset int, size int) ([]*notices.Notice, error)

列出某个Agent相关的消息

func (*MongoNoticeDAO) ListNotices 

func (this *MongoNoticeDAO) ListNotices(isRead bool, offset int, size int) ([]*notices.Notice, error)

列出消息

func (*MongoNoticeDAO) NotifyProxyMessage 

func (this *MongoNoticeDAO) NotifyProxyMessage(cond notices.ProxyCond, message string) error

func (*MongoNoticeDAO) NotifyProxyServerMessage 

func (this *MongoNoticeDAO) NotifyProxyServerMessage(serverId string, level notices.NoticeLevel, message string) error

func (*MongoNoticeDAO) TableName 

func (this *MongoNoticeDAO) TableName() string

func (*MongoNoticeDAO) UpdateAgentNoticesRead 

func (this *MongoNoticeDAO) UpdateAgentNoticesRead(agentId string, noticeIds []string) error

设置Agent的一组通知已读

func (*MongoNoticeDAO) UpdateAllAgentNoticesRead 

func (this *MongoNoticeDAO) UpdateAllAgentNoticesRead(agentId string) error

设置Agent所有通知已读

func (*MongoNoticeDAO) UpdateAllNoticesRead 

func (this *MongoNoticeDAO) UpdateAllNoticesRead() error

func (*MongoNoticeDAO) UpdateNoticeReceivers 

func (this *MongoNoticeDAO) UpdateNoticeReceivers(noticeId string, receiverIds []string) error

func (*MongoNoticeDAO) UpdateNoticesRead 

func (this *MongoNoticeDAO) UpdateNoticesRead(noticeIds []string) error

设置一组通知已读

type MongoServerValueDAO 

type MongoServerValueDAO struct {
}

func (*MongoServerValueDAO) CreateIndex 

func (this *MongoServerValueDAO) CreateIndex(serverId string, fields []*shared.IndexField) error

func (*MongoServerValueDAO) DeleteExpiredValues 

func (this *MongoServerValueDAO) DeleteExpiredValues(serverId string, period stats.ValuePeriod, life int) error

func (*MongoServerValueDAO) DropServerTable 

func (this *MongoServerValueDAO) DropServerTable(serverId string) error

删除代理服务相关表

func (*MongoServerValueDAO) FindOneWithItem 

func (this *MongoServerValueDAO) FindOneWithItem(serverId string, item string) (*stats.Value, error)

func (*MongoServerValueDAO) FindSameItemValue 

func (this *MongoServerValueDAO) FindSameItemValue(serverId string, item *stats.Value) (*stats.Value, error)

根据参数查询已有的数据

func (*MongoServerValueDAO) Init 

func (this *MongoServerValueDAO) Init()

func (*MongoServerValueDAO) InsertOne 

func (this *MongoServerValueDAO) InsertOne(serverId string, value *stats.Value) error

func (*MongoServerValueDAO) QueryValues 

func (this *MongoServerValueDAO) QueryValues(query *Query) ([]*stats.Value, error)

func (*MongoServerValueDAO) TableName 

func (this *MongoServerValueDAO) TableName(serverId string) string

func (*MongoServerValueDAO) UpdateItemValueAndTimestamp 

func (this *MongoServerValueDAO) UpdateItemValueAndTimestamp(serverId string, valueId string, value map[string]interface{}, timestamp int64) error

type MySQLDriver 

type MySQLDriver struct {
}

func (*MySQLDriver) Init 

func (this *MySQLDriver) Init()

type NoticeDAOInterface 

type NoticeDAOInterface interface {
	Init()

	// 写入一个通知
	InsertOne(notice *notices.Notice) error

	// 发送一个代理的通知（形式1）
	NotifyProxyMessage(cond notices.ProxyCond, message string) error

	// 发送一个代理的通知（形式2）
	NotifyProxyServerMessage(serverId string, level notices.NoticeLevel, message string) error

	// 获取所有未读通知数
	CountAllUnreadNotices() (int, error)

	// 获取所有已读通知数
	CountAllReadNotices() (int, error)

	// 获取某个Agent的未读通知数
	CountUnreadNoticesForAgent(agentId string) (int, error)

	// 获取某个Agent已读通知数
	CountReadNoticesForAgent(agentId string) (int, error)

	// 获取某个接收人在某个时间段内接收的通知数
	CountReceivedNotices(receiverId string, cond map[string]interface{}, minutes int) (int, error)

	// 通过Hash判断是否存在相同的消息
	ExistNoticesWithHash(hash string, cond map[string]interface{}, duration time.Duration) (bool, error)

	// 列出消息
	ListNotices(isRead bool, offset int, size int) ([]*notices.Notice, error)

	// 列出某个Agent相关的消息
	ListAgentNotices(agentId string, isRead bool, offset int, size int) ([]*notices.Notice, error)

	// 删除Agent相关通知
	DeleteNoticesForAgent(agentId string) error

	// 更改某个通知的接收人
	UpdateNoticeReceivers(noticeId string, receiverIds []string) error

	// 设置全部已读
	UpdateAllNoticesRead() error

	// 设置一组通知已读
	UpdateNoticesRead(noticeIds []string) error

	// 设置Agent的一组通知已读
	UpdateAgentNoticesRead(agentId string, noticeIds []string) error

	// 设置Agent所有通知已读
	UpdateAllAgentNoticesRead(agentId string) error
}

func NoticeDAO 

func NoticeDAO() NoticeDAOInterface

type Operand 

type Operand struct {
	Code  OperandCode
	Value interface{}
}

func NewOperand 

func NewOperand(code OperandCode, value interface{}) *Operand

type OperandCode 

type OperandCode = string
const (
	OperandEq    OperandCode = "eq"
	OperandLt    OperandCode = "lt"
	OperandLte   OperandCode = "lte"
	OperandGt    OperandCode = "gt"
	OperandGte   OperandCode = "gte"
	OperandIn    OperandCode = "in"
	OperandNotIn OperandCode = "nin"
	OperandNeq   OperandCode = "ne"
	OperandOr    OperandCode = "or"
)

type OperandMap 

type OperandMap map[string][]*Operand

type PostgresDriver 

type PostgresDriver struct {
}

func (*PostgresDriver) Init 

func (this *PostgresDriver) Init()

type Query 

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

func NewQuery 

func NewQuery(table string) *Query

func (*Query) Asc 

func (this *Query) Asc(field string) *Query

func (*Query) Attr 

func (this *Query) Attr(field string, value interface{}) *Query

func (*Query) Avg 

func (this *Query) Avg(field string) (float64, error)

func (*Query) Count 

func (this *Query) Count() (int64, error)

func (*Query) Debug 

func (this *Query) Debug() *Query

func (*Query) Delete 

func (this *Query) Delete() error

func (*Query) Desc 

func (this *Query) Desc(field string) *Query

func (*Query) FindOne 

func (this *Query) FindOne(modelPtr interface{}) (interface{}, error)

func (*Query) FindOnes 

func (this *Query) FindOnes(modelPtr interface{}) ([]interface{}, error)

func (*Query) Group 

func (this *Query) Group(field string, result map[string]Expr) ([]maps.Map, error)

func (*Query) Gt 

func (this *Query) Gt(field string, value interface{}) *Query

func (*Query) Gte 

func (this *Query) Gte(field string, value interface{}) *Query

func (*Query) Init 

func (this *Query) Init() *Query

func (*Query) InsertOne 

func (this *Query) InsertOne(modelPtr interface{}) error

func (*Query) InsertOnes 

func (this *Query) InsertOnes(modelPtrSlice interface{}) error

func (*Query) Limit 

func (this *Query) Limit(size int) *Query

func (*Query) Lt 

func (this *Query) Lt(field string, value interface{}) *Query

func (*Query) Lte 

func (this *Query) Lte(field string, value interface{}) *Query

func (*Query) Max 

func (this *Query) Max(field string) (float64, error)

func (*Query) Min 

func (this *Query) Min(field string) (float64, error)

func (*Query) Node 

func (this *Query) Node() *Query

func (*Query) Not 

func (this *Query) Not(field string, value interface{}) *Query

func (*Query) Offset 

func (this *Query) Offset(offset int) *Query

func (*Query) Op 

func (this *Query) Op(field string, operandCode OperandCode, value interface{}) *Query

func (*Query) Or 

func (this *Query) Or(fieldValues []OperandMap) *Query

func (*Query) Result 

func (this *Query) Result(field ...string) *Query

func (*Query) Sum 

func (this *Query) Sum(field string) (float64, error)

func (*Query) Table 

func (this *Query) Table(table string) *Query

func (*Query) Timeout 

func (this *Query) Timeout(timeout time.Duration) *Query

type ServerValueDAOInterface 

type ServerValueDAOInterface interface {
	Init()
	TableName(serverId string) string

	// 插入新数据
	InsertOne(serverId string, value *stats.Value) error

	// 删除过期的数据
	DeleteExpiredValues(serverId string, period stats.ValuePeriod, life int) error

	// 查询相同的数值记录
	FindSameItemValue(serverId string, item *stats.Value) (*stats.Value, error)

	// 修改值和时间戳
	UpdateItemValueAndTimestamp(serverId string, valueId string, value map[string]interface{}, timestamp int64) error

	// 创建索引
	CreateIndex(serverId string, fields []*shared.IndexField) error

	// 查询数据
	QueryValues(query *Query) ([]*stats.Value, error)

	// 根据item查找一条数据
	FindOneWithItem(serverId string, item string) (*stats.Value, error)

	// 删除代理服务相关表
	DropServerTable(serverId string) error
}

func ServerValueDAO 

func ServerValueDAO() ServerValueDAOInterface

type SortField 

type SortField struct {
	Name string
	Type SortType
}

func (*SortField) IsAsc 

func (this *SortField) IsAsc() bool

func (*SortField) IsDesc 

func (this *SortField) IsDesc() bool

type SortType 

type SortType = string

type SumExpr 

type SumExpr struct {
	Field string
}

func NewSumExpr 

func NewSumExpr(field string) *SumExpr

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.