session

Documentation

Index

• Constants
• Variables
• type Body
• type Op
• type OpOption
  • func WithAutoUpdateExitCode(autoUpdateExitCode int) OpOption
  • func WithEnableAutoUpdate(enableAutoUpdate bool) OpOption
  • func WithMachineID(machineID string) OpOption
  • func WithPipeInterval(t time.Duration) OpOption
• type Request
• type Response
• type Session
  • func NewSession(ctx context.Context, endpoint string, opts ...OpOption) (*Session, error)
  • func (s *Session) Stop()

Constants

const DefaultQuerySince = 30 * time.Minute

Variables

var ErrAutoUpdateDisabledButExitCodeSet = errors.New("auto update is disabled but auto update by exit code is set")

Types

type Body

type Body struct {
	Data  []byte `json:"data,omitempty"`
	ReqID string `json:"req_id,omitempty"`
}

type Op

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

type OpOption

type OpOption func(*Op)

func WithAutoUpdateExitCode

func WithAutoUpdateExitCode(autoUpdateExitCode int) OpOption

Triggers an auto update of GPUd itself by exiting the process with the given exit code. Useful when the machine is managed by the Kubernetes daemonset and we want to trigger an auto update when the daemonset restarts the machine.

func WithEnableAutoUpdate

func WithEnableAutoUpdate(enableAutoUpdate bool) OpOption

func WithMachineID

func WithMachineID(machineID string) OpOption

func WithPipeInterval

func WithPipeInterval(t time.Duration) OpOption

type Request

type Request struct {
	Method        string        `json:"method,omitempty"`
	Components    []string      `json:"components,omitempty"`
	StartTime     time.Time     `json:"start_time"`
	EndTime       time.Time     `json:"end_time"`
	Since         time.Duration `json:"since"`
	UpdateVersion string        `json:"update_version,omitempty"`
}

type Response

type Response struct {
	Error   error            `json:"error,omitempty"`
	States  v1.LeptonStates  `json:"states,omitempty"`
	Events  v1.LeptonEvents  `json:"events,omitempty"`
	Metrics v1.LeptonMetrics `json:"metrics,omitempty"`
}

type Session

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

func NewSession

func NewSession(ctx context.Context, endpoint string, opts ...OpOption) (*Session, error)

func (*Session) Stop

func (s *Session) Stop()