azure

Documentation

Index

• func GetServerNameFromRecord(in AzurePostgresLogRecord) string
• func GetSystemState(ctx context.Context, server *state.Server, logger *util.Logger) (system state.SystemState)
• func ParseRecordToLogLines(in AzurePostgresLogRecord, parser state.LogParser) ([]state.LogLine, error)
• func SetupLogSubscriber(ctx context.Context, wg *sync.WaitGroup, ...) error
• type AzureEventHubData
• type AzurePostgresLogMessage
• type AzurePostgresLogRecord
  • func (record *AzurePostgresLogRecord) IsCosmosDB() bool
  • func (record *AzurePostgresLogRecord) IsSingleServer() bool

Functions

func GetServerNameFromRecord

func GetServerNameFromRecord(in AzurePostgresLogRecord) string

func GetSystemState

func GetSystemState(ctx context.Context, server *state.Server, logger *util.Logger) (system state.SystemState)

GetSystemState - Gets system information about an Azure instance

func ParseRecordToLogLines

func ParseRecordToLogLines(in AzurePostgresLogRecord, parser state.LogParser) ([]state.LogLine, error)

Parses one Azure Event Hub log record into one or two log lines (main + DETAIL)

func SetupLogSubscriber

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

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"`
}

func (*AzurePostgresLogRecord) IsCosmosDB

func (record *AzurePostgresLogRecord) IsCosmosDB() bool

func (*AzurePostgresLogRecord) IsSingleServer

func (record *AzurePostgresLogRecord) IsSingleServer() bool