takodclient

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Jun 16, 2026 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	JSONRequestTimeout   = 2 * time.Minute
	StreamRequestTimeout = 30 * time.Minute
)
View Source
const DefaultSocket = "/run/tako/takod.sock"

Variables

This section is empty.

Functions

func AccessLogsEndpoint

func AccessLogsEndpoint(tail int, follow bool) string

func ActualStateEndpoint

func ActualStateEndpoint(project string, environment string) string

func BackupsEndpoint

func BackupsEndpoint(project string, environment string, volume string, backupID string) string

func DiscoveryEndpoint

func DiscoveryEndpoint(project string, environment string, service string, port int, roundRobin bool) string

func EnvBundleEndpoint

func EnvBundleEndpoint(project string, environment string) string

func ExecTargetEndpoint

func ExecTargetEndpoint(project string, environment string, service string, slot int) string

func ImageBuildEndpoint

func ImageBuildEndpoint(image string, platform ...string) string

func ImageBuildEndpointWithOptions

func ImageBuildEndpointWithOptions(image string, opts ImageBuildEndpointOptions) string

func ImagesEndpoint

func ImagesEndpoint(project string, environment string) string

func InspectEndpoint

func InspectEndpoint(project string, environment string, service string) string

func LeaseEndpoint

func LeaseEndpoint(project string, environment string) string

func LogsEndpoint

func LogsEndpoint(project string, environment string, service string, tail int, follow bool) string

func MeshRTTEndpoint

func MeshRTTEndpoint(target string, count int) string

func MetricsEndpoint

func MetricsEndpoint(collect bool) string

func NodeInfoEndpoint

func NodeInfoEndpoint() string

func NodeLogsEndpoint

func NodeLogsEndpoint(unit string, tail int, follow bool) string

func PrometheusMetricsEndpoint

func PrometheusMetricsEndpoint(project string, environment string, collect bool) string

func ProxyFileEndpoint

func ProxyFileEndpoint(name string) string

func ProxyTargetEndpoint

func ProxyTargetEndpoint(project string, environment string, service string, port int) string

func RequestJSON

func RequestJSON(client RequestExecutor, socket string, method string, endpoint string, value any) (string, error)

func StateEndpoint

func StateEndpoint(project string, environment string, document string) string

func StateNodeEndpoint

func StateNodeEndpoint(project string, environment string, document string, node string) string

func StateRevisionEndpoint

func StateRevisionEndpoint(project string, environment string, document string, revisionID string) string

func StatsEndpoint

func StatsEndpoint(project string, environment string, service string, all bool) string

func StreamOutput

func StreamOutput(client StreamExecutor, socket string, endpoint string, stdout io.Writer, stderr io.Writer) error

func StreamRequest

func StreamRequest(client RequestExecutor, socket string, method string, endpoint string, reader io.Reader) (string, error)

func VolumesEndpoint

func VolumesEndpoint(project string, environment string) string

Types

type ImageBuildEndpointOptions

type ImageBuildEndpointOptions struct {
	Platform   string
	Dockerfile string
	CacheFrom  []string
	CacheTo    []string
	Builder    string
	Buildx     bool
}

type RequestExecutor

type RequestExecutor interface {
	ExecuteWithContext(ctx context.Context, cmd string) (string, error)
	ExecuteWithInput(ctx context.Context, cmd string, input io.Reader) (string, error)
}

type StreamExecutor

type StreamExecutor interface {
	RequestExecutor
	ExecuteStream(cmd string, stdout io.Writer, stderr io.Writer) error
}

Jump to

Keyboard shortcuts

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