connections

Apr 26, 2023

Changes in this version

type WS

+ SubscribeMethodName string

+ UnsubscribeMethodName string

Mar 13, 2023

Changes in this version

type Streamer

+ func WSStreamAny(w *WS, ctx context.Context, streamName string, streamParams interface{}) (Streamer[T], error)

+ func WSStreamProto(w *WS, ctx context.Context, streamName string, streamParams proto.Message, ...) (Streamer[T], error)

Oct 10, 2022

Changes in this version

+ func HTTPGetWithClient(url string, client *http.Client, val T, authHeader string) error

+ func HTTPPostWithClient(url string, client *http.Client, body interface{}, val T, authHeader string) error

+ type FeedUpdate struct

+ Result json.RawMessage

+ SubscriptionID string

+ type HTTPError struct

+ Code int

+ Details interface{}

+ Message string

+ func (h HTTPError) Error() string

+ type Streamer func() (T, error)

+ func GRPCStream(stream grpc.ClientStream, input string) Streamer[*T]

+ func WSStream(w *WS, ctx context.Context, streamName string, streamParams proto.Message, ...) (Streamer[T], error)

+ func (s Streamer[T]) Channel(size int) chan T

+ func (s Streamer[T]) Into(ch chan T)

+ type SubscribeParams struct

+ StreamName string

+ StreamOpts json.RawMessage

+ func (s *SubscribeParams) UnmarshalJSON(b []byte) error

+ func (s SubscribeParams) MarshalJSON() ([]byte, error)

+ type UnsubscribeParams struct

+ SubscriptionID string

+ func (s *UnsubscribeParams) UnmarshalJSON(b []byte) error

+ func (s UnsubscribeParams) MarshalJSON() ([]byte, error)

+ type WS struct

+ func NewWS(endpoint string, authHeader string) (*WS, error)

+ func (w *WS) Close(reason error) error

+ func (w *WS) Request(ctx context.Context, method string, request proto.Message, ...) error