google_cloudsql

Documentation

Index

• func LogTestRun(server *state.Server, globalCollectionOpts state.CollectionOpts, ...) error
• func SetupLogReceiver(ctx context.Context, servers []*state.Server, ...)
• func SetupLogSubscriber(ctx context.Context, wg *sync.WaitGroup, ...) error
• type LogStreamItem

Functions

func LogTestRun

func LogTestRun(server *state.Server, globalCollectionOpts state.CollectionOpts, logger *util.Logger) error

func SetupLogReceiver

func SetupLogReceiver(ctx context.Context, servers []*state.Server, globalCollectionOpts state.CollectionOpts, logger *util.Logger, gcpLogStream <-chan LogStreamItem)

func SetupLogSubscriber

func SetupLogSubscriber(ctx context.Context, wg *sync.WaitGroup, globalCollectionOpts state.CollectionOpts, logger *util.Logger, servers []*state.Server, gcpLogStream chan LogStreamItem) error

Types

type LogStreamItem

type LogStreamItem struct {
	GcpProjectID          string
	GcpCloudSQLInstanceID string
	OccurredAt            time.Time
	Content               string
}