liveplugin

Documentation

Index

• type ChannelLocalPublisher
  • func NewChannelLocalPublisher(node *centrifuge.Node, pipeline *pipeline.Pipeline) *ChannelLocalPublisher
  • func (p *ChannelLocalPublisher) PublishLocal(channel string, data []byte) error
• type ContextGetter
  • func NewContextGetter(pluginContextProvider *plugincontext.Provider, ...) *ContextGetter
  • func (g *ContextGetter) GetPluginContext(ctx context.Context, user identity.Requester, pluginID string, ...) (backend.PluginContext, error)
• type NumLocalSubscribersGetter
  • func NewNumLocalSubscribersGetter(node *centrifuge.Node) *NumLocalSubscribersGetter
  • func (p *NumLocalSubscribersGetter) GetNumLocalSubscribers(channelID string) (int, error)

Types

type ChannelLocalPublisher

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

func NewChannelLocalPublisher

func NewChannelLocalPublisher(node *centrifuge.Node, pipeline *pipeline.Pipeline) *ChannelLocalPublisher

func (*ChannelLocalPublisher) PublishLocal

func (p *ChannelLocalPublisher) PublishLocal(channel string, data []byte) error

type ContextGetter

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

func NewContextGetter

func NewContextGetter(pluginContextProvider *plugincontext.Provider, dataSourceCache datasources.CacheService) *ContextGetter

func (*ContextGetter) GetPluginContext

func (g *ContextGetter) GetPluginContext(ctx context.Context, user identity.Requester, pluginID string, datasourceUID string, skipCache bool) (backend.PluginContext, error)

type NumLocalSubscribersGetter

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

func NewNumLocalSubscribersGetter

func NewNumLocalSubscribersGetter(node *centrifuge.Node) *NumLocalSubscribersGetter

func (*NumLocalSubscribersGetter) GetNumLocalSubscribers

func (p *NumLocalSubscribersGetter) GetNumLocalSubscribers(channelID string) (int, error)