v2

Nov 14, 2023

Changes in this version

+ const ApiVersion

+ const ServiceDiscoveryPathV2

+ type ServiceDiscoveryClientV2 struct

+ func NewServiceDiscoveryClientV2(url string) (*ServiceDiscoveryClientV2, error)

+ func (sds *ServiceDiscoveryClientV2) Get() (io.Reader, error)

+ func (sds *ServiceDiscoveryClientV2) GetHost() string

+ func (sds *ServiceDiscoveryClientV2) GetPath() string

+ func (sds *ServiceDiscoveryClientV2) GetScheme() string

+ func (sds *ServiceDiscoveryClientV2) GetServiceDiscoveryUrl() string

+ func (sds *ServiceDiscoveryClientV2) ParseResponse(response json.RawMessage) (schema.IBackendServices, error)

+ type ServiceDiscoveryFileV2 struct

+ func NewServiceDiscoveryFileV2(path string) *ServiceDiscoveryFileV2

+ func (s *ServiceDiscoveryFileV2) Get() (io.Reader, error)

+ func (s *ServiceDiscoveryFileV2) ParseResponse(response json.RawMessage) (schema.IBackendServices, error)

+ type ServiceDiscoveryServerV2 struct

+ func NewServiceDiscoveryServerV2(services ServicesV2) *ServiceDiscoveryServerV2

+ func (sds *ServiceDiscoveryServerV2) CacheResponse(response []byte)

+ func (sds *ServiceDiscoveryServerV2) GetCachedResponse() ([]byte, bool)

+ func (sds *ServiceDiscoveryServerV2) GetResponse() json.RawMessage

+ func (sds *ServiceDiscoveryServerV2) GetVersion() string

+ type ServiceDiscoveryStreamV2 struct

+ func NewServiceDiscoveryStreamV2(data []byte) *ServiceDiscoveryStreamV2

+ func (s *ServiceDiscoveryStreamV2) Get() (io.Reader, error)

+ func (s *ServiceDiscoveryStreamV2) ParseResponse(response json.RawMessage) (schema.IBackendServices, error)

+ type ServicesV2 struct

+ ApiServerUrl string

+ EventReceiverHttpUrl string

+ EventReceiverWebsocketUrl string

+ GatewayUrl string

+ MetricsUrl string

+ SynchronizerUrl string

+ func (s *ServicesV2) GetApiServerUrl() string

+ func (s *ServicesV2) GetGatewayUrl() string

+ func (s *ServicesV2) GetMetricsUrl() string

+ func (s *ServicesV2) GetReportReceiverHttpUrl() string

+ func (s *ServicesV2) GetReportReceiverWebsocketUrl() string

+ func (s *ServicesV2) GetSynchronizerUrl() string

+ func (s *ServicesV2) SetApiServerUrl(val string)

+ func (s *ServicesV2) SetGatewayUrl(val string)

+ func (s *ServicesV2) SetMetricsUrl(val string)

+ func (s *ServicesV2) SetReportReceiverHttpUrl(val string)

+ func (s *ServicesV2) SetReportReceiverWebsocketUrl(val string)

+ func (s *ServicesV2) SetSynchronizerUrl(val string)