Versions in this module Expand all Collapse all v1 v1.2.1 Jun 19, 2015 v1.2.0 Jun 9, 2015 Changes in this version + const ServiceName + func DecodeConnectionError(data []byte, dec TypeDecoder) (interface{}, string, error) + func DecodeData(data []byte, dec TypeDecoder) (interface{}, string, error) + type ClientServer interface + AddRequestHandler func(RequestHandler) + Connect func() error + MakeRequest func(input interface{}) error + Serve func() error + type ClientServerImpl struct + AcceptInvalidCert bool + Conn WebsocketConn + CredentialProvider credentials.AWSCredentialProvider + Region string + RequestHandlers map[string]RequestHandler + URL string + func (cs *ClientServerImpl) AddRequestHandler(f RequestHandler) + func (cs *ClientServerImpl) Connect() error + func (cs *ClientServerImpl) ConsumeMessages() error + func (cs *ClientServerImpl) CreateRequestMessage(input interface{}) ([]byte, error) + func (cs *ClientServerImpl) MakeRequest(input interface{}) error + type NotMarshallableWSRequest struct + Err error + Type string + func (u *NotMarshallableWSRequest) Error() string + func (u *NotMarshallableWSRequest) Retry() bool + type ReceivedMessage struct + Message json.RawMessage + Type string + type RequestHandler interface + type RequestMessage struct + Message json.RawMessage + Type string + type ServiceError interface + NewError func(err interface{}) *WSError + type TypeDecoder interface + GetRecognizedTypes func() map[string]reflect.Type + NewOfType func(string) (interface{}, bool) + type UndecodableMessage struct + Msg string + func (u *UndecodableMessage) Error() string + type UnrecognizedWSRequestType struct + Type string + func (u *UnrecognizedWSRequestType) Error() string + func (u *UnrecognizedWSRequestType) Retry() bool + type WSError struct + ErrObj interface{} + Type string + func (err *WSError) Error() string + func (err *WSError) Retry() bool + type WSUnretriableErrors interface + Get func() []interface{} + type WebsocketConn interface + Close func() error + ReadMessage func() (messageType int, data []byte, err error) + WriteMessage func(messageType int, data []byte) error
Go to main page