broker

Documentation

Index

• type Listener
• type Pubsub
  • func NewPubsub(ctx context.Context, database *sql.DB, connectURL string) (Pubsub, error)
  • func NewPubsubInMemory() Pubsub
• type Signal

Types

type Listener

type Listener chan *Signal

type Pubsub

type Pubsub interface {
	Subscribe(tailnet uint64, listener Listener) (cancel func(), err error)
	Publish(tailnet uint64, message *Signal) error
	Close() error
}

func NewPubsub

func NewPubsub(ctx context.Context, database *sql.DB, connectURL string) (Pubsub, error)

func NewPubsubInMemory

func NewPubsubInMemory() Pubsub

type Signal

type Signal struct {
	PeerUpdated  *uint64
	PeersRemoved []uint64
	ACLUpdated   bool
	DNSUpdated   bool
}