internalclient

Documentation

Index

• Constants
• Variables
• func WithAsynqWorker(redisURI string) clientOption
• type Client
  • func NewClient(opts ...clientOption) (Client, error)
• type LeveledLogger
  • func (l *LeveledLogger) Debugf(msg string, keysAndValues ...interface{})
  • func (l *LeveledLogger) Errorf(msg string, keysAndValues ...interface{})
  • func (l *LeveledLogger) Warnf(msg string, keysAndValues ...interface{})
• type Tunnel

Constants

const (
	DeviceUIDHeader = "X-Device-UID"
)

Variables

var (
	ErrConnectionFailed = errors.New("connection failed")
	ErrNotFound         = errors.New("not found")
	ErrForbidden        = errors.New("forbidden")
	ErrUnknown          = errors.New("unknown error")
)

var (
	ErrFirewallConnection = errors.New("failed to make the request to evaluate the firewall")
	ErrFirewallBlock      = errors.New("a firewall rule prohibit this connection")
)

Functions

func WithAsynqWorker

func WithAsynqWorker(redisURI string) clientOption

Types

type Client

type Client interface {
	// contains filtered or unexported methods
}

func NewClient

func NewClient(opts ...clientOption) (Client, error)

type LeveledLogger

type LeveledLogger struct {
	Logger *logrus.Logger
}

func (*LeveledLogger) Debugf

func (l *LeveledLogger) Debugf(msg string, keysAndValues ...interface{})

func (*LeveledLogger) Errorf

func (l *LeveledLogger) Errorf(msg string, keysAndValues ...interface{})

func (*LeveledLogger) Warnf

func (l *LeveledLogger) Warnf(msg string, keysAndValues ...interface{})

type Tunnel

type Tunnel struct {
	Address    string    `json:"address"`
	Namespace  string    `json:"namespace"`
	Device     string    `json:"device"`
	Host       string    `json:"host"`
	Port       int       `json:"port"`
	TimeToLive int       `json:"ttl"`
	ExpiresIn  time.Time `json:"expires_in"`
	CreatedAt  time.Time `json:"time" bson:"time"`
}