service

type Config struct {
	Address                  string             `envconfig:"ADDRESS"`
	Listen                   certManager.Config `envconfig:"LISTEN"`
	Dial                     certManager.Config `envconfig:"DIAL"`
	JwksURL                  string             `envconfig:"JWKS_URL"`
	ResourceDirectoryAddr    string             `envconfig:"RESOURCE_DIRECTORY_ADDRESS"`
	CertificateAuthorityAddr string             `envconfig:"CERTIFICATE_AUTHORITY_ADDRESS"`
	WebSocketReadLimit       int64              `envconfig:"WEBSOCKET_READ_LIMIT"`
	WebSocketReadTimeout     time.Duration      `envconfig:"WEBSOCKET_READ_TIMEOUT"`
}

type Device struct {
	Device schema.Device `json:"device"`
	Status Status        `json:"status"`
}

type DeviceEvent struct {
	DeviceIDs []string `json:"deviceIds"`
	Status    string   `json:"status"`
}

type DeviceResourceObservationEvent struct {
	Resources []schema.ResourceLink `json:"resources"`
	Event     string                `json:"event"`
}

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

type ObservationResolver interface {
	StartObservation(r *http.Request, ws *websocket.Conn, accessToken string) (SubscribeSession, error)
	StopObservation(subscriptionID string) error
}

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

type RetrieveDeviceWithLinksResponse struct {
	Device
	Links []schema.ResourceLink `json:"links"`
}

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

type Status string

type SubscribeSession interface {
	ClientId() string
	SubscriptionId() string
	SetSubscriptionId(id string)
	Write(data interface{})
	ReadLoop(rh *RequestHandler, ob ObservationResolver)
	WriteLoop()
	OnClose()
}

type TokenMessage struct {
	Token string `json:"token"`
}