Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

adapter

package

Go to main page

Versions in this module

v2

v2.3.6

Jan 8, 2025

v2.3.5

Oct 24, 2024

v2.3.4

Oct 23, 2024

v2.3.3

Oct 8, 2024

v2.3.2

Sep 30, 2024

v2.3.1

Sep 30, 2024

v2.3.0

Sep 22, 2024

Changes in this version

+ func DecodeOptions(opts *PacketOptions) *socket.BroadcastOptions

+ func RandomId() (string, error)

+ func SliceMap[I any, O any](i []I, converter func(I) O) (o []O)

+ func Tap[T any](value T, callback func(T)) T

+ func Uid2(length int) (string, error)

+ type Adapter = socket.Adapter

+ func MakeAdapter() Adapter

+ func NewAdapter(nsp socket.Namespace) Adapter

+ type AdapterBuilder struct

+ func (*AdapterBuilder) New(nsp socket.Namespace) Adapter

+ type AdapterConstructor = socket.AdapterConstructor

+ type BroadcastAck struct

+ Packet []any

+ RequestId string

+ type BroadcastClientCount struct

+ ClientCount uint64

+ RequestId string

+ type BroadcastMessage struct

+ Opts *PacketOptions

+ Packet *parser.Packet

+ RequestId *string

+ type ClusterAckRequest struct

+ Ack socket.Ack

+ ClientCountCallback func(uint64)

+ type ClusterAdapter interface

+ DoPublish func(*ClusterMessage) (Offset, error)

+ DoPublishResponse func(ServerId, *ClusterResponse) error

+ OnMessage func(*ClusterMessage, Offset)

+ OnResponse func(*ClusterResponse)

+ Publish func(*ClusterMessage)

+ PublishAndReturnOffset func(*ClusterMessage) (Offset, error)

+ PublishResponse func(ServerId, *ClusterResponse)

+ Uid func() ServerId

+ func MakeClusterAdapter() ClusterAdapter

+ func NewClusterAdapter(nsp socket.Namespace) ClusterAdapter

+ type ClusterAdapterBuilder struct

+ func (cb *ClusterAdapterBuilder) New(nsp socket.Namespace) Adapter

+ type ClusterAdapterOptions struct

+ func DefaultClusterAdapterOptions() *ClusterAdapterOptions

+ func (s *ClusterAdapterOptions) Assign(data ClusterAdapterOptionsInterface) (ClusterAdapterOptionsInterface, error)

+ func (s *ClusterAdapterOptions) GetRawHeartbeatInterval() *time.Duration

+ func (s *ClusterAdapterOptions) GetRawHeartbeatTimeout() *int64

+ func (s *ClusterAdapterOptions) HeartbeatInterval() time.Duration

+ func (s *ClusterAdapterOptions) HeartbeatTimeout() int64

+ func (s *ClusterAdapterOptions) SetHeartbeatInterval(heartbeatInterval time.Duration)

+ func (s *ClusterAdapterOptions) SetHeartbeatTimeout(heartbeatTimeout int64)

+ type ClusterAdapterOptionsInterface interface

+ GetRawHeartbeatInterval func() *time.Duration

+ GetRawHeartbeatTimeout func() *int64

+ HeartbeatInterval func() time.Duration

+ HeartbeatTimeout func() int64

+ SetHeartbeatInterval func(time.Duration)

+ SetHeartbeatTimeout func(int64)

+ type ClusterAdapterWithHeartbeat interface

+ SetOpts func(*ClusterAdapterOptions)

+ func MakeClusterAdapterWithHeartbeat() ClusterAdapterWithHeartbeat

+ func NewClusterAdapterWithHeartbeat(nsp socket.Namespace, opts *ClusterAdapterOptions) ClusterAdapterWithHeartbeat

+ type ClusterAdapterWithHeartbeatBuilder struct

+ Opts *ClusterAdapterOptions

+ func (c *ClusterAdapterWithHeartbeatBuilder) New(nsp socket.Namespace) Adapter

+ type ClusterMessage struct

+ Data any

+ Nsp string

+ Type MessageType

+ Uid ServerId

+ type ClusterRequest struct

+ Current *atomic.Int64

+ Expected int64

+ Resolve func(*types.Slice[any])

+ Responses *types.Slice[any]

+ Timeout *atomic.Pointer[utils.Timer]

+ Type MessageType

+ type ClusterResponse = ClusterMessage

+ type CustomClusterRequest struct

+ MissingUids *types.Set[ServerId]

+ Resolve func(*types.Slice[any])

+ Responses *types.Slice[any]

+ Timeout *atomic.Pointer[utils.Timer]

+ Type MessageType

+ type DisconnectSocketsMessage struct

+ Close bool

+ Opts *PacketOptions

+ type FetchSocketsMessage struct

+ Opts *PacketOptions

+ RequestId string

+ type FetchSocketsResponse struct

+ RequestId string

+ Sockets []*SocketResponse

+ type MessageType int

+ const ADAPTER_CLOSE

+ const BROADCAST

+ const BROADCAST_ACK

+ const BROADCAST_CLIENT_COUNT

+ const DISCONNECT_SOCKETS

+ const FETCH_SOCKETS

+ const FETCH_SOCKETS_RESPONSE

+ const HEARTBEAT

+ const INITIAL_HEARTBEAT

+ const SERVER_SIDE_EMIT

+ const SERVER_SIDE_EMIT_RESPONSE

+ const SOCKETS_JOIN

+ const SOCKETS_LEAVE

+ type Offset string

+ type PacketOptions struct

+ Except []socket.Room

+ Flags *socket.BroadcastFlags

+ Rooms []socket.Room

+ func EncodeOptions(opts *socket.BroadcastOptions) *PacketOptions

+ type RemoteSocket struct

+ func MakeRemoteSocket() *RemoteSocket

+ func NewRemoteSocket(details *SocketResponse) *RemoteSocket

+ func (r *RemoteSocket) Construct(details *SocketResponse)

+ func (r *RemoteSocket) Data() any

+ func (r *RemoteSocket) Handshake() *socket.Handshake

+ func (r *RemoteSocket) Id() socket.SocketId

+ func (r *RemoteSocket) Rooms() *types.Set[socket.Room]

+ type ServerId string

+ const DEFAULT_TIMEOUT

+ const EMITTER_UID

+ type ServerSideEmitMessage struct

+ Packet []any

+ RequestId *string

+ type ServerSideEmitResponse struct

+ Packet []any

+ RequestId string

+ type SessionAwareAdapter = socket.SessionAwareAdapter

+ func MakeSessionAwareAdapter() SessionAwareAdapter

+ func NewSessionAwareAdapter(nsp socket.Namespace) SessionAwareAdapter

+ type SessionAwareAdapterBuilder struct

+ func (*SessionAwareAdapterBuilder) New(nsp socket.Namespace) Adapter

+ type SocketResponse struct

+ Data any

+ Handshake *socket.Handshake

+ Id socket.SocketId

+ Rooms []socket.Room

+ type SocketsJoinLeaveMessage struct

+ Opts *PacketOptions

+ Rooms []socket.Room

v2.3.0-beta.9

Sep 22, 2024

v2.3.0-beta.8

Sep 20, 2024

v2.3.0-beta.7

Sep 21, 2024

v2.3.0-beta.6

Sep 21, 2024

v2.3.0-beta.5

Sep 20, 2024

v2.3.0-beta.4

Sep 20, 2024

v2.3.0-beta.3

Sep 20, 2024

v2.3.0-beta.2

Sep 20, 2024

v2.3.0-beta.1

Sep 19, 2024

v2.3.0-beta.0

Sep 19, 2024