client

Documentation

Index

• Constants
• Variables
• func New() interface{ ... }
• type Client
• type Configuration
  • func (c *Configuration) Default()
  • func (c *Configuration) FromEnv(envs map[string]string)
  • func (c *Configuration) Validate() (err error)

Constants

const (
	ReadTimeout  string = "read timeout is less than 0"
	WriteTimeout string = "read timeout is less than 0"
)

const (
	EnvNameReadTimeout  string = "BLUDGEON_WEBSOCKET_READ_TIMEOUT"
	EnvNameWriteTimeout string = "BLUDGEON_WEBSOCKET_WRITE_TIMEOUT"
)

const (
	DefaultReadTimeout  time.Duration = 10 * time.Second
	DefaultWriteTimeout time.Duration = 10 * time.Second
)

const (
	NotConnected string = "not connected"
)

Variables

var (
	ErrReadTimeout  = errors.New(ReadTimeout)
	ErrWriteTimeout = errors.New(WriteTimeout)
)

var ErrNotConnected = errors.New(NotConnected)

Functions

func New

func New() interface {
	Client
	internal.Configurer
	internal.Parameterizer
	internal.Closer
}

Types

type Client

type Client interface {
	Connect(ctx context.Context, url string, requestHeader http.Header) (*http.Response, error)
	IsConnected() bool
	Write(item interface{}) error
	Read(item interface{}) error
}

type Configuration

type Configuration struct {
	WriteTimeout time.Duration `json:"write_timeout"`
	ReadTimeout  time.Duration `json:"read_timeout"`
}

func (*Configuration) Default

func (c *Configuration) Default()

func (*Configuration) FromEnv

func (c *Configuration) FromEnv(envs map[string]string)

func (*Configuration) Validate

func (c *Configuration) Validate() (err error)