models

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2026 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DashboardModel 

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

func NewDashboardModel 

func NewDashboardModel() DashboardModel

func (DashboardModel) AppendEvent 

func (m DashboardModel) AppendEvent(e tui.EventLogEntry) DashboardModel

AppendEvent adds an event to the recent events list (max 5).

func (DashboardModel) RunningStreamCount 

func (m DashboardModel) RunningStreamCount() int

RunningStreamCount returns the number of currently running streams.

func (DashboardModel) Update 

func (m DashboardModel) Update(msg tea.Msg) (DashboardModel, tea.Cmd)

func (DashboardModel) View 

func (m DashboardModel) View() string

func (DashboardModel) WithPipelineFinished 

func (m DashboardModel) WithPipelineFinished(ok bool) DashboardModel

WithPipelineFinished updates the model when a pipeline finishes.

func (DashboardModel) WithPipelinePhase 

func (m DashboardModel) WithPipelinePhase(phase tui.PipelinePhase) DashboardModel

WithPipelinePhase updates the current pipeline phase.

func (DashboardModel) WithPipelineStarted 

func (m DashboardModel) WithPipelineStarted(run tui.PipelineRunStarted) DashboardModel

WithPipelineStarted updates the model when a pipeline starts.

func (DashboardModel) WithSize 

func (m DashboardModel) WithSize(width, height int) DashboardModel

func (DashboardModel) WithSnapshot 

func (m DashboardModel) WithSnapshot(s tui.StateSnapshot) DashboardModel

func (DashboardModel) WithStreamEnded 

func (m DashboardModel) WithStreamEnded(ev tui.StreamEnded) DashboardModel

WithStreamEnded marks a stream as ended.

func (DashboardModel) WithStreamEvent 

func (m DashboardModel) WithStreamEvent(ev tui.StreamEvent) DashboardModel

WithStreamEvent increments the event count for a stream.

func (DashboardModel) WithStreamStarted 

func (m DashboardModel) WithStreamStarted(ev tui.StreamStarted) DashboardModel

WithStreamStarted adds or updates a stream in the summary.

type EventLogModel 

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

func NewEventLogModel 

func NewEventLogModel() EventLogModel

func (EventLogModel) Append 

func (m EventLogModel) Append(e tui.EventLogEntry) EventLogModel

func (EventLogModel) Update 

func (m EventLogModel) Update(msg tea.Msg) (EventLogModel, tea.Cmd)

func (EventLogModel) View 

func (m EventLogModel) View() string

func (EventLogModel) WithSize 

func (m EventLogModel) WithSize(width, height int) EventLogModel

type LogStream 

type LogStream string
const (
	LogStdout LogStream = "stdout"
	LogStderr LogStream = "stderr"
)

type PipelineModel 

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

func NewPipelineModel 

func NewPipelineModel() PipelineModel

func (PipelineModel) Update 

func (m PipelineModel) Update(msg tea.Msg) (PipelineModel, tea.Cmd)

func (PipelineModel) View 

func (m PipelineModel) View() string

func (PipelineModel) WithSize 

func (m PipelineModel) WithSize(width, height int) PipelineModel

type PluginInfo 

type PluginInfo struct {
	ID        string
	Path      string
	Status    string // "active" | "disabled" | "error"
	Priority  int
	Protocol  string
	Ops       []string
	Streams   []string
	Commands  []string
	CapStatus string
	CapError  string
	CapStart  time.Time
	CapEnd    time.Time
}

PluginInfo contains detailed information about a plugin.

type PluginModel 

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

PluginModel displays and manages the list of plugins.

func NewPluginModel 

func NewPluginModel() PluginModel

NewPluginModel creates a new plugin list model.

func (PluginModel) Update 

func (m PluginModel) Update(msg tea.Msg) (PluginModel, tea.Cmd)

Update handles input events.

func (PluginModel) View 

func (m PluginModel) View() string

View renders the plugin list.

func (PluginModel) WithPlugins 

func (m PluginModel) WithPlugins(plugins []tui.PluginSummary) PluginModel

WithPlugins updates the plugin list from state snapshot.

func (PluginModel) WithSize 

func (m PluginModel) WithSize(width, height int) PluginModel

WithSize sets the model dimensions.

type RootModel 

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

func NewRootModel 

func NewRootModel(opts RootModelOptions) RootModel

func (RootModel) Init 

func (m RootModel) Init() tea.Cmd

func (RootModel) Update 

func (m RootModel) Update(msg tea.Msg) (tea.Model, tea.Cmd)

func (RootModel) View 

func (m RootModel) View() string

type RootModelOptions 

type RootModelOptions struct {
	PublishAction               func(tui.ActionRequest) error
	PublishStreamStart          func(tui.StreamStartRequest) error
	PublishStreamStop           func(tui.StreamStopRequest) error
	PublishIntrospectionRefresh func() error
}

type ServiceModel 

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

func NewServiceModel 

func NewServiceModel() ServiceModel

func (ServiceModel) Update 

func (m ServiceModel) Update(msg tea.Msg) (ServiceModel, tea.Cmd)

func (ServiceModel) View 

func (m ServiceModel) View() string

func (ServiceModel) WithService 

func (m ServiceModel) WithService(name string) ServiceModel

func (ServiceModel) WithSize 

func (m ServiceModel) WithSize(width, height int) ServiceModel

func (ServiceModel) WithSnapshot 

func (m ServiceModel) WithSnapshot(s tui.StateSnapshot) ServiceModel

type StreamsModel 

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

func NewStreamsModel 

func NewStreamsModel() StreamsModel

func (StreamsModel) Update 

func (m StreamsModel) Update(msg tea.Msg) (StreamsModel, tea.Cmd)

func (StreamsModel) View 

func (m StreamsModel) View() string

func (StreamsModel) WithSize 

func (m StreamsModel) WithSize(width, height int) StreamsModel

type ViewID 

type ViewID string
const (
	ViewDashboard ViewID = "dashboard"
	ViewService   ViewID = "service"
	ViewEvents    ViewID = "events"
	ViewPipeline  ViewID = "pipeline"
	ViewPlugins   ViewID = "plugins"
	ViewStreams   ViewID = "streams"
)

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.