Documentation ¶
Index ¶
- type AsyncClient
- func (s AsyncClient) Code() uint32
- func (s AsyncClient) Conn() T
- func (c *AsyncClient[T, P]) Emit(event string, data []byte) (*Stream[T], error)
- func (s AsyncClient) Event() string
- func (c *AsyncClient[T, P]) JsonEmit(event string, data any) (*Stream[T], error)
- func (s AsyncClient) MessageID() uint64
- func (s AsyncClient) MessageType() byte
- func (c *AsyncClient[T, P]) ProtoBufEmit(event string, data proto.Message) (*Stream[T], error)
- func (s AsyncClient) Respond(data any) error
- func (s AsyncClient) SetCode(code uint32)
- func (s AsyncClient) SetMessageID(messageID uint64)
- func (s AsyncClient) SetMessageType(messageType byte)
- type Emitter
- type Packer
- type Params
- type Server
- type ServerSender
- func (s ServerSender) Code() uint32
- func (s ServerSender) Conn() T
- func (s *ServerSender[T, P]) Emit(event string, data []byte) (*Stream[T], error)
- func (s ServerSender) Event() string
- func (s *ServerSender[T, P]) JsonEmit(event string, data any) (*Stream[T], error)
- func (s ServerSender) MessageID() uint64
- func (s ServerSender) MessageType() byte
- func (s *ServerSender[T, P]) ProtoBufEmit(event string, data proto.Message) (*Stream[T], error)
- func (s ServerSender) Respond(data any) error
- func (s ServerSender) SetCode(code uint32)
- func (s ServerSender) SetMessageID(messageID uint64)
- func (s ServerSender) SetMessageType(messageType byte)
- type Stream
- func (s Stream) Code() uint32
- func (s Stream) Conn() T
- func (s *Stream[T]) Data() []byte
- func (s *Stream[T]) Emit(event string, data []byte) error
- func (s Stream) Event() string
- func (s *Stream[T]) JsonEmit(event string, data any) error
- func (s Stream) MessageID() uint64
- func (s Stream) MessageType() byte
- func (s *Stream[T]) ProtoBufEmit(event string, data proto.Message) error
- func (s *Stream[T]) Respond(data any) error
- func (s Stream) SetCode(code uint32)
- func (s Stream) SetMessageID(messageID uint64)
- func (s Stream) SetMessageType(messageType byte)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AsyncClient ¶
func NewAsyncClient ¶
func NewAsyncClient[T Packer, P any](client asyncClient[T, P]) *AsyncClient[T, P]
func (*AsyncClient[T, P]) Emit ¶
func (c *AsyncClient[T, P]) Emit(event string, data []byte) (*Stream[T], error)
func (*AsyncClient[T, P]) JsonEmit ¶
func (c *AsyncClient[T, P]) JsonEmit(event string, data any) (*Stream[T], error)
func (AsyncClient) MessageType ¶
func (s AsyncClient) MessageType() byte
func (*AsyncClient[T, P]) ProtoBufEmit ¶
func (AsyncClient) SetMessageID ¶
func (s AsyncClient) SetMessageID(messageID uint64)
func (AsyncClient) SetMessageType ¶
func (s AsyncClient) SetMessageType(messageType byte)
type Emitter ¶
type Emitter[T Packer] interface { JsonEmit(event string, data any) error ProtoBufEmit(event string, data proto.Message) error Emit(event string, data []byte) error SetCode(code uint32) Code() uint32 SetMessageID(messageID uint64) MessageID() uint64 SetMessageType(messageType byte) MessageType() byte Event() string Conn() T }
type Server ¶
func NewAsyncServer ¶
type ServerSender ¶
func (*ServerSender[T, P]) Emit ¶
func (s *ServerSender[T, P]) Emit(event string, data []byte) (*Stream[T], error)
func (*ServerSender[T, P]) JsonEmit ¶
func (s *ServerSender[T, P]) JsonEmit(event string, data any) (*Stream[T], error)
func (ServerSender) MessageType ¶
func (s ServerSender) MessageType() byte
func (*ServerSender[T, P]) ProtoBufEmit ¶
func (ServerSender) SetMessageID ¶
func (s ServerSender) SetMessageID(messageID uint64)
func (ServerSender) SetMessageType ¶
func (s ServerSender) SetMessageType(messageType byte)
type Stream ¶
type Stream[T Packer] struct { Time time.Time Context kitty.Context Logger kitty.Logger Params Params // contains filtered or unexported fields }
func (Stream) MessageType ¶
func (s Stream) MessageType() byte
func (*Stream[T]) ProtoBufEmit ¶
func (Stream) SetMessageID ¶
func (s Stream) SetMessageID(messageID uint64)
func (Stream) SetMessageType ¶
func (s Stream) SetMessageType(messageType byte)
Source Files ¶
Click to show internal directories.
Click to hide internal directories.