control

package
v0.0.5 Latest Latest
Warning

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

 Go to latest Published: Jan 19, 2021 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AppController 

type AppController interface {
	OnLaunchEditor() (string, error)
	QueueUpdate(func())
	QueueUpdateDraw(func())
	Stop()
}

type CommanderController 

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

func NewCommanderController 

func NewCommanderController(ctrl Control) *CommanderController

func (*CommanderController) AddDocument 

func (c *CommanderController) AddDocument(t string, d *data.Document)

func (*CommanderController) AddFilter added in v0.0.4 

func (c *CommanderController) AddFilter(f string, qos network.Qos)

func (*CommanderController) AddPublishedDocument added in v0.0.4 

func (c *CommanderController) AddPublishedDocument(topic string, doc *data.Document)

func (*CommanderController) OnChangeFocus 

func (c *CommanderController) OnChangeFocus(p tview.Primitive)

func (*CommanderController) OnConnect 

func (c *CommanderController) OnConnect()

func (*CommanderController) OnCopy added in v0.0.4 

func (c *CommanderController) OnCopy()

func (*CommanderController) OnNextDocument 

func (c *CommanderController) OnNextDocument()

func (*CommanderController) OnPrevDocument 

func (c *CommanderController) OnPrevDocument()

func (*CommanderController) OnPublish 

func (c *CommanderController) OnPublish()

func (*CommanderController) OnSetFollow 

func (c *CommanderController) OnSetFollow(enabled bool)

func (*CommanderController) OnSetScrollToTop 

func (c *CommanderController) OnSetScrollToTop(enabled bool)

func (*CommanderController) OnSubscribe 

func (c *CommanderController) OnSubscribe()

func (*CommanderController) OnTopicSelected 

func (c *CommanderController) OnTopicSelected(t string)

func (*CommanderController) RemoveFilter added in v0.0.4 

func (c *CommanderController) RemoveFilter(f string)

func (*CommanderController) SetConnectionStatus 

func (c *CommanderController) SetConnectionStatus(s network.ConnectionStatus)

type Config added in v0.0.4 

type Config struct {
	Server string
	Port   int
	Topics []string
}

type Connector 

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

func NewConnector 

func NewConnector(ctrl Control) *Connector

func (*Connector) Cancel 

func (c *Connector) Cancel()

func (*Connector) OnChangeFocus 

func (c *Connector) OnChangeFocus(p tview.Primitive)

func (*Connector) OnConnect 

func (c *Connector) OnConnect(host string, port int, username, password string)

func (*Connector) OnError 

func (c *Connector) OnError(err error)

type Control 

type Control interface {
	AppController
	MqttController
	ViewController
}

type Filters 

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

func NewFilters 

func NewFilters(ctrl Control) *Filters

func (*Filters) AddFilter added in v0.0.4 

func (f *Filters) AddFilter(filter string, qos network.Qos)

func (*Filters) Cancel 

func (f *Filters) Cancel()

func (*Filters) OnChangeFocus 

func (f *Filters) OnChangeFocus(p tview.Primitive)

func (*Filters) OnSubscribe 

func (f *Filters) OnSubscribe(topic string, qos network.Qos)

func (*Filters) OnUnsubscribe 

func (f *Filters) OnUnsubscribe(topic string)

func (*Filters) RemoveFilter added in v0.0.4 

func (f *Filters) RemoveFilter(filter string)

type MqttApp 

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

func NewMqttApp 

func NewMqttApp(c *network.MqttClient, conf Config) *MqttApp

func (*MqttApp) Cancel 

func (a *MqttApp) Cancel()

func (*MqttApp) Focus 

func (a *MqttApp) Focus(p tview.Primitive)

func (*MqttApp) Hide 

func (a *MqttApp) Hide(pageLabel string)

func (*MqttApp) OnConnect 

func (a *MqttApp) OnConnect(server string, port int, username, password string)

func (*MqttApp) OnDisplayCommander 

func (a *MqttApp) OnDisplayCommander()

func (*MqttApp) OnDisplayConnector 

func (a *MqttApp) OnDisplayConnector()

func (*MqttApp) OnDisplayError 

func (a *MqttApp) OnDisplayError(err error)

func (*MqttApp) OnDisplayOpenFile 

func (a *MqttApp) OnDisplayOpenFile()

func (*MqttApp) OnDisplayPublishHistory 

func (a *MqttApp) OnDisplayPublishHistory()

func (*MqttApp) OnDisplayPublisher 

func (a *MqttApp) OnDisplayPublisher()

func (*MqttApp) OnDisplaySubscriber 

func (a *MqttApp) OnDisplaySubscriber()

func (*MqttApp) OnDisplayWait added in v0.0.4 

func (a *MqttApp) OnDisplayWait(msg string)

func (*MqttApp) OnLaunchEditor 

func (a *MqttApp) OnLaunchEditor() (string, error)

func (*MqttApp) OnPublish 

func (a *MqttApp) OnPublish(topic string, qos network.Qos, retained bool, message []byte)

func (*MqttApp) OnStop 

func (a *MqttApp) OnStop()

func (*MqttApp) OnSubscribe 

func (a *MqttApp) OnSubscribe(filter string, qos network.Qos)

func (*MqttApp) OnUnsubscribe 

func (a *MqttApp) OnUnsubscribe(filter string)

func (*MqttApp) QueueUpdate 

func (a *MqttApp) QueueUpdate(f func())

func (*MqttApp) QueueUpdateDraw 

func (a *MqttApp) QueueUpdateDraw(f func())

func (*MqttApp) Register 

func (a *MqttApp) Register(pageLabel string, p tview.Primitive, visible bool)

func (*MqttApp) Start 

func (a *MqttApp) Start()

func (*MqttApp) Stop 

func (a *MqttApp) Stop()

type MqttController 

type MqttController interface {
	OnConnect(server string, port int, username, password string)
	OnSubscribe(topic string, qos network.Qos)
	OnUnsubscribe(topic string)
	OnPublish(topic string, qos network.Qos, retained bool, message []byte)
}

type Publish 

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

func NewPublish 

func NewPublish(ctrl Control) *Publish

func (*Publish) AddDocument added in v0.0.4 

func (c *Publish) AddDocument(topic string, doc *data.Document)

func (*Publish) Cancel 

func (c *Publish) Cancel()

func (*Publish) OnChangeFocus 

func (c *Publish) OnChangeFocus(p tview.Primitive)

func (*Publish) OnError 

func (c *Publish) OnError(err error)

func (*Publish) OnFileSelected 

func (c *Publish) OnFileSelected(filename string)

func (*Publish) OnLaunchEditor 

func (c *Publish) OnLaunchEditor()

func (*Publish) OnOpenFile 

func (c *Publish) OnOpenFile()

func (*Publish) OnOpenHistory 

func (c *Publish) OnOpenHistory()

func (*Publish) OnPaste added in v0.0.4 

func (c *Publish) OnPaste()

func (*Publish) OnPublish 

func (c *Publish) OnPublish(topic string, qos network.Qos, retained bool, message []byte)

func (*Publish) Register 

func (c *Publish) Register(label string, p tview.Primitive, visible bool)

type PublishHistory 

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

func NewPublishHistory 

func NewPublishHistory(ctrl Control) *PublishHistory

func (*PublishHistory) AddDocument 

func (h *PublishHistory) AddDocument(t string, d *data.Document)

func (*PublishHistory) Cancel 

func (h *PublishHistory) Cancel()

func (*PublishHistory) OnChangeFocus 

func (h *PublishHistory) OnChangeFocus(p tview.Primitive)

func (*PublishHistory) OnDocumentSelected 

func (h *PublishHistory) OnDocumentSelected(topic string, doc *data.Document)

func (*PublishHistory) OnNextDocument 

func (h *PublishHistory) OnNextDocument()

func (*PublishHistory) OnPrevDocument 

func (h *PublishHistory) OnPrevDocument()

func (*PublishHistory) OnTopicSelected 

func (h *PublishHistory) OnTopicSelected(t string)

type ViewController 

type ViewController interface {
	OnDisplayConnector()
	OnDisplayCommander()
	OnDisplaySubscriber()
	OnDisplayPublisher()
	OnDisplayPublishHistory()
	OnDisplayOpenFile()
	OnDisplayError(err error)
	OnDisplayWait(msg string)

	Register(pageLabel string, p tview.Primitive, visible bool)
	Hide(pageLabel string)
	Focus(p tview.Primitive)
	Cancel()
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.