survey

Documentation

Index

• type Caller
  • func NewCaller(managedStreamRunner *managedstream.Runner, node *centrifuge.Node) *Caller
  • func (c *Caller) CallManagedStreams(orgID int64) ([]*managedstream.ManagedChannel, error)
  • func (c *Caller) SetupHandlers() error
• type NodeManagedChannelsRequest
• type NodeManagedChannelsResponse

Types

type Caller

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

func NewCaller

func NewCaller(managedStreamRunner *managedstream.Runner, node *centrifuge.Node) *Caller

func (*Caller) CallManagedStreams

func (c *Caller) CallManagedStreams(orgID int64) ([]*managedstream.ManagedChannel, error)

func (*Caller) SetupHandlers

func (c *Caller) SetupHandlers() error

type NodeManagedChannelsRequest

type NodeManagedChannelsRequest struct {
	OrgID int64 `json:"orgId"`
}

type NodeManagedChannelsResponse

type NodeManagedChannelsResponse struct {
	Channels []*managedstream.ManagedChannel `json:"channels"`
}