publish

package
v0.35.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 14, 2025 License: Unlicense Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type S 

type S struct {
	publisher.Publishers
}

S is the control structure for the subscription management scheme.

func New 

func New(p ...publisher.I) (s *S)

New creates a new publish.S.

func (*S) Deliver 

func (s *S) Deliver(ev *event.E)

func (*S) GetSocketPublisher added in v0.23.0 

func (s *S) GetSocketPublisher() WriteChanSetter

GetSocketPublisher returns the socketapi publisher instance

func (*S) Receive 

func (s *S) Receive(msg typer.T)

func (*S) Type 

func (s *S) Type() string

type WriteChanSetter added in v0.23.0 

type WriteChanSetter interface {
	SetWriteChan(*websocket.Conn, chan WriteRequest)
	GetWriteChan(*websocket.Conn) (chan WriteRequest, bool)
}

WriteChanSetter defines the interface for setting write channels

type WriteRequest added in v0.23.0 

type WriteRequest struct {
	Data      []byte
	MsgType   int
	IsControl bool
	Deadline  time.Time
	IsPing    bool // Special marker for ping messages
}

WriteRequest represents a write operation to be performed by the write worker

Source Files

  • publisher.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.