Versions in this module Expand all Collapse all v1 v1.0.12 Jan 18, 2024 Changes in this version + const AckMessage + const ClosedConnectionMessage + const ModeClient + const ModeServer + const PayloadMessage + const WSRoute + var ErrAckTimeout = errors.New("acknowledge waiting timeout occurred") + var ErrConnectionAlreadyOpen = errors.New("connection already open") + var ErrConnectionNotOpen = errors.New("connection not open") + var ErrEmptyUrl = errors.New("empty websocket url provided") + var ErrExpectedAckWasNotReceivedOnClose = errors.New("expected ack message was not received on close") + var ErrIntOverflowWsMessage = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthWsMessage = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidWebSocketHostMode = errors.New("invalid web socket host mode") + var ErrNilMarshaller = errors.New("nil marshaller") + var ErrNilPayloadConverter = errors.New("nil payload converter provided") + var ErrNilPayloadProcessor = errors.New("nil payload processor provided") + var ErrNoClientsConnected = errors.New("no client connected") + var ErrServerIsClosed = errors.New("http: Server closed") + var ErrUnexpectedEndOfGroupWsMessage = fmt.Errorf("proto: unexpected end of group") + var ErrZeroValueAckTimeout = errors.New("zero value provided for acknowledge timeout") + var ErrZeroValueRetryDuration = errors.New("zero value provided for retry duration") + type WSConn interface + ReadMessage func() (messageType int, payload []byte, err error) + WriteMessage func(messageType int, data []byte) error + type WebSocketConfig struct + AcknowledgeTimeoutInSec int + BlockingAckOnError bool + DropMessagesIfNoConnection bool + Mode string + RetryDurationInSec int + URL string + Version uint32 + WithAcknowledge bool + type WsMessage struct + Counter uint64 + Payload []byte + Topic string + Type int32 + Version uint32 + WithAcknowledge bool + func (*WsMessage) Descriptor() ([]byte, []int) + func (*WsMessage) ProtoMessage() + func (m *WsMessage) GetCounter() uint64 + func (m *WsMessage) GetPayload() []byte + func (m *WsMessage) GetTopic() string + func (m *WsMessage) GetType() int32 + func (m *WsMessage) GetVersion() uint32 + func (m *WsMessage) GetWithAcknowledge() bool + func (m *WsMessage) Marshal() (dAtA []byte, err error) + func (m *WsMessage) MarshalTo(dAtA []byte) (int, error) + func (m *WsMessage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WsMessage) Reset() + func (m *WsMessage) Size() (n int) + func (m *WsMessage) Unmarshal(dAtA []byte) error + func (m *WsMessage) XXX_DiscardUnknown() + func (m *WsMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WsMessage) XXX_Merge(src proto.Message) + func (m *WsMessage) XXX_Size() int + func (m *WsMessage) XXX_Unmarshal(b []byte) error + func (this *WsMessage) Equal(that interface{}) bool + func (this *WsMessage) GoString() string + func (this *WsMessage) String() string