docker

Documentation

Index

• Constants
• Variables
• func DeviceManager(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, deviceRepoUrl string, ...) (hostPort string, ipAddress string, err error)
• func DeviceManagerWithDependencies(basectx context.Context, wg *sync.WaitGroup) (managerUrl string, repoUrl string, permv2Url string, err error)
• func DeviceManagerWithDependenciesAndKafka(basectx context.Context, wg *sync.WaitGroup) (kafkaUrl string, managerUrl string, repoUrl string, permv2Url string, ...)
• func DeviceRepo(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, mongoUrl string, ...) (hostPort string, ipAddress string, err error)
• func Keycloak(ctx context.Context, wg *sync.WaitGroup) (authEndpoint string, err error)
• func MongoDB(ctx context.Context, wg *sync.WaitGroup) (hostport string, containerip string, err error)
• func Mqtt(ctx context.Context, wg *sync.WaitGroup) (hostPort string, ipAddress string, err error)
• func PermissionsV2(ctx context.Context, wg *sync.WaitGroup, mongoUrl string, kafkaUrl string) (hostPort string, ipAddress string, err error)
• type OpenidToken

Constants

const AdminTestToken = "" /* 1527-byte string literal not displayed */

const TestToken = "" /* 1942-byte string literal not displayed */

const UserTestToken = "" /* 1499-byte string literal not displayed */

Variables

var Kafka = docker.Kafka

var Zookeeper = docker.Zookeeper

Functions

func DeviceManager

func DeviceManager(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, deviceRepoUrl string, permv2Url string) (hostPort string, ipAddress string, err error)

func DeviceManagerWithDependencies

func DeviceManagerWithDependencies(basectx context.Context, wg *sync.WaitGroup) (managerUrl string, repoUrl string, permv2Url string, err error)

func DeviceManagerWithDependenciesAndKafka

func DeviceManagerWithDependenciesAndKafka(basectx context.Context, wg *sync.WaitGroup) (kafkaUrl string, managerUrl string, repoUrl string, permv2Url string, err error)

func DeviceRepo

func DeviceRepo(ctx context.Context, wg *sync.WaitGroup, kafkaUrl string, mongoUrl string, permv2Url string) (hostPort string, ipAddress string, err error)

func Keycloak

func Keycloak(ctx context.Context, wg *sync.WaitGroup) (authEndpoint string, err error)

func MongoDB

func MongoDB(ctx context.Context, wg *sync.WaitGroup) (hostport string, containerip string, err error)

func Mqtt

func Mqtt(ctx context.Context, wg *sync.WaitGroup) (hostPort string, ipAddress string, err error)

func PermissionsV2

func PermissionsV2(ctx context.Context, wg *sync.WaitGroup, mongoUrl string, kafkaUrl string) (hostPort string, ipAddress string, err error)

Types

type OpenidToken

type OpenidToken struct {
	AccessToken      string    `json:"access_token"`
	ExpiresIn        float64   `json:"expires_in"`
	RefreshExpiresIn float64   `json:"refresh_expires_in"`
	RefreshToken     string    `json:"refresh_token"`
	TokenType        string    `json:"token_type"`
	RequestTime      time.Time `json:"-"`
}