signalr

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

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

type ClientMsg struct {
	// invocation identifier – allows to match up responses with requests
	InvocationID int `json:"I"`

	// the name of the hub
	Hub string `json:"H"`

	// the name of the method
	Method string `json:"M"`

	// arguments (an array, can be empty if the method does not have any
	// parameters)
	Args []json.RawMessage `json:"A"`

	// state – a dictionary containing additional custom data (optional)
	State *json.RawMessage `json:"S,omitempty"`
}

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

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

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

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

type DialOpt func(*config)

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

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

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

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

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

type Message struct {
	// message id, present for all non-KeepAlive messages
	MessageID string `json:"C"`

	// groups token – an encrypted string representing group membership
	GroupsToken string `json:"G"`

	InvocationID int `json:"I,string"`

	// an array containing actual data
	Messages []ClientMsg `json:"M"`

	// indicates that the transport was initialized (a.k.a. init message)
	Status int `json:"S"`

	// error
	Error       string                  `json:"E"`
	ErrorDetail *map[string]interface{} `json:"D"`
	HubError    bool                    `json:"H"`

	// result
	Result json.RawMessage `json:"R"`
}

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

type ProxyFunc func(req *http.Request) (*url.URL, error)

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

type ServerMsg struct {
	// invocation Id (always present)
	I int

	// the value returned by the server method (present if the method is not
	// void)
	R *json.RawMessage `json:",omitempty"`

	// error message
	E *string `json:",omitempty"`

	// true if this is a hub error
	H *bool `json:",omitempty"`

	// an object containing additional error data (can only be present for
	// hub errors)
	D *json.RawMessage `json:",omitempty"`

	// stack trace (if detailed error reporting (i.e. the
	// HubConfiguration.EnableDetailedErrors property) is turned on on the
	// server)
	T *json.RawMessage `json:",omitempty"`

	// state – a dictionary containing additional custom data (optional)
	S *json.RawMessage `json:",omitempty"`
}

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

type State struct {
	ConnectionData  string
	ConnectionID    string
	ConnectionToken string
	GroupsToken     string
	MessageID       string
	Protocol        string
}

type WebsocketConn interface {
	ReadMessage(ctx context.Context) (messageType int, p []byte, err error)
	WriteMessage(ctx context.Context, messageType int, p []byte) error
	Close() error
}

type WebsocketDialer interface {
	Dial(ctx context.Context, u string, headers http.Header) (conn WebsocketConn, status int, err error)
}

type WebsocketDialerFunc func(client *http.Client) WebsocketDialer

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