websocket

Documentation

Index

• Variables
• type CollectionCursorsResponse
• type CollectionResponse
• 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, dataMap map[string]any) (portfolio.OutputDataInterface, error)
• type ResponseError
• type ResponseErrors

Variables

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

Types

type CollectionCursorsResponse

type CollectionCursorsResponse struct {
	Before string `json:"before"`
	After  string `json:"after,omitempty"`
}

type CollectionResponse

type CollectionResponse[T any] struct {
	Items   []T                       `json:"items"`
	Cursors CollectionCursorsResponse `json:"cursors"`
}

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, dataMap map[string]any) (portfolio.OutputDataInterface, error)

type ResponseError

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

type ResponseErrors

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