Documentation ¶
Index ¶
- Constants
- func AddSSLKeys(w http.ResponseWriter, r *http.Request)
- func AlertExpiringCerts(certsFound ExpirationSummary, config config.Config) (int, error, error)
- func Base64DecodeCertificate(cert *tc.DeliveryServiceSSLKeysCertificate) error
- func ConvertPrivateKeyToKeyPem(userPrivateKey *rsa.PrivateKey) ([]byte, error)
- func CopyURLKeys(w http.ResponseWriter, r *http.Request)
- func CreateDNSSECKeys(exampleURLs []string, cdnKeys tc.DNSSECKeySetV11, kskExpiration time.Duration, ...) (tc.DNSSECKeySetV11, error)
- func CreateV15(w http.ResponseWriter, r *http.Request)
- func CreateV30(w http.ResponseWriter, r *http.Request)
- func CreateV31(w http.ResponseWriter, r *http.Request)
- func CreateV40(w http.ResponseWriter, r *http.Request)
- func DeleteOldCerts(db *sql.DB, tx *sql.Tx, cfg *config.Config, cdn tc.CDNName, ...) error
- func DeleteSSLKeys(w http.ResponseWriter, r *http.Request)
- func DeleteURLKeysByID(w http.ResponseWriter, r *http.Request)
- func DeleteURLKeysByName(w http.ResponseWriter, r *http.Request)
- func EncodePEMToLegacyPerlRiakFormat(pem []byte) []byte
- func EnsureCacheURLParams(tx *sql.Tx, dsID int, xmlID string, cacheURL *string) error
- func EnsureParams(tx *sql.Tx, dsID int, xmlID string, edgeHeaderRewrite *string, ...) error
- func EnsureTopologyBasedRequiredCapabilities(tx *sql.Tx, dsID int, topology string, requiredCapabilities []string) (error, error, int)
- func GenerateAcmeCertificates(w http.ResponseWriter, r *http.Request)
- func GenerateCert(host, country, city, state, org, unit string) ([]byte, []byte, []byte, error)
- func GenerateLetsEncryptCertificates(w http.ResponseWriter, r *http.Request)
- func GeneratePlaceholderSelfSignedCert(ds tc.DeliveryServiceV4, inf *api.APIInfo, context context.Context) (error, int)
- func GenerateSSLKeys(w http.ResponseWriter, r *http.Request)
- func GenerateURLKeys(w http.ResponseWriter, r *http.Request)
- func GenerateURLSigKeys() (tc.URLSigKeys, error)
- func GetAcmeAccountConfig(cfg *config.Config, acmeProvider string) *config.ConfigAcmeAccount
- func GetAcmeCertificates(cfg *config.Config, req tc.DeliveryServiceAcmeSSLKeysReq, ctx context.Context, ...) error
- func GetAcmeClient(acmeAccount *config.ConfigAcmeAccount, userTx *sql.Tx, db *sqlx.DB, ...) (*lego.Client, error)
- func GetCapacity(w http.ResponseWriter, r *http.Request)
- func GetDNSSECKeysV11(keyType string, dsName string, ttl time.Duration, inception time.Time, ...) (tc.DNSSECKeyV11, error)
- func GetDSDomainName(dsExampleURLs []string) (string, error)
- func GetDSTLSVersions(dsID int, tx *sql.Tx) ([]string, error)
- func GetDeliveryServices(query string, queryValues map[string]interface{}, tx *sqlx.Tx) ([]tc.DeliveryServiceV4, error, error, int)
- func GetDeliveryServicesMatchLists(dses []string, tx *sql.Tx) (map[string][]tc.DeliveryServiceMatch, error)
- func GetDnsChallengeRecords(w http.ResponseWriter, r *http.Request)
- func GetHealth(w http.ResponseWriter, r *http.Request)
- func GetInvalidCachegroupsForRequiredCapabilities(cachegroupServers map[string][]int, ...) []string
- func GetSSLKeysByXMLIDV15(w http.ResponseWriter, r *http.Request)
- func GetServersEligible(w http.ResponseWriter, r *http.Request)
- func GetURLKeysByID(w http.ResponseWriter, r *http.Request)
- func GetURLKeysByName(w http.ResponseWriter, r *http.Request)
- func GetXMLID(tx *sql.Tx, id int) (string, bool, error)
- func MakeDNSSECKeysFromTrafficVaultKeys(riakKeys tc.DNSSECKeysTrafficVault, dsTTL time.Duration) (tc.DNSSECKeys, error)
- func MakeDSRecordText(ksk tc.DNSSECKeyV11, ttl time.Duration) (string, error)
- func MakeExampleURLs(protocol *int, dsType tc.DSType, routingName string, ...) []string
- func PutDNSSecKeys(tx *sql.Tx, xmlID string, cdnName string, exampleURLs []string, ...) (error, error, int)
- func RenewAcmeCertificate(w http.ResponseWriter, r *http.Request)
- func RenewCertificates(w http.ResponseWriter, r *http.Request)
- func RenewCertificatesDeprecated(w http.ResponseWriter, r *http.Request)
- func RunAutorenewal(existingCerts []ExistingCerts, cfg *config.Config, ctx context.Context, ...)
- func UpdateSafe(w http.ResponseWriter, r *http.Request)
- func UpdateV15(w http.ResponseWriter, r *http.Request)
- func UpdateV30(w http.ResponseWriter, r *http.Request)
- func UpdateV31(w http.ResponseWriter, r *http.Request)
- func UpdateV40(w http.ResponseWriter, r *http.Request)
- func Validate(tx *sql.Tx, ds *tc.DeliveryServiceV4) error
- type AcmeInfo
- type CapData
- type CapacityResp
- type DNSProviderTrafficRouter
- type DnsRecord
- type DsExpirationInfo
- type DsKey
- type ExistingCerts
- type ExpirationSummary
- type MyUser
- type OldCertDeleter
- type OldCertDeleters
- type RequiredCapability
- func (rc *RequiredCapability) Create() (error, error, int)
- func (rc *RequiredCapability) Delete() (error, error, int)
- func (rc *RequiredCapability) DeleteQuery() string
- func (rc *RequiredCapability) GetAuditName() string
- func (rc RequiredCapability) GetKeyFieldsInfo() []api.KeyFieldInfo
- func (rc RequiredCapability) GetKeys() (map[string]interface{}, bool)
- func (rc *RequiredCapability) GetType() string
- func (rc *RequiredCapability) NewReadObj() interface{}
- func (rc *RequiredCapability) ParamColumns() map[string]dbhelpers.WhereColumnInfo
- func (rc *RequiredCapability) Read(h http.Header, useIMS bool) ([]interface{}, error, error, int, *time.Time)
- func (rc *RequiredCapability) SelectQuery() string
- func (rc *RequiredCapability) SetKeys(keys map[string]interface{})
- func (rc *RequiredCapability) SetLastUpdated(t tc.TimeNoMod)
- func (rc *RequiredCapability) Update(http.Header) (error, error, int)
- func (rc RequiredCapability) Validate() error
- type TODeliveryService
- func (ds *TODeliveryService) APIInfo() *api.APIInfo
- func (ds *TODeliveryService) Delete() (error, error, int)
- func (v *TODeliveryService) DeleteQuery() string
- func (ds *TODeliveryService) GetAuditName() string
- func (ds TODeliveryService) GetKeyFieldsInfo() []api.KeyFieldInfo
- func (ds TODeliveryService) GetKeys() (map[string]interface{}, bool)
- func (ds *TODeliveryService) GetType() string
- func (ds *TODeliveryService) IsTenantAuthorized(user *auth.CurrentUser) (bool, error)
- func (ds TODeliveryService) MarshalJSON() ([]byte, error)
- func (ds *TODeliveryService) Read(h http.Header, useIMS bool) ([]interface{}, error, error, int, *time.Time)
- func (ds *TODeliveryService) SetKeys(keys map[string]interface{})
- func (ds *TODeliveryService) UnmarshalJSON(data []byte) error
- type TODeliveryServiceOldDetails
Constants ¶
const API_ACME_AUTORENEW = "acme_autorenew"
const API_ACME_GENERATE_LE = "/deliveryservices/sslkeys/generate/acme"
const AcmeTimeout = time.Minute * 20
const HasRequiredCapabilitiesQuery = `` /* 132-byte string literal not displayed */
language=SQL
const NewCertValidDuration = time.Hour * 24 * 365
const (
PemCertEndMarker = "-----END CERTIFICATE-----"
)
const SelectDeliveryServicesQuery = `
SELECT
ds.active,
ds.anonymous_blocking_enabled,
ds.ccr_dns_ttl,
ds.cdn_id,
cdn.name AS cdnName,
ds.check_path,
ds.consistent_hash_regex,
CAST(ds.deep_caching_type AS text) AS deep_caching_type,
ds.display_name,
ds.dns_bypass_cname,
ds.dns_bypass_ip,
ds.dns_bypass_ip6,
ds.dns_bypass_ttl,
ds.dscp,
ds.ecs_enabled,
ds.edge_header_rewrite,
ds.first_header_rewrite,
ds.geolimit_redirect_url,
ds.geo_limit,
ds.geo_limit_countries,
ds.geo_provider,
ds.global_max_mbps,
ds.global_max_tps,
ds.fq_pacing_rate,
ds.http_bypass_fqdn,
ds.id,
ds.info_url,
ds.initial_dispersion,
ds.inner_header_rewrite,
ds.ipv6_routing_enabled,
ds.last_header_rewrite,
ds.last_updated,
ds.logs_enabled,
ds.long_desc,
ds.long_desc_1,
ds.long_desc_2,
ds.max_dns_answers,
ds.max_origin_connections,
ds.max_request_header_bytes,
ds.mid_header_rewrite,
COALESCE(ds.miss_lat, 0.0),
COALESCE(ds.miss_long, 0.0),
ds.multi_site_origin,
(SELECT o.protocol::::text || ':://' || o.fqdn || rtrim(concat('::', o.port::::text), '::')
FROM origin o
WHERE o.deliveryservice = ds.id
AND o.is_primary) AS org_server_fqdn,
ds.origin_shield,
ds.profile AS profileID,
profile.name AS profile_name,
profile.description AS profile_description,
ds.protocol,
ds.qstring_ignore,
(SELECT ARRAY_AGG(name ORDER BY name)
FROM deliveryservice_consistent_hash_query_param
WHERE deliveryservice_id = ds.id) AS query_keys,
ds.range_request_handling,
ds.regex_remap,
ds.regional_geo_blocking,
ds.remap_text,
ds.routing_name,
ds.service_category,
ds.signing_algorithm,
ds.range_slice_block_size,
ds.ssl_key_version,
ds.tenant_id,
tenant.name,
(` + baseTLSVersionsQuery + ` WHERE deliveryservice = ds.id) AS tls_versions,
ds.topology,
ds.tr_request_headers,
ds.tr_response_headers,
type.name,
ds.type AS type_id,
ds.xml_id,
cdn.domain_name AS cdn_domain
FROM deliveryservice AS ds
JOIN type ON ds.type = type.id
JOIN cdn ON ds.cdn_id = cdn.id
LEFT JOIN profile ON ds.profile = profile.id
LEFT JOIN tenant ON ds.tenant_id = tenant.id
`
SelectDeliveryServicesQuery is a PostgreSQL query used to fetch Delivery Services from the Traffic Ops Database.
const StatNameKBPS = "kbps"
const StatNameMaxKBPS = "maxKbps"
Variables ¶
This section is empty.
Functions ¶
func AddSSLKeys ¶
func AddSSLKeys(w http.ResponseWriter, r *http.Request)
AddSSLKeys adds the given ssl keys to the given delivery service.
func AlertExpiringCerts ¶
func Base64DecodeCertificate ¶
func Base64DecodeCertificate(cert *tc.DeliveryServiceSSLKeysCertificate) error
func ConvertPrivateKeyToKeyPem ¶
func ConvertPrivateKeyToKeyPem(userPrivateKey *rsa.PrivateKey) ([]byte, error)
ConvertPrivateKeyToKeyPem converts an rsa.PrivateKey to be PEM encoded.
func CopyURLKeys ¶
func CopyURLKeys(w http.ResponseWriter, r *http.Request)
CopyURLKeys copies the URL sig keys from a delivery service in the 'copy-name' path parameter to the delivery service in the 'name' path parameter.
func CreateDNSSECKeys ¶
func CreateDNSSECKeys(exampleURLs []string, cdnKeys tc.DNSSECKeySetV11, kskExpiration time.Duration, zskExpiration time.Duration, ttl time.Duration, overrideTTL bool) (tc.DNSSECKeySetV11, error)
CreateDNSSECKeys creates DNSSEC keys for the given delivery service, updating existing keys if they exist. The overrideTTL parameter determines whether to reuse existing key TTLs if they exist, or to override existing TTLs with the ttl parameter's value.
func CreateV15 ¶
func CreateV15(w http.ResponseWriter, r *http.Request)
CreateV15 is the POST handler for APIv2's deliveryservices endpoint, named with "V15" for legacy reasons. TODO allow users to post names (type, cdn, etc) and get the IDs from the names. This isn't trivial to do in a single query, without dynamically building the entire insert query, and ideally inserting would be one query. But it'd be much more convenient for users. Alternatively, remove IDs from the database entirely and use real candidate keys.
func DeleteOldCerts ¶
func DeleteOldCerts(db *sql.DB, tx *sql.Tx, cfg *config.Config, cdn tc.CDNName, tv trafficvault.TrafficVault) error
DeleteOldCerts asynchronously deletes HTTPS certificates in Riak which have no corresponding delivery service in the database.
Note the delivery service may still be in the CRConfig! Therefore, this should only be called immediately after a CRConfig Snapshot.
This creates a goroutine, and immediately returns. It returns an error if there was an error preparing the delete routine, such as an error creating a db transaction.
Note because it is asynchronous, this may return a nil error, but the asynchronous goroutine may error when fetching or deleting the certificates. If such an error occurs, it will be logged to the error log.
If certificate deletion is already being processed by a goroutine, another delete will be queued, and this immediately returns nil. Only one delete will ever be queued.
func DeleteSSLKeys ¶
func DeleteSSLKeys(w http.ResponseWriter, r *http.Request)
DeleteSSLKeys deletes a Delivery Service's sslkeys via a DELETE method
func DeleteURLKeysByID ¶
func DeleteURLKeysByID(w http.ResponseWriter, r *http.Request)
DeleteURLKeysByID deletes the URL sig keys for the delivery service identified by the id in the path parameter.
func DeleteURLKeysByName ¶
func DeleteURLKeysByName(w http.ResponseWriter, r *http.Request)
DeleteURLKeysByName deletes the URL sig keys for the delivery service identified by the xmlId in the path parameter.
func EncodePEMToLegacyPerlRiakFormat ¶
EncodePEMToLegacyPerlRiakFormat takes a PEM-encoded byte (typically a certificate, csr, or key) and returns the format Perl Traffic Ops used to send to Riak.
func EnsureCacheURLParams ¶
EnsureCacheURLParams ensures the given delivery service's cachrurl parameters exist on profiles of servers assigned to the delivery service.
func EnsureParams ¶
func EnsureParams(tx *sql.Tx, dsID int, xmlID string, edgeHeaderRewrite *string, midHeaderRewrite *string, regexRemap *string, signingAlgorithm *string, dsType tc.DSType, maxOriginConns *int) error
EnsureParams ensures the given delivery service's necessary parameters exist on profiles of servers assigned to the delivery service. Note the edgeHeaderRewrite, midHeaderRewrite, regexRemap may be nil, if the delivery service does not have those values.
func EnsureTopologyBasedRequiredCapabilities ¶
func EnsureTopologyBasedRequiredCapabilities(tx *sql.Tx, dsID int, topology string, requiredCapabilities []string) (error, error, int)
EnsureTopologyBasedRequiredCapabilities ensures that at least one server per cachegroup in this delivery service's topology has this delivery service's required capabilities.
func GenerateAcmeCertificates ¶
func GenerateAcmeCertificates(w http.ResponseWriter, r *http.Request)
GenerateAcmeCertificates gets and saves certificates using ACME protocol from a give ACME provider.
func GenerateCert ¶
GenerateCert generates a key and certificate for serving HTTPS. The generated key is 2048-bit RSA, to match the old Perl code. The certificate will be valid for NewCertValidDuration time after now. Returns PEM-encoded certificate signing request (csr), certificate (crt), and key; or any error.
func GenerateLetsEncryptCertificates ¶
func GenerateLetsEncryptCertificates(w http.ResponseWriter, r *http.Request)
GenerateLetsEncryptCertificates gets and saves new certificates from Let's Encrypt.
func GeneratePlaceholderSelfSignedCert ¶
func GeneratePlaceholderSelfSignedCert(ds tc.DeliveryServiceV4, inf *api.APIInfo, context context.Context) (error, int)
GeneratePlaceholderSelfSignedCert generates a self-signed SSL certificate as a placeholder when a new HTTPS delivery service is created or an HTTP delivery service is updated to use HTTPS.
func GenerateSSLKeys ¶
func GenerateSSLKeys(w http.ResponseWriter, r *http.Request)
GenerateSSLKeys generates a new private key, certificate signing request and certificate based on the values submitted. It then stores these values in TrafficVault and updates the SSL key version.
func GenerateURLKeys ¶
func GenerateURLKeys(w http.ResponseWriter, r *http.Request)
GenerateURLKeys generates new URL sig keys for the delivery service identified by the xmlId in the path parameter.
func GenerateURLSigKeys ¶
func GenerateURLSigKeys() (tc.URLSigKeys, error)
GenerateURLSigKeys generates new URL sig keys.
func GetAcmeAccountConfig ¶
func GetAcmeAccountConfig(cfg *config.Config, acmeProvider string) *config.ConfigAcmeAccount
GetAcmeAccountConfig returns the ACME account information from cdn.conf for a given provider.
func GetAcmeCertificates ¶
func GetAcmeCertificates(cfg *config.Config, req tc.DeliveryServiceAcmeSSLKeysReq, ctx context.Context, cancelTx context.CancelFunc, shouldCancelTx bool, currentUser *auth.CurrentUser, asyncStatusId int, tv trafficvault.TrafficVault) error
GetAcmeCertificates gets or creates an ACME account based on the provider, then gets new certificates for the delivery service requested and saves them to Vault.
func GetAcmeClient ¶
func GetAcmeClient(acmeAccount *config.ConfigAcmeAccount, userTx *sql.Tx, db *sqlx.DB, xmlId *string) (*lego.Client, error)
GetAcmeClient uses the ACME account information in either cdn.conf or the database to create and register an ACME client.
func GetCapacity ¶
func GetCapacity(w http.ResponseWriter, r *http.Request)
func GetDNSSECKeysV11 ¶
func GetDSDomainName ¶
func GetDSTLSVersions ¶
GetDSTLSVersions retrieves the TLS versions explicitly supported by a Delivery Service identified by dsID. This will panic if handed a nil transaction.
func GetDeliveryServices ¶
func GetDnsChallengeRecords ¶
func GetDnsChallengeRecords(w http.ResponseWriter, r *http.Request)
func GetInvalidCachegroupsForRequiredCapabilities ¶
func GetInvalidCachegroupsForRequiredCapabilities( cachegroupServers map[string][]int, serverCapabilities map[int]map[string]struct{}, requiredCapabilities []string, ) []string
GetInvalidCachegroupsForRequiredCapabilities returns the cachegroups that are invalid w.r.t. the given `requiredCapabilities` of a delivery service. `cachegroupServers` is a map of cachegroup names to server IDs that belong to the delivery service's CDN. `serverCapabilities` is a map of those server IDs to their set of capabilities.
func GetSSLKeysByXMLIDV15 ¶
func GetSSLKeysByXMLIDV15(w http.ResponseWriter, r *http.Request)
GetSSLKeysByXMLIDV15 fetches the deliveryservice ssl keys by the specified xmlID. V15 includes expiration date.
func GetServersEligible ¶
func GetServersEligible(w http.ResponseWriter, r *http.Request)
func GetURLKeysByID ¶
func GetURLKeysByID(w http.ResponseWriter, r *http.Request)
GetURLKeysByID returns the URL sig keys for a delivery service identified by the id in the path parameter.
func GetURLKeysByName ¶
func GetURLKeysByName(w http.ResponseWriter, r *http.Request)
GetURLKeysByName returns the URL sig keys for a delivery service identified by the xmlId in the path parameter.
func GetXMLID ¶
GetXMLID loads the DeliveryService's xml_id from the database, from the ID. Returns whether the delivery service was found, and any error.
func MakeDNSSECKeysFromTrafficVaultKeys ¶
func MakeDNSSECKeysFromTrafficVaultKeys(riakKeys tc.DNSSECKeysTrafficVault, dsTTL time.Duration) (tc.DNSSECKeys, error)
MakeDNSSECKeySetFromRiakKeySet creates a DNSSECKeySet (as served by Traffic Ops) from a DNSSECKeysRiak (as stored in Riak), adding any computed data. Notably, this adds the full DS Record text to CDN KSKs
func MakeDSRecordText ¶
func MakeExampleURLs ¶
func MakeExampleURLs(protocol *int, dsType tc.DSType, routingName string, matchList []tc.DeliveryServiceMatch, cdnDomain string) []string
MakeExampleURLs creates the example URLs for a delivery service. The dsProtocol may be nil, if the delivery service type doesn't have a protocol (e.g. ANY_MAP).
func PutDNSSecKeys ¶
func RenewAcmeCertificate ¶
func RenewAcmeCertificate(w http.ResponseWriter, r *http.Request)
RenewAcmeCertificate renews the SSL certificate for a delivery service if possible through ACME protocol.
func RenewCertificates ¶
func RenewCertificates(w http.ResponseWriter, r *http.Request)
RenewCertificates renews all SSL certificates that are expiring within a certain time limit. This will renew Let's Encrypt and ACME certificates.
func RenewCertificatesDeprecated ¶
func RenewCertificatesDeprecated(w http.ResponseWriter, r *http.Request)
RenewCertificatesDeprecated renews all SSL certificates that are expiring within a certain time limit with a deprecation alert. // This will renew Let's Encrypt and ACME certificates.
func RunAutorenewal ¶
func RunAutorenewal(existingCerts []ExistingCerts, cfg *config.Config, ctx context.Context, cancelTx context.CancelFunc, currentUser *auth.CurrentUser, asyncStatusId int, tv trafficvault.TrafficVault)
func UpdateSafe ¶
func UpdateSafe(w http.ResponseWriter, r *http.Request)
UpdateSafe is the handler for PUT requests to /deliveryservices/{{ID}}/safe.
The only fields which are "safe" to modify are the displayName, infoURL, longDesc, and longDesc1.
Types ¶
type AcmeInfo ¶
type AcmeInfo struct { Email string `db:"email"` Key string `db:"private_key"` URI string `db:"uri"` PrivateKey rsa.PrivateKey }
AcmeInfo contains the information that will be stored for an ACME account.
type CapacityResp ¶
type DNSProviderTrafficRouter ¶
type DNSProviderTrafficRouter struct {
// contains filtered or unexported fields
}
DNSProviderTrafficRouter is used in the lego library and contains a database in order to store the DNS challenges for ACME protocol.
func NewDNSProviderTrafficRouter ¶
func NewDNSProviderTrafficRouter() *DNSProviderTrafficRouter
NewDNSProviderTrafficRouter returns a new DNSProviderTrafficRouter object.
func (*DNSProviderTrafficRouter) CleanUp ¶
func (d *DNSProviderTrafficRouter) CleanUp(domain, token, keyAuth string) error
CleanUp removes the DNS challenge record from the database after the challenge has completed. This is used in the lego library.
func (*DNSProviderTrafficRouter) Present ¶
func (d *DNSProviderTrafficRouter) Present(domain, token, keyAuth string) error
Present inserts the DNS challenge record into the database to be used by Traffic Router. This is used in the lego library.
func (*DNSProviderTrafficRouter) Timeout ¶
func (d *DNSProviderTrafficRouter) Timeout() (timeout, interval time.Duration)
Timeout returns timeout information for the lego library including the timeout duration and the interval between checks.
type DsExpirationInfo ¶
type ExistingCerts ¶
type ExpirationSummary ¶
type ExpirationSummary struct { LetsEncryptExpirations []DsExpirationInfo SelfSignedExpirations []DsExpirationInfo AcmeExpirations []DsExpirationInfo OtherExpirations []DsExpirationInfo }
type MyUser ¶
type MyUser struct { Email string Registration *registration.Resource // contains filtered or unexported fields }
MyUser stores the user's information for use in ACME protocol.
func (*MyUser) GetPrivateKey ¶
func (u *MyUser) GetPrivateKey() crypto.PrivateKey
GetPrivateKey returns a user's private key for use in ACME protocol.
func (MyUser) GetRegistration ¶
func (u MyUser) GetRegistration() *registration.Resource
GetRegistration returns a user's registration for use in ACME protocol.
type OldCertDeleter ¶
type OldCertDeleters ¶
type OldCertDeleters struct { D map[tc.CDNName]*OldCertDeleter M sync.Mutex }
type RequiredCapability ¶
type RequiredCapability struct { api.APIInfoImpl `json:"-"` tc.DeliveryServicesRequiredCapability }
RequiredCapability provides a type to define methods on.
func (*RequiredCapability) Create ¶
func (rc *RequiredCapability) Create() (error, error, int)
Create implements the api.CRUDer interface.
func (*RequiredCapability) Delete ¶
func (rc *RequiredCapability) Delete() (error, error, int)
Delete implements the api.CRUDer interface.
func (*RequiredCapability) DeleteQuery ¶
func (rc *RequiredCapability) DeleteQuery() string
DeleteQuery implements the api.GenericDeleter interface.
func (*RequiredCapability) GetAuditName ¶
func (rc *RequiredCapability) GetAuditName() string
GetAuditName implements the api.Identifier interface and returns the name of the object.
func (RequiredCapability) GetKeyFieldsInfo ¶
func (rc RequiredCapability) GetKeyFieldsInfo() []api.KeyFieldInfo
GetKeyFieldsInfo implements the api.Identifier interface.
func (RequiredCapability) GetKeys ¶
func (rc RequiredCapability) GetKeys() (map[string]interface{}, bool)
GetKeys implements the api.Identifier interface and is not needed because Update is not available.
func (*RequiredCapability) GetType ¶
func (rc *RequiredCapability) GetType() string
GetType implements the api.Identifier interface and returns the name of the struct.
func (*RequiredCapability) NewReadObj ¶
func (rc *RequiredCapability) NewReadObj() interface{}
NewReadObj implements the api.GenericReader interfaces.
func (*RequiredCapability) ParamColumns ¶
func (rc *RequiredCapability) ParamColumns() map[string]dbhelpers.WhereColumnInfo
ParamColumns implements the api.GenericReader interface.
func (*RequiredCapability) Read ¶
func (rc *RequiredCapability) Read(h http.Header, useIMS bool) ([]interface{}, error, error, int, *time.Time)
Read implements the api.CRUDer interface.
func (*RequiredCapability) SelectQuery ¶
func (rc *RequiredCapability) SelectQuery() string
SelectQuery implements the api.GenericReader interface.
func (*RequiredCapability) SetKeys ¶
func (rc *RequiredCapability) SetKeys(keys map[string]interface{})
SetKeys implements the api.Identifier interface and allows the create handler to assign deliveryServiceID and requiredCapability.
func (*RequiredCapability) SetLastUpdated ¶
func (rc *RequiredCapability) SetLastUpdated(t tc.TimeNoMod)
SetLastUpdated implements the api.GenericCreator interfaces and sets the timestamp on insert.
func (RequiredCapability) Validate ¶
func (rc RequiredCapability) Validate() error
Validate implements the api.Validator interface.
type TODeliveryService ¶
type TODeliveryService struct { api.APIInfoImpl tc.DeliveryServiceV4 }
we need a type alias to define functions on
func (*TODeliveryService) APIInfo ¶
func (ds *TODeliveryService) APIInfo() *api.APIInfo
func (*TODeliveryService) Delete ¶
func (ds *TODeliveryService) Delete() (error, error, int)
Delete is the DeliveryService implementation of the Deleter interface.
func (*TODeliveryService) DeleteQuery ¶
func (v *TODeliveryService) DeleteQuery() string
func (*TODeliveryService) GetAuditName ¶
func (ds *TODeliveryService) GetAuditName() string
func (TODeliveryService) GetKeyFieldsInfo ¶
func (ds TODeliveryService) GetKeyFieldsInfo() []api.KeyFieldInfo
func (TODeliveryService) GetKeys ¶
func (ds TODeliveryService) GetKeys() (map[string]interface{}, bool)
func (*TODeliveryService) GetType ¶
func (ds *TODeliveryService) GetType() string
func (*TODeliveryService) IsTenantAuthorized ¶
func (ds *TODeliveryService) IsTenantAuthorized(user *auth.CurrentUser) (bool, error)
IsTenantAuthorized checks that the user is authorized for both the delivery service's existing tenant, and the new tenant they're changing it to (if different).
func (TODeliveryService) MarshalJSON ¶
func (ds TODeliveryService) MarshalJSON() ([]byte, error)
func (*TODeliveryService) SetKeys ¶
func (ds *TODeliveryService) SetKeys(keys map[string]interface{})
func (*TODeliveryService) UnmarshalJSON ¶
func (ds *TODeliveryService) UnmarshalJSON(data []byte) error