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 AzureEventHubData
- type AzurePostgresLogMessage
- type AzurePostgresLogRecord
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func LogTestRun ¶
func SetupLogReceiver ¶
func SetupLogReceiver(ctx context.Context, servers []*state.Server, globalCollectionOpts state.CollectionOpts, logger *util.Logger, azureLogStream <-chan AzurePostgresLogRecord)
func SetupLogSubscriber ¶
Types ¶
type AzureEventHubData ¶
type AzureEventHubData struct {
Records []AzurePostgresLogRecord `json:"records"`
}
type AzurePostgresLogMessage ¶
type AzurePostgresLogMessage struct { Prefix string `json:"prefix"` Message string `json:"message"` Detail string `json:"detail"` ErrorLevel string `json:"errorLevel"` Domain string `json:"domain"` SchemaName string `json:"schemaName"` TableName string `json:"tableName"` ColumnName string `json:"columnName"` DatatypeName string `json:"datatypeName"` }
type AzurePostgresLogRecord ¶
type AzurePostgresLogRecord struct { LogicalServerName string `json:"LogicalServerName"` SubscriptionID string `json:"SubscriptionId"` ResourceGroup string `json:"ResourceGroup"` Time string `json:"time"` ResourceID string `json:"resourceId"` Category string `json:"category"` OperationName string `json:"operationName"` Properties AzurePostgresLogMessage `json:"properties"` }
Click to show internal directories.
Click to hide internal directories.