riaksvc

Documentation

Overview

Package riaksvc provides a TrafficVault implementation which uses Riak as the backend.

Index

• Constants
• type Config
• type Riak
  • func (r *Riak) DeleteDNSSECKeys(cdnName string, tx *sql.Tx, ctx context.Context) error
  • func (r *Riak) DeleteDeliveryServiceSSLKeys(xmlID string, version string, tx *sql.Tx, ctx context.Context) error
  • func (r *Riak) DeleteOldDeliveryServiceSSLKeys(existingXMLIDs map[string]struct{}, cdnName string, tx *sql.Tx, ...) error
  • func (r *Riak) DeleteURISigningKeys(xmlID string, tx *sql.Tx, ctx context.Context) error
  • func (r *Riak) DeleteURLSigKeys(xmlID string, tx *sql.Tx, ctx context.Context) error
  • func (r *Riak) GetBucketKey(bucket string, key string, tx *sql.Tx) ([]byte, bool, error)
  • func (r *Riak) GetCDNSSLKeys(cdnName string, tx *sql.Tx, ctx context.Context) ([]tc.CDNSSLKey, error)
  • func (r *Riak) GetDNSSECKeys(cdnName string, tx *sql.Tx, ctx context.Context) (tc.DNSSECKeysTrafficVault, bool, error)
  • func (r *Riak) GetDeliveryServiceSSLKeys(xmlID string, version string, tx *sql.Tx, ctx context.Context) (tc.DeliveryServiceSSLKeysV15, bool, error)
  • func (r *Riak) GetURISigningKeys(xmlID string, tx *sql.Tx, ctx context.Context) ([]byte, bool, error)
  • func (r *Riak) GetURLSigKeys(xmlID string, tx *sql.Tx, ctx context.Context) (tc.URLSigKeys, bool, error)
  • func (r *Riak) Ping(tx *sql.Tx, ctx context.Context) (tc.TrafficVaultPing, error)
  • func (r *Riak) PutDNSSECKeys(cdnName string, keys tc.DNSSECKeysTrafficVault, tx *sql.Tx, ...) error
  • func (r *Riak) PutDeliveryServiceSSLKeys(key tc.DeliveryServiceSSLKeys, tx *sql.Tx, ctx context.Context) error
  • func (r *Riak) PutURISigningKeys(xmlID string, keysJson []byte, tx *sql.Tx, ctx context.Context) error
  • func (r *Riak) PutURLSigKeys(xmlID string, keys tc.URLSigKeys, tx *sql.Tx, ctx context.Context) error
• type RiakStorageCluster
  • func (ri RiakStorageCluster) Execute(command riak.Command) error
  • func (ri RiakStorageCluster) Start() error
  • func (ri RiakStorageCluster) Stop() error
• type ServerAddr
• type StorageCluster
• type TOAuthOptions

Constants

const RiakBackendName = "riak"

Types

type Config

type Config struct {
	riak.AuthOptions
	Port uint
}

type Riak

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

func (*Riak) DeleteDNSSECKeys

func (r *Riak) DeleteDNSSECKeys(cdnName string, tx *sql.Tx, ctx context.Context) error

func (*Riak) DeleteDeliveryServiceSSLKeys

func (r *Riak) DeleteDeliveryServiceSSLKeys(xmlID string, version string, tx *sql.Tx, ctx context.Context) error

func (*Riak) DeleteOldDeliveryServiceSSLKeys

func (r *Riak) DeleteOldDeliveryServiceSSLKeys(existingXMLIDs map[string]struct{}, cdnName string, tx *sql.Tx, ctx context.Context) error

func (*Riak) DeleteURISigningKeys

func (r *Riak) DeleteURISigningKeys(xmlID string, tx *sql.Tx, ctx context.Context) error

func (*Riak) DeleteURLSigKeys

func (r *Riak) DeleteURLSigKeys(xmlID string, tx *sql.Tx, ctx context.Context) error

func (*Riak) GetBucketKey

func (r *Riak) GetBucketKey(bucket string, key string, tx *sql.Tx) ([]byte, bool, error)

func (*Riak) GetCDNSSLKeys

func (r *Riak) GetCDNSSLKeys(cdnName string, tx *sql.Tx, ctx context.Context) ([]tc.CDNSSLKey, error)

func (*Riak) GetDNSSECKeys

func (r *Riak) GetDNSSECKeys(cdnName string, tx *sql.Tx, ctx context.Context) (tc.DNSSECKeysTrafficVault, bool, error)

func (*Riak) GetDeliveryServiceSSLKeys

func (r *Riak) GetDeliveryServiceSSLKeys(xmlID string, version string, tx *sql.Tx, ctx context.Context) (tc.DeliveryServiceSSLKeysV15, bool, error)

func (*Riak) GetURISigningKeys

func (r *Riak) GetURISigningKeys(xmlID string, tx *sql.Tx, ctx context.Context) ([]byte, bool, error)

func (*Riak) GetURLSigKeys

func (r *Riak) GetURLSigKeys(xmlID string, tx *sql.Tx, ctx context.Context) (tc.URLSigKeys, bool, error)

func (*Riak) Ping

func (r *Riak) Ping(tx *sql.Tx, ctx context.Context) (tc.TrafficVaultPing, error)

func (*Riak) PutDNSSECKeys

func (r *Riak) PutDNSSECKeys(cdnName string, keys tc.DNSSECKeysTrafficVault, tx *sql.Tx, ctx context.Context) error

func (*Riak) PutDeliveryServiceSSLKeys

func (r *Riak) PutDeliveryServiceSSLKeys(key tc.DeliveryServiceSSLKeys, tx *sql.Tx, ctx context.Context) error

func (*Riak) PutURISigningKeys

func (r *Riak) PutURISigningKeys(xmlID string, keysJson []byte, tx *sql.Tx, ctx context.Context) error

func (*Riak) PutURLSigKeys

func (r *Riak) PutURLSigKeys(xmlID string, keys tc.URLSigKeys, tx *sql.Tx, ctx context.Context) error

type RiakStorageCluster

type RiakStorageCluster struct {
	Cluster *riak.Cluster
}

RiakStorageCluster ...

func (RiakStorageCluster) Execute

func (ri RiakStorageCluster) Execute(command riak.Command) error

Execute ...

func (RiakStorageCluster) Start

func (ri RiakStorageCluster) Start() error

Start ...

func (RiakStorageCluster) Stop

func (ri RiakStorageCluster) Stop() error

Stop ...

type ServerAddr

type ServerAddr struct {
	FQDN string
	Port string
}

type StorageCluster

type StorageCluster interface {
	Start() error
	Stop() error
	Execute(riak.Command) error
}

StorageCluster ...

type TOAuthOptions

type TOAuthOptions struct {
	riak.AuthOptions
	MaxTLSVersion *string
	Port          uint `json:"port"`
}