mqtt

Documentation

Index

• type MQTTTargetProvider
  • func (i *MQTTTargetProvider) Apply(ctx context.Context, deployment model.DeploymentSpec, ...) (map[string]model.ComponentResultSpec, error)
  • func (i *MQTTTargetProvider) Get(ctx context.Context, deployment model.DeploymentSpec, ...) ([]model.ComponentSpec, error)
  • func (*MQTTTargetProvider) GetValidationRule(ctx context.Context) model.ValidationRule
  • func (i *MQTTTargetProvider) Init(config providers.IProviderConfig) error
  • func (i *MQTTTargetProvider) InitWithMap(properties map[string]string) error
  • func (i *MQTTTargetProvider) Remove(ctx context.Context, deployment model.DeploymentSpec, ...) error
  • func (s *MQTTTargetProvider) SetContext(ctx *contexts.ManagerContext)
• type MQTTTargetProviderConfig
  • func MQTTTargetProviderConfigFromMap(properties map[string]string) (MQTTTargetProviderConfig, error)
• type ProxyResponse
• type TwoComponentSlices

Types

type MQTTTargetProvider

type MQTTTargetProvider struct {
	Config        MQTTTargetProviderConfig
	Context       *contexts.ManagerContext
	MQTTClient    gmqtt.Client
	ResponseChans sync.Map
	Initialized   bool
}

func (*MQTTTargetProvider) Apply

func (i *MQTTTargetProvider) Apply(ctx context.Context, deployment model.DeploymentSpec, step model.DeploymentStep, isDryRun bool) (map[string]model.ComponentResultSpec, error)

func (*MQTTTargetProvider) Get

func (i *MQTTTargetProvider) Get(ctx context.Context, deployment model.DeploymentSpec, references []model.ComponentStep) ([]model.ComponentSpec, error)

func (*MQTTTargetProvider) GetValidationRule

func (*MQTTTargetProvider) GetValidationRule(ctx context.Context) model.ValidationRule

func (*MQTTTargetProvider) Init

func (i *MQTTTargetProvider) Init(config providers.IProviderConfig) error

func (*MQTTTargetProvider) InitWithMap

func (i *MQTTTargetProvider) InitWithMap(properties map[string]string) error

func (*MQTTTargetProvider) Remove

func (i *MQTTTargetProvider) Remove(ctx context.Context, deployment model.DeploymentSpec, currentRef []model.ComponentSpec) error

func (*MQTTTargetProvider) SetContext

func (s *MQTTTargetProvider) SetContext(ctx *contexts.ManagerContext)

type MQTTTargetProviderConfig

type MQTTTargetProviderConfig struct {
	Name               string `json:"name"`
	BrokerAddress      string `json:"brokerAddress"`
	ClientID           string `json:"clientID"`
	RequestTopic       string `json:"requestTopic"`
	ResponseTopic      string `json:"responseTopic"`
	TimeoutSeconds     int    `json:"timeoutSeconds,omitempty"`
	KeepAliveSeconds   int    `json:"keepAliveSeconds,omitempty"`
	PingTimeoutSeconds int    `json:"pingTimeoutSeconds,omitempty"`
}

func MQTTTargetProviderConfigFromMap

func MQTTTargetProviderConfigFromMap(properties map[string]string) (MQTTTargetProviderConfig, error)

type ProxyResponse

type ProxyResponse struct {
	IsOK    bool
	State   v1alpha2.State
	Payload interface{}
}

type TwoComponentSlices

type TwoComponentSlices struct {
	Current []model.ComponentSpec `json:"current"`
	Desired []model.ComponentSpec `json:"desired"`
}