connections

package

v1.1.1 Latest Latest Go to latest Published: Oct 14, 2022 License: MIT Imports: 17 Imported by: 1

Documentation ¶

This section is empty.

This section is empty.

func HTTPGetWithClient[T protoreflect.ProtoMessage](url string, client *http.Client, val T, authHeader string) error

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

type FeedUpdate struct {
	SubscriptionID string          `json:"subscription"`
	Result         json.RawMessage `json:"result"`
}

FeedUpdate wraps the result from any particular stream with the subscription ID it's associated with

type HTTPError struct {
	Code    int         `json:"code"`
	Details interface{} `json:"details"`
	Message string      `json:"message"`
}

func (h HTTPError) Error() string

type Streamer[T any] func() (T, error)

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

func WSStream[T proto.Message](w *WS, ctx context.Context, streamName string, streamParams proto.Message, resultInitFn func() T) (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
}

SubscribeParams exist because subscribe arguments usually look like ["streamName", {"some": "opts"}], which doesn't map elegantly to Go structs

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

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

type UnsubscribeParams struct {
	SubscriptionID string
}

UnsubscribeParams exist because unsubscribe arguments usually look like ["subscriptionID"], which doesn't map elegantly to Go structs

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

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

type WS struct {
	// contains filtered or unexported fields
}

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, response proto.Message) error