websocket

Documentation

Index

• Variables
• type Message
  • func NewMessage(data []byte) (Message, error)
  • func (m Message) Data() []byte
  • func (m Message) HasAuthErrMsg() bool
  • func (m Message) HasContinueState() bool
  • func (m Message) HasErrorState() bool
  • func (m Message) ID() uint
  • func (m Message) State() string
• type Reader
  • func NewReader(authService console.AuthServiceInterface, writer writer.Interface, ...) (*Reader, error)
  • func (r *Reader) Close() error
  • func (r *Reader) Read(dataType string, req reader.Request) (reader.JSONResponse, error)
• type ResponseError
• type ResponseErrors

Variables

var ErrMsgErrorStateReceived = errors.New("error state received")

Types

type Message

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

func NewMessage

func NewMessage(data []byte) (Message, error)

func (Message) Data

func (m Message) Data() []byte

func (Message) HasAuthErrMsg

func (m Message) HasAuthErrMsg() bool

func (Message) HasContinueState

func (m Message) HasContinueState() bool

func (Message) HasErrorState

func (m Message) HasErrorState() bool

func (Message) ID

func (m Message) ID() uint

func (Message) State

func (m Message) State() string

type Reader

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

func NewReader

func NewReader(authService console.AuthServiceInterface, writer writer.Interface, logger *log.Logger) (*Reader, error)

func (*Reader) Close

func (r *Reader) Close() error

func (*Reader) Read

func (r *Reader) Read(dataType string, req reader.Request) (reader.JSONResponse, error)

type ResponseError

type ResponseError struct {
	ErrorCode    string `json:"errorCode"`
	ErrorMessage string `json:"errorMessage"`
}

type ResponseErrors

type ResponseErrors struct {
	Errors []ResponseError `json:"errors"`
}