courier

package

v1.1.15 Latest Latest Go to latest Published: Jun 18, 2026 License: MIT Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/artificial-polyglot/arti

Links

Open Source Insights

Documentation ¶

Index ¶

func GoMailSendMail(ctx context.Context, recipients []string, subject string, msg string, ...) *log.Status
func SQSEnqueue(ctx context.Context, queueURL string, data any) (string, *log.Status)
type CompletionMsg
type Courier
- func NewCourier(ctx context.Context, yaml []byte) Courier
type LongRunNotify
- func NewLongRunNotify(ctx context.Context, request request.Request) LongRunNotify
- func (l LongRunNotify) SendEmail()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GoMailSendMail ¶

func GoMailSendMail(ctx context.Context, recipients []string, subject string, msg string,
	attachments []string) *log.Status

func SQSEnqueue ¶

func SQSEnqueue(ctx context.Context, queueURL string, data any) (string, *log.Status)

Types ¶

type CompletionMsg ¶

type CompletionMsg struct {
	DatasetName string `yaml:"dataset_name"`
	Success     bool   `yaml:"success"`
	Completion  string `yaml:"completion"`
	Duration    string `yaml:"duration"`
	Bucket      string `yaml:"bucket"`
	Object      string `yaml:"object"`
}

type Courier ¶

type Courier struct {
	IsUnitTest bool // Set to true by run_bucket_test.
	// contains filtered or unexported fields
}

func NewCourier ¶

func NewCourier(ctx context.Context, yaml []byte) Courier

func (*Courier) AddDatabase ¶

func (b *Courier) AddDatabase(conn db.DBAdapter)

func (*Courier) AddJson ¶

func (b *Courier) AddJson(records any, filePath string)

func (*Courier) AddLogFile ¶

func (b *Courier) AddLogFile(logPath string)

AddLogFile sets up single-file logging with truncation (legacy behavior) Deprecated: Use AddPerJobLogFile with FCBH_DATASET_LOG_DIR instead

func (*Courier) AddOutput ¶

func (b *Courier) AddOutput(outputPath string)

func (*Courier) AddPerJobLogFile ¶

func (b *Courier) AddPerJobLogFile(logDir string)

AddPerJobLogFile creates a new log file for each job in the specified directory

func (*Courier) GetOutputByExt ¶

func (b *Courier) GetOutputByExt() []string

func (*Courier) GetOutputPaths ¶

func (b *Courier) GetOutputPaths() []string

func (*Courier) Notification ¶

func (b *Courier) Notification(req request.Request, status *log.Status, duration time.Duration) *log.Status

func (*Courier) PersistToBucket ¶

func (b *Courier) PersistToBucket() *log.Status

func (*Courier) ServerInfo ¶

func (b *Courier) ServerInfo(cfg aws.Config) string

type LongRunNotify ¶

type LongRunNotify struct {
	EstimateMin float64
	Threshold   time.Duration
	// contains filtered or unexported fields
}

func NewLongRunNotify ¶

func NewLongRunNotify(ctx context.Context, request request.Request) LongRunNotify

func (LongRunNotify) SendEmail ¶

func (l LongRunNotify) SendEmail()

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
create_sqs_queue

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