compose

package
v0.0.0-...-f73c5c5 Latest Latest
Warning

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

Go to latest
Published: Jan 19, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package docker provides some helpers to manage docker-compose clusters from the test suites

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Compose

type Compose struct {
	Command     string
	DefaultArgs []string
	Path        string
	Logger      io.WriteCloser
	Env         []string
}

func ComposeSuite

func ComposeSuite(composeFile, logFile string) (*Compose, error)

func (*Compose) Close

func (c *Compose) Close() error

func (*Compose) Logs

func (c *Compose) Logs() error

func (*Compose) Remove

func (c *Compose) Remove() error

func (*Compose) Stop

func (c *Compose) Stop() error

func (*Compose) Up

func (c *Compose) Up() error

type ComposeEndpoint

type ComposeEndpoint struct {
	ComposeFilePath string
	LogOutputPath   string
	Env             []string
	Ports           PortsConfig
}

func NewEndpoint

func NewEndpoint(composeFilePath, logOutputPath string, env []string, ports PortsConfig) *ComposeEndpoint

func (*ComposeEndpoint) GetTraceByID

func (e *ComposeEndpoint) GetTraceByID(ctx context.Context, id string) ([]byte, error)

func (*ComposeEndpoint) Logger

func (e *ComposeEndpoint) Logger() io.WriteCloser

func (*ComposeEndpoint) RunPromQL

func (e *ComposeEndpoint) RunPromQL(ctx context.Context, promQL string) ([]byte, error)

func (*ComposeEndpoint) SearchLoki

func (e *ComposeEndpoint) SearchLoki(query string) ([]byte, error)

func (*ComposeEndpoint) SearchTags

func (e *ComposeEndpoint) SearchTags(ctx context.Context, tags map[string]string) ([]byte, error)

func (*ComposeEndpoint) SearchTempo

func (e *ComposeEndpoint) SearchTempo(ctx context.Context, query string) ([]byte, error)

func (*ComposeEndpoint) Start

func (e *ComposeEndpoint) Start(ctx context.Context) error

func (*ComposeEndpoint) Stop

func (e *ComposeEndpoint) Stop(ctx context.Context) error

func (*ComposeEndpoint) TracerProvider

func (e *ComposeEndpoint) TracerProvider(ctx context.Context, r *resource.Resource) (*trace.TracerProvider, error)

type PortsConfig

type PortsConfig struct {
	TracesGRPCPort     int
	TracesHTTPPort     int
	TempoHTTPPort      int
	MimirHTTPPort      int
	PrometheusHTTPPort int
	LokiHttpPort       int
}

Jump to

Keyboard shortcuts

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