v2

Documentation

Index

• Constants
• type ServiceDiscoveryClientV2
  • 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
  • func NewServiceDiscoveryFileV2(path string) *ServiceDiscoveryFileV2
  • func (s *ServiceDiscoveryFileV2) Get() (io.Reader, error)
  • func (s *ServiceDiscoveryFileV2) ParseResponse(response json.RawMessage) (schema.IBackendServices, error)
• type ServiceDiscoveryServerV2
  • 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
  • func NewServiceDiscoveryStreamV2(data []byte) *ServiceDiscoveryStreamV2
  • func (s *ServiceDiscoveryStreamV2) Get() (io.Reader, error)
  • func (s *ServiceDiscoveryStreamV2) ParseResponse(response json.RawMessage) (schema.IBackendServices, error)
• type ServicesV2
  • 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)

Constants

const (
	ServiceDiscoveryPathV2 = "/api/v2/servicediscovery"
	ApiVersion             = "v2"
)

Types

type ServiceDiscoveryClientV2

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

func NewServiceDiscoveryClientV2

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

func (*ServiceDiscoveryClientV2) Get

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

func (*ServiceDiscoveryClientV2) GetHost

func (sds *ServiceDiscoveryClientV2) GetHost() string

func (*ServiceDiscoveryClientV2) GetPath

func (sds *ServiceDiscoveryClientV2) GetPath() string

func (*ServiceDiscoveryClientV2) GetScheme

func (sds *ServiceDiscoveryClientV2) GetScheme() string

func (*ServiceDiscoveryClientV2) GetServiceDiscoveryUrl

func (sds *ServiceDiscoveryClientV2) GetServiceDiscoveryUrl() string

func (*ServiceDiscoveryClientV2) ParseResponse

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

type ServiceDiscoveryFileV2

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

func NewServiceDiscoveryFileV2

func NewServiceDiscoveryFileV2(path string) *ServiceDiscoveryFileV2

func (*ServiceDiscoveryFileV2) Get

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

func (*ServiceDiscoveryFileV2) ParseResponse

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

type ServiceDiscoveryServerV2

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

func NewServiceDiscoveryServerV2

func NewServiceDiscoveryServerV2(services ServicesV2) *ServiceDiscoveryServerV2

func (*ServiceDiscoveryServerV2) CacheResponse

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

func (*ServiceDiscoveryServerV2) GetCachedResponse

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

func (*ServiceDiscoveryServerV2) GetResponse

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

func (*ServiceDiscoveryServerV2) GetVersion

func (sds *ServiceDiscoveryServerV2) GetVersion() string

type ServiceDiscoveryStreamV2

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

func NewServiceDiscoveryStreamV2

func NewServiceDiscoveryStreamV2(data []byte) *ServiceDiscoveryStreamV2

func (*ServiceDiscoveryStreamV2) Get

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

func (*ServiceDiscoveryStreamV2) ParseResponse

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

type ServicesV2

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

	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"`
	SynchronizerUrl           string `json:"synchronizer"`
}

func (*ServicesV2) GetApiServerUrl

func (s *ServicesV2) GetApiServerUrl() string

func (*ServicesV2) GetGatewayUrl

func (s *ServicesV2) GetGatewayUrl() string

func (*ServicesV2) GetMetricsUrl

func (s *ServicesV2) GetMetricsUrl() string

func (*ServicesV2) GetReportReceiverHttpUrl

func (s *ServicesV2) GetReportReceiverHttpUrl() string

func (*ServicesV2) GetReportReceiverWebsocketUrl

func (s *ServicesV2) GetReportReceiverWebsocketUrl() string

func (*ServicesV2) GetSynchronizerUrl

func (s *ServicesV2) GetSynchronizerUrl() string

func (*ServicesV2) SetApiServerUrl

func (s *ServicesV2) SetApiServerUrl(val string)

func (*ServicesV2) SetGatewayUrl

func (s *ServicesV2) SetGatewayUrl(val string)

func (*ServicesV2) SetMetricsUrl

func (s *ServicesV2) SetMetricsUrl(val string)

func (*ServicesV2) SetReportReceiverHttpUrl

func (s *ServicesV2) SetReportReceiverHttpUrl(val string)

func (*ServicesV2) SetReportReceiverWebsocketUrl

func (s *ServicesV2) SetReportReceiverWebsocketUrl(val string)

func (*ServicesV2) SetSynchronizerUrl

func (s *ServicesV2) SetSynchronizerUrl(val string)