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"`
	CreatedAt time.Time `json:"time" bson:"time"`
}