tester

Documentation

Index

• type FlowValue
  • func (f FlowValue) FlowData() (map[string]interface{}, error)
• type Loki
  • func (l *Loki) Query(limit int, logQL string) (*LokiQueryResponse, error)
  • func (l *Loki) Ready() error
• type LokiQueryData
• type LokiQueryResponse
• type LokiQueryResult
• type Pods
  • 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)

Types

type FlowValue

type FlowValue []string

func (FlowValue) FlowData

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

type Loki

type Loki struct {
	BaseURL string
}

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

func (*Loki) Query

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

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

func (*Loki) Ready

func (l *Loki) Ready() error

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

type LokiQueryData

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

type LokiQueryResponse

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

type LokiQueryResult

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

type Pods

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

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

func NewPods

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

func (*Pods) Execute

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

func (*Pods) MACAddress

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