utils

Documentation

Index

• func Check(address *net.TCPAddr, timeout time.Duration) error
• func IsPortOpen(port int) bool
• func NewRedisClient() *redis.Client
• func RedisPort() int
• type DeadlineActionFunc
• type DeadlineEnforcer
  • func (deadlineEnforcer DeadlineEnforcer) DoWithin(duration time.Duration) error
• type RedisRunner
  • func (runner *RedisRunner) Start(redisArgs ...string) error
  • func (runner *RedisRunner) Stop() error

Functions

func Check

func Check(address *net.TCPAddr, timeout time.Duration) error

Check ports whether is open

func IsPortOpen

func IsPortOpen(port int) bool

IsPortOpen returns true if port is open

func NewRedisClient

func NewRedisClient() *redis.Client

NewRedisClient creates a new redis client

func RedisPort

func RedisPort() int

RedisPort is the default port

Types

type DeadlineActionFunc

type DeadlineActionFunc func(success chan<- struct{}, terminate <-chan struct{})

DeadlineActionFunc is a function called by enforcer

type DeadlineEnforcer

type DeadlineEnforcer struct {
	// Action that enforcec end
	Action DeadlineActionFunc
}

DeadlineEnforcer encforces deadlines

func (DeadlineEnforcer) DoWithin

func (deadlineEnforcer DeadlineEnforcer) DoWithin(duration time.Duration) error

DoWithin do with duration

type RedisRunner

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

RedisRunner runs redis server

func (*RedisRunner) Start

func (runner *RedisRunner) Start(redisArgs ...string) error

Start starts the server

func (*RedisRunner) Stop

func (runner *RedisRunner) Stop() error

Stop stops the server