storage

Documentation

Index

• func NewNotificationReceiver() *s3.NotificationReceiver
• type Config
• type Storage
  • func NewLocalStorage(storagePath string) (Storage, error)
  • func NewS3Storage(storageBucket, storagePath, awsRegion, storageNotifications string, ...) (Storage, error)
  • func NewStorage(t string, config interface{}) (Storage, error)

Functions

func NewNotificationReceiver

func NewNotificationReceiver() *s3.NotificationReceiver

Types

type Config

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

type Storage

type Storage interface {
	SetLogLevel(loglevel string)
	SetStoragePath(path string)
	GetError(name string) error
	ListObjects() ([]api.Object, error)
	GetObject(name string) ([]api.Object, error)
	ListCerts() (map[string]string, error)
	GetCert(name string) (string, error)
	GetCertBundle(name string) (string, error)
	WriteCert(name string, cert []byte) error
	WriteCertBundle(name string, certs []byte) error
	GetPrivateAccountkey() (*rsa.PrivateKey, error)
	GetPublicAccountkey() (*rsa.PublicKey, error)
	CreateAccountKey() error
	CreateKey(name string) error
	GetPrivateKey(name string) (*rsa.PrivateKey, error)
	GetPrivateKeyPem(name string) (string, error)
	WriteChallenge(name string, data []byte) error
	GetCachedObjectName(filename string) ([]*api.Object, error)
	DeleteCachedObject(filename string) error
	CountCachedObjectByCondition(condition api.RuleConditions, actions []api.RuleActions) int
	CountCachedJwtRulesByCondition(condition api.RuleConditions, jwtProvider string) int
	GetCachedRule(name string) *api.Object
}

func NewLocalStorage

func NewLocalStorage(storagePath string) (Storage, error)

func NewS3Storage

func NewS3Storage(storageBucket, storagePath, awsRegion, storageNotifications string, startQueue bool) (Storage, error)

func NewStorage

func NewStorage(t string, config interface{}) (Storage, error)