hippo

package module

Go to main page

Versions in this module

v1

v1.5.3

Jul 7, 2020

v1.5.2

Jun 21, 2019

Changes in this version

+ func EnsureDir(dirName string, mode int) (bool, error)

v1.5.1

Jun 1, 2019

v1.5.0

May 26, 2019

Changes in this version

+ type Latency struct

+ Actions map[string][]Point

+ func NewLatencyTracker() *Latency

+ func (l *Latency) GetLatency(name string) (time.Duration, error)

+ func (l *Latency) NewAction(name string)

+ func (l *Latency) SetEnd(name string, end time.Time) bool

+ func (l *Latency) SetPoint(name string, start, end time.Time)

+ func (l *Latency) SetStart(name string, start time.Time) bool

+ type Point struct

+ End time.Time

+ Start time.Time

+ func (p *Point) GetLatency() time.Duration

v1.4.0

May 26, 2019

Changes in this version

+ func DirExists(path string) bool

+ func FileExists(path string) bool

+ func PathExists(path string) bool

v1.3.0

May 22, 2019

Changes in this version

+ func NewLogger(level, encoding string, outputPaths []string) (*zap.Logger, error)

v1.2.0

May 21, 2019

Changes in this version

+ const ServiceDown

+ const ServiceUnknown

+ const ServiceUp

+ func CleanupCallers(cleanAfter time.Duration)

+ func ExampleUUIDv4()

+ func HTTPCheck(serviceName, URL string, parameters map[string]string, ...) (bool, error)

+ func NewCallerLimiter(identifier string, eventsRate rate.Limit, tokenBurst int) *rate.Limiter

+ func PkgName() string

+ func RedisCheck(serviceName string, addr string, password string, db int) (bool, error)

+ type Check struct

+ Error string

+ ID string

+ Result bool

+ Status string

+ type Clock struct

+ func (c *Clock) Now() time.Time

+ func (c *Clock) Sleep(d time.Duration)

+ type ConsulConfig struct

+ URL string

+ Version string

+ type ConsulKv struct

+ Config ConsulConfig

+ func (c *ConsulKv) Delete(key string, parameters map[string]string) (string, error)

+ func (c *ConsulKv) Read(key string, parameters map[string]string) (string, error)

+ func (c *ConsulKv) Update(key string, value string, parameters map[string]string) (string, error)

+ type ConsulStatus struct

+ Config ConsulConfig

+ func (c *ConsulStatus) GetRaftLeader(parameters map[string]string) (string, error)

+ func (c *ConsulStatus) ListRaftPeers(parameters map[string]string) (string, error)

+ type Correlation interface

+ UUIDv4 func() string

+ func NewCorrelation() Correlation

+ type HTTPClient interface

+ BuildData func(parameters map[string]string) string

+ BuildParameters func(endpoint string, parameters map[string]string) (string, error)

+ Delete func(endpoint string, parameters map[string]string, headers map[string]string) (*http.Response, error)

+ Get func(endpoint string, parameters map[string]string, headers map[string]string) (*http.Response, error)

+ GetStatusCode func(response *http.Response) int

+ Post func(endpoint string, data string, parameters map[string]string, ...) (*http.Response, error)

+ Put func(endpoint string, data string, parameters map[string]string, ...) (*http.Response, error)

+ ToString func(response *http.Response) (string, error)

+ func NewHTTPClient() HTTPClient

+ type Health struct

+ Checks []*Check

+ Status string

+ func NewHealthChecker() *Health

+ func (h *Health) AddCheck(ID string, callable func() (bool, error))

+ func (h *Health) ChecksReport() (string, error)

+ func (h *Health) ChecksStatus() string

+ func (h *Health) Down() *Health

+ func (h *Health) IsDown() bool

+ func (h *Health) IsUnknown() bool

+ func (h *Health) IsUp() bool

+ func (h *Health) RunChecks()

+ func (h *Health) Unknown() *Health

+ func (h *Health) Up() *Health

+ type Logger struct

+ Driver string

+ func (l *Logger) Info(v ...interface{})

+ func (l *Logger) New() (*zap.Logger, error)

+ type Message struct

+ Channel string

+ Payload string

+ type Metric struct

+ Name string

+ Timestamp int64

+ Value string

+ func NewMetric(name, value string, timestamp int64) Metric

+ func NewMetrics(name, value string, timestamp int64) []Metric

+ func (metric Metric) String() string

+ type ProcessLimiter interface

+ Take func() time.Time

+ func NewProcessLimiter(rate int) ProcessLimiter

+ type Redis struct

+ Addr string

+ Client *redis.Client

+ DB int

+ Password string

+ func NewRedisDriver(addr string, password string, db int) *Redis

+ func (r *Redis) Connect() (bool, error)

+ func (r *Redis) Del(key string) (int64, error)

+ func (r *Redis) Exists(key string) (bool, error)

+ func (r *Redis) Get(key string) (string, error)

+ func (r *Redis) HDel(key, field string) (int64, error)

+ func (r *Redis) HExists(key, field string) (bool, error)

+ func (r *Redis) HGet(key, field string) (string, error)

+ func (r *Redis) HLen(key string) (int64, error)

+ func (r *Redis) HScan(key string, cursor uint64, match string, count int64) *redis.ScanCmd

+ func (r *Redis) HSet(key, field, value string) (bool, error)

+ func (r *Redis) HTruncate(key string) (int64, error)

+ func (r *Redis) Ping() (bool, error)

+ func (r *Redis) Publish(channel string, message string) (bool, error)

+ func (r *Redis) Set(key, value string, expiration time.Duration) (bool, error)

+ func (r *Redis) Subscribe(channel string, callback func(message Message) error) error

+ type SystemStats struct

+ EnableCPU bool

+ EnableGC bool

+ EnableMem bool

+ StartTime time.Time

+ Stats map[string]uint64

+ func NewSystemStats(enableCPU, enableMem, enableGC bool) *SystemStats

+ func (s *SystemStats) Collect()

+ func (s *SystemStats) GetStats() map[string]uint64

+ type Task struct

+ Err error

+ Result string

+ func NewTask(f func() (string, error)) *Task

+ func (t *Task) Run(wg *sync.WaitGroup)

+ type TimeSeries interface

+ Connect func() error

+ Disconnect func() error

+ IsNop func() bool

+ SendMetric func(metric Metric) error

+ SendMetrics func(metrics []Metric) error

+ func NewGraphite(protocol string, host string, port int, prefix string) TimeSeries

+ type WorkersPool struct

+ Tasks []*Task

+ func NewWorkersPool(tasks []*Task, concurrency int) *WorkersPool

+ func (w *WorkersPool) Run()

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