localproxy

Nov 28, 2023

Changes in this version

type Client

+ func (c *Client) PatchAllocation(ctx context.Context, allocationID string, args *model.PatchAllocationRequest) error

Jul 26, 2023

Changes in this version

type Client

+ func (c *Client) HoldSelf(ctx context.Context, args *model.HoldRequest) (*model.HoldStatus, error)

+ func (c *Client) HoldStatus(ctx context.Context) (*model.HoldStatus, error)

+ func (c *Client) ReleaseSelf(ctx context.Context) error

Jun 6, 2023

Changes in this version

type Client

+ func (c *Client) ReserveSelf(ctx context.Context, args *model.ReserveRequest) (*model.ReserveResponse, error)

+ func (c *Client) UnreserveSelf(ctx context.Context) error

+ type UnexpectedResponseError struct

+ RequestID string

+ ResponseBody string

+ StatusCode int

+ func NewUnexpectedResponseWithBody(requestID string, statusCode int, responseBody []byte) *UnexpectedResponseError

+ func NewUnexpectedResponseWithError(requestID string, statusCode int, err error) *UnexpectedResponseError

+ func (e *UnexpectedResponseError) Error() string

May 23, 2023

Changes in this version

+ const AllocateEventType

+ const DeallocateEventType

+ type AllocateEvent struct

+ AllocationID string

+ type BaseEvent struct

+ EventID string

+ ServerID int64

+ Typ EventType

+ func (b *BaseEvent) Type() EventType

+ type Client struct

+ func New(host string, serverID int64, chanError chan<- error) (*Client, error)

+ func (c *Client) OnPublish(_ *centrifuge.Subscription, e centrifuge.PublishEvent)

+ func (c *Client) OnSubscribeError(_ *centrifuge.Subscription, _ centrifuge.SubscribeErrorEvent)

+ func (c *Client) OnSubscribeSuccess(_ *centrifuge.Subscription, _ centrifuge.SubscribeSuccessEvent)

+ func (c *Client) RegisterCallback(ev EventType, cb func(Event))

+ func (c *Client) Start() error

+ func (c *Client) Stop() error

+ type DeallocateEvent struct

+ AllocationID string

+ type Event interface

+ Type func() EventType

+ type EventType string