common

Documentation

Index

• Constants
• Variables
• func ErrorResponse(code int, msg string, w http.ResponseWriter)
• func ParsePagingParams(page, perPage string, maxPerPage int) (int, int, error)
• func PerItemPagination(_qLimit, _page, _perPage, _numOfSrcs int) (perItems []int, offsets []int)
• func SetVersion(version string)
• func SupportedAggregate(a string) bool
• func SupportedPeriod(p string) bool
• func SupportedPeriods() []string
• func ValidatePagingParams(page, perPage, maxPerPage int) error
• func ValidatePerItemLimit(_qLimit, _perPage, _numOfSrcs int) error
• type AggrConf
• type Config
• type DataBackendConf
• type DataConf
• type Error
• type HTTPConf
• type RegBackendConf
• type RegConf
  • func (c RegConf) ConfiguredRetention(period string) bool
• type ServiceCatalogConf
• type WebConfig

Constants

const (
	// IDSeparator is used for separation of IDs in the BrokerURL
	IDSeparator = ","

	// Location of APIs
	RegistryAPILoc = "/registry"
	DataAPILoc     = "/data"
	// Query parameters
	ParamPage        = "page"
	ParamPerPage     = "perPage"
	ParamLimit       = "limit"
	ParamFrom        = "from"
	ParamTo          = "to"
	ParamSort        = "sort"
	ParamDenormalize = "denormalize"
	ParamCount       = "count"

	// Values for ParamSort
	Asc  = "asc"  // ascending
	Desc = "desc" // descending
	//values for auth providers
	Keycloak = "keycloak"

	DNSSDServiceType = "_linksmart-hds._tcp"
)

Variables

var (
	// APIVersion defines the API version
	APIVersion string

	// Default MIME type for all responses
	DefaultMIMEType string
)

Functions

func ErrorResponse

func ErrorResponse(code int, msg string, w http.ResponseWriter)

ErrorResponse writes error to HTTP ResponseWriter

func ParsePagingParams

func ParsePagingParams(page, perPage string, maxPerPage int) (int, int, error)

func PerItemPagination

func PerItemPagination(_qLimit, _page, _perPage, _numOfSrcs int) (perItems []int, offsets []int)

Calculate perItem and offset given the page, perPage, limit, and number of streams

func SetVersion

func SetVersion(version string)

func SupportedAggregate

func SupportedAggregate(a string) bool

SupportedAggregate validates an aggregate

func SupportedPeriod

func SupportedPeriod(p string) bool

SupportedPeriod validates a period

func SupportedPeriods

func SupportedPeriods() []string

SupportedPeriods returns supported periods

func ValidatePagingParams

func ValidatePagingParams(page, perPage, maxPerPage int) error

func ValidatePerItemLimit

func ValidatePerItemLimit(_qLimit, _perPage, _numOfSrcs int) error

Check if the parameters match the criteria required by PerItemPagination function

Types

type AggrConf

type AggrConf struct{}

Aggregation config

type Config

type Config struct {
	// Service ID
	ServiceID string `json:"serviceID"`
	// HDS API addr
	HTTP HTTPConf `json:"http"`
	//DNS service discovery
	DnssdEnabled bool `json:"dnssdEnabled"`
	//DNS-SD description
	Description string `json:"description"`
	// Registry API Config
	Reg RegConf `json:"registry"`
	// Data API Config
	Data DataConf `json:"data"`
	// Aggregation API Config
	Aggr AggrConf `json:"aggregation"`
	// LinkSmart Service Catalog registration config
	ServiceCatalog ServiceCatalogConf `json:"serviceCatalog"`
	// Auth config
	Auth validator.Conf `json:"auth"`
}

type DataBackendConf

type DataBackendConf struct {
	Type string `json:"type"`
	DSN  string `json:"dsn"`
}

Data backend config

type DataConf

type DataConf struct {
	Backend DataBackendConf `json:"backend"`
	// RetentionPeriods is deprecated, will be removed from v0.6.0. Use registry.retentionPeriods instead.
	RetentionPeriods []string `json:"retentionPeriods"`
	AutoRegistration bool     `json:"autoRegistration"`
}

Data config

type Error

type Error struct {
	// Code is the (http) code of the error
	Code int `json:"code"`
	// Message is the (human-readable) error message
	Message string `json:"message"`
}

Error describes an API error (serializable in JSON)

type HTTPConf

type HTTPConf struct {
	PublicEndpoint string `json:"publicEndpoint"`
	BindAddr       string `json:"bindAddr"`
	BindPort       uint16 `json:"bindPort"`
}

HTTP config

type RegBackendConf

type RegBackendConf struct {
	Type string `json:"type"`
	DSN  string `json:"dsn"`
}

Registry backend config

type RegConf

type RegConf struct {
	Backend          RegBackendConf `json:"backend"`
	RetentionPeriods []string       `json:"retentionPeriods"`
}

Registry config

func (RegConf) ConfiguredRetention

func (c RegConf) ConfiguredRetention(period string) bool

type ServiceCatalogConf

type ServiceCatalogConf struct {
	Enabled  bool          `json:"enabled"`
	Discover bool          `json:"discover"`
	Endpoint string        `json:"endpoint"`
	TTL      uint          `json:"ttl"`
	Auth     obtainer.Conf `json:"auth"`
}

LinkSmart Service Catalog registration config

type WebConfig

type WebConfig struct {
	BindAddr  string `json:"bindAddr"`
	BindPort  uint16 `json:"bindPort"`
	StaticDir string `json:"staticDir"`
}

Web GUI Config