canary

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

type CommandRequestMsg = map[ProtocolSegmentName]string

type CommandResponseMsg = map[ProtocolSegmentName]string

type Conn struct {
	Client paho.Client
}

type DeviceInfo = devicemetadata.DeviceInfo

type Event interface {
	ProcessStartup(token string, info DeviceInfo) error
	ProcessTeardown(token string) error
}

type HubInfo struct {
	Id             string   `json:"id"`
	Name           string   `json:"name"`
	DeviceIds      []string `json:"device_ids,omitempty"`
	DeviceLocalIds []string `json:"device_local_ids,omitempty"`
}

type LastValue struct {
	Time  string      `json:"time"`
	Value interface{} `json:"value"`
}

type OpenidToken struct {
	AccessToken      string    `json:"access_token"`
	ExpiresIn        float64   `json:"expires_in"`
	RefreshExpiresIn float64   `json:"refresh_expires_in"`
	RefreshToken     string    `json:"refresh_token"`
	TokenType        string    `json:"token_type"`
	RequestTime      time.Time `json:"-"`
}

type PermDevice = devicemetadata.PermDevice

type Process interface {
	NotifyCommand(topic string, payload []byte) error
	ProcessStartup(token string, info DeviceInfo) error
	ProcessTeardown(token string) error
}

type ProtocolSegmentName = string

type RequestEnvelope struct {
	CorrelationId      string            `json:"correlation_id"`
	Payload            CommandRequestMsg `json:"payload"`
	Time               int64             `json:"timestamp"`
	CompletionStrategy string            `json:"completion_strategy"`
}

type ResponseEnvelope struct {
	CorrelationId string             `json:"correlation_id"`
	Payload       CommandResponseMsg `json:"payload"`
}