riaksvc

package
v6.0.1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 9, 2021 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 1 more Imports: 21 Imported by: 0

Documentation

Overview

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

Index

Constants

View Source
const RiakBackendName = "riak"

Variables

This section is empty.

Functions

This section is empty.

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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL