nsgflowlogs

type EventACKer struct {
	// contains filtered or unexported fields
}

type LogProcessor struct {
	// contains filtered or unexported fields
}

type NsgMessage struct {
	Time          time.Time            `json:"time"`
	SystemID      string               `json:"systemId"`
	MacAddress    string               `json:"macAddress"`
	Category      string               `json:"category"`
	ResourceID    string               `json:"resourceId"`
	OperationName string               `json:"operationName"`
	Properties    NsgMessageProperties `json:"properties"`
}

type NsgMessageFlow struct {
	Rule  string        `json:"rule"`
	Flows []NsgRuleFlow `json:"flows"`
}

type NsgMessageProperties struct {
	Version int              `json:"Version"`
	Flows   []NsgMessageFlow `json:"flows"`
}

type NsgRuleFlow struct {
	Mac        string   `json:"mac"`
	FlowTuples []string `json:"flowTuples"`
}

type ReaderQueueItem struct {
	Name         string
	PartitionKey string
	RowKey       string
	ETag         string
	Index        int64
	Length       int64
}

type Worker struct {
	// contains filtered or unexported fields
}