aproto

type AgentMessage struct {
	MasterSetAgentOptions *MasterSetAgentOptions
	StartContainer        *StartContainer
	SignalContainer       *SignalContainer
	AgentShutdown         *AgentShutdown
}

type AgentShutdown struct {
	ErrMsg string
}

type AgentStarted struct {
	Version              string
	Devices              []device.Device
	ContainersReattached []ContainerReattachAck
}

type ContainerFailure struct {
	FailureType FailureType
	ErrMsg      string
	ExitCode    *ExitCode
}

type ContainerLog struct {
	ContainerID cproto.ID
	Timestamp   time.Time
	Level       *string
	PullMessage *string
	RunMessage  *RunMessage
	AuxMessage  *string
	Source      *string
	AgentID     *string
}

type ContainerReattach struct {
	Container cproto.Container
}

type ContainerReattachAck struct {
	Container cproto.Container
	Failure   *ContainerFailure
}

type ContainerStarted struct {
	ProxyAddress  string
	ContainerInfo types.ContainerJSON
}

type ContainerStateChanged struct {
	Container cproto.Container

	ContainerStarted *ContainerStarted
	ContainerStopped *ContainerStopped
}

type ContainerStatsRecord struct {
	EndStats bool
	Stats    *model.TaskStats
	TaskType model.TaskType
}

type ContainerStopped struct {
	Failure *ContainerFailure
}

type ExitCode int

type FailureType string

type GetRPConfig struct{}

type GetRPResponse struct {
	AgentReconnectWait    model.Duration
	MaxZeroSlotContainers int
}

type ID string

type MasterInfo struct {
	Version     string        `json:"version"`
	MasterID    string        `json:"master_id"`
	ClusterID   string        `json:"cluster_id"`
	ClusterName string        `json:"cluster_name"`
	Telemetry   TelemetryInfo `json:"telemetry"`
}

type MasterMessage struct {
	AgentStarted          *AgentStarted
	ContainerStateChanged *ContainerStateChanged
	ContainerLog          *ContainerLog
	ContainerStatsRecord  *ContainerStatsRecord
}

type MasterSetAgentOptions struct {
	MasterInfo           MasterInfo
	LoggingOptions       model.LoggingConfig
	ContainersToReattach []ContainerReattach
}

type RunMessage struct {
	Value   string
	StdType stdcopy.StdType
}

type SignalContainer struct {
	ContainerID cproto.ID
	Signal      syscall.Signal
}

type StartContainer struct {
	Container cproto.Container
	Spec      cproto.Spec
}

type TelemetryInfo struct {
	Enabled                  bool   `json:"enabled"`
	SegmentKey               string `json:"segment_key,omitempty"`
	OtelEnabled              bool   `json:"otel_enabled"`
	OtelExportedOtlpEndpoint string `json:"otel_endpoint"`
}