telemetry

Documentation

Index

• Constants
• func Init(ctx context.Context, opts TelemetryOptions) error
• func IsEnabled() bool
• func LogF(f string, args ...interface{})
• func NewTraceExporter(url string) (*otlptrace.Exporter, error)
• func Shutdown(ctx context.Context) error
• type CommandExited
  • func NewCommandExited(exitCode int) *CommandExited
  • func (e *CommandExited) GetData() interface{}
  • func (e *CommandExited) GetType() EventType
• type CommandOption
• type CommandStarted
  • func NewCommandStarted(commandOptions []CommandOption) *CommandStarted
  • func (e *CommandStarted) GetData() interface{}
  • func (e *CommandStarted) GetType() EventType
• type Event
• type EventType
• type NoTelemetryWerfIO
  • func (t *NoTelemetryWerfIO) CommandExited(context.Context, int)
  • func (t *NoTelemetryWerfIO) CommandStarted(context.Context)
  • func (t *NoTelemetryWerfIO) SetCommand(context.Context, string)
  • func (t *NoTelemetryWerfIO) SetCommandOptions(context.Context, []CommandOption)
  • func (t *NoTelemetryWerfIO) SetProjectID(context.Context, string)
• type TelemetryOptions
• type TelemetryWerfIO
  • func NewTelemetryWerfIO(url string, opts TelemetryWerfIOOptions) (*TelemetryWerfIO, error)
  • func (t *TelemetryWerfIO) CommandExited(ctx context.Context, exitCode int)
  • func (t *TelemetryWerfIO) CommandStarted(ctx context.Context)
  • func (t *TelemetryWerfIO) SetCommand(ctx context.Context, command string)
  • func (t *TelemetryWerfIO) SetCommandOptions(ctx context.Context, options []CommandOption)
  • func (t *TelemetryWerfIO) SetProjectID(ctx context.Context, projectID string)
  • func (t *TelemetryWerfIO) Shutdown(ctx context.Context) error
  • func (t *TelemetryWerfIO) Start(ctx context.Context) error
• type TelemetryWerfIOInterface
  • func GetTelemetryWerfIO() TelemetryWerfIOInterface
• type TelemetryWerfIOOptions

Constants

const (
	TracesURL = "https://telemetry.werf.io/v1/traces"
)

Functions

func Init

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

func IsEnabled

func IsEnabled() bool

func LogF

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

func NewTraceExporter

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

func Shutdown

func Shutdown(ctx context.Context) error

Types

type CommandExited

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

func NewCommandExited

func NewCommandExited(exitCode int) *CommandExited

func (*CommandExited) GetData

func (e *CommandExited) GetData() interface{}

func (*CommandExited) GetType

func (e *CommandExited) GetType() EventType

type CommandOption

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

type CommandStarted

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

func NewCommandStarted

func NewCommandStarted(commandOptions []CommandOption) *CommandStarted

func (*CommandStarted) GetData

func (e *CommandStarted) GetData() interface{}

func (*CommandStarted) GetType

func (e *CommandStarted) GetType() EventType

type Event

type Event interface {
	GetType() EventType
	GetData() interface{}
}

type EventType

type EventType string

const (
	CommandStartedEvent EventType = "CommandStarted"
	CommandExitedEvent  EventType = "CommandExited"
)

type NoTelemetryWerfIO

type NoTelemetryWerfIO struct{}

func (*NoTelemetryWerfIO) CommandExited

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

func (*NoTelemetryWerfIO) CommandStarted

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

func (*NoTelemetryWerfIO) SetCommand

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

func (*NoTelemetryWerfIO) SetCommandOptions

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

func (*NoTelemetryWerfIO) SetProjectID

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

type TelemetryOptions

type TelemetryOptions struct {
	ErrorHandlerFunc func(err error)
}

type TelemetryWerfIO

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

func NewTelemetryWerfIO

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

func (*TelemetryWerfIO) CommandExited

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

func (*TelemetryWerfIO) CommandStarted

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

func (*TelemetryWerfIO) SetCommand

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

func (*TelemetryWerfIO) SetCommandOptions

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

func (*TelemetryWerfIO) SetProjectID

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

func (*TelemetryWerfIO) Shutdown

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

func (*TelemetryWerfIO) Start

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

type TelemetryWerfIOInterface

type TelemetryWerfIOInterface interface {
	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)
}

func GetTelemetryWerfIO

func GetTelemetryWerfIO() TelemetryWerfIOInterface

type TelemetryWerfIOOptions

type TelemetryWerfIOOptions struct {
	HandleErrorFunc func(err error)
}