broker

Documentation

Index

• Constants
• type Broker
  • func NewBroker() *Broker
  • func (broker *Broker) Broadcast(event events.PubEvent) error
  • func (broker *Broker) Connect(clientId string, client *ConnectedClient)
  • func (broker *Broker) Disconnect(client *ConnectedClient)
• type ConnectedClient
  • func NewConnectedClient(conn GenericConnection, id string) *ConnectedClient
  • func NewUnidentifiedClient(conn GenericConnection) *ConnectedClient
  • func (client *ConnectedClient) GetEligibility(topic string) *Subscription
  • func (client *ConnectedClient) GetId() string
  • func (client *ConnectedClient) IsIdentified() bool
  • func (client *ConnectedClient) SetId(id string)
  • func (client *ConnectedClient) SubscribeToPattern(pattern string, group string)
  • func (client *ConnectedClient) UnsubscribeFromPattern(pattern string)
  • func (client *ConnectedClient) WriteDataMessage(data []byte) error
  • func (client *ConnectedClient) WriteInterface(v any) error
• type GenericConnection
• type Subscription
  • func (s *Subscription) GetGroup() string
  • func (s *Subscription) GetPattern() string
  • func (s *Subscription) IsActive() bool
  • func (s *Subscription) Matches(topic string) bool

Constants

const (
	PatternSeparator   = "."
	SingleTokenMatcher = "*"
	MultiTokenMatcher  = ">"
)

Types

type Broker

type Broker struct {
	// contains filtered or unexported fields
}

func NewBroker

func NewBroker() *Broker

func (*Broker) Broadcast

func (broker *Broker) Broadcast(event events.PubEvent) error

func (*Broker) Connect

func (broker *Broker) Connect(clientId string, client *ConnectedClient)

func (*Broker) Disconnect

func (broker *Broker) Disconnect(client *ConnectedClient)

type ConnectedClient

type ConnectedClient struct {
	// contains filtered or unexported fields
}

func NewConnectedClient

func NewConnectedClient(conn GenericConnection, id string) *ConnectedClient

func NewUnidentifiedClient

func NewUnidentifiedClient(conn GenericConnection) *ConnectedClient

func (*ConnectedClient) GetEligibility

func (client *ConnectedClient) GetEligibility(topic string) *Subscription

func (*ConnectedClient) GetId

func (client *ConnectedClient) GetId() string

func (*ConnectedClient) IsIdentified

func (client *ConnectedClient) IsIdentified() bool

func (*ConnectedClient) SetId

func (client *ConnectedClient) SetId(id string)

func (*ConnectedClient) SubscribeToPattern

func (client *ConnectedClient) SubscribeToPattern(pattern string, group string)

func (*ConnectedClient) UnsubscribeFromPattern

func (client *ConnectedClient) UnsubscribeFromPattern(pattern string)

func (*ConnectedClient) WriteDataMessage

func (client *ConnectedClient) WriteDataMessage(data []byte) error

func (*ConnectedClient) WriteInterface

func (client *ConnectedClient) WriteInterface(v any) error

type GenericConnection

type GenericConnection interface {
	WriteMessage(data []byte) error
}

type Subscription

type Subscription struct {
	// contains filtered or unexported fields
}

func (*Subscription) GetGroup

func (s *Subscription) GetGroup() string

func (*Subscription) GetPattern

func (s *Subscription) GetPattern() string

func (*Subscription) IsActive

func (s *Subscription) IsActive() bool

func (*Subscription) Matches

func (s *Subscription) Matches(topic string) bool