canary

Documentation

Index

• type Canary
  • func New(ctx context.Context, wg *sync.WaitGroup, config configuration.Config) (canary *Canary, err error)
  • func (this *Canary) GetMetricsHandler() (h http.Handler, err error)
  • func (this *Canary) ServeHTTP(writer http.ResponseWriter, request *http.Request)
  • func (this *Canary) StartTests()
• type CommandRequestMsg
• type CommandResponseMsg
• type Conn
• type DeviceInfo
• type Event
• type HubInfo
• type LastValue
• type OpenidToken
• type PermDevice
• type Process
• type ProtocolSegmentName
• type RequestEnvelope
• type ResponseEnvelope

Types

type Canary

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

func New

func New(ctx context.Context, wg *sync.WaitGroup, config configuration.Config) (canary *Canary, err error)

func (*Canary) GetMetricsHandler

func (this *Canary) GetMetricsHandler() (h http.Handler, err error)

func (*Canary) ServeHTTP

func (this *Canary) ServeHTTP(writer http.ResponseWriter, request *http.Request)

func (*Canary) StartTests

func (this *Canary) StartTests()

type CommandRequestMsg

type CommandRequestMsg = map[ProtocolSegmentName]string

type CommandResponseMsg

type CommandResponseMsg = map[ProtocolSegmentName]string

type Conn

type Conn struct {
	Client paho.Client
}

type DeviceInfo

type DeviceInfo = devicemetadata.DeviceInfo

type Event

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

type HubInfo

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

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

type OpenidToken

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

type PermDevice = devicemetadata.PermDevice

type Process

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

type ProtocolSegmentName

type ProtocolSegmentName = string

type RequestEnvelope

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

type ResponseEnvelope

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