tester

package

v0.1.2 Latest Latest Go to latest Published: Aug 2, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type FlowValue []string

func (f FlowValue) FlowData() (map[string]interface{}, error)

type Loki struct {
	BaseURL string
}

Loki enables basic testing operations for the Loki component of the test cluster

func (l *Loki) Query(limit int, logQL string) (*LokiQueryResponse, error)

Query executes an arbitrary logQL query, given a limit in the results

func (l *Loki) Ready() error

Ready returns error if the Loki API is ready to accept calls

type LokiQueryData struct {
	Result []LokiQueryResult `json:"result"`
}

type LokiQueryResponse struct {
	Status string        `json:"status"`
	Data   LokiQueryData `json:"data"`
}

type LokiQueryResult struct {
	Stream map[string]string `json:"stream"`
	Values []FlowValue       `json:"values"`
}

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

Pods enables some basic operations in cluster pods (e.g. searching, executing commands...)

func NewPods(cfg *envconf.Config) (*Pods, error)

func (p *Pods) Execute(ctx context.Context, namespace, name string, command ...string) (string, string, error)

func (p *Pods) MACAddress(
	ctx context.Context, namespace, name, iface string,
) (net.HardwareAddr, error)