messaging

Documentation

Index

• Constants
• Variables
• func InitBigQueryPubsubClient(projectID, topicID, pubsubCredentials string) error
• func InitPubsubClient(projectID string, pubsubCredentials string) error
• func PublishFTLTestReportCreatedEvent(ctx context.Context, logger *zap.Logger, build models.Build, appSlug string, ...)
• func PublishTestReportCreatedEvent(ctx context.Context, tr models.TestReport, appSlug, buildSlug string)
• func PublishTestReportProcessedEvent(ctx context.Context, logger *zap.Logger, data []byte, ...) error

Constants

const (
	// TestReportType ...
	TestReportType = "test_report"
	// FTLTestReportType ...
	FTLTestReportType = "ftl_test_report"
	// DebugPanicOnceType ...
	DebugPanicOnceType = "debug_panic_once"
)

Variables

var PubsubClient *pubsub.Client

PubsubClient ...

Functions

func InitBigQueryPubsubClient

func InitBigQueryPubsubClient(projectID, topicID, pubsubCredentials string) error

InitBigQueryPubsubClient ...

func InitPubsubClient

func InitPubsubClient(projectID string, pubsubCredentials string) error

InitPubsubClient ...

func PublishFTLTestReportCreatedEvent

func PublishFTLTestReportCreatedEvent(ctx context.Context, logger *zap.Logger, build models.Build, appSlug string, ftlPlatformType models.FTLPlatformType)

PublishFTLTestReportCreatedEvent ...

func PublishTestReportCreatedEvent

func PublishTestReportCreatedEvent(ctx context.Context, tr models.TestReport, appSlug, buildSlug string)

PublishTestReportCreatedEvent ...

func PublishTestReportProcessedEvent

func PublishTestReportProcessedEvent(ctx context.Context, logger *zap.Logger, data []byte, appSlug, buildSlug, reportType string) error

PublishTestReportProcessedEvent ...