telemetry

package
v1.2.332 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	TracesURL    = "https://telemetry.werf.io/v1/traces"
	TelemetryEnv = "WERF_TELEMETRY"
)

Variables

This section is empty.

Functions

func GetTraceUrl added in v1.2.154 

func GetTraceUrl() string

func Init 

func Init(ctx context.Context, opts TelemetryOptions) error

func IsEnabled 

func IsEnabled() bool

func LogF added in v1.2.128 

func LogF(f string, args ...interface{})

func NewTraceExporter added in v1.2.119 

func NewTraceExporter(url string) (*otlptrace.Exporter, error)

func Shutdown 

func Shutdown(ctx context.Context) error

Types

type CommandExited added in v1.2.128 

type CommandExited struct {
	ExitCode   int   `json:"exitCode"`
	DurationMs int64 `json:"durationMs"`
}

func NewCommandExited added in v1.2.128 

func NewCommandExited(exitCode int, durationMs int64) *CommandExited

func (*CommandExited) GetType added in v1.2.128 

func (e *CommandExited) GetType() EventType

type CommandOption added in v1.2.128 

type CommandOption struct {
	Name  string `json:"name"`
	AsCli bool   `json:"asCli"`
	AsEnv bool   `json:"asEnv"`
	Count int    `json:"count"`
}

type CommandStarted added in v1.2.128 

type CommandStarted struct {
	CommandOptions []CommandOption `json:"commandOptions,omitempty"`
}

func NewCommandStarted added in v1.2.128 

func NewCommandStarted(commandOptions []CommandOption) *CommandStarted

func (*CommandStarted) GetType added in v1.2.128 

func (e *CommandStarted) GetType() EventType

type Event added in v1.2.128 

type Event interface {
	GetType() EventType
}

type EventType added in v1.2.122 

type EventType string
const (
	CommandStartedEvent  EventType = "CommandStarted"
	CommandExitedEvent   EventType = "CommandExited"
	UnshallowFailedEvent EventType = "UnshallowFailed"
)

type NoTelemetryWerfIO added in v1.2.120 

type NoTelemetryWerfIO struct{}

func (*NoTelemetryWerfIO) CommandExited added in v1.2.128 

func (t *NoTelemetryWerfIO) CommandExited(context.Context, int)

func (*NoTelemetryWerfIO) CommandStarted added in v1.2.120 

func (t *NoTelemetryWerfIO) CommandStarted(context.Context)

func (*NoTelemetryWerfIO) SetCommand added in v1.2.120 

func (t *NoTelemetryWerfIO) SetCommand(context.Context, string)

func (*NoTelemetryWerfIO) SetCommandOptions added in v1.2.128 

func (t *NoTelemetryWerfIO) SetCommandOptions(context.Context, []CommandOption)

func (*NoTelemetryWerfIO) SetProjectID added in v1.2.120 

func (t *NoTelemetryWerfIO) SetProjectID(context.Context, string)

func (*NoTelemetryWerfIO) SetUserID added in v1.2.154 

func (t *NoTelemetryWerfIO) SetUserID(context.Context, string)

func (*NoTelemetryWerfIO) UnshallowFailed added in v1.2.170 

func (t *NoTelemetryWerfIO) UnshallowFailed(context.Context, error)

type TelemetryOptions added in v1.2.121 

type TelemetryOptions struct {
	ErrorHandlerFunc func(err error)
}

type TelemetryWerfIO added in v1.2.120 

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

func NewTelemetryWerfIO added in v1.2.120 

func NewTelemetryWerfIO(url string, opts TelemetryWerfIOOptions) (*TelemetryWerfIO, error)

func (*TelemetryWerfIO) CommandExited added in v1.2.128 

func (t *TelemetryWerfIO) CommandExited(ctx context.Context, exitCode int)

func (*TelemetryWerfIO) CommandStarted added in v1.2.120 

func (t *TelemetryWerfIO) CommandStarted(ctx context.Context)

func (*TelemetryWerfIO) SetCommand added in v1.2.120 

func (t *TelemetryWerfIO) SetCommand(ctx context.Context, command string)

func (*TelemetryWerfIO) SetCommandOptions added in v1.2.128 

func (t *TelemetryWerfIO) SetCommandOptions(ctx context.Context, options []CommandOption)

func (*TelemetryWerfIO) SetProjectID added in v1.2.120 

func (t *TelemetryWerfIO) SetProjectID(ctx context.Context, projectID string)

func (*TelemetryWerfIO) SetUserID added in v1.2.154 

func (t *TelemetryWerfIO) SetUserID(_ context.Context, userID string)

func (*TelemetryWerfIO) Shutdown added in v1.2.120 

func (t *TelemetryWerfIO) Shutdown(ctx context.Context) error

func (*TelemetryWerfIO) Start added in v1.2.120 

func (t *TelemetryWerfIO) Start(ctx context.Context) error

func (*TelemetryWerfIO) UnshallowFailed added in v1.2.170 

func (t *TelemetryWerfIO) UnshallowFailed(ctx context.Context, err error)

type TelemetryWerfIOInterface added in v1.2.120 

type TelemetryWerfIOInterface interface {
	SetUserID(ctx context.Context, projectID string)
	SetProjectID(ctx context.Context, projectID string)
	SetCommand(ctx context.Context, command string)
	SetCommandOptions(ctx context.Context, options []CommandOption)

	CommandStarted(ctx context.Context)
	CommandExited(ctx context.Context, exitCode int)
	UnshallowFailed(ctx context.Context, err error)
}

func GetTelemetryWerfIO added in v1.2.120 

func GetTelemetryWerfIO() TelemetryWerfIOInterface

type TelemetryWerfIOOptions added in v1.2.122 

type TelemetryWerfIOOptions struct {
	HandleErrorFunc func(err error)
}

type UnshallowFailed added in v1.2.170 

type UnshallowFailed struct {
	ErrorMessage        string `json:"errorMessage"`
	GitlabRunnerVersion string `json:"gitlabRunnerVersion"`
	GitlabServerVersion string `json:"gitlabServerVersion"`
}

func NewUnshallowFailed added in v1.2.170 

func NewUnshallowFailed(errorMessage string) *UnshallowFailed

func (*UnshallowFailed) GetType added in v1.2.170 

func (*UnshallowFailed) GetType() EventType

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.