archiver

package module

Go to main page

Versions in this module

v1

v1.0.2

Jan 8, 2019

v1.0.1

Oct 22, 2018

v1.0.0

Jul 24, 2018

v0

v0.0.27

Jul 24, 2018

v0.0.26

Jun 21, 2018

v0.0.25

Jun 18, 2018

v0.0.24

Jun 14, 2018

v0.0.23

Jun 14, 2018

v0.0.22

Jun 14, 2018

v0.0.21

Jun 14, 2018

Changes in this version

type Org

+ Language *string

v0.0.20

Jun 11, 2018

Changes in this version

type Archive

+ DeletedOn *time.Time

type Config

+ Delete bool

+ KeepFiles bool

v0.0.19

Jun 8, 2018

v0.0.18

Jun 8, 2018

Changes in this version

+ func DeleteArchivedRuns(ctx context.Context, config *Config, db *sqlx.DB, s3Client s3iface.S3API, ...) error

v0.0.17

Jun 5, 2018

Changes in this version

+ func UploadToS3(ctx context.Context, s3Client s3iface.S3API, bucket string, path string, ...) error

v0.0.16

Jun 5, 2018

Changes in this version

type Archive

+ DeletionDate *time.Time

v0.0.15

Jun 5, 2018

v0.0.14

Jun 5, 2018

v0.0.13

Jun 5, 2018

v0.0.12

Jun 4, 2018

v0.0.11

Jun 4, 2018

Changes in this version

+ func DeleteArchivedMessages(ctx context.Context, config *Config, db *sqlx.DB, s3Client s3iface.S3API, ...) error

+ func GetCurrentArchiveCount(ctx context.Context, db *sqlx.DB, org Org, archiveType ArchiveType) (int, error)

+ func GetS3FileETAG(ctx context.Context, s3Client s3iface.S3API, fileURL string) (string, error)

type Archive

+ NeedsDeletion bool

+ func DeleteArchivedOrgRecords(ctx context.Context, now time.Time, config *Config, db *sqlx.DB, ...) ([]*Archive, error)

+ func GetArchivesNeedingDeletion(ctx context.Context, db *sqlx.DB, org Org, archiveType ArchiveType) ([]*Archive, error)

+ func GetDailyArchivesForDateRange(ctx context.Context, db *sqlx.DB, org Org, archiveType ArchiveType, ...) ([]*Archive, error)

+ func GetMissingDailyArchives(ctx context.Context, db *sqlx.DB, now time.Time, org Org, ...) ([]*Archive, error)

+ func GetMissingDailyArchivesForDateRange(ctx context.Context, db *sqlx.DB, startDate time.Time, endDate time.Time, ...) ([]*Archive, error)

+ func GetMissingMonthlyArchives(ctx context.Context, db *sqlx.DB, now time.Time, org Org, ...) ([]*Archive, error)

type Config

+ DeleteRecords bool

v0.0.10

May 22, 2018

v0.0.9

May 22, 2018

Changes in this version

+ func BuildRollupArchive(ctx context.Context, conf *Config, s3Client s3iface.S3API, archives []*Archive, ...) error

type Archive

+ func CreateOrgArchives(ctx context.Context, now time.Time, config *Config, db *sqlx.DB, ...) ([]*Archive, error)

+ func RollupOrgArchives(ctx context.Context, now time.Time, config *Config, db *sqlx.DB, ...) ([]*Archive, error)

v0.0.8

May 19, 2018

v0.0.7

May 19, 2018

v0.0.6

May 18, 2018

Changes in this version

+ const DayPeriod

+ const MonthPeriod

+ const RunType

+ func BuildMonthlyArchive(ctx context.Context, conf *Config, s3Client s3iface.S3API, archives []*Archive, ...) error

+ func CreateArchiveFile(ctx context.Context, db *sqlx.DB, archive *Archive, archivePath string) error

+ func DeleteArchiveFile(archive *Archive) error

+ func EnsureTempArchiveDirectory(path string) error

+ func GetS3File(ctx context.Context, s3Client s3iface.S3API, fileURL string) (io.ReadCloser, error)

+ func NewS3Client(config *Config) (s3iface.S3API, error)

+ func PutS3File(s3Client s3iface.S3API, bucket string, path string, contentType string, ...) (string, error)

+ func TestS3(s3Client s3iface.S3API, bucket string) error

+ func WithAcceptEncoding(e string) request.Option

+ type Archive struct

+ ArchiveFile string

+ ArchiveType ArchiveType

+ BuildTime int

+ CreatedOn time.Time

+ Dailies []*Archive

+ Hash string

+ ID int

+ IsPurged bool

+ Org Org

+ OrgID int

+ Period ArchivePeriod

+ RecordCount int

+ Rollup *int

+ Size int64

+ StartDate time.Time

+ URL string

+ func ArchiveOrg(ctx context.Context, now time.Time, config *Config, db *sqlx.DB, ...) ([]*Archive, error)

+ func BuildOrgDailyArchives(ctx context.Context, now time.Time, config *Config, db *sqlx.DB, ...) ([]*Archive, error)

+ func BuildOrgMonthlyArchives(ctx context.Context, now time.Time, config *Config, db *sqlx.DB, ...) ([]*Archive, error)

+ func GetCurrentArchives(ctx context.Context, db *sqlx.DB, org Org, archiveType ArchiveType) ([]*Archive, error)

+ func GetMissingDayArchives(archives []*Archive, now time.Time, org Org, archiveType ArchiveType) ([]*Archive, error)

+ func GetMissingMonthArchives(archives []*Archive, now time.Time, org Org, archiveType ArchiveType) ([]*Archive, error)

+ type ArchivePeriod string

type Config

+ ArchiveMessages bool

+ ArchiveRuns bool

+ DeleteAfterUpload bool

+ TempDir string

+ UploadToS3 bool

+ type Org struct

+ ActiveDays int

+ CreatedOn time.Time

+ ID int

+ IsAnon bool

+ Name string

v0.0.5

May 12, 2018

v0.0.4

May 12, 2018

v0.0.3

May 12, 2018

Changes in this version

type Config

+ S3Bucket string

v0.0.2

May 12, 2018

v0.0.1

May 12, 2018

Changes in this version

+ const FlowRunType

+ const MessageType

+ const SessionType

+ func CreateMsgArchive(ctx context.Context, db *sqlx.DB, task *ArchiveTask) error

+ func UploadArchive(ctx context.Context, s3Client s3iface.S3API, bucket string, task *ArchiveTask) error

+ func WriteArchiveToDB(ctx context.Context, db *sqlx.DB, task *ArchiveTask) error

+ type ArchiveTask struct

+ ArchiveType ArchiveType

+ BuildStart time.Time

+ EndDate time.Time

+ FileHash string

+ FileSize int64

+ Filename string

+ ID int

+ Org DBOrg

+ RecordCount int

+ StartDate time.Time

+ URL string

+ func GetArchiveTasks(ctx context.Context, db *sqlx.DB, org DBOrg, archiveType ArchiveType) ([]ArchiveTask, error)

+ type ArchiveType string

+ type Config struct

+ AWSAccessKeyID string

+ AWSSecretAccessKey string

+ DB string

+ LogLevel string

+ S3ArchiveBucket string

+ S3DisableSSL bool

+ S3Endpoint string

+ S3ForcePathStyle bool

+ S3Region string

+ SentryDSN string

+ func NewConfig() *Config

+ type DBArchive struct

+ ArchiveDuration int

+ ArchiveHash string

+ ArchiveSize int

+ ArchiveType string

+ ArchiveURL string

+ BuildTime int

+ CreatedOn time.Time

+ EndDate time.Time

+ ID int

+ IsPurged bool

+ OrgID int

+ RecordCount int

+ StartDate time.Time

+ type DBOrg struct

+ ActiveDays int

+ CreatedOn time.Time

+ ID int

+ Name string

+ func GetActiveOrgs(ctx context.Context, db *sqlx.DB) ([]DBOrg, error)

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