config

Documentation

Index

• Constants
• Variables
• func CreateJwtToken(t *testing.T, claims jwt.MapClaims) string
• func HubID() string
• func MakeAuthURL() string
• func MakeAuthorizationConfig() validator.Config
• func MakeDeviceAuthorization() oauth2.Config
• func MakeEventsStoreMongoDBConfig() mongodb.Config
• func MakeGrpcClientConfig(address string) grpcClient.Config
• func MakeGrpcServerConfig(address string) grpcServer.Config
• func MakeHttpClientConfig() httpClient.Config
• func MakeHttpServerConfig() httpServer.Config
• func MakeListenerConfig(address string) listener.Config
• func MakeLogConfig(t require.TestingT, envLogLevel, envLogDumpBody string) log.Config
• func MakeOpenTelemetryCollectorClient() otelClient.Config
• func MakePublisherConfig() natsClient.ConfigPublisher
• func MakeSubscriberConfig() natsClient.Config
• func MakeTLSClientConfig() client.Config
• func MakeTLSServerConfig() server.Config

Constants

const (
	IDENTITY_STORE_HOST             = "localhost:20000"
	IDENTITY_STORE_DB               = "ownersDevices"
	COAP_GW_HOST                    = "localhost:20002"
	RESOURCE_AGGREGATE_HOST         = "localhost:20003"
	RESOURCE_DIRECTORY_HOST         = "localhost:20004"
	CERTIFICATE_AUTHORITY_HOST      = "localhost:20011"
	CERTIFICATE_AUTHORITY_HTTP_HOST = "localhost:20012"
	GRPC_GW_HOST                    = "localhost:20005"
	C2C_CONNECTOR_HOST              = "localhost:20006"
	C2C_CONNECTOR_DB                = "cloud2cloudConnector"
	C2C_GW_HOST                     = "localhost:20007"
	C2C_GW_DB                       = "cloud2cloudGateway"
	OAUTH_SERVER_HOST               = "localhost:20009"
	TEST_TIMEOUT                    = time.Second * 30
	OAUTH_MANAGER_CLIENT_ID         = "test"
	OAUTH_MANAGER_AUDIENCE          = "localhost"
	HTTP_GW_HOST                    = "localhost:20010"
	DEVICE_PROVIDER                 = "plgd"
	OPENTELEMETRY_COLLECTOR_HOST    = "localhost:55690"
	TRUE_STRING                     = "true"
)

const DefaultGrpcMaxMsgSize = 1024 * 1024 * 128

const JWTSecret = "secret"

Variables

var (
	CA_POOL                  = os.Getenv("LISTEN_FILE_CA_POOL")
	KEY_FILE                 = os.Getenv("LISTEN_FILE_CERT_DIR_PATH") + "/" + os.Getenv("LISTEN_FILE_CERT_KEY_NAME")
	CERT_FILE                = os.Getenv("LISTEN_FILE_CERT_DIR_PATH") + "/" + os.Getenv("LISTEN_FILE_CERT_NAME")
	MONGODB_URI              = "mongodb://localhost:27017"
	NATS_URL                 = "nats://localhost:4222"
	OWNER_CLAIM              = "sub"
	COAP_GATEWAY_UDP_ENABLED = os.Getenv("TEST_COAP_GATEWAY_UDP_ENABLED") == TRUE_STRING
	ACTIVE_COAP_SCHEME       = func() string {
		if os.Getenv("TEST_COAP_GATEWAY_UDP_ENABLED") == TRUE_STRING {
			return string(schema.UDPSecureScheme)
		}
		return string(schema.TCPSecureScheme)
	}()
)

var (
	OAUTH_MANAGER_ENDPOINT_AUTHURL  = http.HTTPS_SCHEME + OAUTH_SERVER_HOST + uri.Authorize
	OAUTH_MANAGER_ENDPOINT_TOKENURL = http.HTTPS_SCHEME + OAUTH_SERVER_HOST + uri.Token
	C2C_CONNECTOR_EVENTS_URL        = http.HTTPS_SCHEME + C2C_CONNECTOR_HOST + c2curi.Events
	C2C_CONNECTOR_OAUTH_CALLBACK    = http.HTTPS_SCHEME + C2C_CONNECTOR_HOST + c2curi.OAuthCallback
)

Functions

func CreateJwtToken

func CreateJwtToken(t *testing.T, claims jwt.MapClaims) string

func HubID

func HubID() string

func MakeAuthURL

func MakeAuthURL() string

func MakeAuthorizationConfig

func MakeAuthorizationConfig() validator.Config

func MakeDeviceAuthorization

func MakeDeviceAuthorization() oauth2.Config

func MakeEventsStoreMongoDBConfig

func MakeEventsStoreMongoDBConfig() mongodb.Config

func MakeGrpcClientConfig

func MakeGrpcClientConfig(address string) grpcClient.Config

func MakeGrpcServerConfig

func MakeGrpcServerConfig(address string) grpcServer.Config

func MakeHttpClientConfig

func MakeHttpClientConfig() httpClient.Config

func MakeHttpServerConfig

func MakeHttpServerConfig() httpServer.Config

func MakeListenerConfig

func MakeListenerConfig(address string) listener.Config

func MakeLogConfig

func MakeLogConfig(t require.TestingT, envLogLevel, envLogDumpBody string) log.Config

func MakeOpenTelemetryCollectorClient

func MakeOpenTelemetryCollectorClient() otelClient.Config

func MakePublisherConfig

func MakePublisherConfig() natsClient.ConfigPublisher

func MakeSubscriberConfig

func MakeSubscriberConfig() natsClient.Config

func MakeTLSClientConfig

func MakeTLSClientConfig() client.Config

func MakeTLSServerConfig

func MakeTLSServerConfig() server.Config