Documentation
¶
Index ¶
- Constants
- func AddAddress(conn redis.Conn, address, timestamp string) error
- func AddAddressRequest(conn redis.Conn, address, timestamp, requestId string) error
- func AddParentRequest(conn redis.Conn, address, timestamp, parentRequestId string) error
- func AddRequest(conn redis.Conn, request *Request) error
- func AddStat(conn redis.Conn, requestId string, stat Stat) error
- func AddStatAddress(conn redis.Conn, address, timestamp string) error
- func AddTask(conn redis.Conn, taskKey string, task Task) error
- func AddTaskForTaskId(conn redis.Conn, taskId, timestamp, taskKey string) error
- func AddTaskToParentRequest(conn redis.Conn, parentRequestId, timestamp, taskKey string) error
- func ScanMap(values []interface{}) (map[string]string, error)
- type DBPool
- type Request
- type Stat
- type StatDAL
- type StatDataAccess
- type Task
- type TaskDAL
- type TaskDataAccess
- func (c *TaskDataAccess) GetAddresses() ([]string, error)
- func (c *TaskDataAccess) GetRequestTaskKeys(requestId string) ([]string, error)
- func (c *TaskDataAccess) GetRequests(address string) ([]string, error)
- func (c *TaskDataAccess) GetTaskForKey(taskKey string) (Task, error)
- func (c *TaskDataAccess) GetTaskKeys(taskId string) ([]string, error)
- func (c *TaskDataAccess) SaveTask(task Task) (string, error)
Constants ¶
View Source
const ( PARENT_TASK_ID = "parent_task_id" TASK_ID = "task_id" REQUEST_ID = "request_id" PARENT_REQUESTS = "ParentRequests" PARENT_REQUEST_ID = "parent_request_id" HOST = "host" ADDRESS = "Address" URL = "url" STAT_NAME = "stat_name" STATUS_CODE = "status_code" CONTEXT_ID = "context_id" LATENCY = "gae_latency_seconds" RUN_TIME = "run_time" )
View Source
const ( ID = "id" MACHINE_INFO = "machine_info" STATS = "stats" STAT_PREFIX = "Stat" STAT_REQUEST_PREFIX = "StatRequests" STAT_ADDRESS_REQUEST = "StatAddressRequest" STAT_ADDRESS = "StatAddress" )
Variables ¶
This section is empty.
Functions ¶
func AddAddressRequest ¶
func AddParentRequest ¶
func AddTaskForTaskId ¶
func AddTaskToParentRequest ¶
Types ¶
type StatDataAccess ¶
type StatDataAccess struct {
// contains filtered or unexported fields
}
func NewStatDataAccess ¶
func NewStatDataAccess(pool DBPool) *StatDataAccess
func (*StatDataAccess) GetStatForRequest ¶
func (s *StatDataAccess) GetStatForRequest(requestId string) (Stat, error)
func (*StatDataAccess) SaveRequestStats ¶
func (s *StatDataAccess) SaveRequestStats(request *Request, stats Stat) (string, error)
type TaskDataAccess ¶
type TaskDataAccess struct {
// contains filtered or unexported fields
}
func NewTaskDataAccess ¶
func NewTaskDataAccess(pool DBPool) *TaskDataAccess
func (*TaskDataAccess) GetAddresses ¶
func (c *TaskDataAccess) GetAddresses() ([]string, error)
func (*TaskDataAccess) GetRequestTaskKeys ¶
func (c *TaskDataAccess) GetRequestTaskKeys(requestId string) ([]string, error)
func (*TaskDataAccess) GetRequests ¶
func (c *TaskDataAccess) GetRequests(address string) ([]string, error)
func (*TaskDataAccess) GetTaskForKey ¶
func (c *TaskDataAccess) GetTaskForKey(taskKey string) (Task, error)
func (*TaskDataAccess) GetTaskKeys ¶
func (c *TaskDataAccess) GetTaskKeys(taskId string) ([]string, error)
Click to show internal directories.
Click to hide internal directories.