v3

package
v0.0.39 Latest Latest
Warning

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

Go to latest
Published: Mar 19, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ServiceDiscoveryPathV3 = "/api/v3/servicediscovery"
	ApiVersion             = "v3"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ServiceDiscoveryClientV3

type ServiceDiscoveryClientV3 struct {
	// contains filtered or unexported fields
}

func NewServiceDiscoveryClientV3

func NewServiceDiscoveryClientV3(url string) (*ServiceDiscoveryClientV3, error)

func (*ServiceDiscoveryClientV3) Get

func (sds *ServiceDiscoveryClientV3) Get() (io.Reader, error)

func (*ServiceDiscoveryClientV3) GetHost

func (sds *ServiceDiscoveryClientV3) GetHost() string

func (*ServiceDiscoveryClientV3) GetPath

func (sds *ServiceDiscoveryClientV3) GetPath() string

func (*ServiceDiscoveryClientV3) GetScheme

func (sds *ServiceDiscoveryClientV3) GetScheme() string

func (*ServiceDiscoveryClientV3) GetServiceDiscoveryUrl

func (sds *ServiceDiscoveryClientV3) GetServiceDiscoveryUrl() string

func (*ServiceDiscoveryClientV3) ParseResponse

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

type ServiceDiscoveryFileV3

type ServiceDiscoveryFileV3 struct {
	// contains filtered or unexported fields
}

func NewServiceDiscoveryFileV3

func NewServiceDiscoveryFileV3(path string) *ServiceDiscoveryFileV3

func (*ServiceDiscoveryFileV3) Get

func (s *ServiceDiscoveryFileV3) Get() (io.Reader, error)

func (*ServiceDiscoveryFileV3) ParseResponse

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

type ServiceDiscoveryServerV3

type ServiceDiscoveryServerV3 struct {
	// contains filtered or unexported fields
}

func NewServiceDiscoveryServerV3

func NewServiceDiscoveryServerV3(services ServicesV3) *ServiceDiscoveryServerV3

func (*ServiceDiscoveryServerV3) CacheResponse

func (sds *ServiceDiscoveryServerV3) CacheResponse(response []byte)

func (*ServiceDiscoveryServerV3) GetCachedResponse

func (sds *ServiceDiscoveryServerV3) GetCachedResponse() ([]byte, bool)

func (*ServiceDiscoveryServerV3) GetResponse

func (sds *ServiceDiscoveryServerV3) GetResponse() json.RawMessage

func (*ServiceDiscoveryServerV3) GetVersion

func (sds *ServiceDiscoveryServerV3) GetVersion() string

type ServiceDiscoveryStreamV3

type ServiceDiscoveryStreamV3 struct {
	// contains filtered or unexported fields
}

func NewServiceDiscoveryStreamV3

func NewServiceDiscoveryStreamV3(data []byte) *ServiceDiscoveryStreamV3

func (*ServiceDiscoveryStreamV3) Get

func (*ServiceDiscoveryStreamV3) ParseResponse

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

type ServicesV3

type ServicesV3 struct {
	schema.IBackendServices `json:"-"`

	EventReceiverHttpUrl string `json:"event-receiver-http"`
	ApiServerUrl         string `json:"api-server"`
	MetricsUrl           string `json:"metrics"`
	SynchronizerUrl      string `json:"synchronizer"`
	StorageUrl           string `json:"storage"`
}

func (*ServicesV3) GetApiServerUrl

func (s *ServicesV3) GetApiServerUrl() string

func (*ServicesV3) GetGatewayUrl

func (s *ServicesV3) GetGatewayUrl() string

deprecated

func (*ServicesV3) GetMetricsUrl

func (s *ServicesV3) GetMetricsUrl() string

func (*ServicesV3) GetReportReceiverHttpUrl

func (s *ServicesV3) GetReportReceiverHttpUrl() string

func (*ServicesV3) GetReportReceiverWebsocketUrl

func (s *ServicesV3) GetReportReceiverWebsocketUrl() string

deprecated

func (*ServicesV3) GetStorageUrl added in v0.0.31

func (s *ServicesV3) GetStorageUrl() string

func (*ServicesV3) GetSynchronizerUrl

func (s *ServicesV3) GetSynchronizerUrl() string

func (*ServicesV3) SetApiServerUrl

func (s *ServicesV3) SetApiServerUrl(val string)

func (*ServicesV3) SetGatewayUrl

func (s *ServicesV3) SetGatewayUrl(val string)

deprecated

func (*ServicesV3) SetMetricsUrl

func (s *ServicesV3) SetMetricsUrl(val string)

func (*ServicesV3) SetReportReceiverHttpUrl

func (s *ServicesV3) SetReportReceiverHttpUrl(val string)

func (*ServicesV3) SetReportReceiverWebsocketUrl

func (s *ServicesV3) SetReportReceiverWebsocketUrl(val string)

deprecated

func (*ServicesV3) SetStorageUrl added in v0.0.31

func (s *ServicesV3) SetStorageUrl(val string)

func (*ServicesV3) SetSynchronizerUrl

func (s *ServicesV3) SetSynchronizerUrl(val string)

Jump to

Keyboard shortcuts

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