handler_mgmt

Documentation

Index

• func NewBindHandler(network *network.Network, xmgmts *concurrenz.CopyOnWriteSlice[xmgmt.Xmgmt]) channel.BindHandler
• type BindHandler
  • func (bindHandler *BindHandler) BindChannel(binding channel.Binding) error
• type EventsStreamHandler
  • func (handler *EventsStreamHandler) AcceptFormattedEvent(eventType string, formattedEvent []byte)
• type StreamEventsRequest

Functions

func NewBindHandler

func NewBindHandler(network *network.Network, xmgmts *concurrenz.CopyOnWriteSlice[xmgmt.Xmgmt]) channel.BindHandler

Types

type BindHandler

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

func (*BindHandler) BindChannel

func (bindHandler *BindHandler) BindChannel(binding channel.Binding) error

type EventsStreamHandler

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

func (*EventsStreamHandler) AcceptFormattedEvent

func (handler *EventsStreamHandler) AcceptFormattedEvent(eventType string, formattedEvent []byte)

type StreamEventsRequest

type StreamEventsRequest struct {
	Format        string                `json:"format"`
	Subscriptions []*event.Subscription `json:"subscriptions"`
}