Documentation
¶
Overview ¶
Package responseobserver composes the agent-side response-observation workflow.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type API ¶
type API interface {
RegisterSigningKey(context.Context, string, fleetagent.AgentSigningKey, string) error
ShipResponseVerification(context.Context, string, fleetagent.ResponseVerificationReport) (fleetclient.ResponseVerificationShipResponse, error)
Progress(context.Context, string, string, string) error
SubmitResult(context.Context, string, string, string, string, string) error
}
API is the fleet transport required by independent response observation.
type Runtime ¶
type Runtime struct {
// contains filtered or unexported fields
}
Runtime owns the concrete durable state and fleet adapters used by one agent process.
func New ¶
func New(store *fleetclient.CredentialStore, api API, delay time.Duration) (*Runtime, error)
New constructs the response-observation runtime using the system clock.
func NewWithClock ¶
func NewWithClock(store *fleetclient.CredentialStore, api API, delay time.Duration, clock ports.Clock) (*Runtime, error)
NewWithClock constructs the response-observation runtime with an injected clock for tests.
func (*Runtime) Observe ¶
func (r *Runtime) Observe(ctx context.Context, credential fleetclient.Credential, order fleetclient.Order) error
Observe executes one server-addressed response-observation order.
Source Files
Click to show internal directories.
Click to hide internal directories.