Versions in this module Expand all Collapse all v0 v0.1.0 Aug 25, 2026 Changes in this version + func FromTemplate() runtime.Runtime + type Nerv struct + func (n *Nerv) SetDaemonRunning(status bool) + func (n *Nerv) StartCustomEvent(event *types.WorkloadEventMessage) + func (n *Nerv) StartEvents() + type Runtime struct + func NewRuntime(t interface{ ... }) *Runtime + func (_m *Runtime) EXPECT() *Runtime_Expecter + func (_mock *Runtime) AttachWorkload(ctx context.Context, ID string) (io.Reader, io.Reader, error) + func (_mock *Runtime) CollectWorkloadMetrics(ctx context.Context, ID string) + func (_mock *Runtime) Events(ctx context.Context, filters map[string]string) (<-chan *types.WorkloadEventMessage, <-chan error) + func (_mock *Runtime) GetStatus(ctx context.Context, ID string, checkHealth bool) (*types.WorkloadStatus, error) + func (_mock *Runtime) GetWorkloadName(ctx context.Context, ID string) (string, error) + func (_mock *Runtime) IsDaemonRunning(ctx context.Context) bool + func (_mock *Runtime) ListWorkloadIDs(ctx context.Context, filters map[string]string) ([]string, error) + func (_mock *Runtime) LogFieldsExtra(ctx context.Context, ID string) (map[string]string, error) + type Runtime_AttachWorkload_Call struct + func (_c *Runtime_AttachWorkload_Call) Return(reader io.Reader, reader1 io.Reader, err error) *Runtime_AttachWorkload_Call + func (_c *Runtime_AttachWorkload_Call) Run(run func(ctx context.Context, ID string)) *Runtime_AttachWorkload_Call + func (_c *Runtime_AttachWorkload_Call) RunAndReturn(run func(ctx context.Context, ID string) (io.Reader, io.Reader, error)) *Runtime_AttachWorkload_Call + type Runtime_CollectWorkloadMetrics_Call struct + func (_c *Runtime_CollectWorkloadMetrics_Call) Return() *Runtime_CollectWorkloadMetrics_Call + func (_c *Runtime_CollectWorkloadMetrics_Call) Run(run func(ctx context.Context, ID string)) *Runtime_CollectWorkloadMetrics_Call + func (_c *Runtime_CollectWorkloadMetrics_Call) RunAndReturn(run func(ctx context.Context, ID string)) *Runtime_CollectWorkloadMetrics_Call + type Runtime_Events_Call struct + func (_c *Runtime_Events_Call) Return(workloadEventMessageCh <-chan *types.WorkloadEventMessage, errCh <-chan error) *Runtime_Events_Call + func (_c *Runtime_Events_Call) Run(run func(ctx context.Context, filters map[string]string)) *Runtime_Events_Call + func (_c *Runtime_Events_Call) RunAndReturn(...) *Runtime_Events_Call + type Runtime_Expecter struct + func (_e *Runtime_Expecter) AttachWorkload(ctx any, ID any) *Runtime_AttachWorkload_Call + func (_e *Runtime_Expecter) CollectWorkloadMetrics(ctx any, ID any) *Runtime_CollectWorkloadMetrics_Call + func (_e *Runtime_Expecter) Events(ctx any, filters any) *Runtime_Events_Call + func (_e *Runtime_Expecter) GetStatus(ctx any, ID any, checkHealth any) *Runtime_GetStatus_Call + func (_e *Runtime_Expecter) GetWorkloadName(ctx any, ID any) *Runtime_GetWorkloadName_Call + func (_e *Runtime_Expecter) IsDaemonRunning(ctx any) *Runtime_IsDaemonRunning_Call + func (_e *Runtime_Expecter) ListWorkloadIDs(ctx any, filters any) *Runtime_ListWorkloadIDs_Call + func (_e *Runtime_Expecter) LogFieldsExtra(ctx any, ID any) *Runtime_LogFieldsExtra_Call + type Runtime_GetStatus_Call struct + func (_c *Runtime_GetStatus_Call) Return(workloadStatus *types.WorkloadStatus, err error) *Runtime_GetStatus_Call + func (_c *Runtime_GetStatus_Call) Run(run func(ctx context.Context, ID string, checkHealth bool)) *Runtime_GetStatus_Call + func (_c *Runtime_GetStatus_Call) RunAndReturn(...) *Runtime_GetStatus_Call + type Runtime_GetWorkloadName_Call struct + func (_c *Runtime_GetWorkloadName_Call) Return(s string, err error) *Runtime_GetWorkloadName_Call + func (_c *Runtime_GetWorkloadName_Call) Run(run func(ctx context.Context, ID string)) *Runtime_GetWorkloadName_Call + func (_c *Runtime_GetWorkloadName_Call) RunAndReturn(run func(ctx context.Context, ID string) (string, error)) *Runtime_GetWorkloadName_Call + type Runtime_IsDaemonRunning_Call struct + func (_c *Runtime_IsDaemonRunning_Call) Return(b bool) *Runtime_IsDaemonRunning_Call + func (_c *Runtime_IsDaemonRunning_Call) Run(run func(ctx context.Context)) *Runtime_IsDaemonRunning_Call + func (_c *Runtime_IsDaemonRunning_Call) RunAndReturn(run func(ctx context.Context) bool) *Runtime_IsDaemonRunning_Call + type Runtime_ListWorkloadIDs_Call struct + func (_c *Runtime_ListWorkloadIDs_Call) Return(strings []string, err error) *Runtime_ListWorkloadIDs_Call + func (_c *Runtime_ListWorkloadIDs_Call) Run(run func(ctx context.Context, filters map[string]string)) *Runtime_ListWorkloadIDs_Call + func (_c *Runtime_ListWorkloadIDs_Call) RunAndReturn(run func(ctx context.Context, filters map[string]string) ([]string, error)) *Runtime_ListWorkloadIDs_Call + type Runtime_LogFieldsExtra_Call struct + func (_c *Runtime_LogFieldsExtra_Call) Return(stringToString map[string]string, err error) *Runtime_LogFieldsExtra_Call + func (_c *Runtime_LogFieldsExtra_Call) Run(run func(ctx context.Context, ID string)) *Runtime_LogFieldsExtra_Call + func (_c *Runtime_LogFieldsExtra_Call) RunAndReturn(run func(ctx context.Context, ID string) (map[string]string, error)) *Runtime_LogFieldsExtra_Call