dbservice

Documentation

Index

• Variables
• func AggregateScans(output string, currentScan map[string]string, scansPerTicket int, ...) ([]map[string]string, error)
• func ChangeDbPath(newPath string)
• func CheckExpiredData()
• func CheckSizeLimit()
• func EnsureApiKey() error
• func GetApiKey() (string, error)
• func MayBeStoreMessage(message []byte, messageKey string, expired *time.Time) (wasStored bool, err error)
• func RegisterPlgnInvctn(name string) error
• func SetNewDbPathFromEnv()

Variables

var (
	DbBucketActionStats  = "WebhookActionStats"
	DbBucketSharedConfig = "WebhookSharedConfig"

	DbSizeLimit = 0

	DateFmt = time.RFC3339Nano

	DbPath = "/server/database/webhooks.db"
)

var Init = func(db *bbolt.DB, bucket string) error {
	return db.Update(func(tx *bbolt.Tx) error {
		_, err := tx.CreateBucketIfNotExists([]byte(bucket))
		return err
	})
}

Functions

func AggregateScans

func AggregateScans(output string,
	currentScan map[string]string,
	scansPerTicket int,
	ignoreTheQuantity bool) ([]map[string]string, error)

func ChangeDbPath

func ChangeDbPath(newPath string)

func CheckExpiredData

func CheckExpiredData()

func CheckSizeLimit

func CheckSizeLimit()

func EnsureApiKey

func EnsureApiKey() error

func GetApiKey

func GetApiKey() (string, error)

func MayBeStoreMessage

func MayBeStoreMessage(message []byte, messageKey string, expired *time.Time) (wasStored bool, err error)

func RegisterPlgnInvctn

func RegisterPlgnInvctn(name string) error

func SetNewDbPathFromEnv

func SetNewDbPathFromEnv()