plugin

package

v0.0.0-...-7b4b282 Latest Latest Go to latest Published: Mar 13, 2025 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 4 more Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/zosmac/gomon-datasource

Links

Open Source Insights

Documentation ¶

Index ¶

func Factory(ctx context.Context) datasource.InstanceFactoryFunc
func Nodegraph(link string, queryPid Pid) backend.DataResponse
type Instance
type Pid
type Query

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Factory ¶

func Factory(ctx context.Context) datasource.InstanceFactoryFunc

func Nodegraph ¶

func Nodegraph(link string, queryPid Pid) backend.DataResponse

Nodegraph produces the process connections node graph.

Types ¶

type Instance ¶

type Instance struct {
	Health struct {
		Checks int `json:"checks"`
	} `json:"health"`
	Query struct {
		Requests int `json:"requests"`
		Queries  int `json:"count"`
	} `json:"query"`
	Stream struct {
		Streams       int `json:"count"`
		Messages      int `json:"messages"`
		Subscriptions int `json:"subscriptions"`
		Published     int `json:"published"`
		Errors        int `json:"errors"`
	} `json:"stream"`
	// contains filtered or unexported fields
}

Instance of the datasource.

func (*Instance) CallResource ¶

func (instance *Instance) CallResource(_ context.Context, req *backend.CallResourceRequest, sender backend.CallResourceResponseSender) error

CallResource of data source.

func (*Instance) CheckHealth ¶

func (instance *Instance) CheckHealth(_ context.Context, req *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)

CheckHealth run when "save and test" of data source run.

func (*Instance) Dispose ¶

func (instance *Instance) Dispose()

Dispose run when instance cleaned up.

func (*Instance) PublishStream ¶

func (dsi *Instance) PublishStream(_ context.Context, req *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)

PublishStream sends client message to the stream.

func (*Instance) QueryData ¶

func (instance *Instance) QueryData(_ context.Context, req *backend.QueryDataRequest) (resp *backend.QueryDataResponse, err error)

QueryData handler for data source.

func (*Instance) RunStream ¶

func (dsi *Instance) RunStream(ctx context.Context, req *backend.RunStreamRequest, sender *backend.StreamSender) error

RunStream initiates data source's stream to channel.

func (*Instance) SubscribeStream ¶

func (dsi *Instance) SubscribeStream(_ context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)

SubscribeStream connects client to stream.

type Pid ¶

type Pid = process.Pid

Pid alias for Pid in process package.

type Query ¶

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

query parameters for request.

func (Query) Arrow ¶

func (query Query) Arrow() string

Arrow returns the character to use in edges' tooltip connections list.

func (Query) BuildGraph ¶

func (query Query) BuildGraph(
	tb process.Table,
	itr process.Tree,
	hosts map[Pid][]any,
	prcss map[int]map[Pid][]any,
	datas map[Pid][]any,
	edges map[[2]Pid][]any,
) []*data.Frame

func (Query) DataEdge ¶

func (query Query) DataEdge(tb process.Table, conn process.Connection) []any

func (Query) DataNode ¶

func (query Query) DataNode(conn process.Connection) []any

func (Query) HostEdge ¶

func (query Query) HostEdge(tb process.Table, conn process.Connection) []any

func (Query) HostNode ¶

func (query Query) HostNode(conn process.Connection) []any

func (Query) Pid ¶

func (query Query) Pid() Pid

Pid returns the query's pid.

func (Query) ProcEdge ¶

func (query Query) ProcEdge(tb process.Table, self, peer Pid) []any

func (Query) ProcNode ¶

func (query Query) ProcNode(p *process.Process) []any

Source Files ¶

View all Source files

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