v1

package
v0.0.13 Latest Latest
Warning

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

Go to latest
Published: Oct 26, 2023 License: Apache-2.0 Imports: 9 Imported by: 4

Documentation

Index

Constants

View Source
const (
	ServiceDiscoveryPathV1 = "/api/v1/servicediscovery"
	ApiVersion             = "v1"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ServiceDiscoveryClientV1

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

func NewServiceDiscoveryClientV1

func NewServiceDiscoveryClientV1(url string) (*ServiceDiscoveryClientV1, error)

func (*ServiceDiscoveryClientV1) Get

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

func (*ServiceDiscoveryClientV1) GetHost

func (sds *ServiceDiscoveryClientV1) GetHost() string

func (*ServiceDiscoveryClientV1) GetPath

func (sds *ServiceDiscoveryClientV1) GetPath() string

func (*ServiceDiscoveryClientV1) GetScheme

func (sds *ServiceDiscoveryClientV1) GetScheme() string

func (*ServiceDiscoveryClientV1) GetServiceDiscoveryUrl

func (sds *ServiceDiscoveryClientV1) GetServiceDiscoveryUrl() string

func (*ServiceDiscoveryClientV1) ParseResponse

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

type ServiceDiscoveryFileV1

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

func NewServiceDiscoveryFileV1

func NewServiceDiscoveryFileV1(path string) *ServiceDiscoveryFileV1

func (*ServiceDiscoveryFileV1) Get

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

func (*ServiceDiscoveryFileV1) ParseResponse

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

type ServiceDiscoveryServerV1

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

func NewServiceDiscoveryServerV1

func NewServiceDiscoveryServerV1(services ServicesV1) *ServiceDiscoveryServerV1

func (*ServiceDiscoveryServerV1) CacheResponse

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

func (*ServiceDiscoveryServerV1) GetCachedResponse

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

func (*ServiceDiscoveryServerV1) GetResponse

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

func (*ServiceDiscoveryServerV1) GetVersion

func (sds *ServiceDiscoveryServerV1) GetVersion() string

type ServiceDiscoveryStreamV1 added in v0.0.2

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

func NewServiceDiscoveryStreamV1 added in v0.0.2

func NewServiceDiscoveryStreamV1(data []byte) *ServiceDiscoveryStreamV1

func (*ServiceDiscoveryStreamV1) Get added in v0.0.2

func (*ServiceDiscoveryStreamV1) ParseResponse added in v0.0.2

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

type ServicesV1

type ServicesV1 struct {
	EventReceiverHttpUrl      string `json:"event-receiver-http"`
	EventReceiverWebsocketUrl string `json:"event-receiver-ws"`
	GatewayUrl                string `json:"gateway"`
	ApiServerUrl              string `json:"api-server"`
	MetricsUrl                string `json:"metrics"`
}

func (*ServicesV1) GetApiServerUrl

func (s *ServicesV1) GetApiServerUrl() string

func (*ServicesV1) GetGatewayUrl

func (s *ServicesV1) GetGatewayUrl() string

func (*ServicesV1) GetMetricsUrl

func (s *ServicesV1) GetMetricsUrl() string

func (*ServicesV1) GetReportReceiverHttpUrl

func (s *ServicesV1) GetReportReceiverHttpUrl() string

func (*ServicesV1) GetReportReceiverWebsocketUrl

func (s *ServicesV1) GetReportReceiverWebsocketUrl() string

func (*ServicesV1) SetApiServerUrl

func (s *ServicesV1) SetApiServerUrl(val string)

func (*ServicesV1) SetGatewayUrl

func (s *ServicesV1) SetGatewayUrl(val string)

func (*ServicesV1) SetMetricsUrl

func (s *ServicesV1) SetMetricsUrl(val string)

func (*ServicesV1) SetReportReceiverHttpUrl

func (s *ServicesV1) SetReportReceiverHttpUrl(val string)

func (*ServicesV1) SetReportReceiverWebsocketUrl

func (s *ServicesV1) SetReportReceiverWebsocketUrl(val string)

Jump to

Keyboard shortcuts

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