Versions in this module Expand all Collapse all v0 v0.4.0 Apr 21, 2026 v0.3.0 Jun 11, 2025 Changes in this version + const PubTopic + const SubTopic v0.2.0 Feb 7, 2025 Changes in this version + type HTTPProxyConfig struct + Authenticate bool + ChunkSize int + Password string + RegistryURL string + Token string + Username string + func (c *HTTPProxyConfig) FetchFromReg(ctx context.Context, containerPath string, chunkSize int) ([]proplet.ChunkPayload, error) + type MQTTProxyConfig struct + BrokerURL string + ChannelID string + Password string + PropletID string + type ProxyService struct + func NewService(ctx context.Context, mqttCfg *MQTTProxyConfig, httpCfg *HTTPProxyConfig, ...) (*ProxyService, error) + func (s *ProxyService) ContainerChan() chan string + func (s *ProxyService) MQTTClient() *RegistryClient + func (s *ProxyService) StreamHTTP(ctx context.Context) error + func (s *ProxyService) StreamMQTT(ctx context.Context) error + type RegistryClient struct + func NewMQTTClient(cfg *MQTTProxyConfig) (*RegistryClient, error) + func (c *RegistryClient) Connect(ctx context.Context) error + func (c *RegistryClient) Disconnect(ctx context.Context) error + func (c *RegistryClient) PublishContainer(ctx context.Context, chunk proplet.ChunkPayload) error + func (c *RegistryClient) Subscribe(ctx context.Context, containerChan chan<- string) error
Go to main page