liveplugin

package
v0.0.85-test Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 8, 2023 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 {
	PluginContextProvider *plugincontext.Provider
}

func NewContextGetter

func NewContextGetter(pluginContextProvider *plugincontext.Provider) *ContextGetter

func (*ContextGetter) GetPluginContext

func (g *ContextGetter) GetPluginContext(ctx context.Context, user *models.SignedInUser, pluginID string, datasourceUID string, skipCache bool) (backend.PluginContext, bool, 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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL