aws

Documentation

Index

• type AwsConfiguration
• type AwsConnectorSettings
  • func (s *AwsConnectorSettings) AttachAccessPolicy(ctx context.Context, caName string, caSerialNumber string, ...) error
  • func (s *AwsConnectorSettings) GetConfiguration(ctx context.Context) (interface{}, []cloudproviders.CloudProviderCAConfig, error)
  • func (s *AwsConnectorSettings) GetDeviceConfiguration(ctx context.Context, deviceID string) (interface{}, error)
  • func (s *AwsConnectorSettings) RegisterCA(ctx context.Context, caName string, caSerialNumber string, ...) error
  • func (s *AwsConnectorSettings) UpdateCaStatus(ctx context.Context, caName string, status string, certificateID string) error
  • func (s *AwsConnectorSettings) UpdateCertStatus(ctx context.Context, caName string, certSerialNumber string, status string, ...) error
• type AwsService
  • func NewAwsConnectorClient(id string, ip string, port string, logger log.Logger) AwsService
• type IotCoreCAConfig
• type IotCoreConfig

Types

type AwsConfiguration

type AwsConfiguration struct {
	AccountID string        `json:"account_id"`
	IotCore   IotCoreConfig `json:"iot_core"`
}

type AwsConnectorSettings

type AwsConnectorSettings struct {
	ID   string
	IP   string
	Port string
	// contains filtered or unexported fields
}

func (*AwsConnectorSettings) AttachAccessPolicy

func (s *AwsConnectorSettings) AttachAccessPolicy(ctx context.Context, caName string, caSerialNumber string, serializedAccessPolicy string) error

func (*AwsConnectorSettings) GetConfiguration

func (s *AwsConnectorSettings) GetConfiguration(ctx context.Context) (interface{}, []cloudproviders.CloudProviderCAConfig, error)

func (*AwsConnectorSettings) GetDeviceConfiguration

func (s *AwsConnectorSettings) GetDeviceConfiguration(ctx context.Context, deviceID string) (interface{}, error)

func (*AwsConnectorSettings) RegisterCA

func (s *AwsConnectorSettings) RegisterCA(ctx context.Context, caName string, caSerialNumber string, caCertificate string) error

func (*AwsConnectorSettings) UpdateCaStatus

func (s *AwsConnectorSettings) UpdateCaStatus(ctx context.Context, caName string, status string, certificateID string) error

func (*AwsConnectorSettings) UpdateCertStatus

func (s *AwsConnectorSettings) UpdateCertStatus(ctx context.Context, caName string, certSerialNumber string, status string, deviceCert string, caCert string) error

type AwsService

type AwsService interface {
	RegisterCA(ctx context.Context, caName string, caSerialNumber string, caCertificate string) error
	AttachAccessPolicy(ctx context.Context, caName string, caSerialNumber string, serializedAccessPolicy string) error
	GetConfiguration(ctx context.Context) (interface{}, []cloudproviders.CloudProviderCAConfig, error)
	GetDeviceConfiguration(ctx context.Context, deviceID string) (interface{}, error)
	UpdateCertStatus(ctx context.Context, caName string, certSerialNumber string, status string, deviceCert string, caCert string) error
	UpdateCaStatus(ctx context.Context, caName string, status string, certificateID string) error
}

func NewAwsConnectorClient

func NewAwsConnectorClient(id string, ip string, port string, logger log.Logger) AwsService

type IotCoreCAConfig

type IotCoreCAConfig struct {
	ID               string `json:"id"`
	ARN              string `json:"arn"`
	RegistrationDate string `json:"registration_date"`
	ActivePolicy     string `json:"active_policy"`
}

type IotCoreConfig

type IotCoreConfig struct {
	Endpoint string          `json:"endpoint"`
	CA       IotCoreCAConfig `json:"ca"`
}