e2e

Documentation

Index

• Constants
• type Broker
  • func NewBroker(brokerURL string) (*Broker, error)
  • func (b *Broker) PublishPingOneV2(ppm v2.ProposalPingMessage) error
  • func (b *Broker) PublishPingV2(ppm []v2.ProposalPingMessage) error
  • func (b *Broker) PublishUnregisterOneV2(pum v2.ProposalUnregisterMessage) error
• type Query

Constants

const (
	DBdsn           = "postgresql://discovery:discovery@localhost:5432/discovery"
	BrokerURL       = "nats://localhost"
	DockerFile      = "e2e/docker-compose.yml"
	DiscoveryAPIurl = "http://localhost:8080"
	QualityAPIUrl   = "http://localhost:8004"
)

Types

type Broker

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

func NewBroker

func NewBroker(brokerURL string) (*Broker, error)

func (*Broker) PublishPingOneV2

func (b *Broker) PublishPingOneV2(ppm v2.ProposalPingMessage) error

func (*Broker) PublishPingV2

func (b *Broker) PublishPingV2(ppm []v2.ProposalPingMessage) error

func (*Broker) PublishUnregisterOneV2

func (b *Broker) PublishUnregisterOneV2(pum v2.ProposalUnregisterMessage) error

type Query

type Query struct {
	From                    string  `url:"from"`
	ProviderID              string  `url:"provider_id"`
	ServiceType             string  `url:"service_type"`
	Country                 string  `url:"location_country"`
	IPType                  string  `url:"ip_type"`
	AccessPolicy            string  `url:"access_policy"`
	AccessPolicySource      string  `url:"access_policy_source"`
	PriceGibMax             int64   `url:"price_gib_max"`
	PriceHourMax            int64   `url:"price_hour_max"`
	CompatibilityMin        int     `url:"compatibility_min"`
	CompatibilityMax        int     `url:"compatibility_max"`
	QualityMin              float64 `url:"quality_min"`
	IncludeMonitoringFailed bool    `url:"include_monitoring_failed"`
}