device

type Connection interface {
	Send(interchange.DeviceMessage) error
	Receive() (io.Reader, error)
	GetID() string
	Close() error
}

type FeedbackStore interface {
	LogFeedback(interchange.FeedbackMessage) error
	ListFeedback(string, int) ([]interchange.FeedbackMessage, error)
}

type Index interface {
	RemoveDevice(string) error
	FindDevice(string) (RegistrationDetails, error)
}

type RedisRegistry struct {
	*logging.Logger
	*redis.Pool
	TokenGenerator
}

type RegistrationDetails struct {
	SharedSecret string `json:"-"`
	Name         string `json:"name"`
	DeviceID     string `json:"device_id"`
}

type RegistrationRequest struct {
	SharedSecret string `json:"-"`
	Name         string `json:"name"`
}

type RegistrationStream chan Connection

type Registry interface {
	Index
	ListRegistrations() ([]RegistrationDetails, error)
	FillRegistration(string, string) error
	AllocateRegistration(RegistrationRequest) error
}

type StreamerConnection struct {
	logging.LeveledLogger
	defs.Streamer
	defs.Signer
	// contains filtered or unexported fields
}

type TokenDetails struct {
	TokenID    string `json:"token_id"`
	DeviceID   string `json:"device_id"`
	Token      string `json:"token"`
	Name       string `json:"name"`
	Permission uint   `json:"permission"`
}

type TokenGenerator interface {
	GenerateToken() (string, error)
}

type TokenStore interface {
	CreateToken(string, string, uint) (TokenDetails, error)
	ListTokens(string) ([]TokenDetails, error)
	AuthorizeToken(string, string, uint) bool
}