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 ¶
View Source
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" )
View Source
const DefaultGrpcMaxMsgSize = 1024 * 1024 * 128
View Source
const JWTSecret = "secret"
Variables ¶
View Source
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) }() )
View Source
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 MakeAuthURL ¶
func MakeAuthURL() string
func MakeAuthorizationConfig ¶
func MakeDeviceAuthorization ¶
func MakeGrpcClientConfig ¶
func MakeGrpcClientConfig(address string) grpcClient.Config
func MakeGrpcServerConfig ¶
func MakeGrpcServerConfig(address string) grpcServer.Config
func MakeHttpClientConfig ¶
func MakeHttpClientConfig() httpClient.Config
func MakeHttpServerConfig ¶ added in v2.4.6
func MakeHttpServerConfig() httpServer.Config
func MakeListenerConfig ¶
func MakeLogConfig ¶ added in v2.7.5
func MakeOpenTelemetryCollectorClient ¶ added in v2.4.0
func MakeOpenTelemetryCollectorClient() otelClient.Config
func MakePublisherConfig ¶
func MakePublisherConfig() natsClient.ConfigPublisher
func MakeSubscriberConfig ¶
func MakeSubscriberConfig() natsClient.Config
func MakeTLSClientConfig ¶
func MakeTLSServerConfig ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.