rdsaudit

Documentation

Index

• type AuditLog
  • func (a *AuditLog) ToCSV() (string, error)
  • func (a *AuditLog) ToMap() map[string]interface{}
• type RDSAudit
  • func New() *RDSAudit
  • func (r *RDSAudit) Err() error
  • func (r *RDSAudit) NewFakeLogEvent() (*datasource.LogEvent, error)
  • func (r *RDSAudit) Parse(ctx context.Context, in <-chan *datasource.LogEvent) <-chan *parser.Parsed
  • func (r *RDSAudit) ParseLogEvent(e *datasource.LogEvent) ([]*parser.Parsed, error)

Types

type AuditLog

type AuditLog struct {
	Timestamp      string `faker:"rds_timestamp"`
	Serverhost     string `faker:"ipv4"`
	Username       string `faker:"username"`
	Host           string `faker:"ipv4"`
	Connectionid   string `faker:"uuid_digit"`
	Queryid        string `faker:"uuid_digit"`
	Operation      string `faker:"oneof: CONNECT, QUERY, READ, WRITE, CREATE, ALTER, RENAME, DROP"`
	Database       string `faker:"domain_name"`
	Object         string `faker:"username"`
	Retcode        int64  `faker:"oneof: 0, 1"`
	ConnectionType int64  `faker:"oneof: 0, 1, 2, 3, 4, 5"`
}

https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/Appendix.MySQL.Options.AuditPlugin.html

func (*AuditLog) ToCSV

func (a *AuditLog) ToCSV() (string, error)

func (*AuditLog) ToMap

func (a *AuditLog) ToMap() map[string]interface{}

type RDSAudit

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

func New

func New() *RDSAudit

func (*RDSAudit) Err

func (r *RDSAudit) Err() error

func (*RDSAudit) NewFakeLogEvent

func (r *RDSAudit) NewFakeLogEvent() (*datasource.LogEvent, error)

func (*RDSAudit) Parse

func (r *RDSAudit) Parse(ctx context.Context, in <-chan *datasource.LogEvent) <-chan *parser.Parsed

func (*RDSAudit) ParseLogEvent

func (r *RDSAudit) ParseLogEvent(e *datasource.LogEvent) ([]*parser.Parsed, error)