server

type Config struct {
	Store              sessionstore.Store
	Issuer             auth.Issuer
	Verifier           auth.Verifier
	Integration        integrationv1.Document
	RequestIdentity    RequestIdentity
	Readiness          func(context.Context) error
	LeaseDuration      time.Duration
	Heartbeat          time.Duration
	StreamDuration     time.Duration
	StreamHeartbeat    time.Duration
	StreamWriteTimeout time.Duration
}

type DeviceExecutor interface {
	FrameProducer
	Execute(context.Context, string, json.RawMessage) error
}

type DriverExecutor struct{ Driver device.Driver }

type Frame struct {
	Content     []byte
	ContentType string
	Orientation string
	Width       int
	Height      int
}

type FrameProducer interface {
	CaptureFrame(context.Context) (Frame, error)
}

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

type RequestIdentity func(*http.Request) (certificateFingerprint, channelBindingSHA256 string, err error)

type RuntimeConfig struct {
	Address   string
	TLSConfig *tls.Config
	Handler   http.Handler
	Listener  net.Listener
	Started   func()
}

type Worker struct {
	NodeLease        sessionstore.NodeLease
	Store            WorkerStore
	Executors        map[string]DeviceExecutor
	PollInterval     time.Duration
	ClaimDuration    time.Duration
	ExecutionTimeout time.Duration
	Now              func() time.Time
}

type WorkerStore interface {
	ClaimFrame(context.Context, sessionstore.NodeLease, time.Duration) (sessionstore.FrameWork, error)
	CompleteFrame(context.Context, sessionstore.FrameWork, sessionstore.FrameData) error
	FailFrame(context.Context, sessionstore.FrameWork, string, bool, string) error
	ClaimInput(context.Context, sessionstore.NodeLease, time.Duration) (sessionstore.InputWork, error)
	StartInput(context.Context, sessionstore.InputWork) error
	CompleteInput(context.Context, sessionstore.InputWork, string, time.Duration, *sessionstore.ExecutionFailure) error
	WaitInputActive(context.Context, sessionstore.InputWork, time.Duration) (bool, error)
	WaitForWork(context.Context, string, time.Duration) error
}