runstream

Documentation

Overview

Package runstream is a generated GoMock package.

Index

• type ChannelLocalPublisher
• type Manager
  • func NewManager(channelSender ChannelLocalPublisher, presenceGetter NumLocalSubscribersGetter, ...) *Manager
  • func (s *Manager) HandleDatasourceDelete(orgID int64, dsUID string) error
  • func (s *Manager) HandleDatasourceUpdate(orgID int64, dsUID string) error
  • func (s *Manager) Run(ctx context.Context) error
  • func (s *Manager) SubmitStream(ctx context.Context, user *models.SignedInUser, channel string, path string, ...) (*submitResult, error)
• type ManagerOption
  • func WithCheckConfig(interval time.Duration, maxChecks int) ManagerOption
• type MockChannelLocalPublisher
  • func NewMockChannelLocalPublisher(ctrl *gomock.Controller) *MockChannelLocalPublisher
  • func (m *MockChannelLocalPublisher) EXPECT() *MockChannelLocalPublisherMockRecorder
  • func (m *MockChannelLocalPublisher) PublishLocal(arg0 string, arg1 []byte) error
• type MockChannelLocalPublisherMockRecorder
  • func (mr *MockChannelLocalPublisherMockRecorder) PublishLocal(arg0, arg1 interface{}) *gomock.Call
• type MockNumLocalSubscribersGetter
  • func NewMockNumLocalSubscribersGetter(ctrl *gomock.Controller) *MockNumLocalSubscribersGetter
  • func (m *MockNumLocalSubscribersGetter) EXPECT() *MockNumLocalSubscribersGetterMockRecorder
  • func (m *MockNumLocalSubscribersGetter) GetNumLocalSubscribers(arg0 string) (int, error)
• type MockNumLocalSubscribersGetterMockRecorder
  • func (mr *MockNumLocalSubscribersGetterMockRecorder) GetNumLocalSubscribers(arg0 interface{}) *gomock.Call
• type MockPluginContextGetter
  • func NewMockPluginContextGetter(ctrl *gomock.Controller) *MockPluginContextGetter
  • func (m *MockPluginContextGetter) EXPECT() *MockPluginContextGetterMockRecorder
  • func (m *MockPluginContextGetter) GetPluginContext(ctx context.Context, arg0 *models.SignedInUser, arg1, arg2 string, arg3 bool) (backend.PluginContext, bool, error)
• type MockPluginContextGetterMockRecorder
  • func (mr *MockPluginContextGetterMockRecorder) GetPluginContext(ctx, arg0, arg1, arg2, arg3 interface{}) *gomock.Call
• type MockStreamRunner
  • func NewMockStreamRunner(ctrl *gomock.Controller) *MockStreamRunner
  • func (m *MockStreamRunner) EXPECT() *MockStreamRunnerMockRecorder
  • func (m *MockStreamRunner) RunStream(arg0 context.Context, arg1 *backend.RunStreamRequest, ...) error
• type MockStreamRunnerMockRecorder
  • func (mr *MockStreamRunnerMockRecorder) RunStream(ctx, arg0, arg1, arg2 interface{}) *gomock.Call
• type NumLocalSubscribersGetter
• type PluginContextGetter
• type StreamRunner

Types

type ChannelLocalPublisher

type ChannelLocalPublisher interface {
	PublishLocal(channel string, data []byte) error
}

type Manager

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

Manager manages streams from Grafana to plugins (i.e. RunStream method).

func NewManager

func NewManager(channelSender ChannelLocalPublisher, presenceGetter NumLocalSubscribersGetter, pluginContextGetter PluginContextGetter, opts ...ManagerOption) *Manager

NewManager creates new Manager.

func (*Manager) HandleDatasourceDelete

func (s *Manager) HandleDatasourceDelete(orgID int64, dsUID string) error

func (*Manager) HandleDatasourceUpdate

func (s *Manager) HandleDatasourceUpdate(orgID int64, dsUID string) error

func (*Manager) Run

func (s *Manager) Run(ctx context.Context) error

Run Manager till context canceled.

func (*Manager) SubmitStream

func (s *Manager) SubmitStream(ctx context.Context, user *models.SignedInUser, channel string, path string, data []byte, pCtx backend.PluginContext, streamRunner StreamRunner, isResubmit bool) (*submitResult, error)

SubmitStream submits stream handler in Manager to manage. The stream will be opened and kept till channel has active subscribers.

type ManagerOption

type ManagerOption func(*Manager)

ManagerOption modifies Manager behavior (used for tests for example).

func WithCheckConfig

func WithCheckConfig(interval time.Duration, maxChecks int) ManagerOption

WithCheckConfig allows setting custom check rules.

type MockChannelLocalPublisher

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

MockChannelLocalPublisher is a mock of ChannelLocalPublisher interface.

func NewMockChannelLocalPublisher

func NewMockChannelLocalPublisher(ctrl *gomock.Controller) *MockChannelLocalPublisher

NewMockChannelLocalPublisher creates a new mock instance.

func (*MockChannelLocalPublisher) EXPECT

func (m *MockChannelLocalPublisher) EXPECT() *MockChannelLocalPublisherMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockChannelLocalPublisher) PublishLocal

func (m *MockChannelLocalPublisher) PublishLocal(arg0 string, arg1 []byte) error

PublishLocal mocks base method.

type MockChannelLocalPublisherMockRecorder

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

MockChannelLocalPublisherMockRecorder is the mock recorder for MockChannelLocalPublisher.

func (*MockChannelLocalPublisherMockRecorder) PublishLocal

func (mr *MockChannelLocalPublisherMockRecorder) PublishLocal(arg0, arg1 interface{}) *gomock.Call

PublishLocal indicates an expected call of PublishLocal.

type MockNumLocalSubscribersGetter

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

MockNumLocalSubscribersGetter is a mock of NumLocalSubscribersGetter interface.

func NewMockNumLocalSubscribersGetter

func NewMockNumLocalSubscribersGetter(ctrl *gomock.Controller) *MockNumLocalSubscribersGetter

NewMockNumLocalSubscribersGetter creates a new mock instance.

func (*MockNumLocalSubscribersGetter) EXPECT

func (m *MockNumLocalSubscribersGetter) EXPECT() *MockNumLocalSubscribersGetterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockNumLocalSubscribersGetter) GetNumLocalSubscribers

func (m *MockNumLocalSubscribersGetter) GetNumLocalSubscribers(arg0 string) (int, error)

GetNumLocalSubscribers mocks base method.

type MockNumLocalSubscribersGetterMockRecorder

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

MockNumLocalSubscribersGetterMockRecorder is the mock recorder for MockNumLocalSubscribersGetter.

func (*MockNumLocalSubscribersGetterMockRecorder) GetNumLocalSubscribers

func (mr *MockNumLocalSubscribersGetterMockRecorder) GetNumLocalSubscribers(arg0 interface{}) *gomock.Call

GetNumLocalSubscribers indicates an expected call of GetNumLocalSubscribers.

type MockPluginContextGetter

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

MockPluginContextGetter is a mock of PluginContextGetter interface.

func NewMockPluginContextGetter

func NewMockPluginContextGetter(ctrl *gomock.Controller) *MockPluginContextGetter

NewMockPluginContextGetter creates a new mock instance.

func (*MockPluginContextGetter) EXPECT

func (m *MockPluginContextGetter) EXPECT() *MockPluginContextGetterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPluginContextGetter) GetPluginContext

func (m *MockPluginContextGetter) GetPluginContext(ctx context.Context, arg0 *models.SignedInUser, arg1, arg2 string, arg3 bool) (backend.PluginContext, bool, error)

GetPluginContext mocks base method.

type MockPluginContextGetterMockRecorder

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

MockPluginContextGetterMockRecorder is the mock recorder for MockPluginContextGetter.

func (*MockPluginContextGetterMockRecorder) GetPluginContext

func (mr *MockPluginContextGetterMockRecorder) GetPluginContext(ctx, arg0, arg1, arg2, arg3 interface{}) *gomock.Call

GetPluginContext indicates an expected call of GetPluginContext.

type MockStreamRunner

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

MockStreamRunner is a mock of StreamRunner interface.

func NewMockStreamRunner

func NewMockStreamRunner(ctrl *gomock.Controller) *MockStreamRunner

NewMockStreamRunner creates a new mock instance.

func (*MockStreamRunner) EXPECT

func (m *MockStreamRunner) EXPECT() *MockStreamRunnerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStreamRunner) RunStream

func (m *MockStreamRunner) RunStream(arg0 context.Context, arg1 *backend.RunStreamRequest, arg2 *backend.StreamSender) error

RunStream mocks base method.

type MockStreamRunnerMockRecorder

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

MockStreamRunnerMockRecorder is the mock recorder for MockStreamRunner.

func (*MockStreamRunnerMockRecorder) RunStream

func (mr *MockStreamRunnerMockRecorder) RunStream(ctx, arg0, arg1, arg2 interface{}) *gomock.Call

RunStream indicates an expected call of RunStream.

type NumLocalSubscribersGetter

type NumLocalSubscribersGetter interface {
	// GetNumSubscribers returns number of channel subscribers throughout all nodes.
	GetNumLocalSubscribers(channel string) (int, error)
}

type PluginContextGetter

type PluginContextGetter interface {
	GetPluginContext(ctx context.Context, user *models.SignedInUser, pluginID string, datasourceUID string, skipCache bool) (backend.PluginContext, bool, error)
}

type StreamRunner

type StreamRunner interface {
	RunStream(ctx context.Context, request *backend.RunStreamRequest, sender *backend.StreamSender) error
}