whippet

Documentation

Index

• func Connect(ctx context.Context, config Config, logger *slog.Logger) (*paho.Client, chan *paho.Publish, error)
• func Request(ctx context.Context, client *paho.Client, config Config, payload []byte, ...) ([]byte, error)
• type Config
  • func GetConfig(args []string) (Config, bool, error)

Functions

func Connect

func Connect(ctx context.Context, config Config, logger *slog.Logger) (*paho.Client, chan *paho.Publish, error)

func Request

func Request(ctx context.Context, client *paho.Client, config Config, payload []byte, msgCh chan *paho.Publish, logger *slog.Logger) ([]byte, error)

Types

type Config

type Config struct {
	Server      string
	PublishTo   string
	SubscribeTo string
	Qos         int
	Retained    bool
	ClientID    string
	Username    string
	Password    string
	Timeout     time.Duration
}

func GetConfig

func GetConfig(args []string) (Config, bool, error)