controlplane

package
v0.0.0-...-351111d Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

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

func NewClient 

func NewClient(uuid string, address string, opts ...client.Option) (*Client, error)

type Commands 

type Commands struct {
	Commands interpoler.CommandNodes
}

func NewCommands 

func NewCommands(controlPlaneExecutors *Executors, controlPlaneCompleters *Completers) *Commands

type Completers 

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

func NewCompleters 

func NewCompleters(controlPlaneClient *Client) *Completers

func (*Completers) ListDigestsName 

func (c *Completers) ListDigestsName(ctx context.Context, parameters interpoler.ParametersWithValue) []string

func (*Completers) ListEventsName 

func (c *Completers) ListEventsName(ctx context.Context, parameters interpoler.ParametersWithValue) []string

func (*Completers) ListResourcesUID 

func (c *Completers) ListResourcesUID(ctx context.Context, parameters interpoler.ParametersWithValue) []string

TODO: Generic sampler filter based on supplied parameters

func (*Completers) ListSampleType 

func (c *Completers) ListSampleType(ctx context.Context, parameters interpoler.ParametersWithValue) []string

func (*Completers) ListSamplersUID 

func (c *Completers) ListSamplersUID(ctx context.Context, parameters interpoler.ParametersWithValue) []string

ListSamplersUID lists all the available samplers. If a resource parameter is provided, it will just return the samplers that are part of the resource

func (*Completers) ListStreamsName 

func (c *Completers) ListStreamsName(ctx context.Context, parameters interpoler.ParametersWithValue) []string

type Executors 

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

func NewExecutors 

func NewExecutors(controlPlaneClient *Client) *Executors

func (*Executors) DigestsDelete 

func (e *Executors) DigestsDelete(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) DigestsList 

func (e *Executors) DigestsList(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) DigestsStructureCreate 

func (e *Executors) DigestsStructureCreate(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) DigestsStructureUpdate 

func (e *Executors) DigestsStructureUpdate(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) DigestsValueCreate 

func (e *Executors) DigestsValueCreate(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) DigestsValueUpdate 

func (e *Executors) DigestsValueUpdate(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) EventsCreate 

func (e *Executors) EventsCreate(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) EventsDelete 

func (e *Executors) EventsDelete(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) EventsList 

func (e *Executors) EventsList(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) EventsUpdate 

func (e *Executors) EventsUpdate(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) ResourcesList 

func (e *Executors) ResourcesList(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) SamplersLimiterInSet 

func (e *Executors) SamplersLimiterInSet(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) SamplersLimiterInUnset 

func (e *Executors) SamplersLimiterInUnset(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) SamplersLimiterOutSet 

func (e *Executors) SamplersLimiterOutSet(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) SamplersLimiterOutUnset 

func (e *Executors) SamplersLimiterOutUnset(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) SamplersList 

func (e *Executors) SamplersList(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) SamplersListConfig 

func (e *Executors) SamplersListConfig(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) SamplersSamplerInSetDeterministic 

func (e *Executors) SamplersSamplerInSetDeterministic(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) SamplersSamplerInUnset 

func (e *Executors) SamplersSamplerInUnset(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) StreamsCreate 

func (e *Executors) StreamsCreate(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) StreamsDelete 

func (e *Executors) StreamsDelete(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) StreamsList 

func (e *Executors) StreamsList(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

func (*Executors) StreamsUpdate 

func (e *Executors) StreamsUpdate(ctx context.Context, parameters interpoler.ParametersWithValue, writer *internal.Writer) error

type ListDigestsView 

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

ListDigestsView shows a table with all the configured digests for each resource and sampler. Data is ordered by resource and sampler.

func NewListDigestsView 

func NewListDigestsView() *ListDigestsView

func (*ListDigestsView) AddSampler 

func (ldv *ListDigestsView) AddSampler(sampler *control.Sampler)

func (*ListDigestsView) Render 

func (ldv *ListDigestsView) Render(writer io.Writer)

type ListEventsView 

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

ListEventsView shows a table with all the events for each resource and sampler. Data is ordered by resource and sampler.

func NewListEventsView 

func NewListEventsView() *ListEventsView

func (*ListEventsView) AddSampler 

func (lev *ListEventsView) AddSampler(sampler *control.Sampler)

func (*ListEventsView) Render 

func (lev *ListEventsView) Render(writer io.Writer)

type ListResourcesView 

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

ListResourcesView shows a table with all the resources

func NewListResourcesView 

func NewListResourcesView() *ListResourcesView

func (*ListResourcesView) AddSampler 

func (lrv *ListResourcesView) AddSampler(sampler *control.Sampler)

func (*ListResourcesView) Render 

func (lrv *ListResourcesView) Render(writer io.Writer)

type ListSamplersConfigView 

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

ListSamplersConfigView shows a table with all samplers and their config.

func NewListSamplersConfigView 

func NewListSamplersConfigView() *ListSamplersConfigView

func (*ListSamplersConfigView) AddSampler 

func (lscv *ListSamplersConfigView) AddSampler(sampler *control.Sampler)

func (*ListSamplersConfigView) Render 

func (lscv *ListSamplersConfigView) Render(writer io.Writer)

type ListSamplersView 

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

ListSamplersView shows a table with all samplers and their stats.

func NewListSamplersView 

func NewListSamplersView() *ListSamplersView

func (*ListSamplersView) AddSampler 

func (lsv *ListSamplersView) AddSampler(sampler *control.Sampler)

func (*ListSamplersView) Render 

func (lsv *ListSamplersView) Render(writer io.Writer)

type ListStreamsView 

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

ListStreamsView shows a table with all the configured streams for each resource and sampler. Data is ordered by resource and sampler.

func NewListStreamsView 

func NewListStreamsView() *ListStreamsView

func (*ListStreamsView) AddSampler 

func (lsv *ListStreamsView) AddSampler(sampler *control.Sampler)

func (*ListStreamsView) Render 

func (lsv *ListStreamsView) Render(writer io.Writer)

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.