Versions in this module Expand all Collapse all v0 v0.1.0 May 30, 2023 Changes in this version + var ErrContextCanceled = errors.New("proxy client queue: context canceled") + func NewClient(queue *Queue) proxyclient.Client + type Map struct + func NewMap() *Map[T] + func (m *Map[T]) Del(k string) + func (m *Map[T]) Get(k string) (T, bool) + func (m *Map[T]) Pop(k string) (T, bool) + func (m *Map[T]) Range(f func(k string, v T) bool) + func (m *Map[T]) Set(k string, v T) + type Proxy struct + func NewProxy(queue *Queue) *Proxy + func (p *Proxy) Activate(ctx context.Context, proxy entity.Proxy) error + func (p *Proxy) Deactivate(ctx context.Context, proxyID string) error + type Queue struct + func NewQueue(client *http.Client, interval time.Duration) *Queue + func (q *Queue) Close() + func (q *Queue) Start() error + type Route struct + func NewRoute(queue *Queue) *Route + func (r *Route) Delete(ctx context.Context, routes []entity.Route) error + func (r *Route) Register(ctx context.Context, routes []entity.Route) error
Go to main page