db

package

v0.0.0-...-ae11625 Latest Latest Go to latest Published: Aug 13, 2014 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/lyddonb/trajectory

Links

Open Source Insights

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 ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL