mqtt

package
v0.0.0-...-d09eed2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 17, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultPort          = 1883
	DefaultWebsocketPort = 9001
	DefaultVersion       = "2.0.15"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Container

type Container struct {
	testcontainers.Container
}

func NewContainer

func NewContainer(ctx context.Context, opts ...RequestFn) (*Container, error)

func (*Container) Address

func (c *Container) Address(ctx context.Context) (string, error)

func (*Container) Broker

func (c *Container) Broker(ctx context.Context) (string, error)

func (*Container) Client

func (c *Container) Client(ctx context.Context) (paho.Client, error)

func (*Container) Stop

func (c *Container) Stop(ctx context.Context) error

type Request

type Request struct {
	testcontainers.ContainerRequest
	Config string
}

type RequestFn

type RequestFn func(*Request) *Request

func WithConfig

func WithConfig(path string) RequestFn

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL