db

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
  • func StartDB(server, password string) DBPool
• type Request
• type Stat
• type StatDAL
• type StatDataAccess
  • func NewStatDataAccess(pool DBPool) *StatDataAccess
  • func (s *StatDataAccess) GetStatForRequest(requestId string) (Stat, error)
  • func (s *StatDataAccess) SaveRequestStats(request *Request, stats Stat) (string, error)
• type Task
  • func (t Task) Key() string
• type TaskDAL
• type TaskDataAccess
  • func NewTaskDataAccess(pool DBPool) *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

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"
)

const (
	ID                   = "id"
	MACHINE_INFO         = "machine_info"
	STATS                = "stats"
	STAT_PREFIX          = "Stat"
	STAT_REQUEST_PREFIX  = "StatRequests"
	STAT_ADDRESS_REQUEST = "StatAddressRequest"
	STAT_ADDRESS         = "StatAddress"
)

Functions

func AddAddress

func AddAddress(conn redis.Conn, address, timestamp string) error

func AddAddressRequest

func AddAddressRequest(conn redis.Conn, address, timestamp, requestId string) error

func AddParentRequest

func AddParentRequest(conn redis.Conn, address, timestamp, parentRequestId string) error

func AddRequest

func AddRequest(conn redis.Conn, request *Request) error

func AddStat

func AddStat(conn redis.Conn, requestId string, stat Stat) error

func AddStatAddress

func AddStatAddress(conn redis.Conn, address, timestamp string) error

func AddTask

func AddTask(conn redis.Conn, taskKey string, task Task) error

func AddTaskForTaskId

func AddTaskForTaskId(
	conn redis.Conn, taskId, timestamp, taskKey string) error

func AddTaskToParentRequest

func AddTaskToParentRequest(
	conn redis.Conn, parentRequestId, timestamp, taskKey string) error

func ScanMap

func ScanMap(values []interface{}) (map[string]string, error)

Types

type DBPool

type DBPool interface {
	Get() redis.Conn
}

func StartDB

func StartDB(server, password string) DBPool

type Request

type Request struct {
	RequestId   string `redis:request_id`
	MachineInfo string `redis:machine_info`
	Url         string `redis:url`
}

type Stat

type Stat map[string]string

type StatDAL

type StatDAL interface {
	SaveRequestStats(request *Request, stats Stat) (string, error)
	GetStatForRequest(requestId string) (Stat, error)
}

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 Task

type Task map[string]string

func (Task) Key

func (t Task) Key() string

type TaskDAL

type TaskDAL interface {
	GetRequests(machine string) ([]string, error)
	GetRequestTaskKeys(requestId string) ([]string, error)
	GetAddresses() ([]string, error)
	SaveTask(task Task) (string, error)
	GetTaskForKey(taskKey string) (Task, error)
	GetTaskKeys(taskId string) ([]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)

func (*TaskDataAccess) SaveTask

func (c *TaskDataAccess) SaveTask(task Task) (string, error)