agentsobs

package

v1.0.0 Latest Latest Go to latest Published: Jul 3, 2025 License: Apache-2.0 Imports: 2 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/deepak191093/protocol

Links

Open Source Insights

Documentation ¶

Overview ¶

Code generated; DO NOT EDIT.

Index ¶

Constants
type AgentKind
type AgentReporter
- func NewNoopAgentReporter() AgentReporter
type AgentTx
type JobKind
- func JobKindFromProto(kind livekit.JobType) JobKind
type JobReporter
- func NewNoopJobReporter() JobReporter
type JobStatus
- func JobStatusFromProto(status livekit.JobStatus) JobStatus
type JobTx
type KeyResolver
type ProjectReporter
- func NewNoopProjectReporter() ProjectReporter
type ProjectTx
type Reporter
- func NewNoopReporter() Reporter
type Rollup
type WorkerReporter
- func NewNoopWorkerReporter() WorkerReporter
type WorkerState
type WorkerStatus
- func WorkerStatusFromProto(status livekit.WorkerStatus) WorkerStatus
type WorkerTx

Constants ¶

View Source

const Version_9IAJBGO = true

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type AgentKind ¶

type AgentKind string

const (
	AgentKindUndefined AgentKind = ""
	AgentKindCloud     AgentKind = "cloud"
	AgentKindSelfhost  AgentKind = "selfhost"
)

type AgentReporter ¶

type AgentReporter interface {
	RegisterFunc(func(ts time.Time, tx AgentTx) bool)
	Tx(func(tx AgentTx))
	TxAt(time.Time, func(tx AgentTx))
	WithWorker(id string) WorkerReporter
	WithDeferredWorker() (WorkerReporter, KeyResolver)
}

func NewNoopAgentReporter ¶

func NewNoopAgentReporter() AgentReporter

type AgentTx ¶

type AgentTx interface{}

type JobKind ¶

type JobKind string

const (
	JobKindUndefined   JobKind = ""
	JobKindRoom        JobKind = "room"
	JobKindPublisher   JobKind = "publisher"
	JobKindParticipant JobKind = "participant"
)

func JobKindFromProto ¶

func JobKindFromProto(kind livekit.JobType) JobKind

type JobReporter ¶

type JobReporter interface {
	RegisterFunc(func(ts time.Time, tx JobTx) bool)
	Tx(func(tx JobTx))
	TxAt(time.Time, func(tx JobTx))
	ReportRoomSessionID(v string)
	ReportKind(v JobKind)
	ReportStatus(v JobStatus)
	ReportDuration(v uint32)
	ReportDispatchedAt(v time.Time)
	ReportJoinedAt(v time.Time)
	ReportCompletedAt(v time.Time)
}

func NewNoopJobReporter ¶

func NewNoopJobReporter() JobReporter

type JobStatus ¶

type JobStatus string

const (
	JobStatusUndefined JobStatus = ""
	JobStatusPending   JobStatus = "pending"
	JobStatusRunning   JobStatus = "running"
	JobStatusSuccess   JobStatus = "success"
	JobStatusFailed    JobStatus = "failed"
)

func JobStatusFromProto ¶

func JobStatusFromProto(status livekit.JobStatus) JobStatus

type JobTx ¶

type JobTx interface {
	ReportRoomSessionID(v string)
	ReportKind(v JobKind)
	ReportStatus(v JobStatus)
	ReportDuration(v uint32)
	ReportDispatchedAt(v time.Time)
	ReportJoinedAt(v time.Time)
	ReportCompletedAt(v time.Time)
}

type KeyResolver ¶

type KeyResolver interface {
	Resolve(string)
	Reset()
}

type ProjectReporter ¶

type ProjectReporter interface {
	RegisterFunc(func(ts time.Time, tx ProjectTx) bool)
	Tx(func(tx ProjectTx))
	TxAt(time.Time, func(tx ProjectTx))
	WithAgent(name string) AgentReporter
	WithDeferredAgent() (AgentReporter, KeyResolver)
}

func NewNoopProjectReporter ¶

func NewNoopProjectReporter() ProjectReporter

type ProjectTx ¶

type ProjectTx interface{}

type Reporter ¶

type Reporter interface {
	WithProject(id string) ProjectReporter
	WithDeferredProject() (ProjectReporter, KeyResolver)
}

func NewNoopReporter ¶

func NewNoopReporter() Reporter

type Rollup ¶

type Rollup string

const (
	RollupUndefined    Rollup = ""
	RollupWorker       Rollup = "worker"
	RollupWorkerSeries Rollup = "worker_series"
	RollupJob          Rollup = "job"
)

type WorkerReporter ¶

type WorkerReporter interface {
	RegisterFunc(func(ts time.Time, tx WorkerTx) bool)
	Tx(func(tx WorkerTx))
	TxAt(time.Time, func(tx WorkerTx))
	WithJob(id string) JobReporter
	WithDeferredJob() (JobReporter, KeyResolver)
	ReportCPU(v int64)
	ReportCPULimit(v int64)
	ReportMem(v int64)
	ReportMemLimit(v int64)
	ReportLoad(v float32)
	ReportStatus(v WorkerStatus)
	ReportRegion(v string)
	ReportVersion(v string)
	ReportSdkVersion(v string)
	ReportState(v WorkerState)
	ReportStartedAt(v time.Time)
	ReportJobsCurrent(v uint16)
	ReportKind(v AgentKind)
}

func NewNoopWorkerReporter ¶

func NewNoopWorkerReporter() WorkerReporter

type WorkerState ¶

type WorkerState string

const (
	WorkerStateUndefined WorkerState = ""
	WorkerStateOnline    WorkerState = "online"
	WorkerStateOffline   WorkerState = "offline"
)

type WorkerStatus ¶

type WorkerStatus string

const (
	WorkerStatusUndefined WorkerStatus = ""
	WorkerStatusAvailable WorkerStatus = "available"
	WorkerStatusFull      WorkerStatus = "full"
)

func WorkerStatusFromProto ¶

func WorkerStatusFromProto(status livekit.WorkerStatus) WorkerStatus

type WorkerTx ¶

type WorkerTx interface {
	ReportCPU(v int64)
	ReportCPULimit(v int64)
	ReportMem(v int64)
	ReportMemLimit(v int64)
	ReportLoad(v float32)
	ReportStatus(v WorkerStatus)
	ReportRegion(v string)
	ReportVersion(v string)
	ReportSdkVersion(v string)
	ReportState(v WorkerState)
	ReportStartedAt(v time.Time)
	ReportJobsCurrent(v uint16)
	ReportKind(v AgentKind)
}

Source Files ¶

View all Source files

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