toxiproxy

Mar 18, 2025

Changes in this version

type Proxy

+ func (proxy *Proxy) Differs(other *Proxy) (bool, error)

Aug 22, 2023

Changes in this version

type ApiServer

+ func (server *ApiServer) Routes() *mux.Router

+ func (server *ApiServer) Shutdown() error

Sep 10, 2022

Changes in this version

type ApiServer

+ Logger *zerolog.Logger

type Proxy

+ Logger *zerolog.Logger

type ToxicLink

+ Logger *zerolog.Logger

Mar 7, 2022

Changes in this version

+ func NewMetricsContainer(registry *prometheus.Registry) *metricsContainer

type ApiServer

+ Metrics *metricsContainer

type ToxicLink

+ func (link *ToxicLink) Direction() string

Sep 23, 2021

Changes in this version

+ var ErrBadRequestBody = newError("bad request body", http.StatusBadRequest)

+ var ErrInvalidStream = newError("stream was invalid, can be either upstream or downstream", ...)

+ var ErrInvalidToxicType = newError("invalid toxic type", http.StatusBadRequest)

+ var ErrMissingField = newError("missing required field", http.StatusBadRequest)

+ var ErrProxyAlreadyExists = newError("proxy already exists", http.StatusConflict)

+ var ErrProxyAlreadyStarted = errors.New("Proxy already started")

+ var ErrProxyNotFound = newError("proxy not found", http.StatusNotFound)

+ var ErrToxicAlreadyExists = newError("toxic already exists", http.StatusConflict)

+ var ErrToxicNotFound = newError("toxic not found", http.StatusNotFound)

+ var Version = "git"

+ func StopBrowsersMiddleware(h http.Handler) http.Handler

+ type ApiError struct

+ Message string

+ StatusCode int

+ func (e *ApiError) Error() string

+ type ApiServer struct

+ Collection *ProxyCollection

+ func NewServer() *ApiServer

+ func (server *ApiServer) Listen(host string, port string)

+ func (server *ApiServer) Populate(response http.ResponseWriter, request *http.Request)

+ func (server *ApiServer) PopulateConfig(filename string)

+ func (server *ApiServer) ProxyCreate(response http.ResponseWriter, request *http.Request)

+ func (server *ApiServer) ProxyDelete(response http.ResponseWriter, request *http.Request)

+ func (server *ApiServer) ProxyIndex(response http.ResponseWriter, request *http.Request)

+ func (server *ApiServer) ProxyShow(response http.ResponseWriter, request *http.Request)

+ func (server *ApiServer) ProxyUpdate(response http.ResponseWriter, request *http.Request)

+ func (server *ApiServer) ResetState(response http.ResponseWriter, request *http.Request)

+ func (server *ApiServer) ToxicCreate(response http.ResponseWriter, request *http.Request)

+ func (server *ApiServer) ToxicDelete(response http.ResponseWriter, request *http.Request)

+ func (server *ApiServer) ToxicIndex(response http.ResponseWriter, request *http.Request)

+ func (server *ApiServer) ToxicShow(response http.ResponseWriter, request *http.Request)

+ func (server *ApiServer) ToxicUpdate(response http.ResponseWriter, request *http.Request)

+ func (server *ApiServer) Version(response http.ResponseWriter, request *http.Request)

+ type ConnectionList struct

+ func (c *ConnectionList) Lock()

+ func (c *ConnectionList) Unlock()

+ type Proxy struct

+ Enabled bool

+ Listen string

+ Name string

+ Toxics *ToxicCollection

+ Upstream string

+ func NewProxy() *Proxy

+ func (proxy *Proxy) RemoveConnection(name string)

+ func (proxy *Proxy) Start() error

+ func (proxy *Proxy) Stop()

+ func (proxy *Proxy) Update(input *Proxy) error

+ type ProxyCollection struct

+ func NewProxyCollection() *ProxyCollection

+ func (collection *ProxyCollection) Add(proxy *Proxy, start bool) error

+ func (collection *ProxyCollection) AddOrReplace(proxy *Proxy, start bool) error

+ func (collection *ProxyCollection) Clear() error

+ func (collection *ProxyCollection) Get(name string) (*Proxy, error)

+ func (collection *ProxyCollection) PopulateJson(data io.Reader) ([]*Proxy, error)

+ func (collection *ProxyCollection) Proxies() map[string]*Proxy

+ func (collection *ProxyCollection) Remove(name string) error

+ type ToxicCollection struct

+ func NewToxicCollection(proxy *Proxy) *ToxicCollection

+ func (c *ToxicCollection) AddToxicJson(data io.Reader) (*toxics.ToxicWrapper, error)

+ func (c *ToxicCollection) GetToxic(name string) *toxics.ToxicWrapper

+ func (c *ToxicCollection) GetToxicArray() []toxics.Toxic

+ func (c *ToxicCollection) RemoveLink(name string)

+ func (c *ToxicCollection) RemoveToxic(name string) error

+ func (c *ToxicCollection) ResetToxics()

+ func (c *ToxicCollection) StartLink(name string, input io.Reader, output io.WriteCloser, ...)

+ func (c *ToxicCollection) UpdateToxicJson(name string, data io.Reader) (*toxics.ToxicWrapper, error)

+ type ToxicLink struct

+ func NewToxicLink(proxy *Proxy, collection *ToxicCollection, direction stream.Direction) *ToxicLink

+ func (link *ToxicLink) AddToxic(toxic *toxics.ToxicWrapper)

+ func (link *ToxicLink) RemoveToxic(toxic *toxics.ToxicWrapper)

+ func (link *ToxicLink) Start(name string, source io.Reader, dest io.WriteCloser)

+ func (link *ToxicLink) UpdateToxic(toxic *toxics.ToxicWrapper)