eventpb

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 20, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

Package eventpb defines standardized payloads for cluster-level and SQL-level event reporting.

The consumers of structured events include:

  • Instrusion Detection Systems in the CockroachCloud infrastructure. Check in with the security team before changing or evolving any payloads related to privilege changes, user management, authentication or other security-adjacent features.

- The DB Console (ex "Admin UI") code. See ui/util/events*.ts.

  • Customers using automatic event triaging in network log collectors. Check in with the product team before changing or evolving the way event types are classified into categories or channels. Also check in with the product team before changing or evolving "Common" payload types shared across multiple event types.
  • Documentation. These are published APIs. A reference doc is automatically generated (docs/generated/eventlog.md). Significant changes to the event documentation should be reviewed by the doc team.

Maintenance instructions:

Generally, the event payloads must be stable across releases.

They are also part of the external API. Any changes to event definitions must be supported by a release note in the commit message. The deprecation process applies to remove non-alpha, non-reserved published APIs.

It is possible to opt out of the stability guarantee for a new payload by documenting an entire event payload or individual fields as "Reserved and subject to change without notice". That mention must also be placed in a release note.

Note that the JSON compatibility rules apply, not just protobuf:

  • The names of the types and fields are part of the interface. A name change is a breaking change. The casing of the field names matters too.
  • the fields in the proto definition have jsontag starting with the empty string before the comma, e.g. ",omitempty" so as to override the default JSON field name generated by the protobuf compiler. We want to keep the cased names for compatibility with pre-v21.1 consumers of system.eventlog.
  • likewise, the entire CommonXXXX payloads are marked as embedded and their json tag is removed in every event log message, to ensure that it appears inline in the JSON output. This is because we wish our event structures to be flat and easier to consume.

Beware: because the common structs are marked inline in the individual events, care must be taken to not reuse field identifiers across the message and common types, otherwise the JSON conversions cannot work.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthClusterEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowClusterEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupClusterEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthDdlEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDdlEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDdlEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthDebugEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDebugEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDebugEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthHealthEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHealthEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupHealthEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthJobEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowJobEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupJobEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMiscSqlEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMiscSqlEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMiscSqlEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPrivilegeEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPrivilegeEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPrivilegeEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthRoleEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRoleEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRoleEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthSessionEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSessionEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSessionEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthSqlAuditEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSqlAuditEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSqlAuditEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTelemetry        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTelemetry          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTelemetry = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthZoneEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowZoneEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupZoneEvents = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var AuthFailReason_name = map[int32]string{
	0: "UNKNOWN",
	1: "USER_RETRIEVAL_ERROR",
	2: "USER_NOT_FOUND",
	3: "LOGIN_DISABLED",
	4: "METHOD_NOT_FOUND",
	5: "PRE_HOOK_ERROR",
	6: "CREDENTIALS_INVALID",
	7: "CREDENTIALS_EXPIRED",
}
View Source 
var AuthFailReason_value = map[string]int32{
	"UNKNOWN":              0,
	"USER_RETRIEVAL_ERROR": 1,
	"USER_NOT_FOUND":       2,
	"LOGIN_DISABLED":       3,
	"METHOD_NOT_FOUND":     4,
	"PRE_HOOK_ERROR":       5,
	"CREDENTIALS_INVALID":  6,
	"CREDENTIALS_EXPIRED":  7,
}

Functions

func GetEventTypeName 

func GetEventTypeName(event EventPayload) string

GetEventTypeName retrieves the system.eventlog type name for the given payload.

Types

type AdminQuery 

type AdminQuery struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonSQLExecDetails  `protobuf:"bytes,3,opt,name=exec,proto3,embedded=exec" json:""`
}

AdminQuery is recorded when a user with admin privileges (the user is directly or indirectly a member of the admin role) executes a query.

func (*AdminQuery) AppendJSONFields 

func (m *AdminQuery) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AdminQuery) Descriptor 

func (*AdminQuery) Descriptor() ([]byte, []int)

func (*AdminQuery) LoggingChannel 

func (m *AdminQuery) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AdminQuery) Marshal 

func (m *AdminQuery) Marshal() (dAtA []byte, err error)

func (*AdminQuery) MarshalTo 

func (m *AdminQuery) MarshalTo(dAtA []byte) (int, error)

func (*AdminQuery) MarshalToSizedBuffer 

func (m *AdminQuery) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AdminQuery) ProtoMessage 

func (*AdminQuery) ProtoMessage()

func (*AdminQuery) Reset 

func (m *AdminQuery) Reset()

func (*AdminQuery) Size 

func (m *AdminQuery) Size() (n int)

func (*AdminQuery) String 

func (m *AdminQuery) String() string

func (*AdminQuery) Unmarshal 

func (m *AdminQuery) Unmarshal(dAtA []byte) error

func (*AdminQuery) XXX_DiscardUnknown 

func (m *AdminQuery) XXX_DiscardUnknown()

func (*AdminQuery) XXX_Marshal 

func (m *AdminQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AdminQuery) XXX_Merge 

func (m *AdminQuery) XXX_Merge(src proto.Message)

func (*AdminQuery) XXX_Size 

func (m *AdminQuery) XXX_Size() int

func (*AdminQuery) XXX_Unmarshal 

func (m *AdminQuery) XXX_Unmarshal(b []byte) error

type AlterDatabaseAddRegion 

type AlterDatabaseAddRegion struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the database.
	DatabaseName string `protobuf:"bytes,3,opt,name=database_name,json=databaseName,proto3" json:",omitempty"`
	// The region being added.
	RegionName string `protobuf:"bytes,4,opt,name=region_name,json=regionName,proto3" json:",omitempty"`
}

AlterDatabaseAddRegion is recorded when a region is added to a database.

func (*AlterDatabaseAddRegion) AppendJSONFields 

func (m *AlterDatabaseAddRegion) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AlterDatabaseAddRegion) Descriptor 

func (*AlterDatabaseAddRegion) Descriptor() ([]byte, []int)

func (*AlterDatabaseAddRegion) LoggingChannel 

func (m *AlterDatabaseAddRegion) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AlterDatabaseAddRegion) Marshal 

func (m *AlterDatabaseAddRegion) Marshal() (dAtA []byte, err error)

func (*AlterDatabaseAddRegion) MarshalTo 

func (m *AlterDatabaseAddRegion) MarshalTo(dAtA []byte) (int, error)

func (*AlterDatabaseAddRegion) MarshalToSizedBuffer 

func (m *AlterDatabaseAddRegion) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlterDatabaseAddRegion) ProtoMessage 

func (*AlterDatabaseAddRegion) ProtoMessage()

func (*AlterDatabaseAddRegion) Reset 

func (m *AlterDatabaseAddRegion) Reset()

func (*AlterDatabaseAddRegion) Size 

func (m *AlterDatabaseAddRegion) Size() (n int)

func (*AlterDatabaseAddRegion) String 

func (m *AlterDatabaseAddRegion) String() string

func (*AlterDatabaseAddRegion) Unmarshal 

func (m *AlterDatabaseAddRegion) Unmarshal(dAtA []byte) error

func (*AlterDatabaseAddRegion) XXX_DiscardUnknown 

func (m *AlterDatabaseAddRegion) XXX_DiscardUnknown()

func (*AlterDatabaseAddRegion) XXX_Marshal 

func (m *AlterDatabaseAddRegion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterDatabaseAddRegion) XXX_Merge 

func (m *AlterDatabaseAddRegion) XXX_Merge(src proto.Message)

func (*AlterDatabaseAddRegion) XXX_Size 

func (m *AlterDatabaseAddRegion) XXX_Size() int

func (*AlterDatabaseAddRegion) XXX_Unmarshal 

func (m *AlterDatabaseAddRegion) XXX_Unmarshal(b []byte) error

type AlterDatabaseDropRegion 

type AlterDatabaseDropRegion struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the database.
	DatabaseName string `protobuf:"bytes,3,opt,name=database_name,json=databaseName,proto3" json:",omitempty"`
	// The region being dropped.
	RegionName string `protobuf:"bytes,4,opt,name=region_name,json=regionName,proto3" json:",omitempty"`
}

AlterDatabaseAddRegion is recorded when a region is added to a database.

func (*AlterDatabaseDropRegion) AppendJSONFields 

func (m *AlterDatabaseDropRegion) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AlterDatabaseDropRegion) Descriptor 

func (*AlterDatabaseDropRegion) Descriptor() ([]byte, []int)

func (*AlterDatabaseDropRegion) LoggingChannel 

func (m *AlterDatabaseDropRegion) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AlterDatabaseDropRegion) Marshal 

func (m *AlterDatabaseDropRegion) Marshal() (dAtA []byte, err error)

func (*AlterDatabaseDropRegion) MarshalTo 

func (m *AlterDatabaseDropRegion) MarshalTo(dAtA []byte) (int, error)

func (*AlterDatabaseDropRegion) MarshalToSizedBuffer 

func (m *AlterDatabaseDropRegion) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlterDatabaseDropRegion) ProtoMessage 

func (*AlterDatabaseDropRegion) ProtoMessage()

func (*AlterDatabaseDropRegion) Reset 

func (m *AlterDatabaseDropRegion) Reset()

func (*AlterDatabaseDropRegion) Size 

func (m *AlterDatabaseDropRegion) Size() (n int)

func (*AlterDatabaseDropRegion) String 

func (m *AlterDatabaseDropRegion) String() string

func (*AlterDatabaseDropRegion) Unmarshal 

func (m *AlterDatabaseDropRegion) Unmarshal(dAtA []byte) error

func (*AlterDatabaseDropRegion) XXX_DiscardUnknown 

func (m *AlterDatabaseDropRegion) XXX_DiscardUnknown()

func (*AlterDatabaseDropRegion) XXX_Marshal 

func (m *AlterDatabaseDropRegion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterDatabaseDropRegion) XXX_Merge 

func (m *AlterDatabaseDropRegion) XXX_Merge(src proto.Message)

func (*AlterDatabaseDropRegion) XXX_Size 

func (m *AlterDatabaseDropRegion) XXX_Size() int

func (*AlterDatabaseDropRegion) XXX_Unmarshal 

func (m *AlterDatabaseDropRegion) XXX_Unmarshal(b []byte) error

type AlterDatabaseOwner 

type AlterDatabaseOwner struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the database being affected.
	DatabaseName string `protobuf:"bytes,3,opt,name=database_name,json=databaseName,proto3" json:",omitempty"`
	// The name of the new owner.
	Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:",omitempty"`
}

AlterDatabaseOwner is recorded when a database's owner is changed.

func (*AlterDatabaseOwner) AppendJSONFields 

func (m *AlterDatabaseOwner) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AlterDatabaseOwner) Descriptor 

func (*AlterDatabaseOwner) Descriptor() ([]byte, []int)

func (*AlterDatabaseOwner) LoggingChannel 

func (m *AlterDatabaseOwner) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AlterDatabaseOwner) Marshal 

func (m *AlterDatabaseOwner) Marshal() (dAtA []byte, err error)

func (*AlterDatabaseOwner) MarshalTo 

func (m *AlterDatabaseOwner) MarshalTo(dAtA []byte) (int, error)

func (*AlterDatabaseOwner) MarshalToSizedBuffer 

func (m *AlterDatabaseOwner) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlterDatabaseOwner) ProtoMessage 

func (*AlterDatabaseOwner) ProtoMessage()

func (*AlterDatabaseOwner) Reset 

func (m *AlterDatabaseOwner) Reset()

func (*AlterDatabaseOwner) Size 

func (m *AlterDatabaseOwner) Size() (n int)

func (*AlterDatabaseOwner) String 

func (m *AlterDatabaseOwner) String() string

func (*AlterDatabaseOwner) Unmarshal 

func (m *AlterDatabaseOwner) Unmarshal(dAtA []byte) error

func (*AlterDatabaseOwner) XXX_DiscardUnknown 

func (m *AlterDatabaseOwner) XXX_DiscardUnknown()

func (*AlterDatabaseOwner) XXX_Marshal 

func (m *AlterDatabaseOwner) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterDatabaseOwner) XXX_Merge 

func (m *AlterDatabaseOwner) XXX_Merge(src proto.Message)

func (*AlterDatabaseOwner) XXX_Size 

func (m *AlterDatabaseOwner) XXX_Size() int

func (*AlterDatabaseOwner) XXX_Unmarshal 

func (m *AlterDatabaseOwner) XXX_Unmarshal(b []byte) error

type AlterDatabasePlacement 

type AlterDatabasePlacement struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the database.
	DatabaseName string `protobuf:"bytes,3,opt,name=database_name,json=databaseName,proto3" json:",omitempty"`
	// The new placement policy.
	Placement string `protobuf:"bytes,4,opt,name=placement,proto3" json:",omitempty"`
}

AlterDatabasePlacement is recorded when the database placement is modified.

func (*AlterDatabasePlacement) AppendJSONFields 

func (m *AlterDatabasePlacement) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AlterDatabasePlacement) Descriptor 

func (*AlterDatabasePlacement) Descriptor() ([]byte, []int)

func (*AlterDatabasePlacement) LoggingChannel 

func (m *AlterDatabasePlacement) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AlterDatabasePlacement) Marshal 

func (m *AlterDatabasePlacement) Marshal() (dAtA []byte, err error)

func (*AlterDatabasePlacement) MarshalTo 

func (m *AlterDatabasePlacement) MarshalTo(dAtA []byte) (int, error)

func (*AlterDatabasePlacement) MarshalToSizedBuffer 

func (m *AlterDatabasePlacement) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlterDatabasePlacement) ProtoMessage 

func (*AlterDatabasePlacement) ProtoMessage()

func (*AlterDatabasePlacement) Reset 

func (m *AlterDatabasePlacement) Reset()

func (*AlterDatabasePlacement) Size 

func (m *AlterDatabasePlacement) Size() (n int)

func (*AlterDatabasePlacement) String 

func (m *AlterDatabasePlacement) String() string

func (*AlterDatabasePlacement) Unmarshal 

func (m *AlterDatabasePlacement) Unmarshal(dAtA []byte) error

func (*AlterDatabasePlacement) XXX_DiscardUnknown 

func (m *AlterDatabasePlacement) XXX_DiscardUnknown()

func (*AlterDatabasePlacement) XXX_Marshal 

func (m *AlterDatabasePlacement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterDatabasePlacement) XXX_Merge 

func (m *AlterDatabasePlacement) XXX_Merge(src proto.Message)

func (*AlterDatabasePlacement) XXX_Size 

func (m *AlterDatabasePlacement) XXX_Size() int

func (*AlterDatabasePlacement) XXX_Unmarshal 

func (m *AlterDatabasePlacement) XXX_Unmarshal(b []byte) error

type AlterDatabasePrimaryRegion 

type AlterDatabasePrimaryRegion struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the database.
	DatabaseName string `protobuf:"bytes,3,opt,name=database_name,json=databaseName,proto3" json:",omitempty"`
	// The new primary region.
	PrimaryRegionName string `protobuf:"bytes,4,opt,name=primary_region_name,json=primaryRegionName,proto3" json:",omitempty"`
}

AlterDatabasePrimaryRegion is recorded when a primary region is added/modified.

func (*AlterDatabasePrimaryRegion) AppendJSONFields 

func (m *AlterDatabasePrimaryRegion) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AlterDatabasePrimaryRegion) Descriptor 

func (*AlterDatabasePrimaryRegion) Descriptor() ([]byte, []int)

func (*AlterDatabasePrimaryRegion) LoggingChannel 

func (m *AlterDatabasePrimaryRegion) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AlterDatabasePrimaryRegion) Marshal 

func (m *AlterDatabasePrimaryRegion) Marshal() (dAtA []byte, err error)

func (*AlterDatabasePrimaryRegion) MarshalTo 

func (m *AlterDatabasePrimaryRegion) MarshalTo(dAtA []byte) (int, error)

func (*AlterDatabasePrimaryRegion) MarshalToSizedBuffer 

func (m *AlterDatabasePrimaryRegion) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlterDatabasePrimaryRegion) ProtoMessage 

func (*AlterDatabasePrimaryRegion) ProtoMessage()

func (*AlterDatabasePrimaryRegion) Reset 

func (m *AlterDatabasePrimaryRegion) Reset()

func (*AlterDatabasePrimaryRegion) Size 

func (m *AlterDatabasePrimaryRegion) Size() (n int)

func (*AlterDatabasePrimaryRegion) String 

func (m *AlterDatabasePrimaryRegion) String() string

func (*AlterDatabasePrimaryRegion) Unmarshal 

func (m *AlterDatabasePrimaryRegion) Unmarshal(dAtA []byte) error

func (*AlterDatabasePrimaryRegion) XXX_DiscardUnknown 

func (m *AlterDatabasePrimaryRegion) XXX_DiscardUnknown()

func (*AlterDatabasePrimaryRegion) XXX_Marshal 

func (m *AlterDatabasePrimaryRegion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterDatabasePrimaryRegion) XXX_Merge 

func (m *AlterDatabasePrimaryRegion) XXX_Merge(src proto.Message)

func (*AlterDatabasePrimaryRegion) XXX_Size 

func (m *AlterDatabasePrimaryRegion) XXX_Size() int

func (*AlterDatabasePrimaryRegion) XXX_Unmarshal 

func (m *AlterDatabasePrimaryRegion) XXX_Unmarshal(b []byte) error

type AlterDatabaseSurvivalGoal 

type AlterDatabaseSurvivalGoal struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the database.
	DatabaseName string `protobuf:"bytes,3,opt,name=database_name,json=databaseName,proto3" json:",omitempty"`
	// The new survival goal
	SurvivalGoal string `protobuf:"bytes,4,opt,name=survival_goal,json=survivalGoal,proto3" json:",omitempty"`
}

AlterDatabaseSurvivalGoal is recorded when the survival goal is modified.

func (*AlterDatabaseSurvivalGoal) AppendJSONFields 

func (m *AlterDatabaseSurvivalGoal) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AlterDatabaseSurvivalGoal) Descriptor 

func (*AlterDatabaseSurvivalGoal) Descriptor() ([]byte, []int)

func (*AlterDatabaseSurvivalGoal) LoggingChannel 

func (m *AlterDatabaseSurvivalGoal) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AlterDatabaseSurvivalGoal) Marshal 

func (m *AlterDatabaseSurvivalGoal) Marshal() (dAtA []byte, err error)

func (*AlterDatabaseSurvivalGoal) MarshalTo 

func (m *AlterDatabaseSurvivalGoal) MarshalTo(dAtA []byte) (int, error)

func (*AlterDatabaseSurvivalGoal) MarshalToSizedBuffer 

func (m *AlterDatabaseSurvivalGoal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlterDatabaseSurvivalGoal) ProtoMessage 

func (*AlterDatabaseSurvivalGoal) ProtoMessage()

func (*AlterDatabaseSurvivalGoal) Reset 

func (m *AlterDatabaseSurvivalGoal) Reset()

func (*AlterDatabaseSurvivalGoal) Size 

func (m *AlterDatabaseSurvivalGoal) Size() (n int)

func (*AlterDatabaseSurvivalGoal) String 

func (m *AlterDatabaseSurvivalGoal) String() string

func (*AlterDatabaseSurvivalGoal) Unmarshal 

func (m *AlterDatabaseSurvivalGoal) Unmarshal(dAtA []byte) error

func (*AlterDatabaseSurvivalGoal) XXX_DiscardUnknown 

func (m *AlterDatabaseSurvivalGoal) XXX_DiscardUnknown()

func (*AlterDatabaseSurvivalGoal) XXX_Marshal 

func (m *AlterDatabaseSurvivalGoal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterDatabaseSurvivalGoal) XXX_Merge 

func (m *AlterDatabaseSurvivalGoal) XXX_Merge(src proto.Message)

func (*AlterDatabaseSurvivalGoal) XXX_Size 

func (m *AlterDatabaseSurvivalGoal) XXX_Size() int

func (*AlterDatabaseSurvivalGoal) XXX_Unmarshal 

func (m *AlterDatabaseSurvivalGoal) XXX_Unmarshal(b []byte) error

type AlterDefaultPrivileges 

type AlterDefaultPrivileges struct {
	CommonEventDetails             `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails          `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonSQLPrivilegeEventDetails `protobuf:"bytes,3,opt,name=privs,proto3,embedded=privs" json:""`
	// The name of the affected database.
	DatabaseName string `protobuf:"bytes,4,opt,name=database_name,json=databaseName,proto3" json:",omitempty"`
	// Either role_name should be populated or for_all_roles should be true.
	// The role having its default privileges altered.
	RoleName string `protobuf:"bytes,5,opt,name=role_name,json=roleName,proto3" json:",omitempty"`
	// Identifies if FOR ALL ROLES is used.
	ForAllRoles bool `protobuf:"varint,6,opt,name=for_all_roles,json=forAllRoles,proto3" json:",omitempty"`
	// The name of the affected schema.
	SchemaName string `protobuf:"bytes,7,opt,name=schema_name,json=schemaName,proto3" json:",omitempty"`
}

AlterDefaultPrivileges is recorded when default privileges are changed.

func (*AlterDefaultPrivileges) AppendJSONFields 

func (m *AlterDefaultPrivileges) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AlterDefaultPrivileges) Descriptor 

func (*AlterDefaultPrivileges) Descriptor() ([]byte, []int)

func (*AlterDefaultPrivileges) LoggingChannel 

func (m *AlterDefaultPrivileges) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AlterDefaultPrivileges) Marshal 

func (m *AlterDefaultPrivileges) Marshal() (dAtA []byte, err error)

func (*AlterDefaultPrivileges) MarshalTo 

func (m *AlterDefaultPrivileges) MarshalTo(dAtA []byte) (int, error)

func (*AlterDefaultPrivileges) MarshalToSizedBuffer 

func (m *AlterDefaultPrivileges) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlterDefaultPrivileges) ProtoMessage 

func (*AlterDefaultPrivileges) ProtoMessage()

func (*AlterDefaultPrivileges) Reset 

func (m *AlterDefaultPrivileges) Reset()

func (*AlterDefaultPrivileges) Size 

func (m *AlterDefaultPrivileges) Size() (n int)

func (*AlterDefaultPrivileges) String 

func (m *AlterDefaultPrivileges) String() string

func (*AlterDefaultPrivileges) Unmarshal 

func (m *AlterDefaultPrivileges) Unmarshal(dAtA []byte) error

func (*AlterDefaultPrivileges) XXX_DiscardUnknown 

func (m *AlterDefaultPrivileges) XXX_DiscardUnknown()

func (*AlterDefaultPrivileges) XXX_Marshal 

func (m *AlterDefaultPrivileges) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterDefaultPrivileges) XXX_Merge 

func (m *AlterDefaultPrivileges) XXX_Merge(src proto.Message)

func (*AlterDefaultPrivileges) XXX_Size 

func (m *AlterDefaultPrivileges) XXX_Size() int

func (*AlterDefaultPrivileges) XXX_Unmarshal 

func (m *AlterDefaultPrivileges) XXX_Unmarshal(b []byte) error

type AlterIndex 

type AlterIndex struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the table containing the affected index.
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
	// The name of the affected index.
	IndexName string `protobuf:"bytes,4,opt,name=index_name,json=indexName,proto3" json:",omitempty"`
	// The mutation ID for the asynchronous job that is processing the index update.
	MutationID uint32 `protobuf:"varint,5,opt,name=mutation_id,json=mutationId,proto3" json:",omitempty"`
}

AlterIndex is recorded when an index is altered.

func (*AlterIndex) AppendJSONFields 

func (m *AlterIndex) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AlterIndex) Descriptor 

func (*AlterIndex) Descriptor() ([]byte, []int)

func (*AlterIndex) LoggingChannel 

func (m *AlterIndex) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AlterIndex) Marshal 

func (m *AlterIndex) Marshal() (dAtA []byte, err error)

func (*AlterIndex) MarshalTo 

func (m *AlterIndex) MarshalTo(dAtA []byte) (int, error)

func (*AlterIndex) MarshalToSizedBuffer 

func (m *AlterIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlterIndex) ProtoMessage 

func (*AlterIndex) ProtoMessage()

func (*AlterIndex) Reset 

func (m *AlterIndex) Reset()

func (*AlterIndex) Size 

func (m *AlterIndex) Size() (n int)

func (*AlterIndex) String 

func (m *AlterIndex) String() string

func (*AlterIndex) Unmarshal 

func (m *AlterIndex) Unmarshal(dAtA []byte) error

func (*AlterIndex) XXX_DiscardUnknown 

func (m *AlterIndex) XXX_DiscardUnknown()

func (*AlterIndex) XXX_Marshal 

func (m *AlterIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterIndex) XXX_Merge 

func (m *AlterIndex) XXX_Merge(src proto.Message)

func (*AlterIndex) XXX_Size 

func (m *AlterIndex) XXX_Size() int

func (*AlterIndex) XXX_Unmarshal 

func (m *AlterIndex) XXX_Unmarshal(b []byte) error

type AlterRole 

type AlterRole struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected user/role.
	RoleName string `protobuf:"bytes,3,opt,name=role_name,json=roleName,proto3" json:",omitempty"`
	// The options set on the user/role.
	Options []string `protobuf:"bytes,4,rep,name=options,proto3" json:",omitempty" redact:"nonsensitive"`
}

AlterRole is recorded when a role is altered.

func (*AlterRole) AppendJSONFields 

func (m *AlterRole) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AlterRole) Descriptor 

func (*AlterRole) Descriptor() ([]byte, []int)

func (*AlterRole) LoggingChannel 

func (m *AlterRole) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AlterRole) Marshal 

func (m *AlterRole) Marshal() (dAtA []byte, err error)

func (*AlterRole) MarshalTo 

func (m *AlterRole) MarshalTo(dAtA []byte) (int, error)

func (*AlterRole) MarshalToSizedBuffer 

func (m *AlterRole) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlterRole) ProtoMessage 

func (*AlterRole) ProtoMessage()

func (*AlterRole) Reset 

func (m *AlterRole) Reset()

func (*AlterRole) Size 

func (m *AlterRole) Size() (n int)

func (*AlterRole) String 

func (m *AlterRole) String() string

func (*AlterRole) Unmarshal 

func (m *AlterRole) Unmarshal(dAtA []byte) error

func (*AlterRole) XXX_DiscardUnknown 

func (m *AlterRole) XXX_DiscardUnknown()

func (*AlterRole) XXX_Marshal 

func (m *AlterRole) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterRole) XXX_Merge 

func (m *AlterRole) XXX_Merge(src proto.Message)

func (*AlterRole) XXX_Size 

func (m *AlterRole) XXX_Size() int

func (*AlterRole) XXX_Unmarshal 

func (m *AlterRole) XXX_Unmarshal(b []byte) error

type AlterSchemaOwner 

type AlterSchemaOwner struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected schema.
	SchemaName string `protobuf:"bytes,3,opt,name=schema_name,json=schemaName,proto3" json:",omitempty"`
	// The name of the new owner.
	Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:",omitempty"`
}

AlterSchemaOwner is recorded when a schema's owner is changed.

func (*AlterSchemaOwner) AppendJSONFields 

func (m *AlterSchemaOwner) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AlterSchemaOwner) Descriptor 

func (*AlterSchemaOwner) Descriptor() ([]byte, []int)

func (*AlterSchemaOwner) LoggingChannel 

func (m *AlterSchemaOwner) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AlterSchemaOwner) Marshal 

func (m *AlterSchemaOwner) Marshal() (dAtA []byte, err error)

func (*AlterSchemaOwner) MarshalTo 

func (m *AlterSchemaOwner) MarshalTo(dAtA []byte) (int, error)

func (*AlterSchemaOwner) MarshalToSizedBuffer 

func (m *AlterSchemaOwner) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlterSchemaOwner) ProtoMessage 

func (*AlterSchemaOwner) ProtoMessage()

func (*AlterSchemaOwner) Reset 

func (m *AlterSchemaOwner) Reset()

func (*AlterSchemaOwner) Size 

func (m *AlterSchemaOwner) Size() (n int)

func (*AlterSchemaOwner) String 

func (m *AlterSchemaOwner) String() string

func (*AlterSchemaOwner) Unmarshal 

func (m *AlterSchemaOwner) Unmarshal(dAtA []byte) error

func (*AlterSchemaOwner) XXX_DiscardUnknown 

func (m *AlterSchemaOwner) XXX_DiscardUnknown()

func (*AlterSchemaOwner) XXX_Marshal 

func (m *AlterSchemaOwner) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterSchemaOwner) XXX_Merge 

func (m *AlterSchemaOwner) XXX_Merge(src proto.Message)

func (*AlterSchemaOwner) XXX_Size 

func (m *AlterSchemaOwner) XXX_Size() int

func (*AlterSchemaOwner) XXX_Unmarshal 

func (m *AlterSchemaOwner) XXX_Unmarshal(b []byte) error

type AlterSequence 

type AlterSequence struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected sequence.
	SequenceName string `protobuf:"bytes,3,opt,name=sequence_name,json=sequenceName,proto3" json:",omitempty"`
}

AlterSequence is recorded when a sequence is altered.

func (*AlterSequence) AppendJSONFields 

func (m *AlterSequence) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AlterSequence) Descriptor 

func (*AlterSequence) Descriptor() ([]byte, []int)

func (*AlterSequence) LoggingChannel 

func (m *AlterSequence) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AlterSequence) Marshal 

func (m *AlterSequence) Marshal() (dAtA []byte, err error)

func (*AlterSequence) MarshalTo 

func (m *AlterSequence) MarshalTo(dAtA []byte) (int, error)

func (*AlterSequence) MarshalToSizedBuffer 

func (m *AlterSequence) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlterSequence) ProtoMessage 

func (*AlterSequence) ProtoMessage()

func (*AlterSequence) Reset 

func (m *AlterSequence) Reset()

func (*AlterSequence) Size 

func (m *AlterSequence) Size() (n int)

func (*AlterSequence) String 

func (m *AlterSequence) String() string

func (*AlterSequence) Unmarshal 

func (m *AlterSequence) Unmarshal(dAtA []byte) error

func (*AlterSequence) XXX_DiscardUnknown 

func (m *AlterSequence) XXX_DiscardUnknown()

func (*AlterSequence) XXX_Marshal 

func (m *AlterSequence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterSequence) XXX_Merge 

func (m *AlterSequence) XXX_Merge(src proto.Message)

func (*AlterSequence) XXX_Size 

func (m *AlterSequence) XXX_Size() int

func (*AlterSequence) XXX_Unmarshal 

func (m *AlterSequence) XXX_Unmarshal(b []byte) error

type AlterTable 

type AlterTable struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected table.
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
	// The mutation ID for the asynchronous job that is processing the index update, if any.
	MutationID uint32 `protobuf:"varint,4,opt,name=mutation_id,json=mutationId,proto3" json:",omitempty"`
	// The names of the views dropped as a result of a cascade operation.
	CascadeDroppedViews []string `protobuf:"bytes,5,rep,name=cascade_dropped_views,json=cascadeDroppedViews,proto3" json:",omitempty"`
}

AlterTable is recorded when a table is altered.

func (*AlterTable) AppendJSONFields 

func (m *AlterTable) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AlterTable) Descriptor 

func (*AlterTable) Descriptor() ([]byte, []int)

func (*AlterTable) LoggingChannel 

func (m *AlterTable) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AlterTable) Marshal 

func (m *AlterTable) Marshal() (dAtA []byte, err error)

func (*AlterTable) MarshalTo 

func (m *AlterTable) MarshalTo(dAtA []byte) (int, error)

func (*AlterTable) MarshalToSizedBuffer 

func (m *AlterTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlterTable) ProtoMessage 

func (*AlterTable) ProtoMessage()

func (*AlterTable) Reset 

func (m *AlterTable) Reset()

func (*AlterTable) Size 

func (m *AlterTable) Size() (n int)

func (*AlterTable) String 

func (m *AlterTable) String() string

func (*AlterTable) Unmarshal 

func (m *AlterTable) Unmarshal(dAtA []byte) error

func (*AlterTable) XXX_DiscardUnknown 

func (m *AlterTable) XXX_DiscardUnknown()

func (*AlterTable) XXX_Marshal 

func (m *AlterTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterTable) XXX_Merge 

func (m *AlterTable) XXX_Merge(src proto.Message)

func (*AlterTable) XXX_Size 

func (m *AlterTable) XXX_Size() int

func (*AlterTable) XXX_Unmarshal 

func (m *AlterTable) XXX_Unmarshal(b []byte) error

type AlterTableOwner 

type AlterTableOwner struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected object.
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
	// The name of the new owner.
	Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:",omitempty"`
}

AlterTableOwner is recorded when the owner of a table, view or sequence is changed.

func (*AlterTableOwner) AppendJSONFields 

func (m *AlterTableOwner) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AlterTableOwner) Descriptor 

func (*AlterTableOwner) Descriptor() ([]byte, []int)

func (*AlterTableOwner) LoggingChannel 

func (m *AlterTableOwner) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AlterTableOwner) Marshal 

func (m *AlterTableOwner) Marshal() (dAtA []byte, err error)

func (*AlterTableOwner) MarshalTo 

func (m *AlterTableOwner) MarshalTo(dAtA []byte) (int, error)

func (*AlterTableOwner) MarshalToSizedBuffer 

func (m *AlterTableOwner) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlterTableOwner) ProtoMessage 

func (*AlterTableOwner) ProtoMessage()

func (*AlterTableOwner) Reset 

func (m *AlterTableOwner) Reset()

func (*AlterTableOwner) Size 

func (m *AlterTableOwner) Size() (n int)

func (*AlterTableOwner) String 

func (m *AlterTableOwner) String() string

func (*AlterTableOwner) Unmarshal 

func (m *AlterTableOwner) Unmarshal(dAtA []byte) error

func (*AlterTableOwner) XXX_DiscardUnknown 

func (m *AlterTableOwner) XXX_DiscardUnknown()

func (*AlterTableOwner) XXX_Marshal 

func (m *AlterTableOwner) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterTableOwner) XXX_Merge 

func (m *AlterTableOwner) XXX_Merge(src proto.Message)

func (*AlterTableOwner) XXX_Size 

func (m *AlterTableOwner) XXX_Size() int

func (*AlterTableOwner) XXX_Unmarshal 

func (m *AlterTableOwner) XXX_Unmarshal(b []byte) error

type AlterType 

type AlterType struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected type.
	TypeName string `protobuf:"bytes,3,opt,name=type_name,json=typeName,proto3" json:",omitempty"`
}

EventAlterType is recorded when a user-defined type is altered.

func (*AlterType) AppendJSONFields 

func (m *AlterType) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AlterType) Descriptor 

func (*AlterType) Descriptor() ([]byte, []int)

func (*AlterType) LoggingChannel 

func (m *AlterType) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AlterType) Marshal 

func (m *AlterType) Marshal() (dAtA []byte, err error)

func (*AlterType) MarshalTo 

func (m *AlterType) MarshalTo(dAtA []byte) (int, error)

func (*AlterType) MarshalToSizedBuffer 

func (m *AlterType) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlterType) ProtoMessage 

func (*AlterType) ProtoMessage()

func (*AlterType) Reset 

func (m *AlterType) Reset()

func (*AlterType) Size 

func (m *AlterType) Size() (n int)

func (*AlterType) String 

func (m *AlterType) String() string

func (*AlterType) Unmarshal 

func (m *AlterType) Unmarshal(dAtA []byte) error

func (*AlterType) XXX_DiscardUnknown 

func (m *AlterType) XXX_DiscardUnknown()

func (*AlterType) XXX_Marshal 

func (m *AlterType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterType) XXX_Merge 

func (m *AlterType) XXX_Merge(src proto.Message)

func (*AlterType) XXX_Size 

func (m *AlterType) XXX_Size() int

func (*AlterType) XXX_Unmarshal 

func (m *AlterType) XXX_Unmarshal(b []byte) error

type AlterTypeOwner 

type AlterTypeOwner struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected type.
	TypeName string `protobuf:"bytes,3,opt,name=type_name,json=typeName,proto3" json:",omitempty"`
	// The name of the new owner.
	Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:",omitempty"`
}

AlterTypeOwner is recorded when the owner of a user-defiend type is changed.

func (*AlterTypeOwner) AppendJSONFields 

func (m *AlterTypeOwner) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*AlterTypeOwner) Descriptor 

func (*AlterTypeOwner) Descriptor() ([]byte, []int)

func (*AlterTypeOwner) LoggingChannel 

func (m *AlterTypeOwner) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*AlterTypeOwner) Marshal 

func (m *AlterTypeOwner) Marshal() (dAtA []byte, err error)

func (*AlterTypeOwner) MarshalTo 

func (m *AlterTypeOwner) MarshalTo(dAtA []byte) (int, error)

func (*AlterTypeOwner) MarshalToSizedBuffer 

func (m *AlterTypeOwner) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AlterTypeOwner) ProtoMessage 

func (*AlterTypeOwner) ProtoMessage()

func (*AlterTypeOwner) Reset 

func (m *AlterTypeOwner) Reset()

func (*AlterTypeOwner) Size 

func (m *AlterTypeOwner) Size() (n int)

func (*AlterTypeOwner) String 

func (m *AlterTypeOwner) String() string

func (*AlterTypeOwner) Unmarshal 

func (m *AlterTypeOwner) Unmarshal(dAtA []byte) error

func (*AlterTypeOwner) XXX_DiscardUnknown 

func (m *AlterTypeOwner) XXX_DiscardUnknown()

func (*AlterTypeOwner) XXX_Marshal 

func (m *AlterTypeOwner) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterTypeOwner) XXX_Merge 

func (m *AlterTypeOwner) XXX_Merge(src proto.Message)

func (*AlterTypeOwner) XXX_Size 

func (m *AlterTypeOwner) XXX_Size() int

func (*AlterTypeOwner) XXX_Unmarshal 

func (m *AlterTypeOwner) XXX_Unmarshal(b []byte) error

type AuthFailReason 

type AuthFailReason int32

AuthFailReason is the inventory of possible reasons for an authentication failure. 

const (
	// UNKNOWN is reported when the reason is unknown.
	AuthFailReason_UNKNOWN AuthFailReason = 0
	// USER_RETRIEVAL_ERROR occurs when there was an internal error accessing the principals.
	AuthFailReason_USER_RETRIEVAL_ERROR AuthFailReason = 1
	// USER_NOT_FOUND occurs when the principal is unknown.
	AuthFailReason_USER_NOT_FOUND AuthFailReason = 2
	// LOGIN_DISABLED occurs when the user does not have LOGIN privileges.
	AuthFailReason_LOGIN_DISABLED AuthFailReason = 3
	// METHOD_NOT_FOUND occurs when no HBA rule matches or the method does not exist.
	AuthFailReason_METHOD_NOT_FOUND AuthFailReason = 4
	// PRE_HOOK_ERROR occurs when the authentication handshake encountered a protocol error.
	AuthFailReason_PRE_HOOK_ERROR AuthFailReason = 5
	// CREDENTIALS_INVALID occurs when the client-provided credentials were invalid.
	AuthFailReason_CREDENTIALS_INVALID AuthFailReason = 6
	// CREDENTIALS_EXPIRED occur when the credentials provided by the client are expired.
	AuthFailReason_CREDENTIALS_EXPIRED AuthFailReason = 7
)

func (AuthFailReason) EnumDescriptor 

func (AuthFailReason) EnumDescriptor() ([]byte, []int)

func (AuthFailReason) String 

func (x AuthFailReason) String() string

type CapturedIndexUsageStats 

type CapturedIndexUsageStats struct {
	CommonEventDetails `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	// TotalReadCount is the number of times this index has been read from.
	TotalReadCount uint64 `protobuf:"varint,2,opt,name=total_read_count,json=totalReadCount,proto3" json:"total_read_count,omitempty"`
	// LastRead is the timestamp that this index was last being read from.
	LastRead string `protobuf:"bytes,3,opt,name=last_read,json=lastRead,proto3" json:",omitempty"`
	// TableID is the ID of the table this index is created on. This is same as
	// descpb.TableID and is unique within the cluster.
	TableID uint32 `protobuf:"varint,4,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	// IndexID is the ID of the index within the scope of the given table.
	IndexID      uint32 `protobuf:"varint,5,opt,name=index_id,json=indexId,proto3" json:"index_id,omitempty"`
	DatabaseName string `protobuf:"bytes,6,opt,name=database_name,json=databaseName,proto3" json:",omitempty"`
	TableName    string `protobuf:"bytes,7,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
	IndexName    string `protobuf:"bytes,8,opt,name=index_name,json=indexName,proto3" json:",omitempty"`
	IndexType    string `protobuf:"bytes,9,opt,name=index_type,json=indexType,proto3" json:",omitempty"`
	IsUnique     bool   `protobuf:"varint,10,opt,name=is_unique,json=isUnique,proto3" json:",omitempty"`
	IsInverted   bool   `protobuf:"varint,11,opt,name=is_inverted,json=isInverted,proto3" json:",omitempty"`
}

CapturedIndexUsageStats

func (*CapturedIndexUsageStats) AppendJSONFields 

func (m *CapturedIndexUsageStats) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CapturedIndexUsageStats) Descriptor 

func (*CapturedIndexUsageStats) Descriptor() ([]byte, []int)

func (*CapturedIndexUsageStats) LoggingChannel 

func (m *CapturedIndexUsageStats) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CapturedIndexUsageStats) Marshal 

func (m *CapturedIndexUsageStats) Marshal() (dAtA []byte, err error)

func (*CapturedIndexUsageStats) MarshalTo 

func (m *CapturedIndexUsageStats) MarshalTo(dAtA []byte) (int, error)

func (*CapturedIndexUsageStats) MarshalToSizedBuffer 

func (m *CapturedIndexUsageStats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CapturedIndexUsageStats) ProtoMessage 

func (*CapturedIndexUsageStats) ProtoMessage()

func (*CapturedIndexUsageStats) Reset 

func (m *CapturedIndexUsageStats) Reset()

func (*CapturedIndexUsageStats) Size 

func (m *CapturedIndexUsageStats) Size() (n int)

func (*CapturedIndexUsageStats) String 

func (m *CapturedIndexUsageStats) String() string

func (*CapturedIndexUsageStats) Unmarshal 

func (m *CapturedIndexUsageStats) Unmarshal(dAtA []byte) error

func (*CapturedIndexUsageStats) XXX_DiscardUnknown 

func (m *CapturedIndexUsageStats) XXX_DiscardUnknown()

func (*CapturedIndexUsageStats) XXX_Marshal 

func (m *CapturedIndexUsageStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CapturedIndexUsageStats) XXX_Merge 

func (m *CapturedIndexUsageStats) XXX_Merge(src proto.Message)

func (*CapturedIndexUsageStats) XXX_Size 

func (m *CapturedIndexUsageStats) XXX_Size() int

func (*CapturedIndexUsageStats) XXX_Unmarshal 

func (m *CapturedIndexUsageStats) XXX_Unmarshal(b []byte) error

type CertsReload 

type CertsReload struct {
	CommonEventDetails `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	// Whether the operation completed without errors.
	Success bool `protobuf:"varint,2,opt,name=success,proto3" json:",omitempty"`
	// If an error was encountered, the text of the error.
	ErrorMessage string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:",omitempty"`
}

CertsReload is recorded when the TLS certificates are reloaded/rotated from disk.

func (*CertsReload) AppendJSONFields 

func (m *CertsReload) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CertsReload) Descriptor 

func (*CertsReload) Descriptor() ([]byte, []int)

func (*CertsReload) LoggingChannel 

func (m *CertsReload) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CertsReload) Marshal 

func (m *CertsReload) Marshal() (dAtA []byte, err error)

func (*CertsReload) MarshalTo 

func (m *CertsReload) MarshalTo(dAtA []byte) (int, error)

func (*CertsReload) MarshalToSizedBuffer 

func (m *CertsReload) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CertsReload) ProtoMessage 

func (*CertsReload) ProtoMessage()

func (*CertsReload) Reset 

func (m *CertsReload) Reset()

func (*CertsReload) Size 

func (m *CertsReload) Size() (n int)

func (*CertsReload) String 

func (m *CertsReload) String() string

func (*CertsReload) Unmarshal 

func (m *CertsReload) Unmarshal(dAtA []byte) error

func (*CertsReload) XXX_DiscardUnknown 

func (m *CertsReload) XXX_DiscardUnknown()

func (*CertsReload) XXX_Marshal 

func (m *CertsReload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CertsReload) XXX_Merge 

func (m *CertsReload) XXX_Merge(src proto.Message)

func (*CertsReload) XXX_Size 

func (m *CertsReload) XXX_Size() int

func (*CertsReload) XXX_Unmarshal 

func (m *CertsReload) XXX_Unmarshal(b []byte) error

type ChangeDatabasePrivilege 

type ChangeDatabasePrivilege struct {
	CommonEventDetails             `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails          `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonSQLPrivilegeEventDetails `protobuf:"bytes,3,opt,name=privs,proto3,embedded=privs" json:""`
	// The name of the affected database.
	DatabaseName string `protobuf:"bytes,4,opt,name=database_name,json=databaseName,proto3" json:",omitempty"`
}

ChangeDatabasePrivilege is recorded when privileges are added to / removed from a user for a database object.

func (*ChangeDatabasePrivilege) AppendJSONFields 

func (m *ChangeDatabasePrivilege) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*ChangeDatabasePrivilege) Descriptor 

func (*ChangeDatabasePrivilege) Descriptor() ([]byte, []int)

func (*ChangeDatabasePrivilege) LoggingChannel 

func (m *ChangeDatabasePrivilege) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*ChangeDatabasePrivilege) Marshal 

func (m *ChangeDatabasePrivilege) Marshal() (dAtA []byte, err error)

func (*ChangeDatabasePrivilege) MarshalTo 

func (m *ChangeDatabasePrivilege) MarshalTo(dAtA []byte) (int, error)

func (*ChangeDatabasePrivilege) MarshalToSizedBuffer 

func (m *ChangeDatabasePrivilege) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChangeDatabasePrivilege) ProtoMessage 

func (*ChangeDatabasePrivilege) ProtoMessage()

func (*ChangeDatabasePrivilege) Reset 

func (m *ChangeDatabasePrivilege) Reset()

func (*ChangeDatabasePrivilege) Size 

func (m *ChangeDatabasePrivilege) Size() (n int)

func (*ChangeDatabasePrivilege) String 

func (m *ChangeDatabasePrivilege) String() string

func (*ChangeDatabasePrivilege) Unmarshal 

func (m *ChangeDatabasePrivilege) Unmarshal(dAtA []byte) error

func (*ChangeDatabasePrivilege) XXX_DiscardUnknown 

func (m *ChangeDatabasePrivilege) XXX_DiscardUnknown()

func (*ChangeDatabasePrivilege) XXX_Marshal 

func (m *ChangeDatabasePrivilege) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChangeDatabasePrivilege) XXX_Merge 

func (m *ChangeDatabasePrivilege) XXX_Merge(src proto.Message)

func (*ChangeDatabasePrivilege) XXX_Size 

func (m *ChangeDatabasePrivilege) XXX_Size() int

func (*ChangeDatabasePrivilege) XXX_Unmarshal 

func (m *ChangeDatabasePrivilege) XXX_Unmarshal(b []byte) error

type ChangeSchemaPrivilege 

type ChangeSchemaPrivilege struct {
	CommonEventDetails             `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails          `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonSQLPrivilegeEventDetails `protobuf:"bytes,3,opt,name=privs,proto3,embedded=privs" json:""`
	// The name of the affected schema.
	SchemaName string `protobuf:"bytes,4,opt,name=schema_name,json=schemaName,proto3" json:",omitempty"`
}

ChangeSchemaPrivilege is recorded when privileges are added to / removed from a user for a schema object.

func (*ChangeSchemaPrivilege) AppendJSONFields 

func (m *ChangeSchemaPrivilege) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*ChangeSchemaPrivilege) Descriptor 

func (*ChangeSchemaPrivilege) Descriptor() ([]byte, []int)

func (*ChangeSchemaPrivilege) LoggingChannel 

func (m *ChangeSchemaPrivilege) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*ChangeSchemaPrivilege) Marshal 

func (m *ChangeSchemaPrivilege) Marshal() (dAtA []byte, err error)

func (*ChangeSchemaPrivilege) MarshalTo 

func (m *ChangeSchemaPrivilege) MarshalTo(dAtA []byte) (int, error)

func (*ChangeSchemaPrivilege) MarshalToSizedBuffer 

func (m *ChangeSchemaPrivilege) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChangeSchemaPrivilege) ProtoMessage 

func (*ChangeSchemaPrivilege) ProtoMessage()

func (*ChangeSchemaPrivilege) Reset 

func (m *ChangeSchemaPrivilege) Reset()

func (*ChangeSchemaPrivilege) Size 

func (m *ChangeSchemaPrivilege) Size() (n int)

func (*ChangeSchemaPrivilege) String 

func (m *ChangeSchemaPrivilege) String() string

func (*ChangeSchemaPrivilege) Unmarshal 

func (m *ChangeSchemaPrivilege) Unmarshal(dAtA []byte) error

func (*ChangeSchemaPrivilege) XXX_DiscardUnknown 

func (m *ChangeSchemaPrivilege) XXX_DiscardUnknown()

func (*ChangeSchemaPrivilege) XXX_Marshal 

func (m *ChangeSchemaPrivilege) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChangeSchemaPrivilege) XXX_Merge 

func (m *ChangeSchemaPrivilege) XXX_Merge(src proto.Message)

func (*ChangeSchemaPrivilege) XXX_Size 

func (m *ChangeSchemaPrivilege) XXX_Size() int

func (*ChangeSchemaPrivilege) XXX_Unmarshal 

func (m *ChangeSchemaPrivilege) XXX_Unmarshal(b []byte) error

type ChangeTablePrivilege 

type ChangeTablePrivilege struct {
	CommonEventDetails             `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails          `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonSQLPrivilegeEventDetails `protobuf:"bytes,3,opt,name=privs,proto3,embedded=privs" json:""`
	// The name of the affected table.
	TableName string `protobuf:"bytes,4,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
}

ChangeTablePrivilege is recorded when privileges are added to / removed from a user for a table, sequence or view object.

func (*ChangeTablePrivilege) AppendJSONFields 

func (m *ChangeTablePrivilege) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*ChangeTablePrivilege) Descriptor 

func (*ChangeTablePrivilege) Descriptor() ([]byte, []int)

func (*ChangeTablePrivilege) LoggingChannel 

func (m *ChangeTablePrivilege) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*ChangeTablePrivilege) Marshal 

func (m *ChangeTablePrivilege) Marshal() (dAtA []byte, err error)

func (*ChangeTablePrivilege) MarshalTo 

func (m *ChangeTablePrivilege) MarshalTo(dAtA []byte) (int, error)

func (*ChangeTablePrivilege) MarshalToSizedBuffer 

func (m *ChangeTablePrivilege) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChangeTablePrivilege) ProtoMessage 

func (*ChangeTablePrivilege) ProtoMessage()

func (*ChangeTablePrivilege) Reset 

func (m *ChangeTablePrivilege) Reset()

func (*ChangeTablePrivilege) Size 

func (m *ChangeTablePrivilege) Size() (n int)

func (*ChangeTablePrivilege) String 

func (m *ChangeTablePrivilege) String() string

func (*ChangeTablePrivilege) Unmarshal 

func (m *ChangeTablePrivilege) Unmarshal(dAtA []byte) error

func (*ChangeTablePrivilege) XXX_DiscardUnknown 

func (m *ChangeTablePrivilege) XXX_DiscardUnknown()

func (*ChangeTablePrivilege) XXX_Marshal 

func (m *ChangeTablePrivilege) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChangeTablePrivilege) XXX_Merge 

func (m *ChangeTablePrivilege) XXX_Merge(src proto.Message)

func (*ChangeTablePrivilege) XXX_Size 

func (m *ChangeTablePrivilege) XXX_Size() int

func (*ChangeTablePrivilege) XXX_Unmarshal 

func (m *ChangeTablePrivilege) XXX_Unmarshal(b []byte) error

type ChangeTypePrivilege 

type ChangeTypePrivilege struct {
	CommonEventDetails             `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails          `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonSQLPrivilegeEventDetails `protobuf:"bytes,3,opt,name=privs,proto3,embedded=privs" json:""`
	// The name of the affected type.
	TypeName string `protobuf:"bytes,4,opt,name=type_name,json=typeName,proto3" json:",omitempty"`
}

ChangeTypePrivilege is recorded when privileges are added to / removed from a user for a type object.

func (*ChangeTypePrivilege) AppendJSONFields 

func (m *ChangeTypePrivilege) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*ChangeTypePrivilege) Descriptor 

func (*ChangeTypePrivilege) Descriptor() ([]byte, []int)

func (*ChangeTypePrivilege) LoggingChannel 

func (m *ChangeTypePrivilege) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*ChangeTypePrivilege) Marshal 

func (m *ChangeTypePrivilege) Marshal() (dAtA []byte, err error)

func (*ChangeTypePrivilege) MarshalTo 

func (m *ChangeTypePrivilege) MarshalTo(dAtA []byte) (int, error)

func (*ChangeTypePrivilege) MarshalToSizedBuffer 

func (m *ChangeTypePrivilege) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChangeTypePrivilege) ProtoMessage 

func (*ChangeTypePrivilege) ProtoMessage()

func (*ChangeTypePrivilege) Reset 

func (m *ChangeTypePrivilege) Reset()

func (*ChangeTypePrivilege) Size 

func (m *ChangeTypePrivilege) Size() (n int)

func (*ChangeTypePrivilege) String 

func (m *ChangeTypePrivilege) String() string

func (*ChangeTypePrivilege) Unmarshal 

func (m *ChangeTypePrivilege) Unmarshal(dAtA []byte) error

func (*ChangeTypePrivilege) XXX_DiscardUnknown 

func (m *ChangeTypePrivilege) XXX_DiscardUnknown()

func (*ChangeTypePrivilege) XXX_Marshal 

func (m *ChangeTypePrivilege) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChangeTypePrivilege) XXX_Merge 

func (m *ChangeTypePrivilege) XXX_Merge(src proto.Message)

func (*ChangeTypePrivilege) XXX_Size 

func (m *ChangeTypePrivilege) XXX_Size() int

func (*ChangeTypePrivilege) XXX_Unmarshal 

func (m *ChangeTypePrivilege) XXX_Unmarshal(b []byte) error

type ClientAuthenticationFailed 

type ClientAuthenticationFailed struct {
	CommonEventDetails      `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonConnectionDetails `protobuf:"bytes,2,opt,name=conn,proto3,embedded=conn" json:""`
	CommonSessionDetails    `protobuf:"bytes,3,opt,name=session,proto3,embedded=session" json:""`
	// The reason for the authentication failure.
	Reason AuthFailReason `` /* 129-byte string literal not displayed */
	// The detailed error for the authentication failure.
	Detail string `protobuf:"bytes,5,opt,name=detail,proto3" json:",omitempty"`
	// The authentication method used.
	Method string `protobuf:"bytes,6,opt,name=method,proto3" json:",omitempty" redact:"nonsensitive"`
}

ClientAuthenticationFailed is reported when a client session did not authenticate successfully.

Events of this type are only emitted when the cluster setting `server.auth_log.sql_sessions.enabled` is set.

func (*ClientAuthenticationFailed) AppendJSONFields 

func (m *ClientAuthenticationFailed) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*ClientAuthenticationFailed) Descriptor 

func (*ClientAuthenticationFailed) Descriptor() ([]byte, []int)

func (*ClientAuthenticationFailed) LoggingChannel 

func (m *ClientAuthenticationFailed) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*ClientAuthenticationFailed) Marshal 

func (m *ClientAuthenticationFailed) Marshal() (dAtA []byte, err error)

func (*ClientAuthenticationFailed) MarshalTo 

func (m *ClientAuthenticationFailed) MarshalTo(dAtA []byte) (int, error)

func (*ClientAuthenticationFailed) MarshalToSizedBuffer 

func (m *ClientAuthenticationFailed) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientAuthenticationFailed) ProtoMessage 

func (*ClientAuthenticationFailed) ProtoMessage()

func (*ClientAuthenticationFailed) Reset 

func (m *ClientAuthenticationFailed) Reset()

func (*ClientAuthenticationFailed) Size 

func (m *ClientAuthenticationFailed) Size() (n int)

func (*ClientAuthenticationFailed) String 

func (m *ClientAuthenticationFailed) String() string

func (*ClientAuthenticationFailed) Unmarshal 

func (m *ClientAuthenticationFailed) Unmarshal(dAtA []byte) error

func (*ClientAuthenticationFailed) XXX_DiscardUnknown 

func (m *ClientAuthenticationFailed) XXX_DiscardUnknown()

func (*ClientAuthenticationFailed) XXX_Marshal 

func (m *ClientAuthenticationFailed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientAuthenticationFailed) XXX_Merge 

func (m *ClientAuthenticationFailed) XXX_Merge(src proto.Message)

func (*ClientAuthenticationFailed) XXX_Size 

func (m *ClientAuthenticationFailed) XXX_Size() int

func (*ClientAuthenticationFailed) XXX_Unmarshal 

func (m *ClientAuthenticationFailed) XXX_Unmarshal(b []byte) error

type ClientAuthenticationInfo 

type ClientAuthenticationInfo struct {
	CommonEventDetails      `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonConnectionDetails `protobuf:"bytes,2,opt,name=conn,proto3,embedded=conn" json:""`
	CommonSessionDetails    `protobuf:"bytes,3,opt,name=session,proto3,embedded=session" json:""`
	// The authentication method used, once known.
	Method string `protobuf:"bytes,4,opt,name=method,proto3" json:",omitempty" redact:"nonsensitive"`
	// The authentication progress message.
	Info string `protobuf:"bytes,5,opt,name=info,proto3" json:",omitempty"`
}

ClientAuthenticationInfo is reported for intermediate steps during the authentication process.

Events of this type are only emitted when the cluster setting `server.auth_log.sql_sessions.enabled` is set.

func (*ClientAuthenticationInfo) AppendJSONFields 

func (m *ClientAuthenticationInfo) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*ClientAuthenticationInfo) Descriptor 

func (*ClientAuthenticationInfo) Descriptor() ([]byte, []int)

func (*ClientAuthenticationInfo) LoggingChannel 

func (m *ClientAuthenticationInfo) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*ClientAuthenticationInfo) Marshal 

func (m *ClientAuthenticationInfo) Marshal() (dAtA []byte, err error)

func (*ClientAuthenticationInfo) MarshalTo 

func (m *ClientAuthenticationInfo) MarshalTo(dAtA []byte) (int, error)

func (*ClientAuthenticationInfo) MarshalToSizedBuffer 

func (m *ClientAuthenticationInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientAuthenticationInfo) ProtoMessage 

func (*ClientAuthenticationInfo) ProtoMessage()

func (*ClientAuthenticationInfo) Reset 

func (m *ClientAuthenticationInfo) Reset()

func (*ClientAuthenticationInfo) Size 

func (m *ClientAuthenticationInfo) Size() (n int)

func (*ClientAuthenticationInfo) String 

func (m *ClientAuthenticationInfo) String() string

func (*ClientAuthenticationInfo) Unmarshal 

func (m *ClientAuthenticationInfo) Unmarshal(dAtA []byte) error

func (*ClientAuthenticationInfo) XXX_DiscardUnknown 

func (m *ClientAuthenticationInfo) XXX_DiscardUnknown()

func (*ClientAuthenticationInfo) XXX_Marshal 

func (m *ClientAuthenticationInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientAuthenticationInfo) XXX_Merge 

func (m *ClientAuthenticationInfo) XXX_Merge(src proto.Message)

func (*ClientAuthenticationInfo) XXX_Size 

func (m *ClientAuthenticationInfo) XXX_Size() int

func (*ClientAuthenticationInfo) XXX_Unmarshal 

func (m *ClientAuthenticationInfo) XXX_Unmarshal(b []byte) error

type ClientAuthenticationOk 

type ClientAuthenticationOk struct {
	CommonEventDetails      `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonConnectionDetails `protobuf:"bytes,2,opt,name=conn,proto3,embedded=conn" json:""`
	CommonSessionDetails    `protobuf:"bytes,3,opt,name=session,proto3,embedded=session" json:""`
	// The authentication method used.
	Method string `protobuf:"bytes,4,opt,name=method,proto3" json:",omitempty" redact:"nonsensitive"`
}

ClientAuthenticationOk is reported when a client session was authenticated successfully.

Events of this type are only emitted when the cluster setting `server.auth_log.sql_sessions.enabled` is set.

func (*ClientAuthenticationOk) AppendJSONFields 

func (m *ClientAuthenticationOk) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*ClientAuthenticationOk) Descriptor 

func (*ClientAuthenticationOk) Descriptor() ([]byte, []int)

func (*ClientAuthenticationOk) LoggingChannel 

func (m *ClientAuthenticationOk) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*ClientAuthenticationOk) Marshal 

func (m *ClientAuthenticationOk) Marshal() (dAtA []byte, err error)

func (*ClientAuthenticationOk) MarshalTo 

func (m *ClientAuthenticationOk) MarshalTo(dAtA []byte) (int, error)

func (*ClientAuthenticationOk) MarshalToSizedBuffer 

func (m *ClientAuthenticationOk) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientAuthenticationOk) ProtoMessage 

func (*ClientAuthenticationOk) ProtoMessage()

func (*ClientAuthenticationOk) Reset 

func (m *ClientAuthenticationOk) Reset()

func (*ClientAuthenticationOk) Size 

func (m *ClientAuthenticationOk) Size() (n int)

func (*ClientAuthenticationOk) String 

func (m *ClientAuthenticationOk) String() string

func (*ClientAuthenticationOk) Unmarshal 

func (m *ClientAuthenticationOk) Unmarshal(dAtA []byte) error

func (*ClientAuthenticationOk) XXX_DiscardUnknown 

func (m *ClientAuthenticationOk) XXX_DiscardUnknown()

func (*ClientAuthenticationOk) XXX_Marshal 

func (m *ClientAuthenticationOk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientAuthenticationOk) XXX_Merge 

func (m *ClientAuthenticationOk) XXX_Merge(src proto.Message)

func (*ClientAuthenticationOk) XXX_Size 

func (m *ClientAuthenticationOk) XXX_Size() int

func (*ClientAuthenticationOk) XXX_Unmarshal 

func (m *ClientAuthenticationOk) XXX_Unmarshal(b []byte) error

type ClientConnectionEnd 

type ClientConnectionEnd struct {
	CommonEventDetails      `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonConnectionDetails `protobuf:"bytes,2,opt,name=conn,proto3,embedded=conn" json:""`
	// The duration of the connection in nanoseconds.
	Duration int64 `protobuf:"varint,3,opt,name=duration,proto3" json:",omitempty"`
}

ClientConnectionEnd is reported when a client connection is closed. This is reported even when authentication fails, and even for simple cancellation messages.

Events of this type are only emitted when the cluster setting `server.auth_log.sql_connections.enabled` is set.

func (*ClientConnectionEnd) AppendJSONFields 

func (m *ClientConnectionEnd) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*ClientConnectionEnd) Descriptor 

func (*ClientConnectionEnd) Descriptor() ([]byte, []int)

func (*ClientConnectionEnd) LoggingChannel 

func (m *ClientConnectionEnd) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*ClientConnectionEnd) Marshal 

func (m *ClientConnectionEnd) Marshal() (dAtA []byte, err error)

func (*ClientConnectionEnd) MarshalTo 

func (m *ClientConnectionEnd) MarshalTo(dAtA []byte) (int, error)

func (*ClientConnectionEnd) MarshalToSizedBuffer 

func (m *ClientConnectionEnd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientConnectionEnd) ProtoMessage 

func (*ClientConnectionEnd) ProtoMessage()

func (*ClientConnectionEnd) Reset 

func (m *ClientConnectionEnd) Reset()

func (*ClientConnectionEnd) Size 

func (m *ClientConnectionEnd) Size() (n int)

func (*ClientConnectionEnd) String 

func (m *ClientConnectionEnd) String() string

func (*ClientConnectionEnd) Unmarshal 

func (m *ClientConnectionEnd) Unmarshal(dAtA []byte) error

func (*ClientConnectionEnd) XXX_DiscardUnknown 

func (m *ClientConnectionEnd) XXX_DiscardUnknown()

func (*ClientConnectionEnd) XXX_Marshal 

func (m *ClientConnectionEnd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientConnectionEnd) XXX_Merge 

func (m *ClientConnectionEnd) XXX_Merge(src proto.Message)

func (*ClientConnectionEnd) XXX_Size 

func (m *ClientConnectionEnd) XXX_Size() int

func (*ClientConnectionEnd) XXX_Unmarshal 

func (m *ClientConnectionEnd) XXX_Unmarshal(b []byte) error

type ClientConnectionStart 

type ClientConnectionStart struct {
	CommonEventDetails      `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonConnectionDetails `protobuf:"bytes,2,opt,name=conn,proto3,embedded=conn" json:""`
}

ClientConnectionStart is reported when a client connection is established. This is reported even when authentication fails, and even for simple cancellation messages.

Events of this type are only emitted when the cluster setting `server.auth_log.sql_connections.enabled` is set.

func (*ClientConnectionStart) AppendJSONFields 

func (m *ClientConnectionStart) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*ClientConnectionStart) Descriptor 

func (*ClientConnectionStart) Descriptor() ([]byte, []int)

func (*ClientConnectionStart) LoggingChannel 

func (m *ClientConnectionStart) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*ClientConnectionStart) Marshal 

func (m *ClientConnectionStart) Marshal() (dAtA []byte, err error)

func (*ClientConnectionStart) MarshalTo 

func (m *ClientConnectionStart) MarshalTo(dAtA []byte) (int, error)

func (*ClientConnectionStart) MarshalToSizedBuffer 

func (m *ClientConnectionStart) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientConnectionStart) ProtoMessage 

func (*ClientConnectionStart) ProtoMessage()

func (*ClientConnectionStart) Reset 

func (m *ClientConnectionStart) Reset()

func (*ClientConnectionStart) Size 

func (m *ClientConnectionStart) Size() (n int)

func (*ClientConnectionStart) String 

func (m *ClientConnectionStart) String() string

func (*ClientConnectionStart) Unmarshal 

func (m *ClientConnectionStart) Unmarshal(dAtA []byte) error

func (*ClientConnectionStart) XXX_DiscardUnknown 

func (m *ClientConnectionStart) XXX_DiscardUnknown()

func (*ClientConnectionStart) XXX_Marshal 

func (m *ClientConnectionStart) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientConnectionStart) XXX_Merge 

func (m *ClientConnectionStart) XXX_Merge(src proto.Message)

func (*ClientConnectionStart) XXX_Size 

func (m *ClientConnectionStart) XXX_Size() int

func (*ClientConnectionStart) XXX_Unmarshal 

func (m *ClientConnectionStart) XXX_Unmarshal(b []byte) error

type ClientSessionEnd 

type ClientSessionEnd struct {
	CommonEventDetails      `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonConnectionDetails `protobuf:"bytes,2,opt,name=conn,proto3,embedded=conn" json:""`
	CommonSessionDetails    `protobuf:"bytes,3,opt,name=session,proto3,embedded=session" json:""`
	// The duration of the connection in nanoseconds.
	Duration int64 `protobuf:"varint,4,opt,name=duration,proto3" json:",omitempty"`
}

ClientSessionEnd is reported when a client session is completed.

Events of this type are only emitted when the cluster setting `server.auth_log.sql_sessions.enabled` is set.

func (*ClientSessionEnd) AppendJSONFields 

func (m *ClientSessionEnd) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*ClientSessionEnd) Descriptor 

func (*ClientSessionEnd) Descriptor() ([]byte, []int)

func (*ClientSessionEnd) LoggingChannel 

func (m *ClientSessionEnd) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*ClientSessionEnd) Marshal 

func (m *ClientSessionEnd) Marshal() (dAtA []byte, err error)

func (*ClientSessionEnd) MarshalTo 

func (m *ClientSessionEnd) MarshalTo(dAtA []byte) (int, error)

func (*ClientSessionEnd) MarshalToSizedBuffer 

func (m *ClientSessionEnd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientSessionEnd) ProtoMessage 

func (*ClientSessionEnd) ProtoMessage()

func (*ClientSessionEnd) Reset 

func (m *ClientSessionEnd) Reset()

func (*ClientSessionEnd) Size 

func (m *ClientSessionEnd) Size() (n int)

func (*ClientSessionEnd) String 

func (m *ClientSessionEnd) String() string

func (*ClientSessionEnd) Unmarshal 

func (m *ClientSessionEnd) Unmarshal(dAtA []byte) error

func (*ClientSessionEnd) XXX_DiscardUnknown 

func (m *ClientSessionEnd) XXX_DiscardUnknown()

func (*ClientSessionEnd) XXX_Marshal 

func (m *ClientSessionEnd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientSessionEnd) XXX_Merge 

func (m *ClientSessionEnd) XXX_Merge(src proto.Message)

func (*ClientSessionEnd) XXX_Size 

func (m *ClientSessionEnd) XXX_Size() int

func (*ClientSessionEnd) XXX_Unmarshal 

func (m *ClientSessionEnd) XXX_Unmarshal(b []byte) error

type CommentOnColumn 

type CommentOnColumn struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the table containing the affected column.
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
	// The affected column.
	ColumnName string `protobuf:"bytes,4,opt,name=column_name,json=columnName,proto3" json:",omitempty"`
	// The new comment.
	Comment string `protobuf:"bytes,5,opt,name=comment,proto3" json:",omitempty"`
	// Set to true if the comment was removed entirely.
	NullComment bool `protobuf:"varint,6,opt,name=null_comment,json=nullComment,proto3" json:",omitempty"`
}

CommentOnColumn is recorded when a column is commented.

func (*CommentOnColumn) AppendJSONFields 

func (m *CommentOnColumn) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommentOnColumn) Descriptor 

func (*CommentOnColumn) Descriptor() ([]byte, []int)

func (*CommentOnColumn) LoggingChannel 

func (m *CommentOnColumn) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CommentOnColumn) Marshal 

func (m *CommentOnColumn) Marshal() (dAtA []byte, err error)

func (*CommentOnColumn) MarshalTo 

func (m *CommentOnColumn) MarshalTo(dAtA []byte) (int, error)

func (*CommentOnColumn) MarshalToSizedBuffer 

func (m *CommentOnColumn) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommentOnColumn) ProtoMessage 

func (*CommentOnColumn) ProtoMessage()

func (*CommentOnColumn) Reset 

func (m *CommentOnColumn) Reset()

func (*CommentOnColumn) Size 

func (m *CommentOnColumn) Size() (n int)

func (*CommentOnColumn) String 

func (m *CommentOnColumn) String() string

func (*CommentOnColumn) Unmarshal 

func (m *CommentOnColumn) Unmarshal(dAtA []byte) error

func (*CommentOnColumn) XXX_DiscardUnknown 

func (m *CommentOnColumn) XXX_DiscardUnknown()

func (*CommentOnColumn) XXX_Marshal 

func (m *CommentOnColumn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommentOnColumn) XXX_Merge 

func (m *CommentOnColumn) XXX_Merge(src proto.Message)

func (*CommentOnColumn) XXX_Size 

func (m *CommentOnColumn) XXX_Size() int

func (*CommentOnColumn) XXX_Unmarshal 

func (m *CommentOnColumn) XXX_Unmarshal(b []byte) error

type CommentOnConstraint 

type CommentOnConstraint struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the table containing the affected constraint.
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
	// The name of the affected constraint.
	ConstraintName string `protobuf:"bytes,4,opt,name=constraint_name,json=constraintName,proto3" json:",omitempty"`
	// The new comment.
	Comment string `protobuf:"bytes,5,opt,name=comment,proto3" json:",omitempty"`
	// Set to true if the comment was removed entirely.
	NullComment bool `protobuf:"varint,6,opt,name=null_comment,json=nullComment,proto3" json:",omitempty"`
}

CommentOnConstraint is recorded when an constraint is commented.

func (*CommentOnConstraint) AppendJSONFields 

func (m *CommentOnConstraint) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommentOnConstraint) Descriptor 

func (*CommentOnConstraint) Descriptor() ([]byte, []int)

func (*CommentOnConstraint) LoggingChannel 

func (m *CommentOnConstraint) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CommentOnConstraint) Marshal 

func (m *CommentOnConstraint) Marshal() (dAtA []byte, err error)

func (*CommentOnConstraint) MarshalTo 

func (m *CommentOnConstraint) MarshalTo(dAtA []byte) (int, error)

func (*CommentOnConstraint) MarshalToSizedBuffer 

func (m *CommentOnConstraint) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommentOnConstraint) ProtoMessage 

func (*CommentOnConstraint) ProtoMessage()

func (*CommentOnConstraint) Reset 

func (m *CommentOnConstraint) Reset()

func (*CommentOnConstraint) Size 

func (m *CommentOnConstraint) Size() (n int)

func (*CommentOnConstraint) String 

func (m *CommentOnConstraint) String() string

func (*CommentOnConstraint) Unmarshal 

func (m *CommentOnConstraint) Unmarshal(dAtA []byte) error

func (*CommentOnConstraint) XXX_DiscardUnknown 

func (m *CommentOnConstraint) XXX_DiscardUnknown()

func (*CommentOnConstraint) XXX_Marshal 

func (m *CommentOnConstraint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommentOnConstraint) XXX_Merge 

func (m *CommentOnConstraint) XXX_Merge(src proto.Message)

func (*CommentOnConstraint) XXX_Size 

func (m *CommentOnConstraint) XXX_Size() int

func (*CommentOnConstraint) XXX_Unmarshal 

func (m *CommentOnConstraint) XXX_Unmarshal(b []byte) error

type CommentOnDatabase 

type CommentOnDatabase struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected database.
	DatabaseName string `protobuf:"bytes,3,opt,name=database_name,json=databaseName,proto3" json:",omitempty"`
	// The new comment.
	Comment string `protobuf:"bytes,4,opt,name=comment,proto3" json:",omitempty"`
	// Set to true if the comment was removed entirely.
	NullComment bool `protobuf:"varint,6,opt,name=null_comment,json=nullComment,proto3" json:",omitempty"`
}

CommentOnTable is recorded when a database is commented.

func (*CommentOnDatabase) AppendJSONFields 

func (m *CommentOnDatabase) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommentOnDatabase) Descriptor 

func (*CommentOnDatabase) Descriptor() ([]byte, []int)

func (*CommentOnDatabase) LoggingChannel 

func (m *CommentOnDatabase) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CommentOnDatabase) Marshal 

func (m *CommentOnDatabase) Marshal() (dAtA []byte, err error)

func (*CommentOnDatabase) MarshalTo 

func (m *CommentOnDatabase) MarshalTo(dAtA []byte) (int, error)

func (*CommentOnDatabase) MarshalToSizedBuffer 

func (m *CommentOnDatabase) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommentOnDatabase) ProtoMessage 

func (*CommentOnDatabase) ProtoMessage()

func (*CommentOnDatabase) Reset 

func (m *CommentOnDatabase) Reset()

func (*CommentOnDatabase) Size 

func (m *CommentOnDatabase) Size() (n int)

func (*CommentOnDatabase) String 

func (m *CommentOnDatabase) String() string

func (*CommentOnDatabase) Unmarshal 

func (m *CommentOnDatabase) Unmarshal(dAtA []byte) error

func (*CommentOnDatabase) XXX_DiscardUnknown 

func (m *CommentOnDatabase) XXX_DiscardUnknown()

func (*CommentOnDatabase) XXX_Marshal 

func (m *CommentOnDatabase) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommentOnDatabase) XXX_Merge 

func (m *CommentOnDatabase) XXX_Merge(src proto.Message)

func (*CommentOnDatabase) XXX_Size 

func (m *CommentOnDatabase) XXX_Size() int

func (*CommentOnDatabase) XXX_Unmarshal 

func (m *CommentOnDatabase) XXX_Unmarshal(b []byte) error

type CommentOnIndex 

type CommentOnIndex struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the table containing the affected index.
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
	// The name of the affected index.
	IndexName string `protobuf:"bytes,4,opt,name=index_name,json=indexName,proto3" json:",omitempty"`
	// The new comment.
	Comment string `protobuf:"bytes,5,opt,name=comment,proto3" json:",omitempty"`
	// Set to true if the comment was removed entirely.
	NullComment bool `protobuf:"varint,6,opt,name=null_comment,json=nullComment,proto3" json:",omitempty"`
}

CommentOnIndex is recorded when an index is commented.

func (*CommentOnIndex) AppendJSONFields 

func (m *CommentOnIndex) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommentOnIndex) Descriptor 

func (*CommentOnIndex) Descriptor() ([]byte, []int)

func (*CommentOnIndex) LoggingChannel 

func (m *CommentOnIndex) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CommentOnIndex) Marshal 

func (m *CommentOnIndex) Marshal() (dAtA []byte, err error)

func (*CommentOnIndex) MarshalTo 

func (m *CommentOnIndex) MarshalTo(dAtA []byte) (int, error)

func (*CommentOnIndex) MarshalToSizedBuffer 

func (m *CommentOnIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommentOnIndex) ProtoMessage 

func (*CommentOnIndex) ProtoMessage()

func (*CommentOnIndex) Reset 

func (m *CommentOnIndex) Reset()

func (*CommentOnIndex) Size 

func (m *CommentOnIndex) Size() (n int)

func (*CommentOnIndex) String 

func (m *CommentOnIndex) String() string

func (*CommentOnIndex) Unmarshal 

func (m *CommentOnIndex) Unmarshal(dAtA []byte) error

func (*CommentOnIndex) XXX_DiscardUnknown 

func (m *CommentOnIndex) XXX_DiscardUnknown()

func (*CommentOnIndex) XXX_Marshal 

func (m *CommentOnIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommentOnIndex) XXX_Merge 

func (m *CommentOnIndex) XXX_Merge(src proto.Message)

func (*CommentOnIndex) XXX_Size 

func (m *CommentOnIndex) XXX_Size() int

func (*CommentOnIndex) XXX_Unmarshal 

func (m *CommentOnIndex) XXX_Unmarshal(b []byte) error

type CommentOnTable 

type CommentOnTable struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected table.
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
	// The new comment.
	Comment string `protobuf:"bytes,4,opt,name=comment,proto3" json:",omitempty"`
	// Set to true if the comment was removed entirely.
	NullComment bool `protobuf:"varint,6,opt,name=null_comment,json=nullComment,proto3" json:",omitempty"`
}

CommentOnTable is recorded when a table is commented.

func (*CommentOnTable) AppendJSONFields 

func (m *CommentOnTable) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommentOnTable) Descriptor 

func (*CommentOnTable) Descriptor() ([]byte, []int)

func (*CommentOnTable) LoggingChannel 

func (m *CommentOnTable) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CommentOnTable) Marshal 

func (m *CommentOnTable) Marshal() (dAtA []byte, err error)

func (*CommentOnTable) MarshalTo 

func (m *CommentOnTable) MarshalTo(dAtA []byte) (int, error)

func (*CommentOnTable) MarshalToSizedBuffer 

func (m *CommentOnTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommentOnTable) ProtoMessage 

func (*CommentOnTable) ProtoMessage()

func (*CommentOnTable) Reset 

func (m *CommentOnTable) Reset()

func (*CommentOnTable) Size 

func (m *CommentOnTable) Size() (n int)

func (*CommentOnTable) String 

func (m *CommentOnTable) String() string

func (*CommentOnTable) Unmarshal 

func (m *CommentOnTable) Unmarshal(dAtA []byte) error

func (*CommentOnTable) XXX_DiscardUnknown 

func (m *CommentOnTable) XXX_DiscardUnknown()

func (*CommentOnTable) XXX_Marshal 

func (m *CommentOnTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommentOnTable) XXX_Merge 

func (m *CommentOnTable) XXX_Merge(src proto.Message)

func (*CommentOnTable) XXX_Size 

func (m *CommentOnTable) XXX_Size() int

func (*CommentOnTable) XXX_Unmarshal 

func (m *CommentOnTable) XXX_Unmarshal(b []byte) error

type CommonConnectionDetails 

type CommonConnectionDetails struct {
	// The instance ID (not tenant ID) of the SQL server where the event was originated.
	InstanceID int32 `protobuf:"varint,1,opt,name=instance_id,json=instanceId,proto3" json:",omitempty"`
	// The network protocol for this connection: tcp4, tcp6, unix, etc.
	Network string `protobuf:"bytes,2,opt,name=network,proto3" json:",omitempty" redact:"nonsensitive"`
	// The remote address of the SQL client. Note that when using a
	// proxy or other intermediate server, this field will contain the
	// address of the intermediate server.
	RemoteAddress string `protobuf:"bytes,3,opt,name=remote_address,json=remoteAddress,proto3" json:",omitempty"`
}

CommonConnectionDetails are payload fields common to all connection/session events.

Events of this type are only emitted when the cluster setting `server.auth_log.sql_connections.enabled` is set.

func (*CommonConnectionDetails) AppendJSONFields 

func (m *CommonConnectionDetails) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommonConnectionDetails) Descriptor 

func (*CommonConnectionDetails) Descriptor() ([]byte, []int)

func (*CommonConnectionDetails) Marshal 

func (m *CommonConnectionDetails) Marshal() (dAtA []byte, err error)

func (*CommonConnectionDetails) MarshalTo 

func (m *CommonConnectionDetails) MarshalTo(dAtA []byte) (int, error)

func (*CommonConnectionDetails) MarshalToSizedBuffer 

func (m *CommonConnectionDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommonConnectionDetails) ProtoMessage 

func (*CommonConnectionDetails) ProtoMessage()

func (*CommonConnectionDetails) Reset 

func (m *CommonConnectionDetails) Reset()

func (*CommonConnectionDetails) Size 

func (m *CommonConnectionDetails) Size() (n int)

func (*CommonConnectionDetails) String 

func (m *CommonConnectionDetails) String() string

func (*CommonConnectionDetails) Unmarshal 

func (m *CommonConnectionDetails) Unmarshal(dAtA []byte) error

func (*CommonConnectionDetails) XXX_DiscardUnknown 

func (m *CommonConnectionDetails) XXX_DiscardUnknown()

func (*CommonConnectionDetails) XXX_Marshal 

func (m *CommonConnectionDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonConnectionDetails) XXX_Merge 

func (m *CommonConnectionDetails) XXX_Merge(src proto.Message)

func (*CommonConnectionDetails) XXX_Size 

func (m *CommonConnectionDetails) XXX_Size() int

func (*CommonConnectionDetails) XXX_Unmarshal 

func (m *CommonConnectionDetails) XXX_Unmarshal(b []byte) error

type CommonDebugEventDetails 

type CommonDebugEventDetails struct {
	// The node ID where the event originated.
	NodeID int32 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:",omitempty"`
	// The user which performed the operation.
	User string `protobuf:"bytes,2,opt,name=user,proto3" json:",omitempty"`
}

CommonDebugEventDetails contains the fields common to all debugging events.

func (*CommonDebugEventDetails) AppendJSONFields 

func (m *CommonDebugEventDetails) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommonDebugEventDetails) Descriptor 

func (*CommonDebugEventDetails) Descriptor() ([]byte, []int)

func (*CommonDebugEventDetails) Marshal 

func (m *CommonDebugEventDetails) Marshal() (dAtA []byte, err error)

func (*CommonDebugEventDetails) MarshalTo 

func (m *CommonDebugEventDetails) MarshalTo(dAtA []byte) (int, error)

func (*CommonDebugEventDetails) MarshalToSizedBuffer 

func (m *CommonDebugEventDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommonDebugEventDetails) ProtoMessage 

func (*CommonDebugEventDetails) ProtoMessage()

func (*CommonDebugEventDetails) Reset 

func (m *CommonDebugEventDetails) Reset()

func (*CommonDebugEventDetails) Size 

func (m *CommonDebugEventDetails) Size() (n int)

func (*CommonDebugEventDetails) String 

func (m *CommonDebugEventDetails) String() string

func (*CommonDebugEventDetails) Unmarshal 

func (m *CommonDebugEventDetails) Unmarshal(dAtA []byte) error

func (*CommonDebugEventDetails) XXX_DiscardUnknown 

func (m *CommonDebugEventDetails) XXX_DiscardUnknown()

func (*CommonDebugEventDetails) XXX_Marshal 

func (m *CommonDebugEventDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonDebugEventDetails) XXX_Merge 

func (m *CommonDebugEventDetails) XXX_Merge(src proto.Message)

func (*CommonDebugEventDetails) XXX_Size 

func (m *CommonDebugEventDetails) XXX_Size() int

func (*CommonDebugEventDetails) XXX_Unmarshal 

func (m *CommonDebugEventDetails) XXX_Unmarshal(b []byte) error

type CommonEventDetails 

type CommonEventDetails struct {
	// The timestamp of the event. Expressed as nanoseconds since
	// the Unix epoch.
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:",omitempty"`
	// The type of the event.
	EventType string `protobuf:"bytes,2,opt,name=event_type,json=eventType,proto3" json:",omitempty" redact:"nonsensitive"`
}

CommonEventDetails contains the fields common to all events.

func (*CommonEventDetails) AppendJSONFields 

func (m *CommonEventDetails) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommonEventDetails) CommonDetails 

func (m *CommonEventDetails) CommonDetails() *CommonEventDetails

CommonDetails implements the EventWithCommonPayload interface.

func (*CommonEventDetails) Descriptor 

func (*CommonEventDetails) Descriptor() ([]byte, []int)

func (*CommonEventDetails) Marshal 

func (m *CommonEventDetails) Marshal() (dAtA []byte, err error)

func (*CommonEventDetails) MarshalTo 

func (m *CommonEventDetails) MarshalTo(dAtA []byte) (int, error)

func (*CommonEventDetails) MarshalToSizedBuffer 

func (m *CommonEventDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommonEventDetails) ProtoMessage 

func (*CommonEventDetails) ProtoMessage()

func (*CommonEventDetails) Reset 

func (m *CommonEventDetails) Reset()

func (*CommonEventDetails) Size 

func (m *CommonEventDetails) Size() (n int)

func (*CommonEventDetails) String 

func (m *CommonEventDetails) String() string

func (*CommonEventDetails) Unmarshal 

func (m *CommonEventDetails) Unmarshal(dAtA []byte) error

func (*CommonEventDetails) XXX_DiscardUnknown 

func (m *CommonEventDetails) XXX_DiscardUnknown()

func (*CommonEventDetails) XXX_Marshal 

func (m *CommonEventDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonEventDetails) XXX_Merge 

func (m *CommonEventDetails) XXX_Merge(src proto.Message)

func (*CommonEventDetails) XXX_Size 

func (m *CommonEventDetails) XXX_Size() int

func (*CommonEventDetails) XXX_Unmarshal 

func (m *CommonEventDetails) XXX_Unmarshal(b []byte) error

type CommonJobEventDetails 

type CommonJobEventDetails struct {
	// The ID of the job that triggered the event.
	JobID int64 `protobuf:"varint,1,opt,name=job_id,json=jobId,proto3" json:",omitempty"`
	// The type of the job that triggered the event.
	JobType string `protobuf:"bytes,2,opt,name=job_type,json=jobType,proto3" json:",omitempty" redact:"nonsensitive"`
	// A description of the job that triggered the event. Some jobs populate the
	// description with an approximate representation of the SQL statement run to
	// create the job.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:",omitempty"`
	// The user account that triggered the event.
	User string `protobuf:"bytes,4,opt,name=user,proto3" json:",omitempty"`
	// The object descriptors affected by the job. Set to zero for operations
	// that don't affect descriptors.
	DescriptorIDs []uint32 `protobuf:"varint,5,rep,packed,name=descriptor_ids,json=descriptorIds,proto3" json:",omitempty"`
	// The status of the job that triggered the event. This allows the job to
	// indicate which phase execution it is in when the event is triggered.
	Status string `protobuf:"bytes,6,opt,name=status,proto3" json:",omitempty" redact:"nonsensitive"`
}

CommonJobEventDetails contains the fields common to all job events.

func (*CommonJobEventDetails) AppendJSONFields 

func (m *CommonJobEventDetails) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommonJobEventDetails) CommonJobDetails 

func (m *CommonJobEventDetails) CommonJobDetails() *CommonJobEventDetails

CommonJobDetails implements the EventWithCommonJobPayload interface.

func (*CommonJobEventDetails) Descriptor 

func (*CommonJobEventDetails) Descriptor() ([]byte, []int)

func (*CommonJobEventDetails) Marshal 

func (m *CommonJobEventDetails) Marshal() (dAtA []byte, err error)

func (*CommonJobEventDetails) MarshalTo 

func (m *CommonJobEventDetails) MarshalTo(dAtA []byte) (int, error)

func (*CommonJobEventDetails) MarshalToSizedBuffer 

func (m *CommonJobEventDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommonJobEventDetails) ProtoMessage 

func (*CommonJobEventDetails) ProtoMessage()

func (*CommonJobEventDetails) Reset 

func (m *CommonJobEventDetails) Reset()

func (*CommonJobEventDetails) Size 

func (m *CommonJobEventDetails) Size() (n int)

func (*CommonJobEventDetails) String 

func (m *CommonJobEventDetails) String() string

func (*CommonJobEventDetails) Unmarshal 

func (m *CommonJobEventDetails) Unmarshal(dAtA []byte) error

func (*CommonJobEventDetails) XXX_DiscardUnknown 

func (m *CommonJobEventDetails) XXX_DiscardUnknown()

func (*CommonJobEventDetails) XXX_Marshal 

func (m *CommonJobEventDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonJobEventDetails) XXX_Merge 

func (m *CommonJobEventDetails) XXX_Merge(src proto.Message)

func (*CommonJobEventDetails) XXX_Size 

func (m *CommonJobEventDetails) XXX_Size() int

func (*CommonJobEventDetails) XXX_Unmarshal 

func (m *CommonJobEventDetails) XXX_Unmarshal(b []byte) error

type CommonLargeRowDetails 

type CommonLargeRowDetails struct {
	RowSize    uint32 `protobuf:"varint,1,opt,name=row_size,json=rowSize,proto3" json:",omitempty"`
	TableID    uint32 `protobuf:"varint,2,opt,name=table_id,json=tableId,proto3" json:",omitempty"`
	FamilyID   uint32 `protobuf:"varint,3,opt,name=family_id,json=familyId,proto3" json:",omitempty"`
	PrimaryKey string `protobuf:"bytes,4,opt,name=primary_key,json=primaryKey,proto3" json:",omitempty"`
}

CommonLargeRowDetails contains the fields common to both LargeRow and LargeRowInternal events.

func (*CommonLargeRowDetails) AppendJSONFields 

func (m *CommonLargeRowDetails) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommonLargeRowDetails) Descriptor 

func (*CommonLargeRowDetails) Descriptor() ([]byte, []int)

func (*CommonLargeRowDetails) Error 

func (r *CommonLargeRowDetails) Error() string

Error is part of the error interface, which CommonLargeRowDetails implements.

func (*CommonLargeRowDetails) Format 

func (r *CommonLargeRowDetails) Format(s fmt.State, verb rune)

Format is part of the fmt.Formatter interface, which CommonLargeRowDetails implements.

func (*CommonLargeRowDetails) Marshal 

func (m *CommonLargeRowDetails) Marshal() (dAtA []byte, err error)

func (*CommonLargeRowDetails) MarshalTo 

func (m *CommonLargeRowDetails) MarshalTo(dAtA []byte) (int, error)

func (*CommonLargeRowDetails) MarshalToSizedBuffer 

func (m *CommonLargeRowDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommonLargeRowDetails) ProtoMessage 

func (*CommonLargeRowDetails) ProtoMessage()

func (*CommonLargeRowDetails) Reset 

func (m *CommonLargeRowDetails) Reset()

func (*CommonLargeRowDetails) SafeFormatError 

func (r *CommonLargeRowDetails) SafeFormatError(p errors.Printer) (next error)

SafeFormatError is part of the errors.SafeFormatter interface, which CommonLargeRowDetails implements.

func (*CommonLargeRowDetails) Size 

func (m *CommonLargeRowDetails) Size() (n int)

func (*CommonLargeRowDetails) String 

func (m *CommonLargeRowDetails) String() string

func (*CommonLargeRowDetails) Unmarshal 

func (m *CommonLargeRowDetails) Unmarshal(dAtA []byte) error

func (*CommonLargeRowDetails) XXX_DiscardUnknown 

func (m *CommonLargeRowDetails) XXX_DiscardUnknown()

func (*CommonLargeRowDetails) XXX_Marshal 

func (m *CommonLargeRowDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonLargeRowDetails) XXX_Merge 

func (m *CommonLargeRowDetails) XXX_Merge(src proto.Message)

func (*CommonLargeRowDetails) XXX_Size 

func (m *CommonLargeRowDetails) XXX_Size() int

func (*CommonLargeRowDetails) XXX_Unmarshal 

func (m *CommonLargeRowDetails) XXX_Unmarshal(b []byte) error

type CommonNodeDecommissionDetails 

type CommonNodeDecommissionDetails struct {
	// The node ID where the event was originated.
	RequestingNodeID int32 `protobuf:"varint,1,opt,name=requesting_node_id,json=requestingNodeId,proto3" json:",omitempty"`
	// The node ID affected by the operation.
	TargetNodeID int32 `protobuf:"varint,2,opt,name=target_node_id,json=targetNodeId,proto3" json:",omitempty"`
}

CommonNodeDecommissionDetails contains the fields common to all node-level decommission/recommission events.

Notes to CockroachDB maintainers: refer to doc.go at the package level for more details. Beware that JSON compatibility rules apply here, not protobuf. *Really look at doc.go before modifying this.*

func (*CommonNodeDecommissionDetails) AppendJSONFields 

func (m *CommonNodeDecommissionDetails) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommonNodeDecommissionDetails) Descriptor 

func (*CommonNodeDecommissionDetails) Descriptor() ([]byte, []int)

func (*CommonNodeDecommissionDetails) Marshal 

func (m *CommonNodeDecommissionDetails) Marshal() (dAtA []byte, err error)

func (*CommonNodeDecommissionDetails) MarshalTo 

func (m *CommonNodeDecommissionDetails) MarshalTo(dAtA []byte) (int, error)

func (*CommonNodeDecommissionDetails) MarshalToSizedBuffer 

func (m *CommonNodeDecommissionDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommonNodeDecommissionDetails) ProtoMessage 

func (*CommonNodeDecommissionDetails) ProtoMessage()

func (*CommonNodeDecommissionDetails) Reset 

func (m *CommonNodeDecommissionDetails) Reset()

func (*CommonNodeDecommissionDetails) Size 

func (m *CommonNodeDecommissionDetails) Size() (n int)

func (*CommonNodeDecommissionDetails) String 

func (m *CommonNodeDecommissionDetails) String() string

func (*CommonNodeDecommissionDetails) Unmarshal 

func (m *CommonNodeDecommissionDetails) Unmarshal(dAtA []byte) error

func (*CommonNodeDecommissionDetails) XXX_DiscardUnknown 

func (m *CommonNodeDecommissionDetails) XXX_DiscardUnknown()

func (*CommonNodeDecommissionDetails) XXX_Marshal 

func (m *CommonNodeDecommissionDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonNodeDecommissionDetails) XXX_Merge 

func (m *CommonNodeDecommissionDetails) XXX_Merge(src proto.Message)

func (*CommonNodeDecommissionDetails) XXX_Size 

func (m *CommonNodeDecommissionDetails) XXX_Size() int

func (*CommonNodeDecommissionDetails) XXX_Unmarshal 

func (m *CommonNodeDecommissionDetails) XXX_Unmarshal(b []byte) error

type CommonNodeEventDetails 

type CommonNodeEventDetails struct {
	// The node ID where the event was originated.
	NodeID int32 `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:",omitempty"`
	// The time when this node was last started.
	StartedAt int64 `protobuf:"varint,3,opt,name=started_at,json=startedAt,proto3" json:",omitempty"`
	// The approximate last time the node was up before the last restart.
	LastUp int64 `protobuf:"varint,4,opt,name=last_up,json=lastUp,proto3" json:",omitempty"`
}

CommonNodeEventDetails contains the fields common to all node-level events.

func (*CommonNodeEventDetails) AppendJSONFields 

func (m *CommonNodeEventDetails) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommonNodeEventDetails) Descriptor 

func (*CommonNodeEventDetails) Descriptor() ([]byte, []int)

func (*CommonNodeEventDetails) Marshal 

func (m *CommonNodeEventDetails) Marshal() (dAtA []byte, err error)

func (*CommonNodeEventDetails) MarshalTo 

func (m *CommonNodeEventDetails) MarshalTo(dAtA []byte) (int, error)

func (*CommonNodeEventDetails) MarshalToSizedBuffer 

func (m *CommonNodeEventDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommonNodeEventDetails) ProtoMessage 

func (*CommonNodeEventDetails) ProtoMessage()

func (*CommonNodeEventDetails) Reset 

func (m *CommonNodeEventDetails) Reset()

func (*CommonNodeEventDetails) Size 

func (m *CommonNodeEventDetails) Size() (n int)

func (*CommonNodeEventDetails) String 

func (m *CommonNodeEventDetails) String() string

func (*CommonNodeEventDetails) Unmarshal 

func (m *CommonNodeEventDetails) Unmarshal(dAtA []byte) error

func (*CommonNodeEventDetails) XXX_DiscardUnknown 

func (m *CommonNodeEventDetails) XXX_DiscardUnknown()

func (*CommonNodeEventDetails) XXX_Marshal 

func (m *CommonNodeEventDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonNodeEventDetails) XXX_Merge 

func (m *CommonNodeEventDetails) XXX_Merge(src proto.Message)

func (*CommonNodeEventDetails) XXX_Size 

func (m *CommonNodeEventDetails) XXX_Size() int

func (*CommonNodeEventDetails) XXX_Unmarshal 

func (m *CommonNodeEventDetails) XXX_Unmarshal(b []byte) error

type CommonSQLEventDetails 

type CommonSQLEventDetails struct {
	// A normalized copy of the SQL statement that triggered the event.
	// The statement string contains a mix of sensitive and non-sensitive details (it is redactable).
	Statement github_com_cockroachdb_redact.RedactableString `` /* 135-byte string literal not displayed */
	// The statement tag. This is separate from the statement string,
	// since the statement string can contain sensitive information. The
	// tag is guaranteed not to.
	Tag string `protobuf:"bytes,6,opt,name=tag,proto3" json:",omitempty" redact:"nonsensitive"`
	// The user account that triggered the event.
	// The special usernames `root` and `node` are not considered sensitive.
	User string `protobuf:"bytes,2,opt,name=user,proto3" json:",omitempty" redact:"safeif:root|node"`
	// The primary object descriptor affected by the operation. Set to zero for operations
	// that don't affect descriptors.
	DescriptorID uint32 `protobuf:"varint,3,opt,name=descriptor_id,json=descriptorId,proto3" json:",omitempty"`
	// The application name for the session where the event was emitted.
	// This is included in the event to ease filtering of logging output
	// by application.
	// Application names starting with a dollar sign (`$`) are not considered sensitive.
	ApplicationName string `protobuf:"bytes,4,opt,name=application_name,json=applicationName,proto3" json:",omitempty" redact:"safeif:\$.*"`
	// The mapping of SQL placeholders to their values, for prepared statements.
	PlaceholderValues []string `protobuf:"bytes,5,rep,name=placeholder_values,json=placeholderValues,proto3" json:",omitempty"`
}

CommonSQLEventDetails contains the fields common to all SQL events.

func (*CommonSQLEventDetails) AppendJSONFields 

func (m *CommonSQLEventDetails) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommonSQLEventDetails) CommonSQLDetails 

func (m *CommonSQLEventDetails) CommonSQLDetails() *CommonSQLEventDetails

CommonSQLDetails implements the EventWithCommonSQLPayload interface.

func (*CommonSQLEventDetails) Descriptor 

func (*CommonSQLEventDetails) Descriptor() ([]byte, []int)

func (*CommonSQLEventDetails) Marshal 

func (m *CommonSQLEventDetails) Marshal() (dAtA []byte, err error)

func (*CommonSQLEventDetails) MarshalTo 

func (m *CommonSQLEventDetails) MarshalTo(dAtA []byte) (int, error)

func (*CommonSQLEventDetails) MarshalToSizedBuffer 

func (m *CommonSQLEventDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommonSQLEventDetails) ProtoMessage 

func (*CommonSQLEventDetails) ProtoMessage()

func (*CommonSQLEventDetails) Reset 

func (m *CommonSQLEventDetails) Reset()

func (*CommonSQLEventDetails) Size 

func (m *CommonSQLEventDetails) Size() (n int)

func (*CommonSQLEventDetails) String 

func (m *CommonSQLEventDetails) String() string

func (*CommonSQLEventDetails) Unmarshal 

func (m *CommonSQLEventDetails) Unmarshal(dAtA []byte) error

func (*CommonSQLEventDetails) XXX_DiscardUnknown 

func (m *CommonSQLEventDetails) XXX_DiscardUnknown()

func (*CommonSQLEventDetails) XXX_Marshal 

func (m *CommonSQLEventDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonSQLEventDetails) XXX_Merge 

func (m *CommonSQLEventDetails) XXX_Merge(src proto.Message)

func (*CommonSQLEventDetails) XXX_Size 

func (m *CommonSQLEventDetails) XXX_Size() int

func (*CommonSQLEventDetails) XXX_Unmarshal 

func (m *CommonSQLEventDetails) XXX_Unmarshal(b []byte) error

type CommonSQLExecDetails 

type CommonSQLExecDetails struct {
	// How the statement was being executed (exec/prepare, etc.)
	ExecMode string `protobuf:"bytes,1,opt,name=exec_mode,json=execMode,proto3" json:",omitempty" redact:"nonsensitive"`
	// Number of rows returned. For mutation statements (INSERT, etc) that
	// do not produce result rows, this field reports the number of rows affected.
	NumRows uint64 `protobuf:"varint,2,opt,name=num_rows,json=numRows,proto3" json:",omitempty"`
	// The SQLSTATE code for the error, if an error was encountered. Empty/omitted if no error.
	SQLSTATE string `protobuf:"bytes,3,opt,name=sqlstate,proto3" json:",omitempty" redact:"nonsensitive"`
	// The text of the error if any.
	ErrorText string `protobuf:"bytes,4,opt,name=error_text,json=errorText,proto3" json:",omitempty"`
	// Age of the query in milliseconds.
	Age float32 `protobuf:"fixed32,5,opt,name=age,proto3" json:",omitempty"`
	// Number of retries, when the txn was reretried automatically by the server.
	NumRetries uint32 `protobuf:"varint,6,opt,name=num_retries,json=numRetries,proto3" json:",omitempty"`
	// Whether the query contains a full table scan.
	FullTableScan bool `protobuf:"varint,7,opt,name=full_table_scan,json=fullTableScan,proto3" json:",omitempty"`
	// Whether the query contains a full secondary index scan of a non-partial
	// index.
	FullIndexScan bool `protobuf:"varint,8,opt,name=full_index_scan,json=fullIndexScan,proto3" json:",omitempty"`
	// The sequence number of the SQL transaction inside its session.
	TxnCounter uint32 `protobuf:"varint,9,opt,name=txn_counter,json=txnCounter,proto3" json:",omitempty"`
}

CommonSQLExecDetails contains the field common to all SQL query logs.

func (*CommonSQLExecDetails) AppendJSONFields 

func (m *CommonSQLExecDetails) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommonSQLExecDetails) Descriptor 

func (*CommonSQLExecDetails) Descriptor() ([]byte, []int)

func (*CommonSQLExecDetails) Marshal 

func (m *CommonSQLExecDetails) Marshal() (dAtA []byte, err error)

func (*CommonSQLExecDetails) MarshalTo 

func (m *CommonSQLExecDetails) MarshalTo(dAtA []byte) (int, error)

func (*CommonSQLExecDetails) MarshalToSizedBuffer 

func (m *CommonSQLExecDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommonSQLExecDetails) ProtoMessage 

func (*CommonSQLExecDetails) ProtoMessage()

func (*CommonSQLExecDetails) Reset 

func (m *CommonSQLExecDetails) Reset()

func (*CommonSQLExecDetails) Size 

func (m *CommonSQLExecDetails) Size() (n int)

func (*CommonSQLExecDetails) String 

func (m *CommonSQLExecDetails) String() string

func (*CommonSQLExecDetails) Unmarshal 

func (m *CommonSQLExecDetails) Unmarshal(dAtA []byte) error

func (*CommonSQLExecDetails) XXX_DiscardUnknown 

func (m *CommonSQLExecDetails) XXX_DiscardUnknown()

func (*CommonSQLExecDetails) XXX_Marshal 

func (m *CommonSQLExecDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonSQLExecDetails) XXX_Merge 

func (m *CommonSQLExecDetails) XXX_Merge(src proto.Message)

func (*CommonSQLExecDetails) XXX_Size 

func (m *CommonSQLExecDetails) XXX_Size() int

func (*CommonSQLExecDetails) XXX_Unmarshal 

func (m *CommonSQLExecDetails) XXX_Unmarshal(b []byte) error

type CommonSQLPrivilegeEventDetails 

type CommonSQLPrivilegeEventDetails struct {
	// The user/role affected by the grant or revoke operation.
	Grantee string `protobuf:"bytes,1,opt,name=grantee,proto3" json:",omitempty"`
	// The privileges being granted to the grantee.
	GrantedPrivileges []string `protobuf:"bytes,2,rep,name=granted_privileges,json=grantedPrivileges,proto3" json:",omitempty" redact:"nonsensitive"`
	// The privileges being revoked from the grantee.
	RevokedPrivileges []string `protobuf:"bytes,3,rep,name=revoked_privileges,json=revokedPrivileges,proto3" json:",omitempty" redact:"nonsensitive"`
}

CommonSQLPrivilegeEventDetails contains the fields common to all grant/revoke events.

func (*CommonSQLPrivilegeEventDetails) AppendJSONFields 

func (m *CommonSQLPrivilegeEventDetails) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommonSQLPrivilegeEventDetails) Descriptor 

func (*CommonSQLPrivilegeEventDetails) Descriptor() ([]byte, []int)

func (*CommonSQLPrivilegeEventDetails) Marshal 

func (m *CommonSQLPrivilegeEventDetails) Marshal() (dAtA []byte, err error)

func (*CommonSQLPrivilegeEventDetails) MarshalTo 

func (m *CommonSQLPrivilegeEventDetails) MarshalTo(dAtA []byte) (int, error)

func (*CommonSQLPrivilegeEventDetails) MarshalToSizedBuffer 

func (m *CommonSQLPrivilegeEventDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommonSQLPrivilegeEventDetails) ProtoMessage 

func (*CommonSQLPrivilegeEventDetails) ProtoMessage()

func (*CommonSQLPrivilegeEventDetails) Reset 

func (m *CommonSQLPrivilegeEventDetails) Reset()

func (*CommonSQLPrivilegeEventDetails) Size 

func (m *CommonSQLPrivilegeEventDetails) Size() (n int)

func (*CommonSQLPrivilegeEventDetails) String 

func (m *CommonSQLPrivilegeEventDetails) String() string

func (*CommonSQLPrivilegeEventDetails) Unmarshal 

func (m *CommonSQLPrivilegeEventDetails) Unmarshal(dAtA []byte) error

func (*CommonSQLPrivilegeEventDetails) XXX_DiscardUnknown 

func (m *CommonSQLPrivilegeEventDetails) XXX_DiscardUnknown()

func (*CommonSQLPrivilegeEventDetails) XXX_Marshal 

func (m *CommonSQLPrivilegeEventDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonSQLPrivilegeEventDetails) XXX_Merge 

func (m *CommonSQLPrivilegeEventDetails) XXX_Merge(src proto.Message)

func (*CommonSQLPrivilegeEventDetails) XXX_Size 

func (m *CommonSQLPrivilegeEventDetails) XXX_Size() int

func (*CommonSQLPrivilegeEventDetails) XXX_Unmarshal 

func (m *CommonSQLPrivilegeEventDetails) XXX_Unmarshal(b []byte) error

type CommonSchemaChangeEventDetails 

type CommonSchemaChangeEventDetails struct {
	// The instance ID (not tenant ID) of the SQL server where the event
	// was originated.
	InstanceID int32 `protobuf:"varint,1,opt,name=instance_id,json=instanceId,proto3" json:",omitempty"`
	// The primary object descriptor affected by the operation. Set to
	// zero for operations that don't affect descriptors.
	DescriptorID uint32 `protobuf:"varint,2,opt,name=descriptor_id,json=descriptorId,proto3" json:",omitempty"`
	// The descriptor mutation that this schema change was processing.
	MutationID uint32 `protobuf:"varint,3,opt,name=mutation_id,json=mutationId,proto3" json:",omitempty"`
}

CommonSchemaChangeDetails contains the fields common to all background schema changes.

As above, the field is marked inline in the events below to preserve compatibility with system.eventlog. Likewise, because this is marked inline in the individual events, care must be taken to not reuse field identifiers across the message types, otherwise the JSON conversions cannot work.

func (*CommonSchemaChangeEventDetails) AppendJSONFields 

func (m *CommonSchemaChangeEventDetails) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommonSchemaChangeEventDetails) CommonSchemaChangeDetails 

func (m *CommonSchemaChangeEventDetails) CommonSchemaChangeDetails() *CommonSchemaChangeEventDetails

CommonSchemaChangeDetails implements the EventWithCommonSchemaChangePayload interface.

func (*CommonSchemaChangeEventDetails) Descriptor 

func (*CommonSchemaChangeEventDetails) Descriptor() ([]byte, []int)

func (*CommonSchemaChangeEventDetails) Marshal 

func (m *CommonSchemaChangeEventDetails) Marshal() (dAtA []byte, err error)

func (*CommonSchemaChangeEventDetails) MarshalTo 

func (m *CommonSchemaChangeEventDetails) MarshalTo(dAtA []byte) (int, error)

func (*CommonSchemaChangeEventDetails) MarshalToSizedBuffer 

func (m *CommonSchemaChangeEventDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommonSchemaChangeEventDetails) ProtoMessage 

func (*CommonSchemaChangeEventDetails) ProtoMessage()

func (*CommonSchemaChangeEventDetails) Reset 

func (m *CommonSchemaChangeEventDetails) Reset()

func (*CommonSchemaChangeEventDetails) Size 

func (m *CommonSchemaChangeEventDetails) Size() (n int)

func (*CommonSchemaChangeEventDetails) String 

func (m *CommonSchemaChangeEventDetails) String() string

func (*CommonSchemaChangeEventDetails) Unmarshal 

func (m *CommonSchemaChangeEventDetails) Unmarshal(dAtA []byte) error

func (*CommonSchemaChangeEventDetails) XXX_DiscardUnknown 

func (m *CommonSchemaChangeEventDetails) XXX_DiscardUnknown()

func (*CommonSchemaChangeEventDetails) XXX_Marshal 

func (m *CommonSchemaChangeEventDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonSchemaChangeEventDetails) XXX_Merge 

func (m *CommonSchemaChangeEventDetails) XXX_Merge(src proto.Message)

func (*CommonSchemaChangeEventDetails) XXX_Size 

func (m *CommonSchemaChangeEventDetails) XXX_Size() int

func (*CommonSchemaChangeEventDetails) XXX_Unmarshal 

func (m *CommonSchemaChangeEventDetails) XXX_Unmarshal(b []byte) error

type CommonSessionDetails 

type CommonSessionDetails struct {
	// The connection type after transport negotiation.
	Transport string `protobuf:"bytes,1,opt,name=transport,proto3" json:",omitempty" redact:"nonsensitive"`
	// The database username the session is for. This username will have
	// undergone case-folding and Unicode normalization.
	User string `protobuf:"bytes,2,opt,name=user,proto3" json:",omitempty"`
	// The original system identity provided by the client, if an identity
	// mapping was used per Host-Based Authentication rules. This may be a
	// GSSAPI or X.509 principal or any other external value, so no
	// specific assumptions should be made about the contents of this
	// field.
	SystemIdentity string `protobuf:"bytes,3,opt,name=system_identity,json=systemIdentity,proto3" json:",omitempty"`
}

CommonConnectionDetails are payload fields common to all session events.

Events of this type are only emitted when the cluster setting `server.auth_log.sql_connections.enabled` is set.

func (*CommonSessionDetails) AppendJSONFields 

func (m *CommonSessionDetails) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommonSessionDetails) Descriptor 

func (*CommonSessionDetails) Descriptor() ([]byte, []int)

func (*CommonSessionDetails) Marshal 

func (m *CommonSessionDetails) Marshal() (dAtA []byte, err error)

func (*CommonSessionDetails) MarshalTo 

func (m *CommonSessionDetails) MarshalTo(dAtA []byte) (int, error)

func (*CommonSessionDetails) MarshalToSizedBuffer 

func (m *CommonSessionDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommonSessionDetails) ProtoMessage 

func (*CommonSessionDetails) ProtoMessage()

func (*CommonSessionDetails) Reset 

func (m *CommonSessionDetails) Reset()

func (*CommonSessionDetails) Size 

func (m *CommonSessionDetails) Size() (n int)

func (*CommonSessionDetails) String 

func (m *CommonSessionDetails) String() string

func (*CommonSessionDetails) Unmarshal 

func (m *CommonSessionDetails) Unmarshal(dAtA []byte) error

func (*CommonSessionDetails) XXX_DiscardUnknown 

func (m *CommonSessionDetails) XXX_DiscardUnknown()

func (*CommonSessionDetails) XXX_Marshal 

func (m *CommonSessionDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonSessionDetails) XXX_Merge 

func (m *CommonSessionDetails) XXX_Merge(src proto.Message)

func (*CommonSessionDetails) XXX_Size 

func (m *CommonSessionDetails) XXX_Size() int

func (*CommonSessionDetails) XXX_Unmarshal 

func (m *CommonSessionDetails) XXX_Unmarshal(b []byte) error

type CommonTxnRowsLimitDetails 

type CommonTxnRowsLimitDetails struct {
	// TxnID is the ID of the transaction that hit the row count limit.
	TxnID string `protobuf:"bytes,1,opt,name=txn_id,json=txnId,proto3" json:",omitempty" redact:"nonsensitive"`
	// SessionID is the ID of the session that initiated the transaction.
	SessionID string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:",omitempty" redact:"nonsensitive"`
	// NumRows is the number of rows written/read (depending on the event type) by
	// the transaction that reached the corresponding guardrail.
	NumRows int64 `protobuf:"varint,3,opt,name=num_rows,json=numRows,proto3" json:",omitempty"`
}

CommonTxnRowsLimitDetails contains the fields common to all messages related to reaching the limits on the number of rows written/read by a transaction.

func (*CommonTxnRowsLimitDetails) AppendJSONFields 

func (m *CommonTxnRowsLimitDetails) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommonTxnRowsLimitDetails) Descriptor 

func (*CommonTxnRowsLimitDetails) Descriptor() ([]byte, []int)

func (*CommonTxnRowsLimitDetails) Error 

func (d *CommonTxnRowsLimitDetails) Error(kind string) string

Error helps other structs embedding CommonTxnRowsLimitDetails implement the error interface. (Note that it does not implement the error interface itself.)

func (*CommonTxnRowsLimitDetails) Marshal 

func (m *CommonTxnRowsLimitDetails) Marshal() (dAtA []byte, err error)

func (*CommonTxnRowsLimitDetails) MarshalTo 

func (m *CommonTxnRowsLimitDetails) MarshalTo(dAtA []byte) (int, error)

func (*CommonTxnRowsLimitDetails) MarshalToSizedBuffer 

func (m *CommonTxnRowsLimitDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommonTxnRowsLimitDetails) ProtoMessage 

func (*CommonTxnRowsLimitDetails) ProtoMessage()

func (*CommonTxnRowsLimitDetails) Reset 

func (m *CommonTxnRowsLimitDetails) Reset()

func (*CommonTxnRowsLimitDetails) SafeFormatError 

func (d *CommonTxnRowsLimitDetails) SafeFormatError(p errors.Printer, kind string) (next error)

SafeFormatError helps other structs embedding CommonTxnRowsLimitDetails implement the errors.SafeFormatter interface. (Note that it does not implement the errors.SafeFormatter interface itself.)

func (*CommonTxnRowsLimitDetails) Size 

func (m *CommonTxnRowsLimitDetails) Size() (n int)

func (*CommonTxnRowsLimitDetails) String 

func (m *CommonTxnRowsLimitDetails) String() string

func (*CommonTxnRowsLimitDetails) Unmarshal 

func (m *CommonTxnRowsLimitDetails) Unmarshal(dAtA []byte) error

func (*CommonTxnRowsLimitDetails) XXX_DiscardUnknown 

func (m *CommonTxnRowsLimitDetails) XXX_DiscardUnknown()

func (*CommonTxnRowsLimitDetails) XXX_Marshal 

func (m *CommonTxnRowsLimitDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonTxnRowsLimitDetails) XXX_Merge 

func (m *CommonTxnRowsLimitDetails) XXX_Merge(src proto.Message)

func (*CommonTxnRowsLimitDetails) XXX_Size 

func (m *CommonTxnRowsLimitDetails) XXX_Size() int

func (*CommonTxnRowsLimitDetails) XXX_Unmarshal 

func (m *CommonTxnRowsLimitDetails) XXX_Unmarshal(b []byte) error

type CommonZoneConfigDetails 

type CommonZoneConfigDetails struct {
	// The target object of the zone config change.
	Target string `protobuf:"bytes,1,opt,name=target,proto3" json:",omitempty"`
	// The applied zone config in YAML format.
	Config string `protobuf:"bytes,2,opt,name=config,proto3" json:",omitempty"`
	// The SQL representation of the applied zone config options.
	Options []string `protobuf:"bytes,3,rep,name=options,proto3" json:",omitempty"`
}

CommonZoneConfigDetails is common to zone config change events.

func (*CommonZoneConfigDetails) AppendJSONFields 

func (m *CommonZoneConfigDetails) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CommonZoneConfigDetails) Descriptor 

func (*CommonZoneConfigDetails) Descriptor() ([]byte, []int)

func (*CommonZoneConfigDetails) Marshal 

func (m *CommonZoneConfigDetails) Marshal() (dAtA []byte, err error)

func (*CommonZoneConfigDetails) MarshalTo 

func (m *CommonZoneConfigDetails) MarshalTo(dAtA []byte) (int, error)

func (*CommonZoneConfigDetails) MarshalToSizedBuffer 

func (m *CommonZoneConfigDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CommonZoneConfigDetails) ProtoMessage 

func (*CommonZoneConfigDetails) ProtoMessage()

func (*CommonZoneConfigDetails) Reset 

func (m *CommonZoneConfigDetails) Reset()

func (*CommonZoneConfigDetails) Size 

func (m *CommonZoneConfigDetails) Size() (n int)

func (*CommonZoneConfigDetails) String 

func (m *CommonZoneConfigDetails) String() string

func (*CommonZoneConfigDetails) Unmarshal 

func (m *CommonZoneConfigDetails) Unmarshal(dAtA []byte) error

func (*CommonZoneConfigDetails) XXX_DiscardUnknown 

func (m *CommonZoneConfigDetails) XXX_DiscardUnknown()

func (*CommonZoneConfigDetails) XXX_Marshal 

func (m *CommonZoneConfigDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommonZoneConfigDetails) XXX_Merge 

func (m *CommonZoneConfigDetails) XXX_Merge(src proto.Message)

func (*CommonZoneConfigDetails) XXX_Size 

func (m *CommonZoneConfigDetails) XXX_Size() int

func (*CommonZoneConfigDetails) XXX_Unmarshal 

func (m *CommonZoneConfigDetails) XXX_Unmarshal(b []byte) error

type ConvertToSchema 

type ConvertToSchema struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the database being converted to a schema.
	DatabaseName string `protobuf:"bytes,3,opt,name=database_name,json=databaseName,proto3" json:",omitempty"`
	// The name of the parent database for the new schema.
	NewDatabaseParent string `protobuf:"bytes,4,opt,name=new_database_parent,json=newDatabaseParent,proto3" json:",omitempty"`
}

ConvertToSchema is recorded when a database is converted to a schema.

func (*ConvertToSchema) AppendJSONFields 

func (m *ConvertToSchema) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*ConvertToSchema) Descriptor 

func (*ConvertToSchema) Descriptor() ([]byte, []int)

func (*ConvertToSchema) LoggingChannel 

func (m *ConvertToSchema) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*ConvertToSchema) Marshal 

func (m *ConvertToSchema) Marshal() (dAtA []byte, err error)

func (*ConvertToSchema) MarshalTo 

func (m *ConvertToSchema) MarshalTo(dAtA []byte) (int, error)

func (*ConvertToSchema) MarshalToSizedBuffer 

func (m *ConvertToSchema) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConvertToSchema) ProtoMessage 

func (*ConvertToSchema) ProtoMessage()

func (*ConvertToSchema) Reset 

func (m *ConvertToSchema) Reset()

func (*ConvertToSchema) Size 

func (m *ConvertToSchema) Size() (n int)

func (*ConvertToSchema) String 

func (m *ConvertToSchema) String() string

func (*ConvertToSchema) Unmarshal 

func (m *ConvertToSchema) Unmarshal(dAtA []byte) error

func (*ConvertToSchema) XXX_DiscardUnknown 

func (m *ConvertToSchema) XXX_DiscardUnknown()

func (*ConvertToSchema) XXX_Marshal 

func (m *ConvertToSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConvertToSchema) XXX_Merge 

func (m *ConvertToSchema) XXX_Merge(src proto.Message)

func (*ConvertToSchema) XXX_Size 

func (m *ConvertToSchema) XXX_Size() int

func (*ConvertToSchema) XXX_Unmarshal 

func (m *ConvertToSchema) XXX_Unmarshal(b []byte) error

type CreateDatabase 

type CreateDatabase struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the new database.
	DatabaseName string `protobuf:"bytes,3,opt,name=database_name,json=databaseName,proto3" json:",omitempty"`
}

CreateDatabase is recorded when a database is created.

func (*CreateDatabase) AppendJSONFields 

func (m *CreateDatabase) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CreateDatabase) Descriptor 

func (*CreateDatabase) Descriptor() ([]byte, []int)

func (*CreateDatabase) LoggingChannel 

func (m *CreateDatabase) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CreateDatabase) Marshal 

func (m *CreateDatabase) Marshal() (dAtA []byte, err error)

func (*CreateDatabase) MarshalTo 

func (m *CreateDatabase) MarshalTo(dAtA []byte) (int, error)

func (*CreateDatabase) MarshalToSizedBuffer 

func (m *CreateDatabase) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateDatabase) ProtoMessage 

func (*CreateDatabase) ProtoMessage()

func (*CreateDatabase) Reset 

func (m *CreateDatabase) Reset()

func (*CreateDatabase) Size 

func (m *CreateDatabase) Size() (n int)

func (*CreateDatabase) String 

func (m *CreateDatabase) String() string

func (*CreateDatabase) Unmarshal 

func (m *CreateDatabase) Unmarshal(dAtA []byte) error

func (*CreateDatabase) XXX_DiscardUnknown 

func (m *CreateDatabase) XXX_DiscardUnknown()

func (*CreateDatabase) XXX_Marshal 

func (m *CreateDatabase) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateDatabase) XXX_Merge 

func (m *CreateDatabase) XXX_Merge(src proto.Message)

func (*CreateDatabase) XXX_Size 

func (m *CreateDatabase) XXX_Size() int

func (*CreateDatabase) XXX_Unmarshal 

func (m *CreateDatabase) XXX_Unmarshal(b []byte) error

type CreateIndex 

type CreateIndex struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the table containing the new index.
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
	// The name of the new index.
	IndexName string `protobuf:"bytes,4,opt,name=index_name,json=indexName,proto3" json:",omitempty"`
	// The mutation ID for the asynchronous job that is processing the index update.
	MutationID uint32 `protobuf:"varint,5,opt,name=mutation_id,json=mutationId,proto3" json:",omitempty"`
}

CreateIndex is recorded when an index is created.

func (*CreateIndex) AppendJSONFields 

func (m *CreateIndex) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CreateIndex) Descriptor 

func (*CreateIndex) Descriptor() ([]byte, []int)

func (*CreateIndex) LoggingChannel 

func (m *CreateIndex) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CreateIndex) Marshal 

func (m *CreateIndex) Marshal() (dAtA []byte, err error)

func (*CreateIndex) MarshalTo 

func (m *CreateIndex) MarshalTo(dAtA []byte) (int, error)

func (*CreateIndex) MarshalToSizedBuffer 

func (m *CreateIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateIndex) ProtoMessage 

func (*CreateIndex) ProtoMessage()

func (*CreateIndex) Reset 

func (m *CreateIndex) Reset()

func (*CreateIndex) Size 

func (m *CreateIndex) Size() (n int)

func (*CreateIndex) String 

func (m *CreateIndex) String() string

func (*CreateIndex) Unmarshal 

func (m *CreateIndex) Unmarshal(dAtA []byte) error

func (*CreateIndex) XXX_DiscardUnknown 

func (m *CreateIndex) XXX_DiscardUnknown()

func (*CreateIndex) XXX_Marshal 

func (m *CreateIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateIndex) XXX_Merge 

func (m *CreateIndex) XXX_Merge(src proto.Message)

func (*CreateIndex) XXX_Size 

func (m *CreateIndex) XXX_Size() int

func (*CreateIndex) XXX_Unmarshal 

func (m *CreateIndex) XXX_Unmarshal(b []byte) error

type CreateRole 

type CreateRole struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the new user/role.
	RoleName string `protobuf:"bytes,3,opt,name=role_name,json=roleName,proto3" json:",omitempty"`
}

CreateRole is recorded when a role is created.

func (*CreateRole) AppendJSONFields 

func (m *CreateRole) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CreateRole) Descriptor 

func (*CreateRole) Descriptor() ([]byte, []int)

func (*CreateRole) LoggingChannel 

func (m *CreateRole) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CreateRole) Marshal 

func (m *CreateRole) Marshal() (dAtA []byte, err error)

func (*CreateRole) MarshalTo 

func (m *CreateRole) MarshalTo(dAtA []byte) (int, error)

func (*CreateRole) MarshalToSizedBuffer 

func (m *CreateRole) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateRole) ProtoMessage 

func (*CreateRole) ProtoMessage()

func (*CreateRole) Reset 

func (m *CreateRole) Reset()

func (*CreateRole) Size 

func (m *CreateRole) Size() (n int)

func (*CreateRole) String 

func (m *CreateRole) String() string

func (*CreateRole) Unmarshal 

func (m *CreateRole) Unmarshal(dAtA []byte) error

func (*CreateRole) XXX_DiscardUnknown 

func (m *CreateRole) XXX_DiscardUnknown()

func (*CreateRole) XXX_Marshal 

func (m *CreateRole) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateRole) XXX_Merge 

func (m *CreateRole) XXX_Merge(src proto.Message)

func (*CreateRole) XXX_Size 

func (m *CreateRole) XXX_Size() int

func (*CreateRole) XXX_Unmarshal 

func (m *CreateRole) XXX_Unmarshal(b []byte) error

type CreateSchema 

type CreateSchema struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the new schema.
	SchemaName string `protobuf:"bytes,3,opt,name=schema_name,json=schemaName,proto3" json:",omitempty"`
	// The name of the owner for the new schema.
	Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:",omitempty"`
}

CreateSchema is recorded when a schema is created.

func (*CreateSchema) AppendJSONFields 

func (m *CreateSchema) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CreateSchema) Descriptor 

func (*CreateSchema) Descriptor() ([]byte, []int)

func (*CreateSchema) LoggingChannel 

func (m *CreateSchema) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CreateSchema) Marshal 

func (m *CreateSchema) Marshal() (dAtA []byte, err error)

func (*CreateSchema) MarshalTo 

func (m *CreateSchema) MarshalTo(dAtA []byte) (int, error)

func (*CreateSchema) MarshalToSizedBuffer 

func (m *CreateSchema) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateSchema) ProtoMessage 

func (*CreateSchema) ProtoMessage()

func (*CreateSchema) Reset 

func (m *CreateSchema) Reset()

func (*CreateSchema) Size 

func (m *CreateSchema) Size() (n int)

func (*CreateSchema) String 

func (m *CreateSchema) String() string

func (*CreateSchema) Unmarshal 

func (m *CreateSchema) Unmarshal(dAtA []byte) error

func (*CreateSchema) XXX_DiscardUnknown 

func (m *CreateSchema) XXX_DiscardUnknown()

func (*CreateSchema) XXX_Marshal 

func (m *CreateSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSchema) XXX_Merge 

func (m *CreateSchema) XXX_Merge(src proto.Message)

func (*CreateSchema) XXX_Size 

func (m *CreateSchema) XXX_Size() int

func (*CreateSchema) XXX_Unmarshal 

func (m *CreateSchema) XXX_Unmarshal(b []byte) error

type CreateSequence 

type CreateSequence struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the new sequence.
	SequenceName string `protobuf:"bytes,3,opt,name=sequence_name,json=sequenceName,proto3" json:",omitempty"`
	// The name of the owner for the new sequence.
	Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:",omitempty"`
}

CreateSequence is recorded when a sequence is created.

func (*CreateSequence) AppendJSONFields 

func (m *CreateSequence) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CreateSequence) Descriptor 

func (*CreateSequence) Descriptor() ([]byte, []int)

func (*CreateSequence) LoggingChannel 

func (m *CreateSequence) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CreateSequence) Marshal 

func (m *CreateSequence) Marshal() (dAtA []byte, err error)

func (*CreateSequence) MarshalTo 

func (m *CreateSequence) MarshalTo(dAtA []byte) (int, error)

func (*CreateSequence) MarshalToSizedBuffer 

func (m *CreateSequence) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateSequence) ProtoMessage 

func (*CreateSequence) ProtoMessage()

func (*CreateSequence) Reset 

func (m *CreateSequence) Reset()

func (*CreateSequence) Size 

func (m *CreateSequence) Size() (n int)

func (*CreateSequence) String 

func (m *CreateSequence) String() string

func (*CreateSequence) Unmarshal 

func (m *CreateSequence) Unmarshal(dAtA []byte) error

func (*CreateSequence) XXX_DiscardUnknown 

func (m *CreateSequence) XXX_DiscardUnknown()

func (*CreateSequence) XXX_Marshal 

func (m *CreateSequence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSequence) XXX_Merge 

func (m *CreateSequence) XXX_Merge(src proto.Message)

func (*CreateSequence) XXX_Size 

func (m *CreateSequence) XXX_Size() int

func (*CreateSequence) XXX_Unmarshal 

func (m *CreateSequence) XXX_Unmarshal(b []byte) error

type CreateStatistics 

type CreateStatistics struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the table for which the statistics were created.
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
}

CreateStatistics is recorded when statistics are collected for a table.

Events of this type are only collected when the cluster setting `sql.stats.post_events.enabled` is set.

func (*CreateStatistics) AppendJSONFields 

func (m *CreateStatistics) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CreateStatistics) Descriptor 

func (*CreateStatistics) Descriptor() ([]byte, []int)

func (*CreateStatistics) LoggingChannel 

func (m *CreateStatistics) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CreateStatistics) Marshal 

func (m *CreateStatistics) Marshal() (dAtA []byte, err error)

func (*CreateStatistics) MarshalTo 

func (m *CreateStatistics) MarshalTo(dAtA []byte) (int, error)

func (*CreateStatistics) MarshalToSizedBuffer 

func (m *CreateStatistics) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateStatistics) ProtoMessage 

func (*CreateStatistics) ProtoMessage()

func (*CreateStatistics) Reset 

func (m *CreateStatistics) Reset()

func (*CreateStatistics) Size 

func (m *CreateStatistics) Size() (n int)

func (*CreateStatistics) String 

func (m *CreateStatistics) String() string

func (*CreateStatistics) Unmarshal 

func (m *CreateStatistics) Unmarshal(dAtA []byte) error

func (*CreateStatistics) XXX_DiscardUnknown 

func (m *CreateStatistics) XXX_DiscardUnknown()

func (*CreateStatistics) XXX_Marshal 

func (m *CreateStatistics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateStatistics) XXX_Merge 

func (m *CreateStatistics) XXX_Merge(src proto.Message)

func (*CreateStatistics) XXX_Size 

func (m *CreateStatistics) XXX_Size() int

func (*CreateStatistics) XXX_Unmarshal 

func (m *CreateStatistics) XXX_Unmarshal(b []byte) error

type CreateTable 

type CreateTable struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the new table.
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
	// The name of the owner for the new table.
	Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:",omitempty"`
}

CreateTable is recorded when a table is created.

func (*CreateTable) AppendJSONFields 

func (m *CreateTable) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CreateTable) Descriptor 

func (*CreateTable) Descriptor() ([]byte, []int)

func (*CreateTable) LoggingChannel 

func (m *CreateTable) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CreateTable) Marshal 

func (m *CreateTable) Marshal() (dAtA []byte, err error)

func (*CreateTable) MarshalTo 

func (m *CreateTable) MarshalTo(dAtA []byte) (int, error)

func (*CreateTable) MarshalToSizedBuffer 

func (m *CreateTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateTable) ProtoMessage 

func (*CreateTable) ProtoMessage()

func (*CreateTable) Reset 

func (m *CreateTable) Reset()

func (*CreateTable) Size 

func (m *CreateTable) Size() (n int)

func (*CreateTable) String 

func (m *CreateTable) String() string

func (*CreateTable) Unmarshal 

func (m *CreateTable) Unmarshal(dAtA []byte) error

func (*CreateTable) XXX_DiscardUnknown 

func (m *CreateTable) XXX_DiscardUnknown()

func (*CreateTable) XXX_Marshal 

func (m *CreateTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTable) XXX_Merge 

func (m *CreateTable) XXX_Merge(src proto.Message)

func (*CreateTable) XXX_Size 

func (m *CreateTable) XXX_Size() int

func (*CreateTable) XXX_Unmarshal 

func (m *CreateTable) XXX_Unmarshal(b []byte) error

type CreateType 

type CreateType struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the new type.
	TypeName string `protobuf:"bytes,4,opt,name=type_name,json=typeName,proto3" json:",omitempty"`
	// The name of the owner for the new type.
	Owner string `protobuf:"bytes,5,opt,name=owner,proto3" json:",omitempty"`
}

CreateType is recorded when a user-defined type is created.

func (*CreateType) AppendJSONFields 

func (m *CreateType) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CreateType) Descriptor 

func (*CreateType) Descriptor() ([]byte, []int)

func (*CreateType) LoggingChannel 

func (m *CreateType) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CreateType) Marshal 

func (m *CreateType) Marshal() (dAtA []byte, err error)

func (*CreateType) MarshalTo 

func (m *CreateType) MarshalTo(dAtA []byte) (int, error)

func (*CreateType) MarshalToSizedBuffer 

func (m *CreateType) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateType) ProtoMessage 

func (*CreateType) ProtoMessage()

func (*CreateType) Reset 

func (m *CreateType) Reset()

func (*CreateType) Size 

func (m *CreateType) Size() (n int)

func (*CreateType) String 

func (m *CreateType) String() string

func (*CreateType) Unmarshal 

func (m *CreateType) Unmarshal(dAtA []byte) error

func (*CreateType) XXX_DiscardUnknown 

func (m *CreateType) XXX_DiscardUnknown()

func (*CreateType) XXX_Marshal 

func (m *CreateType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateType) XXX_Merge 

func (m *CreateType) XXX_Merge(src proto.Message)

func (*CreateType) XXX_Size 

func (m *CreateType) XXX_Size() int

func (*CreateType) XXX_Unmarshal 

func (m *CreateType) XXX_Unmarshal(b []byte) error

type CreateView 

type CreateView struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the new view.
	ViewName string `protobuf:"bytes,3,opt,name=view_name,json=viewName,proto3" json:",omitempty"`
	// The name of the owner of the new view.
	Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:",omitempty"`
	// The SQL selection clause used to define the view.
	ViewQuery string `protobuf:"bytes,5,opt,name=view_query,json=viewQuery,proto3" json:",omitempty"`
}

CreateView is recorded when a view is created.

func (*CreateView) AppendJSONFields 

func (m *CreateView) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*CreateView) Descriptor 

func (*CreateView) Descriptor() ([]byte, []int)

func (*CreateView) LoggingChannel 

func (m *CreateView) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*CreateView) Marshal 

func (m *CreateView) Marshal() (dAtA []byte, err error)

func (*CreateView) MarshalTo 

func (m *CreateView) MarshalTo(dAtA []byte) (int, error)

func (*CreateView) MarshalToSizedBuffer 

func (m *CreateView) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateView) ProtoMessage 

func (*CreateView) ProtoMessage()

func (*CreateView) Reset 

func (m *CreateView) Reset()

func (*CreateView) Size 

func (m *CreateView) Size() (n int)

func (*CreateView) String 

func (m *CreateView) String() string

func (*CreateView) Unmarshal 

func (m *CreateView) Unmarshal(dAtA []byte) error

func (*CreateView) XXX_DiscardUnknown 

func (m *CreateView) XXX_DiscardUnknown()

func (*CreateView) XXX_Marshal 

func (m *CreateView) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateView) XXX_Merge 

func (m *CreateView) XXX_Merge(src proto.Message)

func (*CreateView) XXX_Size 

func (m *CreateView) XXX_Size() int

func (*CreateView) XXX_Unmarshal 

func (m *CreateView) XXX_Unmarshal(b []byte) error

type DebugRecoverReplica 

type DebugRecoverReplica struct {
	CommonEventDetails      `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonDebugEventDetails `protobuf:"bytes,2,opt,name=debug,proto3,embedded=debug" json:""`
	RangeID                 int64  `protobuf:"varint,3,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	StoreID                 int64  `protobuf:"varint,4,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	SurvivorReplicaID       int32  `protobuf:"varint,5,opt,name=survivor_replica_id,json=survivorReplicaId,proto3" json:"survivor_replica_id,omitempty"`
	UpdatedReplicaID        int32  `protobuf:"varint,6,opt,name=updated_replica_id,json=updatedReplicaId,proto3" json:"updated_replica_id,omitempty"`
	StartKey                string `protobuf:"bytes,7,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey                  string `protobuf:"bytes,8,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
}

DebugRecoverReplica is recorded when unsafe loss of quorum recovery is performed.

func (*DebugRecoverReplica) AppendJSONFields 

func (m *DebugRecoverReplica) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*DebugRecoverReplica) Descriptor 

func (*DebugRecoverReplica) Descriptor() ([]byte, []int)

func (*DebugRecoverReplica) LoggingChannel 

func (m *DebugRecoverReplica) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*DebugRecoverReplica) Marshal 

func (m *DebugRecoverReplica) Marshal() (dAtA []byte, err error)

func (*DebugRecoverReplica) MarshalTo 

func (m *DebugRecoverReplica) MarshalTo(dAtA []byte) (int, error)

func (*DebugRecoverReplica) MarshalToSizedBuffer 

func (m *DebugRecoverReplica) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DebugRecoverReplica) ProtoMessage 

func (*DebugRecoverReplica) ProtoMessage()

func (*DebugRecoverReplica) Reset 

func (m *DebugRecoverReplica) Reset()

func (*DebugRecoverReplica) Size 

func (m *DebugRecoverReplica) Size() (n int)

func (*DebugRecoverReplica) String 

func (m *DebugRecoverReplica) String() string

func (*DebugRecoverReplica) Unmarshal 

func (m *DebugRecoverReplica) Unmarshal(dAtA []byte) error

func (*DebugRecoverReplica) XXX_DiscardUnknown 

func (m *DebugRecoverReplica) XXX_DiscardUnknown()

func (*DebugRecoverReplica) XXX_Marshal 

func (m *DebugRecoverReplica) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DebugRecoverReplica) XXX_Merge 

func (m *DebugRecoverReplica) XXX_Merge(src proto.Message)

func (*DebugRecoverReplica) XXX_Size 

func (m *DebugRecoverReplica) XXX_Size() int

func (*DebugRecoverReplica) XXX_Unmarshal 

func (m *DebugRecoverReplica) XXX_Unmarshal(b []byte) error

type DebugSendKvBatch 

type DebugSendKvBatch struct {
	CommonEventDetails      `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonDebugEventDetails `protobuf:"bytes,2,opt,name=debug,proto3,embedded=debug" json:""`
	BatchRequest            string `protobuf:"bytes,3,opt,name=batch_request,json=batchRequest,proto3" json:",omitempty"`
}

DebugSendKvBatch is recorded when an arbitrary KV BatchRequest is submitted to the cluster via the `debug send-kv-batch` CLI command.

func (*DebugSendKvBatch) AppendJSONFields 

func (m *DebugSendKvBatch) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*DebugSendKvBatch) Descriptor 

func (*DebugSendKvBatch) Descriptor() ([]byte, []int)

func (*DebugSendKvBatch) LoggingChannel 

func (m *DebugSendKvBatch) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*DebugSendKvBatch) Marshal 

func (m *DebugSendKvBatch) Marshal() (dAtA []byte, err error)

func (*DebugSendKvBatch) MarshalTo 

func (m *DebugSendKvBatch) MarshalTo(dAtA []byte) (int, error)

func (*DebugSendKvBatch) MarshalToSizedBuffer 

func (m *DebugSendKvBatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DebugSendKvBatch) ProtoMessage 

func (*DebugSendKvBatch) ProtoMessage()

func (*DebugSendKvBatch) Reset 

func (m *DebugSendKvBatch) Reset()

func (*DebugSendKvBatch) Size 

func (m *DebugSendKvBatch) Size() (n int)

func (*DebugSendKvBatch) String 

func (m *DebugSendKvBatch) String() string

func (*DebugSendKvBatch) Unmarshal 

func (m *DebugSendKvBatch) Unmarshal(dAtA []byte) error

func (*DebugSendKvBatch) XXX_DiscardUnknown 

func (m *DebugSendKvBatch) XXX_DiscardUnknown()

func (*DebugSendKvBatch) XXX_Marshal 

func (m *DebugSendKvBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DebugSendKvBatch) XXX_Merge 

func (m *DebugSendKvBatch) XXX_Merge(src proto.Message)

func (*DebugSendKvBatch) XXX_Size 

func (m *DebugSendKvBatch) XXX_Size() int

func (*DebugSendKvBatch) XXX_Unmarshal 

func (m *DebugSendKvBatch) XXX_Unmarshal(b []byte) error

type DropDatabase 

type DropDatabase struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected database.
	DatabaseName string `protobuf:"bytes,3,opt,name=database_name,json=databaseName,proto3" json:",omitempty"`
	// The names of the schemas dropped by a cascade operation.
	DroppedSchemaObjects []string `protobuf:"bytes,4,rep,name=dropped_schema_objects,json=droppedSchemaObjects,proto3" json:",omitempty"`
}

DropDatabase is recorded when a database is dropped.

func (*DropDatabase) AppendJSONFields 

func (m *DropDatabase) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*DropDatabase) Descriptor 

func (*DropDatabase) Descriptor() ([]byte, []int)

func (*DropDatabase) LoggingChannel 

func (m *DropDatabase) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*DropDatabase) Marshal 

func (m *DropDatabase) Marshal() (dAtA []byte, err error)

func (*DropDatabase) MarshalTo 

func (m *DropDatabase) MarshalTo(dAtA []byte) (int, error)

func (*DropDatabase) MarshalToSizedBuffer 

func (m *DropDatabase) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DropDatabase) ProtoMessage 

func (*DropDatabase) ProtoMessage()

func (*DropDatabase) Reset 

func (m *DropDatabase) Reset()

func (*DropDatabase) Size 

func (m *DropDatabase) Size() (n int)

func (*DropDatabase) String 

func (m *DropDatabase) String() string

func (*DropDatabase) Unmarshal 

func (m *DropDatabase) Unmarshal(dAtA []byte) error

func (*DropDatabase) XXX_DiscardUnknown 

func (m *DropDatabase) XXX_DiscardUnknown()

func (*DropDatabase) XXX_Marshal 

func (m *DropDatabase) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropDatabase) XXX_Merge 

func (m *DropDatabase) XXX_Merge(src proto.Message)

func (*DropDatabase) XXX_Size 

func (m *DropDatabase) XXX_Size() int

func (*DropDatabase) XXX_Unmarshal 

func (m *DropDatabase) XXX_Unmarshal(b []byte) error

type DropIndex 

type DropIndex struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the table containing the affected index.
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
	// The name of the affected index.
	IndexName string `protobuf:"bytes,4,opt,name=index_name,json=indexName,proto3" json:",omitempty"`
	// The mutation ID for the asynchronous job that is processing the index update.
	MutationID uint32 `protobuf:"varint,5,opt,name=mutation_id,json=mutationId,proto3" json:",omitempty"`
	// The names of the views dropped as a result of a cascade operation.
	CascadeDroppedViews []string `protobuf:"bytes,6,rep,name=cascade_dropped_views,json=cascadeDroppedViews,proto3" json:"cascade_dropped_views,omitempty"`
}

DropIndex is recorded when an index is dropped.

func (*DropIndex) AppendJSONFields 

func (m *DropIndex) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*DropIndex) Descriptor 

func (*DropIndex) Descriptor() ([]byte, []int)

func (*DropIndex) LoggingChannel 

func (m *DropIndex) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*DropIndex) Marshal 

func (m *DropIndex) Marshal() (dAtA []byte, err error)

func (*DropIndex) MarshalTo 

func (m *DropIndex) MarshalTo(dAtA []byte) (int, error)

func (*DropIndex) MarshalToSizedBuffer 

func (m *DropIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DropIndex) ProtoMessage 

func (*DropIndex) ProtoMessage()

func (*DropIndex) Reset 

func (m *DropIndex) Reset()

func (*DropIndex) Size 

func (m *DropIndex) Size() (n int)

func (*DropIndex) String 

func (m *DropIndex) String() string

func (*DropIndex) Unmarshal 

func (m *DropIndex) Unmarshal(dAtA []byte) error

func (*DropIndex) XXX_DiscardUnknown 

func (m *DropIndex) XXX_DiscardUnknown()

func (*DropIndex) XXX_Marshal 

func (m *DropIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropIndex) XXX_Merge 

func (m *DropIndex) XXX_Merge(src proto.Message)

func (*DropIndex) XXX_Size 

func (m *DropIndex) XXX_Size() int

func (*DropIndex) XXX_Unmarshal 

func (m *DropIndex) XXX_Unmarshal(b []byte) error

type DropRole 

type DropRole struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected user/role.
	RoleName string `protobuf:"bytes,3,opt,name=role_name,json=roleName,proto3" json:",omitempty"`
}

DropRole is recorded when a role is dropped.

func (*DropRole) AppendJSONFields 

func (m *DropRole) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*DropRole) Descriptor 

func (*DropRole) Descriptor() ([]byte, []int)

func (*DropRole) LoggingChannel 

func (m *DropRole) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*DropRole) Marshal 

func (m *DropRole) Marshal() (dAtA []byte, err error)

func (*DropRole) MarshalTo 

func (m *DropRole) MarshalTo(dAtA []byte) (int, error)

func (*DropRole) MarshalToSizedBuffer 

func (m *DropRole) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DropRole) ProtoMessage 

func (*DropRole) ProtoMessage()

func (*DropRole) Reset 

func (m *DropRole) Reset()

func (*DropRole) Size 

func (m *DropRole) Size() (n int)

func (*DropRole) String 

func (m *DropRole) String() string

func (*DropRole) Unmarshal 

func (m *DropRole) Unmarshal(dAtA []byte) error

func (*DropRole) XXX_DiscardUnknown 

func (m *DropRole) XXX_DiscardUnknown()

func (*DropRole) XXX_Marshal 

func (m *DropRole) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropRole) XXX_Merge 

func (m *DropRole) XXX_Merge(src proto.Message)

func (*DropRole) XXX_Size 

func (m *DropRole) XXX_Size() int

func (*DropRole) XXX_Unmarshal 

func (m *DropRole) XXX_Unmarshal(b []byte) error

type DropSchema 

type DropSchema struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected schema.
	SchemaName string `protobuf:"bytes,3,opt,name=schema_name,json=schemaName,proto3" json:",omitempty"`
}

DropSchema is recorded when a schema is dropped.

func (*DropSchema) AppendJSONFields 

func (m *DropSchema) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*DropSchema) Descriptor 

func (*DropSchema) Descriptor() ([]byte, []int)

func (*DropSchema) LoggingChannel 

func (m *DropSchema) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*DropSchema) Marshal 

func (m *DropSchema) Marshal() (dAtA []byte, err error)

func (*DropSchema) MarshalTo 

func (m *DropSchema) MarshalTo(dAtA []byte) (int, error)

func (*DropSchema) MarshalToSizedBuffer 

func (m *DropSchema) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DropSchema) ProtoMessage 

func (*DropSchema) ProtoMessage()

func (*DropSchema) Reset 

func (m *DropSchema) Reset()

func (*DropSchema) Size 

func (m *DropSchema) Size() (n int)

func (*DropSchema) String 

func (m *DropSchema) String() string

func (*DropSchema) Unmarshal 

func (m *DropSchema) Unmarshal(dAtA []byte) error

func (*DropSchema) XXX_DiscardUnknown 

func (m *DropSchema) XXX_DiscardUnknown()

func (*DropSchema) XXX_Marshal 

func (m *DropSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropSchema) XXX_Merge 

func (m *DropSchema) XXX_Merge(src proto.Message)

func (*DropSchema) XXX_Size 

func (m *DropSchema) XXX_Size() int

func (*DropSchema) XXX_Unmarshal 

func (m *DropSchema) XXX_Unmarshal(b []byte) error

type DropSequence 

type DropSequence struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected sequence.
	SequenceName string `protobuf:"bytes,3,opt,name=sequence_name,json=sequenceName,proto3" json:",omitempty"`
}

DropSequence is recorded when a sequence is dropped.

func (*DropSequence) AppendJSONFields 

func (m *DropSequence) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*DropSequence) Descriptor 

func (*DropSequence) Descriptor() ([]byte, []int)

func (*DropSequence) LoggingChannel 

func (m *DropSequence) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*DropSequence) Marshal 

func (m *DropSequence) Marshal() (dAtA []byte, err error)

func (*DropSequence) MarshalTo 

func (m *DropSequence) MarshalTo(dAtA []byte) (int, error)

func (*DropSequence) MarshalToSizedBuffer 

func (m *DropSequence) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DropSequence) ProtoMessage 

func (*DropSequence) ProtoMessage()

func (*DropSequence) Reset 

func (m *DropSequence) Reset()

func (*DropSequence) Size 

func (m *DropSequence) Size() (n int)

func (*DropSequence) String 

func (m *DropSequence) String() string

func (*DropSequence) Unmarshal 

func (m *DropSequence) Unmarshal(dAtA []byte) error

func (*DropSequence) XXX_DiscardUnknown 

func (m *DropSequence) XXX_DiscardUnknown()

func (*DropSequence) XXX_Marshal 

func (m *DropSequence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropSequence) XXX_Merge 

func (m *DropSequence) XXX_Merge(src proto.Message)

func (*DropSequence) XXX_Size 

func (m *DropSequence) XXX_Size() int

func (*DropSequence) XXX_Unmarshal 

func (m *DropSequence) XXX_Unmarshal(b []byte) error

type DropTable 

type DropTable struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected table.
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
	// The names of the views dropped as a result of a cascade operation.
	CascadeDroppedViews []string `protobuf:"bytes,4,rep,name=cascade_dropped_views,json=cascadeDroppedViews,proto3" json:",omitempty"`
}

DropTable is recorded when a table is dropped.

func (*DropTable) AppendJSONFields 

func (m *DropTable) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*DropTable) Descriptor 

func (*DropTable) Descriptor() ([]byte, []int)

func (*DropTable) LoggingChannel 

func (m *DropTable) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*DropTable) Marshal 

func (m *DropTable) Marshal() (dAtA []byte, err error)

func (*DropTable) MarshalTo 

func (m *DropTable) MarshalTo(dAtA []byte) (int, error)

func (*DropTable) MarshalToSizedBuffer 

func (m *DropTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DropTable) ProtoMessage 

func (*DropTable) ProtoMessage()

func (*DropTable) Reset 

func (m *DropTable) Reset()

func (*DropTable) Size 

func (m *DropTable) Size() (n int)

func (*DropTable) String 

func (m *DropTable) String() string

func (*DropTable) Unmarshal 

func (m *DropTable) Unmarshal(dAtA []byte) error

func (*DropTable) XXX_DiscardUnknown 

func (m *DropTable) XXX_DiscardUnknown()

func (*DropTable) XXX_Marshal 

func (m *DropTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropTable) XXX_Merge 

func (m *DropTable) XXX_Merge(src proto.Message)

func (*DropTable) XXX_Size 

func (m *DropTable) XXX_Size() int

func (*DropTable) XXX_Unmarshal 

func (m *DropTable) XXX_Unmarshal(b []byte) error

type DropType 

type DropType struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected type.
	TypeName string `protobuf:"bytes,3,opt,name=type_name,json=typeName,proto3" json:",omitempty"`
}

DropType is recorded when a user-defined type is dropped.

func (*DropType) AppendJSONFields 

func (m *DropType) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*DropType) Descriptor 

func (*DropType) Descriptor() ([]byte, []int)

func (*DropType) LoggingChannel 

func (m *DropType) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*DropType) Marshal 

func (m *DropType) Marshal() (dAtA []byte, err error)

func (*DropType) MarshalTo 

func (m *DropType) MarshalTo(dAtA []byte) (int, error)

func (*DropType) MarshalToSizedBuffer 

func (m *DropType) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DropType) ProtoMessage 

func (*DropType) ProtoMessage()

func (*DropType) Reset 

func (m *DropType) Reset()

func (*DropType) Size 

func (m *DropType) Size() (n int)

func (*DropType) String 

func (m *DropType) String() string

func (*DropType) Unmarshal 

func (m *DropType) Unmarshal(dAtA []byte) error

func (*DropType) XXX_DiscardUnknown 

func (m *DropType) XXX_DiscardUnknown()

func (*DropType) XXX_Marshal 

func (m *DropType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropType) XXX_Merge 

func (m *DropType) XXX_Merge(src proto.Message)

func (*DropType) XXX_Size 

func (m *DropType) XXX_Size() int

func (*DropType) XXX_Unmarshal 

func (m *DropType) XXX_Unmarshal(b []byte) error

type DropView 

type DropView struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected view.
	ViewName string `protobuf:"bytes,3,opt,name=view_name,json=viewName,proto3" json:",omitempty"`
	// The names of the views dropped as a result of a cascade operation.
	CascadeDroppedViews []string `protobuf:"bytes,4,rep,name=cascade_dropped_views,json=cascadeDroppedViews,proto3" json:",omitempty"`
}

DropView is recorded when a view is dropped.

func (*DropView) AppendJSONFields 

func (m *DropView) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*DropView) Descriptor 

func (*DropView) Descriptor() ([]byte, []int)

func (*DropView) LoggingChannel 

func (m *DropView) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*DropView) Marshal 

func (m *DropView) Marshal() (dAtA []byte, err error)

func (*DropView) MarshalTo 

func (m *DropView) MarshalTo(dAtA []byte) (int, error)

func (*DropView) MarshalToSizedBuffer 

func (m *DropView) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DropView) ProtoMessage 

func (*DropView) ProtoMessage()

func (*DropView) Reset 

func (m *DropView) Reset()

func (*DropView) Size 

func (m *DropView) Size() (n int)

func (*DropView) String 

func (m *DropView) String() string

func (*DropView) Unmarshal 

func (m *DropView) Unmarshal(dAtA []byte) error

func (*DropView) XXX_DiscardUnknown 

func (m *DropView) XXX_DiscardUnknown()

func (*DropView) XXX_Marshal 

func (m *DropView) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropView) XXX_Merge 

func (m *DropView) XXX_Merge(src proto.Message)

func (*DropView) XXX_Size 

func (m *DropView) XXX_Size() int

func (*DropView) XXX_Unmarshal 

func (m *DropView) XXX_Unmarshal(b []byte) error

type EventPayload 

type EventPayload interface {
	// CommonDetails gives access to the common payload.
	CommonDetails() *CommonEventDetails
	// LoggingChannel indicates which logging channel to send this event to.
	// This is defined by the event category, at the top of each .proto file.
	LoggingChannel() logpb.Channel
	// AppendJSONFields appends the JSON representation of the event's
	// fields to the given redactable byte slice. Note that the
	// representation is missing the outside '{' and '}'
	// delimiters. This is intended so that the outside printer can
	// decide how to embed the event in a larger payload.
	//
	// The printComma, if true, indicates whether to print a comma
	// before the first field. The returned bool value indicates whether
	// to print a comma when appending more fields afterwards.
	AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)
}

EventPayload is implemented by CommonEventDetails.

type EventWithCommonJobPayload 

type EventWithCommonJobPayload interface {
	EventPayload
	CommonJobDetails() *CommonJobEventDetails
}

EventWithCommonJobPayload is implemented by CommonSQLEventDetails.

type EventWithCommonSQLPayload 

type EventWithCommonSQLPayload interface {
	EventPayload
	CommonSQLDetails() *CommonSQLEventDetails
}

EventWithCommonSQLPayload is implemented by CommonSQLEventDetails.

type EventWithCommonSchemaChangePayload 

type EventWithCommonSchemaChangePayload interface {
	EventPayload
	CommonSchemaChangeDetails() *CommonSchemaChangeEventDetails
}

EventWithCommonSchemaChangePayload is implemented by CommonSchemaChangeDetails.

type FinishSchemaChange 

type FinishSchemaChange struct {
	CommonEventDetails             `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSchemaChangeEventDetails `protobuf:"bytes,2,opt,name=sc,proto3,embedded=sc" json:""`
}

FinishSchemaChange is recorded when a previously initiated schema change has completed.

func (*FinishSchemaChange) AppendJSONFields 

func (m *FinishSchemaChange) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*FinishSchemaChange) Descriptor 

func (*FinishSchemaChange) Descriptor() ([]byte, []int)

func (*FinishSchemaChange) LoggingChannel 

func (m *FinishSchemaChange) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*FinishSchemaChange) Marshal 

func (m *FinishSchemaChange) Marshal() (dAtA []byte, err error)

func (*FinishSchemaChange) MarshalTo 

func (m *FinishSchemaChange) MarshalTo(dAtA []byte) (int, error)

func (*FinishSchemaChange) MarshalToSizedBuffer 

func (m *FinishSchemaChange) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FinishSchemaChange) ProtoMessage 

func (*FinishSchemaChange) ProtoMessage()

func (*FinishSchemaChange) Reset 

func (m *FinishSchemaChange) Reset()

func (*FinishSchemaChange) Size 

func (m *FinishSchemaChange) Size() (n int)

func (*FinishSchemaChange) String 

func (m *FinishSchemaChange) String() string

func (*FinishSchemaChange) Unmarshal 

func (m *FinishSchemaChange) Unmarshal(dAtA []byte) error

func (*FinishSchemaChange) XXX_DiscardUnknown 

func (m *FinishSchemaChange) XXX_DiscardUnknown()

func (*FinishSchemaChange) XXX_Marshal 

func (m *FinishSchemaChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FinishSchemaChange) XXX_Merge 

func (m *FinishSchemaChange) XXX_Merge(src proto.Message)

func (*FinishSchemaChange) XXX_Size 

func (m *FinishSchemaChange) XXX_Size() int

func (*FinishSchemaChange) XXX_Unmarshal 

func (m *FinishSchemaChange) XXX_Unmarshal(b []byte) error

type FinishSchemaChangeRollback 

type FinishSchemaChangeRollback struct {
	CommonEventDetails             `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSchemaChangeEventDetails `protobuf:"bytes,2,opt,name=sc,proto3,embedded=sc" json:""`
}

FinishSchemaChangeRollback is recorded when a previously initiated schema change rollback has completed.

func (*FinishSchemaChangeRollback) AppendJSONFields 

func (m *FinishSchemaChangeRollback) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*FinishSchemaChangeRollback) Descriptor 

func (*FinishSchemaChangeRollback) Descriptor() ([]byte, []int)

func (*FinishSchemaChangeRollback) LoggingChannel 

func (m *FinishSchemaChangeRollback) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*FinishSchemaChangeRollback) Marshal 

func (m *FinishSchemaChangeRollback) Marshal() (dAtA []byte, err error)

func (*FinishSchemaChangeRollback) MarshalTo 

func (m *FinishSchemaChangeRollback) MarshalTo(dAtA []byte) (int, error)

func (*FinishSchemaChangeRollback) MarshalToSizedBuffer 

func (m *FinishSchemaChangeRollback) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FinishSchemaChangeRollback) ProtoMessage 

func (*FinishSchemaChangeRollback) ProtoMessage()

func (*FinishSchemaChangeRollback) Reset 

func (m *FinishSchemaChangeRollback) Reset()

func (*FinishSchemaChangeRollback) Size 

func (m *FinishSchemaChangeRollback) Size() (n int)

func (*FinishSchemaChangeRollback) String 

func (m *FinishSchemaChangeRollback) String() string

func (*FinishSchemaChangeRollback) Unmarshal 

func (m *FinishSchemaChangeRollback) Unmarshal(dAtA []byte) error

func (*FinishSchemaChangeRollback) XXX_DiscardUnknown 

func (m *FinishSchemaChangeRollback) XXX_DiscardUnknown()

func (*FinishSchemaChangeRollback) XXX_Marshal 

func (m *FinishSchemaChangeRollback) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FinishSchemaChangeRollback) XXX_Merge 

func (m *FinishSchemaChangeRollback) XXX_Merge(src proto.Message)

func (*FinishSchemaChangeRollback) XXX_Size 

func (m *FinishSchemaChangeRollback) XXX_Size() int

func (*FinishSchemaChangeRollback) XXX_Unmarshal 

func (m *FinishSchemaChangeRollback) XXX_Unmarshal(b []byte) error

type ForceDeleteTableDataEntry 

type ForceDeleteTableDataEntry struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	DescriptorID          uint32 `protobuf:"varint,3,opt,name=desc_id,json=descId,proto3" json:",omitempty"`
}

func (*ForceDeleteTableDataEntry) AppendJSONFields 

func (m *ForceDeleteTableDataEntry) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*ForceDeleteTableDataEntry) Descriptor 

func (*ForceDeleteTableDataEntry) Descriptor() ([]byte, []int)

func (*ForceDeleteTableDataEntry) LoggingChannel 

func (m *ForceDeleteTableDataEntry) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*ForceDeleteTableDataEntry) Marshal 

func (m *ForceDeleteTableDataEntry) Marshal() (dAtA []byte, err error)

func (*ForceDeleteTableDataEntry) MarshalTo 

func (m *ForceDeleteTableDataEntry) MarshalTo(dAtA []byte) (int, error)

func (*ForceDeleteTableDataEntry) MarshalToSizedBuffer 

func (m *ForceDeleteTableDataEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ForceDeleteTableDataEntry) ProtoMessage 

func (*ForceDeleteTableDataEntry) ProtoMessage()

func (*ForceDeleteTableDataEntry) Reset 

func (m *ForceDeleteTableDataEntry) Reset()

func (*ForceDeleteTableDataEntry) Size 

func (m *ForceDeleteTableDataEntry) Size() (n int)

func (*ForceDeleteTableDataEntry) String 

func (m *ForceDeleteTableDataEntry) String() string

func (*ForceDeleteTableDataEntry) Unmarshal 

func (m *ForceDeleteTableDataEntry) Unmarshal(dAtA []byte) error

func (*ForceDeleteTableDataEntry) XXX_DiscardUnknown 

func (m *ForceDeleteTableDataEntry) XXX_DiscardUnknown()

func (*ForceDeleteTableDataEntry) XXX_Marshal 

func (m *ForceDeleteTableDataEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ForceDeleteTableDataEntry) XXX_Merge 

func (m *ForceDeleteTableDataEntry) XXX_Merge(src proto.Message)

func (*ForceDeleteTableDataEntry) XXX_Size 

func (m *ForceDeleteTableDataEntry) XXX_Size() int

func (*ForceDeleteTableDataEntry) XXX_Unmarshal 

func (m *ForceDeleteTableDataEntry) XXX_Unmarshal(b []byte) error

type Import 

type Import struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonJobEventDetails `protobuf:"bytes,2,opt,name=job,proto3,embedded=job" json:""`
}

Import is recorded when an import job is created and successful completion. If the job fails, events will be emitted on job creation, failure, and successful revert.

func (*Import) AppendJSONFields 

func (m *Import) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*Import) Descriptor 

func (*Import) Descriptor() ([]byte, []int)

func (*Import) LoggingChannel 

func (m *Import) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*Import) Marshal 

func (m *Import) Marshal() (dAtA []byte, err error)

func (*Import) MarshalTo 

func (m *Import) MarshalTo(dAtA []byte) (int, error)

func (*Import) MarshalToSizedBuffer 

func (m *Import) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Import) ProtoMessage 

func (*Import) ProtoMessage()

func (*Import) Reset 

func (m *Import) Reset()

func (*Import) Size 

func (m *Import) Size() (n int)

func (*Import) String 

func (m *Import) String() string

func (*Import) Unmarshal 

func (m *Import) Unmarshal(dAtA []byte) error

func (*Import) XXX_DiscardUnknown 

func (m *Import) XXX_DiscardUnknown()

func (*Import) XXX_Marshal 

func (m *Import) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Import) XXX_Merge 

func (m *Import) XXX_Merge(src proto.Message)

func (*Import) XXX_Size 

func (m *Import) XXX_Size() int

func (*Import) XXX_Unmarshal 

func (m *Import) XXX_Unmarshal(b []byte) error

type LargeRow 

type LargeRow struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonLargeRowDetails `protobuf:"bytes,2,opt,name=row,proto3,embedded=row" json:""`
}

LargeRow is recorded when a statement tries to write a row larger than cluster setting `sql.guardrails.max_row_size_log` to the database. Multiple LargeRow events will be recorded for statements writing multiple large rows. LargeRow events are recorded before the transaction commits, so in the case of transaction abort there will not be a corresponding row in the database.

func (*LargeRow) AppendJSONFields 

func (m *LargeRow) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*LargeRow) Descriptor 

func (*LargeRow) Descriptor() ([]byte, []int)

func (*LargeRow) LoggingChannel 

func (m *LargeRow) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*LargeRow) Marshal 

func (m *LargeRow) Marshal() (dAtA []byte, err error)

func (*LargeRow) MarshalTo 

func (m *LargeRow) MarshalTo(dAtA []byte) (int, error)

func (*LargeRow) MarshalToSizedBuffer 

func (m *LargeRow) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LargeRow) ProtoMessage 

func (*LargeRow) ProtoMessage()

func (*LargeRow) Reset 

func (m *LargeRow) Reset()

func (*LargeRow) Size 

func (m *LargeRow) Size() (n int)

func (*LargeRow) String 

func (m *LargeRow) String() string

func (*LargeRow) Unmarshal 

func (m *LargeRow) Unmarshal(dAtA []byte) error

func (*LargeRow) XXX_DiscardUnknown 

func (m *LargeRow) XXX_DiscardUnknown()

func (*LargeRow) XXX_Marshal 

func (m *LargeRow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LargeRow) XXX_Merge 

func (m *LargeRow) XXX_Merge(src proto.Message)

func (*LargeRow) XXX_Size 

func (m *LargeRow) XXX_Size() int

func (*LargeRow) XXX_Unmarshal 

func (m *LargeRow) XXX_Unmarshal(b []byte) error

type LargeRowInternal 

type LargeRowInternal struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonLargeRowDetails `protobuf:"bytes,2,opt,name=row,proto3,embedded=row" json:""`
}

LargeRowInternal is recorded when an internal query tries to write a row larger than cluster settings `sql.guardrails.max_row_size_log` or `sql.guardrails.max_row_size_err` to the database.

func (*LargeRowInternal) AppendJSONFields 

func (m *LargeRowInternal) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*LargeRowInternal) Descriptor 

func (*LargeRowInternal) Descriptor() ([]byte, []int)

func (*LargeRowInternal) LoggingChannel 

func (m *LargeRowInternal) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*LargeRowInternal) Marshal 

func (m *LargeRowInternal) Marshal() (dAtA []byte, err error)

func (*LargeRowInternal) MarshalTo 

func (m *LargeRowInternal) MarshalTo(dAtA []byte) (int, error)

func (*LargeRowInternal) MarshalToSizedBuffer 

func (m *LargeRowInternal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LargeRowInternal) ProtoMessage 

func (*LargeRowInternal) ProtoMessage()

func (*LargeRowInternal) Reset 

func (m *LargeRowInternal) Reset()

func (*LargeRowInternal) Size 

func (m *LargeRowInternal) Size() (n int)

func (*LargeRowInternal) String 

func (m *LargeRowInternal) String() string

func (*LargeRowInternal) Unmarshal 

func (m *LargeRowInternal) Unmarshal(dAtA []byte) error

func (*LargeRowInternal) XXX_DiscardUnknown 

func (m *LargeRowInternal) XXX_DiscardUnknown()

func (*LargeRowInternal) XXX_Marshal 

func (m *LargeRowInternal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LargeRowInternal) XXX_Merge 

func (m *LargeRowInternal) XXX_Merge(src proto.Message)

func (*LargeRowInternal) XXX_Size 

func (m *LargeRowInternal) XXX_Size() int

func (*LargeRowInternal) XXX_Unmarshal 

func (m *LargeRowInternal) XXX_Unmarshal(b []byte) error

type NodeDecommissioned 

type NodeDecommissioned struct {
	CommonEventDetails            `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonNodeDecommissionDetails `protobuf:"bytes,2,opt,name=node,proto3,embedded=node" json:""`
}

NodeDecommissioned is recorded when a node is marked as decommissioned.

func (*NodeDecommissioned) AppendJSONFields 

func (m *NodeDecommissioned) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*NodeDecommissioned) Descriptor 

func (*NodeDecommissioned) Descriptor() ([]byte, []int)

func (*NodeDecommissioned) LoggingChannel 

func (m *NodeDecommissioned) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*NodeDecommissioned) Marshal 

func (m *NodeDecommissioned) Marshal() (dAtA []byte, err error)

func (*NodeDecommissioned) MarshalTo 

func (m *NodeDecommissioned) MarshalTo(dAtA []byte) (int, error)

func (*NodeDecommissioned) MarshalToSizedBuffer 

func (m *NodeDecommissioned) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeDecommissioned) ProtoMessage 

func (*NodeDecommissioned) ProtoMessage()

func (*NodeDecommissioned) Reset 

func (m *NodeDecommissioned) Reset()

func (*NodeDecommissioned) Size 

func (m *NodeDecommissioned) Size() (n int)

func (*NodeDecommissioned) String 

func (m *NodeDecommissioned) String() string

func (*NodeDecommissioned) Unmarshal 

func (m *NodeDecommissioned) Unmarshal(dAtA []byte) error

func (*NodeDecommissioned) XXX_DiscardUnknown 

func (m *NodeDecommissioned) XXX_DiscardUnknown()

func (*NodeDecommissioned) XXX_Marshal 

func (m *NodeDecommissioned) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeDecommissioned) XXX_Merge 

func (m *NodeDecommissioned) XXX_Merge(src proto.Message)

func (*NodeDecommissioned) XXX_Size 

func (m *NodeDecommissioned) XXX_Size() int

func (*NodeDecommissioned) XXX_Unmarshal 

func (m *NodeDecommissioned) XXX_Unmarshal(b []byte) error

type NodeDecommissioning 

type NodeDecommissioning struct {
	CommonEventDetails            `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonNodeDecommissionDetails `protobuf:"bytes,2,opt,name=node,proto3,embedded=node" json:""`
}

NodeDecommissioning is recorded when a node is marked as decommissioning.

func (*NodeDecommissioning) AppendJSONFields 

func (m *NodeDecommissioning) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*NodeDecommissioning) Descriptor 

func (*NodeDecommissioning) Descriptor() ([]byte, []int)

func (*NodeDecommissioning) LoggingChannel 

func (m *NodeDecommissioning) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*NodeDecommissioning) Marshal 

func (m *NodeDecommissioning) Marshal() (dAtA []byte, err error)

func (*NodeDecommissioning) MarshalTo 

func (m *NodeDecommissioning) MarshalTo(dAtA []byte) (int, error)

func (*NodeDecommissioning) MarshalToSizedBuffer 

func (m *NodeDecommissioning) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeDecommissioning) ProtoMessage 

func (*NodeDecommissioning) ProtoMessage()

func (*NodeDecommissioning) Reset 

func (m *NodeDecommissioning) Reset()

func (*NodeDecommissioning) Size 

func (m *NodeDecommissioning) Size() (n int)

func (*NodeDecommissioning) String 

func (m *NodeDecommissioning) String() string

func (*NodeDecommissioning) Unmarshal 

func (m *NodeDecommissioning) Unmarshal(dAtA []byte) error

func (*NodeDecommissioning) XXX_DiscardUnknown 

func (m *NodeDecommissioning) XXX_DiscardUnknown()

func (*NodeDecommissioning) XXX_Marshal 

func (m *NodeDecommissioning) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeDecommissioning) XXX_Merge 

func (m *NodeDecommissioning) XXX_Merge(src proto.Message)

func (*NodeDecommissioning) XXX_Size 

func (m *NodeDecommissioning) XXX_Size() int

func (*NodeDecommissioning) XXX_Unmarshal 

func (m *NodeDecommissioning) XXX_Unmarshal(b []byte) error

type NodeJoin 

type NodeJoin struct {
	CommonEventDetails     `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonNodeEventDetails `protobuf:"bytes,2,opt,name=node,proto3,embedded=node" json:""`
}

NodeJoin is recorded when a node joins the cluster.

func (*NodeJoin) AppendJSONFields 

func (m *NodeJoin) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*NodeJoin) Descriptor 

func (*NodeJoin) Descriptor() ([]byte, []int)

func (*NodeJoin) LoggingChannel 

func (m *NodeJoin) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*NodeJoin) Marshal 

func (m *NodeJoin) Marshal() (dAtA []byte, err error)

func (*NodeJoin) MarshalTo 

func (m *NodeJoin) MarshalTo(dAtA []byte) (int, error)

func (*NodeJoin) MarshalToSizedBuffer 

func (m *NodeJoin) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeJoin) ProtoMessage 

func (*NodeJoin) ProtoMessage()

func (*NodeJoin) Reset 

func (m *NodeJoin) Reset()

func (*NodeJoin) Size 

func (m *NodeJoin) Size() (n int)

func (*NodeJoin) String 

func (m *NodeJoin) String() string

func (*NodeJoin) Unmarshal 

func (m *NodeJoin) Unmarshal(dAtA []byte) error

func (*NodeJoin) XXX_DiscardUnknown 

func (m *NodeJoin) XXX_DiscardUnknown()

func (*NodeJoin) XXX_Marshal 

func (m *NodeJoin) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeJoin) XXX_Merge 

func (m *NodeJoin) XXX_Merge(src proto.Message)

func (*NodeJoin) XXX_Size 

func (m *NodeJoin) XXX_Size() int

func (*NodeJoin) XXX_Unmarshal 

func (m *NodeJoin) XXX_Unmarshal(b []byte) error

type NodeRecommissioned 

type NodeRecommissioned struct {
	CommonEventDetails            `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonNodeDecommissionDetails `protobuf:"bytes,2,opt,name=node,proto3,embedded=node" json:""`
}

NodeRecommissioned is recorded when a decommissioning node is recommissioned.

func (*NodeRecommissioned) AppendJSONFields 

func (m *NodeRecommissioned) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*NodeRecommissioned) Descriptor 

func (*NodeRecommissioned) Descriptor() ([]byte, []int)

func (*NodeRecommissioned) LoggingChannel 

func (m *NodeRecommissioned) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*NodeRecommissioned) Marshal 

func (m *NodeRecommissioned) Marshal() (dAtA []byte, err error)

func (*NodeRecommissioned) MarshalTo 

func (m *NodeRecommissioned) MarshalTo(dAtA []byte) (int, error)

func (*NodeRecommissioned) MarshalToSizedBuffer 

func (m *NodeRecommissioned) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeRecommissioned) ProtoMessage 

func (*NodeRecommissioned) ProtoMessage()

func (*NodeRecommissioned) Reset 

func (m *NodeRecommissioned) Reset()

func (*NodeRecommissioned) Size 

func (m *NodeRecommissioned) Size() (n int)

func (*NodeRecommissioned) String 

func (m *NodeRecommissioned) String() string

func (*NodeRecommissioned) Unmarshal 

func (m *NodeRecommissioned) Unmarshal(dAtA []byte) error

func (*NodeRecommissioned) XXX_DiscardUnknown 

func (m *NodeRecommissioned) XXX_DiscardUnknown()

func (*NodeRecommissioned) XXX_Marshal 

func (m *NodeRecommissioned) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeRecommissioned) XXX_Merge 

func (m *NodeRecommissioned) XXX_Merge(src proto.Message)

func (*NodeRecommissioned) XXX_Size 

func (m *NodeRecommissioned) XXX_Size() int

func (*NodeRecommissioned) XXX_Unmarshal 

func (m *NodeRecommissioned) XXX_Unmarshal(b []byte) error

type NodeRestart 

type NodeRestart struct {
	CommonEventDetails     `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonNodeEventDetails `protobuf:"bytes,2,opt,name=node,proto3,embedded=node" json:""`
}

NodeRestart is recorded when an existing node rejoins the cluster after being offline.

func (*NodeRestart) AppendJSONFields 

func (m *NodeRestart) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*NodeRestart) Descriptor 

func (*NodeRestart) Descriptor() ([]byte, []int)

func (*NodeRestart) LoggingChannel 

func (m *NodeRestart) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*NodeRestart) Marshal 

func (m *NodeRestart) Marshal() (dAtA []byte, err error)

func (*NodeRestart) MarshalTo 

func (m *NodeRestart) MarshalTo(dAtA []byte) (int, error)

func (*NodeRestart) MarshalToSizedBuffer 

func (m *NodeRestart) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeRestart) ProtoMessage 

func (*NodeRestart) ProtoMessage()

func (*NodeRestart) Reset 

func (m *NodeRestart) Reset()

func (*NodeRestart) Size 

func (m *NodeRestart) Size() (n int)

func (*NodeRestart) String 

func (m *NodeRestart) String() string

func (*NodeRestart) Unmarshal 

func (m *NodeRestart) Unmarshal(dAtA []byte) error

func (*NodeRestart) XXX_DiscardUnknown 

func (m *NodeRestart) XXX_DiscardUnknown()

func (*NodeRestart) XXX_Marshal 

func (m *NodeRestart) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeRestart) XXX_Merge 

func (m *NodeRestart) XXX_Merge(src proto.Message)

func (*NodeRestart) XXX_Size 

func (m *NodeRestart) XXX_Size() int

func (*NodeRestart) XXX_Unmarshal 

func (m *NodeRestart) XXX_Unmarshal(b []byte) error

type PasswordHashConverted 

type PasswordHashConverted struct {
	CommonEventDetails `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	// The name of the user/role whose credentials have been converted.
	RoleName string `protobuf:"bytes,3,opt,name=role_name,json=roleName,proto3" json:",omitempty"`
	// The previous hash method.
	OldMethod string `protobuf:"bytes,4,opt,name=old_method,json=oldMethod,proto3" json:",omitempty" redact:"nonsensitive"`
	// The new hash method.
	NewMethod string `protobuf:"bytes,5,opt,name=new_method,json=newMethod,proto3" json:",omitempty" redact:"nonsensitive"`
}

PasswordHashConverted is recorded when the password credentials are automatically converted server-side.

func (*PasswordHashConverted) AppendJSONFields 

func (m *PasswordHashConverted) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*PasswordHashConverted) Descriptor 

func (*PasswordHashConverted) Descriptor() ([]byte, []int)

func (*PasswordHashConverted) LoggingChannel 

func (m *PasswordHashConverted) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*PasswordHashConverted) Marshal 

func (m *PasswordHashConverted) Marshal() (dAtA []byte, err error)

func (*PasswordHashConverted) MarshalTo 

func (m *PasswordHashConverted) MarshalTo(dAtA []byte) (int, error)

func (*PasswordHashConverted) MarshalToSizedBuffer 

func (m *PasswordHashConverted) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PasswordHashConverted) ProtoMessage 

func (*PasswordHashConverted) ProtoMessage()

func (*PasswordHashConverted) Reset 

func (m *PasswordHashConverted) Reset()

func (*PasswordHashConverted) Size 

func (m *PasswordHashConverted) Size() (n int)

func (*PasswordHashConverted) String 

func (m *PasswordHashConverted) String() string

func (*PasswordHashConverted) Unmarshal 

func (m *PasswordHashConverted) Unmarshal(dAtA []byte) error

func (*PasswordHashConverted) XXX_DiscardUnknown 

func (m *PasswordHashConverted) XXX_DiscardUnknown()

func (*PasswordHashConverted) XXX_Marshal 

func (m *PasswordHashConverted) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PasswordHashConverted) XXX_Merge 

func (m *PasswordHashConverted) XXX_Merge(src proto.Message)

func (*PasswordHashConverted) XXX_Size 

func (m *PasswordHashConverted) XXX_Size() int

func (*PasswordHashConverted) XXX_Unmarshal 

func (m *PasswordHashConverted) XXX_Unmarshal(b []byte) error

type QueryExecute 

type QueryExecute struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonSQLExecDetails  `protobuf:"bytes,3,opt,name=exec,proto3,embedded=exec" json:""`
}

QueryExecute is recorded when a query is executed, and the cluster setting `sql.trace.log_statement_execute` is set.

func (*QueryExecute) AppendJSONFields 

func (m *QueryExecute) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*QueryExecute) Descriptor 

func (*QueryExecute) Descriptor() ([]byte, []int)

func (*QueryExecute) LoggingChannel 

func (m *QueryExecute) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*QueryExecute) Marshal 

func (m *QueryExecute) Marshal() (dAtA []byte, err error)

func (*QueryExecute) MarshalTo 

func (m *QueryExecute) MarshalTo(dAtA []byte) (int, error)

func (*QueryExecute) MarshalToSizedBuffer 

func (m *QueryExecute) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryExecute) ProtoMessage 

func (*QueryExecute) ProtoMessage()

func (*QueryExecute) Reset 

func (m *QueryExecute) Reset()

func (*QueryExecute) Size 

func (m *QueryExecute) Size() (n int)

func (*QueryExecute) String 

func (m *QueryExecute) String() string

func (*QueryExecute) Unmarshal 

func (m *QueryExecute) Unmarshal(dAtA []byte) error

func (*QueryExecute) XXX_DiscardUnknown 

func (m *QueryExecute) XXX_DiscardUnknown()

func (*QueryExecute) XXX_Marshal 

func (m *QueryExecute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryExecute) XXX_Merge 

func (m *QueryExecute) XXX_Merge(src proto.Message)

func (*QueryExecute) XXX_Size 

func (m *QueryExecute) XXX_Size() int

func (*QueryExecute) XXX_Unmarshal 

func (m *QueryExecute) XXX_Unmarshal(b []byte) error

type RemoveZoneConfig 

type RemoveZoneConfig struct {
	CommonEventDetails      `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails   `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonZoneConfigDetails `protobuf:"bytes,3,opt,name=config,proto3,embedded=config" json:""`
}

RemoveZoneConfig is recorded when a zone config is removed.

func (*RemoveZoneConfig) AppendJSONFields 

func (m *RemoveZoneConfig) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*RemoveZoneConfig) Descriptor 

func (*RemoveZoneConfig) Descriptor() ([]byte, []int)

func (*RemoveZoneConfig) LoggingChannel 

func (m *RemoveZoneConfig) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*RemoveZoneConfig) Marshal 

func (m *RemoveZoneConfig) Marshal() (dAtA []byte, err error)

func (*RemoveZoneConfig) MarshalTo 

func (m *RemoveZoneConfig) MarshalTo(dAtA []byte) (int, error)

func (*RemoveZoneConfig) MarshalToSizedBuffer 

func (m *RemoveZoneConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoveZoneConfig) ProtoMessage 

func (*RemoveZoneConfig) ProtoMessage()

func (*RemoveZoneConfig) Reset 

func (m *RemoveZoneConfig) Reset()

func (*RemoveZoneConfig) Size 

func (m *RemoveZoneConfig) Size() (n int)

func (*RemoveZoneConfig) String 

func (m *RemoveZoneConfig) String() string

func (*RemoveZoneConfig) Unmarshal 

func (m *RemoveZoneConfig) Unmarshal(dAtA []byte) error

func (*RemoveZoneConfig) XXX_DiscardUnknown 

func (m *RemoveZoneConfig) XXX_DiscardUnknown()

func (*RemoveZoneConfig) XXX_Marshal 

func (m *RemoveZoneConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveZoneConfig) XXX_Merge 

func (m *RemoveZoneConfig) XXX_Merge(src proto.Message)

func (*RemoveZoneConfig) XXX_Size 

func (m *RemoveZoneConfig) XXX_Size() int

func (*RemoveZoneConfig) XXX_Unmarshal 

func (m *RemoveZoneConfig) XXX_Unmarshal(b []byte) error

type RenameDatabase 

type RenameDatabase struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The old name of the affected database.
	DatabaseName string `protobuf:"bytes,3,opt,name=database_name,json=databaseName,proto3" json:",omitempty"`
	// The new name of the affected database.
	NewDatabaseName string `protobuf:"bytes,4,opt,name=new_database_name,json=newDatabaseName,proto3" json:",omitempty"`
}

RenameDatabase is recorded when a database is renamed.

func (*RenameDatabase) AppendJSONFields 

func (m *RenameDatabase) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*RenameDatabase) Descriptor 

func (*RenameDatabase) Descriptor() ([]byte, []int)

func (*RenameDatabase) LoggingChannel 

func (m *RenameDatabase) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*RenameDatabase) Marshal 

func (m *RenameDatabase) Marshal() (dAtA []byte, err error)

func (*RenameDatabase) MarshalTo 

func (m *RenameDatabase) MarshalTo(dAtA []byte) (int, error)

func (*RenameDatabase) MarshalToSizedBuffer 

func (m *RenameDatabase) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RenameDatabase) ProtoMessage 

func (*RenameDatabase) ProtoMessage()

func (*RenameDatabase) Reset 

func (m *RenameDatabase) Reset()

func (*RenameDatabase) Size 

func (m *RenameDatabase) Size() (n int)

func (*RenameDatabase) String 

func (m *RenameDatabase) String() string

func (*RenameDatabase) Unmarshal 

func (m *RenameDatabase) Unmarshal(dAtA []byte) error

func (*RenameDatabase) XXX_DiscardUnknown 

func (m *RenameDatabase) XXX_DiscardUnknown()

func (*RenameDatabase) XXX_Marshal 

func (m *RenameDatabase) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RenameDatabase) XXX_Merge 

func (m *RenameDatabase) XXX_Merge(src proto.Message)

func (*RenameDatabase) XXX_Size 

func (m *RenameDatabase) XXX_Size() int

func (*RenameDatabase) XXX_Unmarshal 

func (m *RenameDatabase) XXX_Unmarshal(b []byte) error

type RenameSchema 

type RenameSchema struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The old name of the affected schema.
	SchemaName string `protobuf:"bytes,3,opt,name=schema_name,json=schemaName,proto3" json:",omitempty"`
	// The new name of the affected schema.
	NewSchemaName string `protobuf:"bytes,4,opt,name=new_schema_name,json=newSchemaName,proto3" json:",omitempty"`
}

RenameSchema is recorded when a schema is renamed.

func (*RenameSchema) AppendJSONFields 

func (m *RenameSchema) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*RenameSchema) Descriptor 

func (*RenameSchema) Descriptor() ([]byte, []int)

func (*RenameSchema) LoggingChannel 

func (m *RenameSchema) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*RenameSchema) Marshal 

func (m *RenameSchema) Marshal() (dAtA []byte, err error)

func (*RenameSchema) MarshalTo 

func (m *RenameSchema) MarshalTo(dAtA []byte) (int, error)

func (*RenameSchema) MarshalToSizedBuffer 

func (m *RenameSchema) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RenameSchema) ProtoMessage 

func (*RenameSchema) ProtoMessage()

func (*RenameSchema) Reset 

func (m *RenameSchema) Reset()

func (*RenameSchema) Size 

func (m *RenameSchema) Size() (n int)

func (*RenameSchema) String 

func (m *RenameSchema) String() string

func (*RenameSchema) Unmarshal 

func (m *RenameSchema) Unmarshal(dAtA []byte) error

func (*RenameSchema) XXX_DiscardUnknown 

func (m *RenameSchema) XXX_DiscardUnknown()

func (*RenameSchema) XXX_Marshal 

func (m *RenameSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RenameSchema) XXX_Merge 

func (m *RenameSchema) XXX_Merge(src proto.Message)

func (*RenameSchema) XXX_Size 

func (m *RenameSchema) XXX_Size() int

func (*RenameSchema) XXX_Unmarshal 

func (m *RenameSchema) XXX_Unmarshal(b []byte) error

type RenameTable 

type RenameTable struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The old name of the affected table.
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
	// The new name of the affected table.
	NewTableName string `protobuf:"bytes,4,opt,name=new_table_name,json=newTableName,proto3" json:",omitempty"`
}

RenameTable is recorded when a table, sequence or view is renamed.

func (*RenameTable) AppendJSONFields 

func (m *RenameTable) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*RenameTable) Descriptor 

func (*RenameTable) Descriptor() ([]byte, []int)

func (*RenameTable) LoggingChannel 

func (m *RenameTable) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*RenameTable) Marshal 

func (m *RenameTable) Marshal() (dAtA []byte, err error)

func (*RenameTable) MarshalTo 

func (m *RenameTable) MarshalTo(dAtA []byte) (int, error)

func (*RenameTable) MarshalToSizedBuffer 

func (m *RenameTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RenameTable) ProtoMessage 

func (*RenameTable) ProtoMessage()

func (*RenameTable) Reset 

func (m *RenameTable) Reset()

func (*RenameTable) Size 

func (m *RenameTable) Size() (n int)

func (*RenameTable) String 

func (m *RenameTable) String() string

func (*RenameTable) Unmarshal 

func (m *RenameTable) Unmarshal(dAtA []byte) error

func (*RenameTable) XXX_DiscardUnknown 

func (m *RenameTable) XXX_DiscardUnknown()

func (*RenameTable) XXX_Marshal 

func (m *RenameTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RenameTable) XXX_Merge 

func (m *RenameTable) XXX_Merge(src proto.Message)

func (*RenameTable) XXX_Size 

func (m *RenameTable) XXX_Size() int

func (*RenameTable) XXX_Unmarshal 

func (m *RenameTable) XXX_Unmarshal(b []byte) error

type RenameType 

type RenameType struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The old name of the affected type.
	TypeName string `protobuf:"bytes,3,opt,name=type_name,json=typeName,proto3" json:",omitempty"`
	// The new name of the affected type.
	NewTypeName string `protobuf:"bytes,4,opt,name=new_type_name,json=newTypeName,proto3" json:",omitempty"`
}

RenameType is recorded when a user-defined type is renamed.

func (*RenameType) AppendJSONFields 

func (m *RenameType) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*RenameType) Descriptor 

func (*RenameType) Descriptor() ([]byte, []int)

func (*RenameType) LoggingChannel 

func (m *RenameType) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*RenameType) Marshal 

func (m *RenameType) Marshal() (dAtA []byte, err error)

func (*RenameType) MarshalTo 

func (m *RenameType) MarshalTo(dAtA []byte) (int, error)

func (*RenameType) MarshalToSizedBuffer 

func (m *RenameType) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RenameType) ProtoMessage 

func (*RenameType) ProtoMessage()

func (*RenameType) Reset 

func (m *RenameType) Reset()

func (*RenameType) Size 

func (m *RenameType) Size() (n int)

func (*RenameType) String 

func (m *RenameType) String() string

func (*RenameType) Unmarshal 

func (m *RenameType) Unmarshal(dAtA []byte) error

func (*RenameType) XXX_DiscardUnknown 

func (m *RenameType) XXX_DiscardUnknown()

func (*RenameType) XXX_Marshal 

func (m *RenameType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RenameType) XXX_Merge 

func (m *RenameType) XXX_Merge(src proto.Message)

func (*RenameType) XXX_Size 

func (m *RenameType) XXX_Size() int

func (*RenameType) XXX_Unmarshal 

func (m *RenameType) XXX_Unmarshal(b []byte) error

type Restore 

type Restore struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonJobEventDetails `protobuf:"bytes,2,opt,name=job,proto3,embedded=job" json:""`
}

Restore is recorded when a restore job is created and successful completion. If the job fails, events will be emitted on job creation, failure, and successful revert.

func (*Restore) AppendJSONFields 

func (m *Restore) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*Restore) Descriptor 

func (*Restore) Descriptor() ([]byte, []int)

func (*Restore) LoggingChannel 

func (m *Restore) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*Restore) Marshal 

func (m *Restore) Marshal() (dAtA []byte, err error)

func (*Restore) MarshalTo 

func (m *Restore) MarshalTo(dAtA []byte) (int, error)

func (*Restore) MarshalToSizedBuffer 

func (m *Restore) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Restore) ProtoMessage 

func (*Restore) ProtoMessage()

func (*Restore) Reset 

func (m *Restore) Reset()

func (*Restore) Size 

func (m *Restore) Size() (n int)

func (*Restore) String 

func (m *Restore) String() string

func (*Restore) Unmarshal 

func (m *Restore) Unmarshal(dAtA []byte) error

func (*Restore) XXX_DiscardUnknown 

func (m *Restore) XXX_DiscardUnknown()

func (*Restore) XXX_Marshal 

func (m *Restore) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Restore) XXX_Merge 

func (m *Restore) XXX_Merge(src proto.Message)

func (*Restore) XXX_Size 

func (m *Restore) XXX_Size() int

func (*Restore) XXX_Unmarshal 

func (m *Restore) XXX_Unmarshal(b []byte) error

type ReverseSchemaChange 

type ReverseSchemaChange struct {
	CommonEventDetails             `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSchemaChangeEventDetails `protobuf:"bytes,2,opt,name=sc,proto3,embedded=sc" json:""`
	// The error encountered that caused the schema change to be reversed.
	// The specific format of the error is variable and can change across releases without warning.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:",omitempty"`
	// The SQLSTATE code for the error.
	SQLSTATE string `protobuf:"bytes,5,opt,name=sqlstate,proto3" json:",omitempty" redact:"nonsensitive"`
}

ReverseSchemaChange is recorded when an in-progress schema change encounters a problem and is reversed.

func (*ReverseSchemaChange) AppendJSONFields 

func (m *ReverseSchemaChange) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*ReverseSchemaChange) Descriptor 

func (*ReverseSchemaChange) Descriptor() ([]byte, []int)

func (*ReverseSchemaChange) LoggingChannel 

func (m *ReverseSchemaChange) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*ReverseSchemaChange) Marshal 

func (m *ReverseSchemaChange) Marshal() (dAtA []byte, err error)

func (*ReverseSchemaChange) MarshalTo 

func (m *ReverseSchemaChange) MarshalTo(dAtA []byte) (int, error)

func (*ReverseSchemaChange) MarshalToSizedBuffer 

func (m *ReverseSchemaChange) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReverseSchemaChange) ProtoMessage 

func (*ReverseSchemaChange) ProtoMessage()

func (*ReverseSchemaChange) Reset 

func (m *ReverseSchemaChange) Reset()

func (*ReverseSchemaChange) Size 

func (m *ReverseSchemaChange) Size() (n int)

func (*ReverseSchemaChange) String 

func (m *ReverseSchemaChange) String() string

func (*ReverseSchemaChange) Unmarshal 

func (m *ReverseSchemaChange) Unmarshal(dAtA []byte) error

func (*ReverseSchemaChange) XXX_DiscardUnknown 

func (m *ReverseSchemaChange) XXX_DiscardUnknown()

func (*ReverseSchemaChange) XXX_Marshal 

func (m *ReverseSchemaChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReverseSchemaChange) XXX_Merge 

func (m *ReverseSchemaChange) XXX_Merge(src proto.Message)

func (*ReverseSchemaChange) XXX_Size 

func (m *ReverseSchemaChange) XXX_Size() int

func (*ReverseSchemaChange) XXX_Unmarshal 

func (m *ReverseSchemaChange) XXX_Unmarshal(b []byte) error

type RuntimeStats 

type RuntimeStats struct {
	CommonEventDetails `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	// The process resident set size. Expressed as bytes.
	MemRSSBytes uint64 `protobuf:"varint,2,opt,name=mem_rss_bytes,json=memRssBytes,proto3" json:",omitempty"`
	// The number of goroutines.
	GoroutineCount uint64 `protobuf:"varint,3,opt,name=goroutine_count,json=goroutineCount,proto3" json:",omitempty"`
	// The stack system memory used. Expressed as bytes.
	MemStackSysBytes uint64 `protobuf:"varint,4,opt,name=mem_stack_sys_bytes,json=memStackSysBytes,proto3" json:",omitempty"`
	// The memory allocated by Go. Expressed as bytes.
	GoAllocBytes uint64 `protobuf:"varint,5,opt,name=go_alloc_bytes,json=goAllocBytes,proto3" json:",omitempty"`
	// The total memory allocated by Go but not released. Expressed as bytes.
	GoTotalBytes uint64 `protobuf:"varint,6,opt,name=go_total_bytes,json=goTotalBytes,proto3" json:",omitempty"`
	// The staleness of the Go memory statistics. Expressed in seconds.
	GoStatsStaleness float32 `protobuf:"fixed32,7,opt,name=go_stats_staleness,json=goStatsStaleness,proto3" json:",omitempty"`
	// The amount of heap fragmentation. Expressed as bytes.
	HeapFragmentBytes uint64 `protobuf:"varint,8,opt,name=heap_fragment_bytes,json=heapFragmentBytes,proto3" json:",omitempty"`
	// The amount of heap reserved. Expressed as bytes.
	HeapReservedBytes uint64 `protobuf:"varint,9,opt,name=heap_reserved_bytes,json=heapReservedBytes,proto3" json:",omitempty"`
	// The amount of heap released. Expressed as bytes.
	HeapReleasedBytes uint64 `protobuf:"varint,10,opt,name=heap_released_bytes,json=heapReleasedBytes,proto3" json:",omitempty"`
	// The memory allocated outside of Go. Expressed as bytes.
	CGoAllocBytes uint64 `protobuf:"varint,11,opt,name=cgo_alloc_bytes,json=cgoAllocBytes,proto3" json:",omitempty"`
	// The total memory allocated outside of Go but not released. Expressed as bytes.
	CGoTotalBytes uint64 `protobuf:"varint,12,opt,name=cgo_total_bytes,json=cgoTotalBytes,proto3" json:",omitempty"`
	// The total number of calls outside of Go over time. Expressed as operations per second.
	CGoCallRate float32 `protobuf:"fixed32,13,opt,name=cgo_call_rate,json=cgoCallRate,proto3" json:",omitempty"`
	// The user CPU percentage.
	CPUUserPercent float32 `protobuf:"fixed32,14,opt,name=cpu_user_percent,json=cpuUserPercent,proto3" json:",omitempty"`
	// The system CPU percentage.
	CPUSysPercent float32 `protobuf:"fixed32,15,opt,name=cpu_sys_percent,json=cpuSysPercent,proto3" json:",omitempty"`
	// The GC pause percentage.
	GCPausePercent float32 `protobuf:"fixed32,16,opt,name=gc_pause_percent,json=gcPausePercent,proto3" json:",omitempty"`
	// The total number of GC runs.
	GCRunCount uint64 `protobuf:"varint,17,opt,name=gc_run_count,json=gcRunCount,proto3" json:",omitempty"`
	// The bytes received on all network interfaces since this process started.
	NetHostRecvBytes uint64 `protobuf:"varint,18,opt,name=net_host_recv_bytes,json=netHostRecvBytes,proto3" json:",omitempty"`
	// The bytes sent on all network interfaces since this process started.
	NetHostSendBytes uint64 `protobuf:"varint,19,opt,name=net_host_send_bytes,json=netHostSendBytes,proto3" json:",omitempty"`
}

RuntimeStats is recorded every 10 seconds as server health metrics.

func (*RuntimeStats) AppendJSONFields 

func (m *RuntimeStats) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*RuntimeStats) Descriptor 

func (*RuntimeStats) Descriptor() ([]byte, []int)

func (*RuntimeStats) LoggingChannel 

func (m *RuntimeStats) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*RuntimeStats) Marshal 

func (m *RuntimeStats) Marshal() (dAtA []byte, err error)

func (*RuntimeStats) MarshalTo 

func (m *RuntimeStats) MarshalTo(dAtA []byte) (int, error)

func (*RuntimeStats) MarshalToSizedBuffer 

func (m *RuntimeStats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RuntimeStats) ProtoMessage 

func (*RuntimeStats) ProtoMessage()

func (*RuntimeStats) Reset 

func (m *RuntimeStats) Reset()

func (*RuntimeStats) Size 

func (m *RuntimeStats) Size() (n int)

func (*RuntimeStats) String 

func (m *RuntimeStats) String() string

func (*RuntimeStats) Unmarshal 

func (m *RuntimeStats) Unmarshal(dAtA []byte) error

func (*RuntimeStats) XXX_DiscardUnknown 

func (m *RuntimeStats) XXX_DiscardUnknown()

func (*RuntimeStats) XXX_Marshal 

func (m *RuntimeStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RuntimeStats) XXX_Merge 

func (m *RuntimeStats) XXX_Merge(src proto.Message)

func (*RuntimeStats) XXX_Size 

func (m *RuntimeStats) XXX_Size() int

func (*RuntimeStats) XXX_Unmarshal 

func (m *RuntimeStats) XXX_Unmarshal(b []byte) error

type SampledQuery 

type SampledQuery struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonSQLExecDetails  `protobuf:"bytes,3,opt,name=exec,proto3,embedded=exec" json:""`
	// skipped_queries indicate how many SQL statements were not
	// considered for sampling prior to this one. If the field is
	// omitted, or its value is zero, this indicates that no statement
	// was omitted since the last event.
	SkippedQueries uint64 `protobuf:"varint,4,opt,name=skipped_queries,json=skippedQueries,proto3" json:",omitempty"`
	// Cost of the query as estimated by the optimizer.
	CostEstimate float64 `protobuf:"fixed64,5,opt,name=cost_estimate,json=costEstimate,proto3" json:",omitempty"`
	// The distribution of the DistSQL query plan (local, full, or partial).
	Distribution string `protobuf:"bytes,6,opt,name=distribution,proto3" json:",omitempty" redact:"nonsensitive"`
}

SampledQuery is the SQL query event logged to the telemetry channel. It contains common SQL event/execution details.

func (*SampledQuery) AppendJSONFields 

func (m *SampledQuery) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*SampledQuery) Descriptor 

func (*SampledQuery) Descriptor() ([]byte, []int)

func (*SampledQuery) LoggingChannel 

func (m *SampledQuery) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*SampledQuery) Marshal 

func (m *SampledQuery) Marshal() (dAtA []byte, err error)

func (*SampledQuery) MarshalTo 

func (m *SampledQuery) MarshalTo(dAtA []byte) (int, error)

func (*SampledQuery) MarshalToSizedBuffer 

func (m *SampledQuery) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SampledQuery) ProtoMessage 

func (*SampledQuery) ProtoMessage()

func (*SampledQuery) Reset 

func (m *SampledQuery) Reset()

func (*SampledQuery) Size 

func (m *SampledQuery) Size() (n int)

func (*SampledQuery) String 

func (m *SampledQuery) String() string

func (*SampledQuery) Unmarshal 

func (m *SampledQuery) Unmarshal(dAtA []byte) error

func (*SampledQuery) XXX_DiscardUnknown 

func (m *SampledQuery) XXX_DiscardUnknown()

func (*SampledQuery) XXX_Marshal 

func (m *SampledQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SampledQuery) XXX_Merge 

func (m *SampledQuery) XXX_Merge(src proto.Message)

func (*SampledQuery) XXX_Size 

func (m *SampledQuery) XXX_Size() int

func (*SampledQuery) XXX_Unmarshal 

func (m *SampledQuery) XXX_Unmarshal(b []byte) error

type SensitiveTableAccess 

type SensitiveTableAccess struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonSQLExecDetails  `protobuf:"bytes,3,opt,name=exec,proto3,embedded=exec" json:""`
	// The name of the table being audited.
	TableName string `protobuf:"bytes,4,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
	// How the table was accessed (r=read / rw=read/write).
	AccessMode string `protobuf:"bytes,5,opt,name=access_mode,json=accessMode,proto3" json:",omitempty" redact:"nonsensitive"`
}

SensitiveTableAccess is recorded when an access is performed to a table marked as audited.

func (*SensitiveTableAccess) AppendJSONFields 

func (m *SensitiveTableAccess) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*SensitiveTableAccess) Descriptor 

func (*SensitiveTableAccess) Descriptor() ([]byte, []int)

func (*SensitiveTableAccess) LoggingChannel 

func (m *SensitiveTableAccess) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*SensitiveTableAccess) Marshal 

func (m *SensitiveTableAccess) Marshal() (dAtA []byte, err error)

func (*SensitiveTableAccess) MarshalTo 

func (m *SensitiveTableAccess) MarshalTo(dAtA []byte) (int, error)

func (*SensitiveTableAccess) MarshalToSizedBuffer 

func (m *SensitiveTableAccess) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SensitiveTableAccess) ProtoMessage 

func (*SensitiveTableAccess) ProtoMessage()

func (*SensitiveTableAccess) Reset 

func (m *SensitiveTableAccess) Reset()

func (*SensitiveTableAccess) Size 

func (m *SensitiveTableAccess) Size() (n int)

func (*SensitiveTableAccess) String 

func (m *SensitiveTableAccess) String() string

func (*SensitiveTableAccess) Unmarshal 

func (m *SensitiveTableAccess) Unmarshal(dAtA []byte) error

func (*SensitiveTableAccess) XXX_DiscardUnknown 

func (m *SensitiveTableAccess) XXX_DiscardUnknown()

func (*SensitiveTableAccess) XXX_Marshal 

func (m *SensitiveTableAccess) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SensitiveTableAccess) XXX_Merge 

func (m *SensitiveTableAccess) XXX_Merge(src proto.Message)

func (*SensitiveTableAccess) XXX_Size 

func (m *SensitiveTableAccess) XXX_Size() int

func (*SensitiveTableAccess) XXX_Unmarshal 

func (m *SensitiveTableAccess) XXX_Unmarshal(b []byte) error

type SetClusterSetting 

type SetClusterSetting struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected cluster setting.
	SettingName string `protobuf:"bytes,3,opt,name=setting_name,json=settingName,proto3" json:",omitempty" redact:"nonsensitive"`
	// The new value of the cluster setting.
	Value string `protobuf:"bytes,4,opt,name=value,proto3" json:",omitempty"`
}

SetClusterSetting is recorded when a cluster setting is changed.

func (*SetClusterSetting) AppendJSONFields 

func (m *SetClusterSetting) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*SetClusterSetting) Descriptor 

func (*SetClusterSetting) Descriptor() ([]byte, []int)

func (*SetClusterSetting) LoggingChannel 

func (m *SetClusterSetting) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*SetClusterSetting) Marshal 

func (m *SetClusterSetting) Marshal() (dAtA []byte, err error)

func (*SetClusterSetting) MarshalTo 

func (m *SetClusterSetting) MarshalTo(dAtA []byte) (int, error)

func (*SetClusterSetting) MarshalToSizedBuffer 

func (m *SetClusterSetting) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetClusterSetting) ProtoMessage 

func (*SetClusterSetting) ProtoMessage()

func (*SetClusterSetting) Reset 

func (m *SetClusterSetting) Reset()

func (*SetClusterSetting) Size 

func (m *SetClusterSetting) Size() (n int)

func (*SetClusterSetting) String 

func (m *SetClusterSetting) String() string

func (*SetClusterSetting) Unmarshal 

func (m *SetClusterSetting) Unmarshal(dAtA []byte) error

func (*SetClusterSetting) XXX_DiscardUnknown 

func (m *SetClusterSetting) XXX_DiscardUnknown()

func (*SetClusterSetting) XXX_Marshal 

func (m *SetClusterSetting) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetClusterSetting) XXX_Merge 

func (m *SetClusterSetting) XXX_Merge(src proto.Message)

func (*SetClusterSetting) XXX_Size 

func (m *SetClusterSetting) XXX_Size() int

func (*SetClusterSetting) XXX_Unmarshal 

func (m *SetClusterSetting) XXX_Unmarshal(b []byte) error

type SetSchema 

type SetSchema struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The old name of the affected descriptor.
	DescriptorName string `protobuf:"bytes,3,opt,name=descriptor_name,json=descriptorName,proto3" json:",omitempty"`
	// The new name of the affected descriptor.
	NewDescriptorName string `protobuf:"bytes,4,opt,name=new_descriptor_name,json=newDescriptorName,proto3" json:",omitempty"`
	// The descriptor type being changed (table, view, sequence, type).
	DescriptorType string `protobuf:"bytes,5,opt,name=descriptor_type,json=descriptorType,proto3" json:",omitempty"`
}

SetSchema is recorded when a table, view, sequence or type's schema is changed.

func (*SetSchema) AppendJSONFields 

func (m *SetSchema) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*SetSchema) Descriptor 

func (*SetSchema) Descriptor() ([]byte, []int)

func (*SetSchema) LoggingChannel 

func (m *SetSchema) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*SetSchema) Marshal 

func (m *SetSchema) Marshal() (dAtA []byte, err error)

func (*SetSchema) MarshalTo 

func (m *SetSchema) MarshalTo(dAtA []byte) (int, error)

func (*SetSchema) MarshalToSizedBuffer 

func (m *SetSchema) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetSchema) ProtoMessage 

func (*SetSchema) ProtoMessage()

func (*SetSchema) Reset 

func (m *SetSchema) Reset()

func (*SetSchema) Size 

func (m *SetSchema) Size() (n int)

func (*SetSchema) String 

func (m *SetSchema) String() string

func (*SetSchema) Unmarshal 

func (m *SetSchema) Unmarshal(dAtA []byte) error

func (*SetSchema) XXX_DiscardUnknown 

func (m *SetSchema) XXX_DiscardUnknown()

func (*SetSchema) XXX_Marshal 

func (m *SetSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetSchema) XXX_Merge 

func (m *SetSchema) XXX_Merge(src proto.Message)

func (*SetSchema) XXX_Size 

func (m *SetSchema) XXX_Size() int

func (*SetSchema) XXX_Unmarshal 

func (m *SetSchema) XXX_Unmarshal(b []byte) error

type SetZoneConfig 

type SetZoneConfig struct {
	CommonEventDetails      `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails   `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonZoneConfigDetails `protobuf:"bytes,3,opt,name=config,proto3,embedded=config" json:""`
}

SetZoneConfig is recorded when a zone config is changed.

func (*SetZoneConfig) AppendJSONFields 

func (m *SetZoneConfig) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*SetZoneConfig) Descriptor 

func (*SetZoneConfig) Descriptor() ([]byte, []int)

func (*SetZoneConfig) LoggingChannel 

func (m *SetZoneConfig) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*SetZoneConfig) Marshal 

func (m *SetZoneConfig) Marshal() (dAtA []byte, err error)

func (*SetZoneConfig) MarshalTo 

func (m *SetZoneConfig) MarshalTo(dAtA []byte) (int, error)

func (*SetZoneConfig) MarshalToSizedBuffer 

func (m *SetZoneConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetZoneConfig) ProtoMessage 

func (*SetZoneConfig) ProtoMessage()

func (*SetZoneConfig) Reset 

func (m *SetZoneConfig) Reset()

func (*SetZoneConfig) Size 

func (m *SetZoneConfig) Size() (n int)

func (*SetZoneConfig) String 

func (m *SetZoneConfig) String() string

func (*SetZoneConfig) Unmarshal 

func (m *SetZoneConfig) Unmarshal(dAtA []byte) error

func (*SetZoneConfig) XXX_DiscardUnknown 

func (m *SetZoneConfig) XXX_DiscardUnknown()

func (*SetZoneConfig) XXX_Marshal 

func (m *SetZoneConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetZoneConfig) XXX_Merge 

func (m *SetZoneConfig) XXX_Merge(src proto.Message)

func (*SetZoneConfig) XXX_Size 

func (m *SetZoneConfig) XXX_Size() int

func (*SetZoneConfig) XXX_Unmarshal 

func (m *SetZoneConfig) XXX_Unmarshal(b []byte) error

type SlowQuery 

type SlowQuery struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonSQLExecDetails  `protobuf:"bytes,3,opt,name=exec,proto3,embedded=exec" json:""`
}

SlowQuery is recorded when a query triggers the "slow query" condition.

As of this writing, the condition requires:

  • the cluster setting `sql.log.slow_query.latency_threshold` set to a non-zero value, AND
  • EITHER of the following conditions:
  • the actual age of the query exceeds the configured threshold; AND/OR
  • the query performs a full table/index scan AND the cluster setting `sql.log.slow_query.experimental_full_table_scans.enabled` is set.

func (*SlowQuery) AppendJSONFields 

func (m *SlowQuery) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*SlowQuery) Descriptor 

func (*SlowQuery) Descriptor() ([]byte, []int)

func (*SlowQuery) LoggingChannel 

func (m *SlowQuery) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*SlowQuery) Marshal 

func (m *SlowQuery) Marshal() (dAtA []byte, err error)

func (*SlowQuery) MarshalTo 

func (m *SlowQuery) MarshalTo(dAtA []byte) (int, error)

func (*SlowQuery) MarshalToSizedBuffer 

func (m *SlowQuery) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SlowQuery) ProtoMessage 

func (*SlowQuery) ProtoMessage()

func (*SlowQuery) Reset 

func (m *SlowQuery) Reset()

func (*SlowQuery) Size 

func (m *SlowQuery) Size() (n int)

func (*SlowQuery) String 

func (m *SlowQuery) String() string

func (*SlowQuery) Unmarshal 

func (m *SlowQuery) Unmarshal(dAtA []byte) error

func (*SlowQuery) XXX_DiscardUnknown 

func (m *SlowQuery) XXX_DiscardUnknown()

func (*SlowQuery) XXX_Marshal 

func (m *SlowQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SlowQuery) XXX_Merge 

func (m *SlowQuery) XXX_Merge(src proto.Message)

func (*SlowQuery) XXX_Size 

func (m *SlowQuery) XXX_Size() int

func (*SlowQuery) XXX_Unmarshal 

func (m *SlowQuery) XXX_Unmarshal(b []byte) error

type SlowQueryInternal 

type SlowQueryInternal struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonSQLExecDetails  `protobuf:"bytes,3,opt,name=exec,proto3,embedded=exec" json:""`
}

SlowQueryInternal is recorded when a query triggers the "slow query" condition, and the cluster setting `sql.log.slow_query.internal_queries.enabled` is set. See the documentation for the event type `slow_query` for details about the "slow query" condition.

func (*SlowQueryInternal) AppendJSONFields 

func (m *SlowQueryInternal) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*SlowQueryInternal) Descriptor 

func (*SlowQueryInternal) Descriptor() ([]byte, []int)

func (*SlowQueryInternal) LoggingChannel 

func (m *SlowQueryInternal) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*SlowQueryInternal) Marshal 

func (m *SlowQueryInternal) Marshal() (dAtA []byte, err error)

func (*SlowQueryInternal) MarshalTo 

func (m *SlowQueryInternal) MarshalTo(dAtA []byte) (int, error)

func (*SlowQueryInternal) MarshalToSizedBuffer 

func (m *SlowQueryInternal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SlowQueryInternal) ProtoMessage 

func (*SlowQueryInternal) ProtoMessage()

func (*SlowQueryInternal) Reset 

func (m *SlowQueryInternal) Reset()

func (*SlowQueryInternal) Size 

func (m *SlowQueryInternal) Size() (n int)

func (*SlowQueryInternal) String 

func (m *SlowQueryInternal) String() string

func (*SlowQueryInternal) Unmarshal 

func (m *SlowQueryInternal) Unmarshal(dAtA []byte) error

func (*SlowQueryInternal) XXX_DiscardUnknown 

func (m *SlowQueryInternal) XXX_DiscardUnknown()

func (*SlowQueryInternal) XXX_Marshal 

func (m *SlowQueryInternal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SlowQueryInternal) XXX_Merge 

func (m *SlowQueryInternal) XXX_Merge(src proto.Message)

func (*SlowQueryInternal) XXX_Size 

func (m *SlowQueryInternal) XXX_Size() int

func (*SlowQueryInternal) XXX_Unmarshal 

func (m *SlowQueryInternal) XXX_Unmarshal(b []byte) error

type TruncateTable 

type TruncateTable struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	// The name of the affected table.
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:",omitempty"`
}

TruncateTable is recorded when a table is truncated.

func (*TruncateTable) AppendJSONFields 

func (m *TruncateTable) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*TruncateTable) Descriptor 

func (*TruncateTable) Descriptor() ([]byte, []int)

func (*TruncateTable) LoggingChannel 

func (m *TruncateTable) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*TruncateTable) Marshal 

func (m *TruncateTable) Marshal() (dAtA []byte, err error)

func (*TruncateTable) MarshalTo 

func (m *TruncateTable) MarshalTo(dAtA []byte) (int, error)

func (*TruncateTable) MarshalToSizedBuffer 

func (m *TruncateTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TruncateTable) ProtoMessage 

func (*TruncateTable) ProtoMessage()

func (*TruncateTable) Reset 

func (m *TruncateTable) Reset()

func (*TruncateTable) Size 

func (m *TruncateTable) Size() (n int)

func (*TruncateTable) String 

func (m *TruncateTable) String() string

func (*TruncateTable) Unmarshal 

func (m *TruncateTable) Unmarshal(dAtA []byte) error

func (*TruncateTable) XXX_DiscardUnknown 

func (m *TruncateTable) XXX_DiscardUnknown()

func (*TruncateTable) XXX_Marshal 

func (m *TruncateTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TruncateTable) XXX_Merge 

func (m *TruncateTable) XXX_Merge(src proto.Message)

func (*TruncateTable) XXX_Size 

func (m *TruncateTable) XXX_Size() int

func (*TruncateTable) XXX_Unmarshal 

func (m *TruncateTable) XXX_Unmarshal(b []byte) error

type TxnRowsReadLimit 

type TxnRowsReadLimit struct {
	CommonEventDetails        `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails     `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonTxnRowsLimitDetails `protobuf:"bytes,3,opt,name=info,proto3,embedded=info" json:""`
}

TxnRowsReadLimit is recorded when a transaction tries to read more rows than cluster setting `sql.defaults.transaction_rows_read_log`. There will only be a single record for a single transaction (unless it is retried) even if there are more statement within the transaction that haven't been executed yet.

func (*TxnRowsReadLimit) AppendJSONFields 

func (m *TxnRowsReadLimit) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*TxnRowsReadLimit) Descriptor 

func (*TxnRowsReadLimit) Descriptor() ([]byte, []int)

func (*TxnRowsReadLimit) LoggingChannel 

func (m *TxnRowsReadLimit) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*TxnRowsReadLimit) Marshal 

func (m *TxnRowsReadLimit) Marshal() (dAtA []byte, err error)

func (*TxnRowsReadLimit) MarshalTo 

func (m *TxnRowsReadLimit) MarshalTo(dAtA []byte) (int, error)

func (*TxnRowsReadLimit) MarshalToSizedBuffer 

func (m *TxnRowsReadLimit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TxnRowsReadLimit) ProtoMessage 

func (*TxnRowsReadLimit) ProtoMessage()

func (*TxnRowsReadLimit) Reset 

func (m *TxnRowsReadLimit) Reset()

func (*TxnRowsReadLimit) Size 

func (m *TxnRowsReadLimit) Size() (n int)

func (*TxnRowsReadLimit) String 

func (m *TxnRowsReadLimit) String() string

func (*TxnRowsReadLimit) Unmarshal 

func (m *TxnRowsReadLimit) Unmarshal(dAtA []byte) error

func (*TxnRowsReadLimit) XXX_DiscardUnknown 

func (m *TxnRowsReadLimit) XXX_DiscardUnknown()

func (*TxnRowsReadLimit) XXX_Marshal 

func (m *TxnRowsReadLimit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TxnRowsReadLimit) XXX_Merge 

func (m *TxnRowsReadLimit) XXX_Merge(src proto.Message)

func (*TxnRowsReadLimit) XXX_Size 

func (m *TxnRowsReadLimit) XXX_Size() int

func (*TxnRowsReadLimit) XXX_Unmarshal 

func (m *TxnRowsReadLimit) XXX_Unmarshal(b []byte) error

type TxnRowsReadLimitInternal 

type TxnRowsReadLimitInternal struct {
	CommonEventDetails        `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails     `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonTxnRowsLimitDetails `protobuf:"bytes,3,opt,name=info,proto3,embedded=info" json:""`
}

TxnRowsReadLimitInternal is recorded when an internal transaction tries to read more rows than cluster setting `sql.defaults.transaction_rows_read_log` or `sql.defaults.transaction_rows_read_err`. There will only be a single record for a single transaction (unless it is retried) even if there are more mutation statements within the transaction that haven't been executed yet.

func (*TxnRowsReadLimitInternal) AppendJSONFields 

func (m *TxnRowsReadLimitInternal) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*TxnRowsReadLimitInternal) Descriptor 

func (*TxnRowsReadLimitInternal) Descriptor() ([]byte, []int)

func (*TxnRowsReadLimitInternal) LoggingChannel 

func (m *TxnRowsReadLimitInternal) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*TxnRowsReadLimitInternal) Marshal 

func (m *TxnRowsReadLimitInternal) Marshal() (dAtA []byte, err error)

func (*TxnRowsReadLimitInternal) MarshalTo 

func (m *TxnRowsReadLimitInternal) MarshalTo(dAtA []byte) (int, error)

func (*TxnRowsReadLimitInternal) MarshalToSizedBuffer 

func (m *TxnRowsReadLimitInternal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TxnRowsReadLimitInternal) ProtoMessage 

func (*TxnRowsReadLimitInternal) ProtoMessage()

func (*TxnRowsReadLimitInternal) Reset 

func (m *TxnRowsReadLimitInternal) Reset()

func (*TxnRowsReadLimitInternal) Size 

func (m *TxnRowsReadLimitInternal) Size() (n int)

func (*TxnRowsReadLimitInternal) String 

func (m *TxnRowsReadLimitInternal) String() string

func (*TxnRowsReadLimitInternal) Unmarshal 

func (m *TxnRowsReadLimitInternal) Unmarshal(dAtA []byte) error

func (*TxnRowsReadLimitInternal) XXX_DiscardUnknown 

func (m *TxnRowsReadLimitInternal) XXX_DiscardUnknown()

func (*TxnRowsReadLimitInternal) XXX_Marshal 

func (m *TxnRowsReadLimitInternal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TxnRowsReadLimitInternal) XXX_Merge 

func (m *TxnRowsReadLimitInternal) XXX_Merge(src proto.Message)

func (*TxnRowsReadLimitInternal) XXX_Size 

func (m *TxnRowsReadLimitInternal) XXX_Size() int

func (*TxnRowsReadLimitInternal) XXX_Unmarshal 

func (m *TxnRowsReadLimitInternal) XXX_Unmarshal(b []byte) error

type TxnRowsWrittenLimit 

type TxnRowsWrittenLimit struct {
	CommonEventDetails        `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails     `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonTxnRowsLimitDetails `protobuf:"bytes,3,opt,name=info,proto3,embedded=info" json:""`
}

TxnRowsWrittenLimit is recorded when a transaction tries to write more rows than cluster setting `sql.defaults.transaction_rows_written_log`. There will only be a single record for a single transaction (unless it is retried) even if there are more mutation statements within the transaction that haven't been executed yet.

func (*TxnRowsWrittenLimit) AppendJSONFields 

func (m *TxnRowsWrittenLimit) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*TxnRowsWrittenLimit) Descriptor 

func (*TxnRowsWrittenLimit) Descriptor() ([]byte, []int)

func (*TxnRowsWrittenLimit) LoggingChannel 

func (m *TxnRowsWrittenLimit) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*TxnRowsWrittenLimit) Marshal 

func (m *TxnRowsWrittenLimit) Marshal() (dAtA []byte, err error)

func (*TxnRowsWrittenLimit) MarshalTo 

func (m *TxnRowsWrittenLimit) MarshalTo(dAtA []byte) (int, error)

func (*TxnRowsWrittenLimit) MarshalToSizedBuffer 

func (m *TxnRowsWrittenLimit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TxnRowsWrittenLimit) ProtoMessage 

func (*TxnRowsWrittenLimit) ProtoMessage()

func (*TxnRowsWrittenLimit) Reset 

func (m *TxnRowsWrittenLimit) Reset()

func (*TxnRowsWrittenLimit) Size 

func (m *TxnRowsWrittenLimit) Size() (n int)

func (*TxnRowsWrittenLimit) String 

func (m *TxnRowsWrittenLimit) String() string

func (*TxnRowsWrittenLimit) Unmarshal 

func (m *TxnRowsWrittenLimit) Unmarshal(dAtA []byte) error

func (*TxnRowsWrittenLimit) XXX_DiscardUnknown 

func (m *TxnRowsWrittenLimit) XXX_DiscardUnknown()

func (*TxnRowsWrittenLimit) XXX_Marshal 

func (m *TxnRowsWrittenLimit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TxnRowsWrittenLimit) XXX_Merge 

func (m *TxnRowsWrittenLimit) XXX_Merge(src proto.Message)

func (*TxnRowsWrittenLimit) XXX_Size 

func (m *TxnRowsWrittenLimit) XXX_Size() int

func (*TxnRowsWrittenLimit) XXX_Unmarshal 

func (m *TxnRowsWrittenLimit) XXX_Unmarshal(b []byte) error

type TxnRowsWrittenLimitInternal 

type TxnRowsWrittenLimitInternal struct {
	CommonEventDetails        `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails     `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	CommonTxnRowsLimitDetails `protobuf:"bytes,3,opt,name=info,proto3,embedded=info" json:""`
}

TxnRowsWrittenLimitInternal is recorded when an internal transaction tries to write more rows than cluster setting `sql.defaults.transaction_rows_written_log` or `sql.defaults.transaction_rows_written_err`. There will only be a single record for a single transaction (unless it is retried) even if there are more mutation statements within the transaction that haven't been executed yet.

func (*TxnRowsWrittenLimitInternal) AppendJSONFields 

func (m *TxnRowsWrittenLimitInternal) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*TxnRowsWrittenLimitInternal) Descriptor 

func (*TxnRowsWrittenLimitInternal) Descriptor() ([]byte, []int)

func (*TxnRowsWrittenLimitInternal) LoggingChannel 

func (m *TxnRowsWrittenLimitInternal) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*TxnRowsWrittenLimitInternal) Marshal 

func (m *TxnRowsWrittenLimitInternal) Marshal() (dAtA []byte, err error)

func (*TxnRowsWrittenLimitInternal) MarshalTo 

func (m *TxnRowsWrittenLimitInternal) MarshalTo(dAtA []byte) (int, error)

func (*TxnRowsWrittenLimitInternal) MarshalToSizedBuffer 

func (m *TxnRowsWrittenLimitInternal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TxnRowsWrittenLimitInternal) ProtoMessage 

func (*TxnRowsWrittenLimitInternal) ProtoMessage()

func (*TxnRowsWrittenLimitInternal) Reset 

func (m *TxnRowsWrittenLimitInternal) Reset()

func (*TxnRowsWrittenLimitInternal) Size 

func (m *TxnRowsWrittenLimitInternal) Size() (n int)

func (*TxnRowsWrittenLimitInternal) String 

func (m *TxnRowsWrittenLimitInternal) String() string

func (*TxnRowsWrittenLimitInternal) Unmarshal 

func (m *TxnRowsWrittenLimitInternal) Unmarshal(dAtA []byte) error

func (*TxnRowsWrittenLimitInternal) XXX_DiscardUnknown 

func (m *TxnRowsWrittenLimitInternal) XXX_DiscardUnknown()

func (*TxnRowsWrittenLimitInternal) XXX_Marshal 

func (m *TxnRowsWrittenLimitInternal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TxnRowsWrittenLimitInternal) XXX_Merge 

func (m *TxnRowsWrittenLimitInternal) XXX_Merge(src proto.Message)

func (*TxnRowsWrittenLimitInternal) XXX_Size 

func (m *TxnRowsWrittenLimitInternal) XXX_Size() int

func (*TxnRowsWrittenLimitInternal) XXX_Unmarshal 

func (m *TxnRowsWrittenLimitInternal) XXX_Unmarshal(b []byte) error

type UnsafeDeleteDescriptor 

type UnsafeDeleteDescriptor struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	ParentID              uint32 `protobuf:"varint,3,opt,name=parent_id,json=parentId,proto3" json:",omitempty"`
	ParentSchemaID        uint32 `protobuf:"varint,4,opt,name=parent_schema_id,json=parentSchemaId,proto3" json:",omitempty"`
	Name                  string `protobuf:"bytes,5,opt,name=name,proto3" json:",omitempty"`
	Force                 bool   `protobuf:"varint,6,opt,name=force,proto3" json:",omitempty"`
	ForceNotice           string `protobuf:"bytes,7,opt,name=force_notice,json=forceNotice,proto3" json:",omitempty"`
}

UnsafeDeleteDescriptor is recorded when a descriptor is written using crdb_internal.unsafe_delete_descriptor().

The fields of this event type are reserved and can change across patch releases without advance notice.

func (*UnsafeDeleteDescriptor) AppendJSONFields 

func (m *UnsafeDeleteDescriptor) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*UnsafeDeleteDescriptor) Descriptor 

func (*UnsafeDeleteDescriptor) Descriptor() ([]byte, []int)

func (*UnsafeDeleteDescriptor) LoggingChannel 

func (m *UnsafeDeleteDescriptor) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*UnsafeDeleteDescriptor) Marshal 

func (m *UnsafeDeleteDescriptor) Marshal() (dAtA []byte, err error)

func (*UnsafeDeleteDescriptor) MarshalTo 

func (m *UnsafeDeleteDescriptor) MarshalTo(dAtA []byte) (int, error)

func (*UnsafeDeleteDescriptor) MarshalToSizedBuffer 

func (m *UnsafeDeleteDescriptor) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnsafeDeleteDescriptor) ProtoMessage 

func (*UnsafeDeleteDescriptor) ProtoMessage()

func (*UnsafeDeleteDescriptor) Reset 

func (m *UnsafeDeleteDescriptor) Reset()

func (*UnsafeDeleteDescriptor) Size 

func (m *UnsafeDeleteDescriptor) Size() (n int)

func (*UnsafeDeleteDescriptor) String 

func (m *UnsafeDeleteDescriptor) String() string

func (*UnsafeDeleteDescriptor) Unmarshal 

func (m *UnsafeDeleteDescriptor) Unmarshal(dAtA []byte) error

func (*UnsafeDeleteDescriptor) XXX_DiscardUnknown 

func (m *UnsafeDeleteDescriptor) XXX_DiscardUnknown()

func (*UnsafeDeleteDescriptor) XXX_Marshal 

func (m *UnsafeDeleteDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnsafeDeleteDescriptor) XXX_Merge 

func (m *UnsafeDeleteDescriptor) XXX_Merge(src proto.Message)

func (*UnsafeDeleteDescriptor) XXX_Size 

func (m *UnsafeDeleteDescriptor) XXX_Size() int

func (*UnsafeDeleteDescriptor) XXX_Unmarshal 

func (m *UnsafeDeleteDescriptor) XXX_Unmarshal(b []byte) error

type UnsafeDeleteNamespaceEntry 

type UnsafeDeleteNamespaceEntry struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	ParentID              uint32 `protobuf:"varint,3,opt,name=parent_id,json=parentId,proto3" json:",omitempty"`
	ParentSchemaID        uint32 `protobuf:"varint,4,opt,name=parent_schema_id,json=parentSchemaId,proto3" json:",omitempty"`
	Name                  string `protobuf:"bytes,5,opt,name=name,proto3" json:",omitempty"`
	Force                 bool   `protobuf:"varint,6,opt,name=force,proto3" json:",omitempty"`
	ForceNotice           string `protobuf:"bytes,7,opt,name=force_notice,json=forceNotice,proto3" json:",omitempty"`
}

UnsafeDeleteNamespaceEntry is recorded when a namespace entry is written using crdb_internal.unsafe_delete_namespace_entry().

The fields of this event type are reserved and can change across patch releases without advance notice.

func (*UnsafeDeleteNamespaceEntry) AppendJSONFields 

func (m *UnsafeDeleteNamespaceEntry) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*UnsafeDeleteNamespaceEntry) Descriptor 

func (*UnsafeDeleteNamespaceEntry) Descriptor() ([]byte, []int)

func (*UnsafeDeleteNamespaceEntry) LoggingChannel 

func (m *UnsafeDeleteNamespaceEntry) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*UnsafeDeleteNamespaceEntry) Marshal 

func (m *UnsafeDeleteNamespaceEntry) Marshal() (dAtA []byte, err error)

func (*UnsafeDeleteNamespaceEntry) MarshalTo 

func (m *UnsafeDeleteNamespaceEntry) MarshalTo(dAtA []byte) (int, error)

func (*UnsafeDeleteNamespaceEntry) MarshalToSizedBuffer 

func (m *UnsafeDeleteNamespaceEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnsafeDeleteNamespaceEntry) ProtoMessage 

func (*UnsafeDeleteNamespaceEntry) ProtoMessage()

func (*UnsafeDeleteNamespaceEntry) Reset 

func (m *UnsafeDeleteNamespaceEntry) Reset()

func (*UnsafeDeleteNamespaceEntry) Size 

func (m *UnsafeDeleteNamespaceEntry) Size() (n int)

func (*UnsafeDeleteNamespaceEntry) String 

func (m *UnsafeDeleteNamespaceEntry) String() string

func (*UnsafeDeleteNamespaceEntry) Unmarshal 

func (m *UnsafeDeleteNamespaceEntry) Unmarshal(dAtA []byte) error

func (*UnsafeDeleteNamespaceEntry) XXX_DiscardUnknown 

func (m *UnsafeDeleteNamespaceEntry) XXX_DiscardUnknown()

func (*UnsafeDeleteNamespaceEntry) XXX_Marshal 

func (m *UnsafeDeleteNamespaceEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnsafeDeleteNamespaceEntry) XXX_Merge 

func (m *UnsafeDeleteNamespaceEntry) XXX_Merge(src proto.Message)

func (*UnsafeDeleteNamespaceEntry) XXX_Size 

func (m *UnsafeDeleteNamespaceEntry) XXX_Size() int

func (*UnsafeDeleteNamespaceEntry) XXX_Unmarshal 

func (m *UnsafeDeleteNamespaceEntry) XXX_Unmarshal(b []byte) error

type UnsafeUpsertDescriptor 

type UnsafeUpsertDescriptor struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	PreviousDescriptor    string `protobuf:"bytes,3,opt,name=previous_descriptor,json=previousDescriptor,proto3" json:",omitempty"`
	NewDescriptor         string `protobuf:"bytes,4,opt,name=new_descriptor,json=newDescriptor,proto3" json:",omitempty"`
	Force                 bool   `protobuf:"varint,5,opt,name=force,proto3" json:",omitempty"`
	ForceNotice           string `protobuf:"bytes,6,opt,name=force_notice,json=forceNotice,proto3" json:",omitempty"`
}

UnsafeUpsertDescriptor is recorded when a descriptor is written using crdb_internal.unsafe_upsert_descriptor().

func (*UnsafeUpsertDescriptor) AppendJSONFields 

func (m *UnsafeUpsertDescriptor) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*UnsafeUpsertDescriptor) Descriptor 

func (*UnsafeUpsertDescriptor) Descriptor() ([]byte, []int)

func (*UnsafeUpsertDescriptor) LoggingChannel 

func (m *UnsafeUpsertDescriptor) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*UnsafeUpsertDescriptor) Marshal 

func (m *UnsafeUpsertDescriptor) Marshal() (dAtA []byte, err error)

func (*UnsafeUpsertDescriptor) MarshalTo 

func (m *UnsafeUpsertDescriptor) MarshalTo(dAtA []byte) (int, error)

func (*UnsafeUpsertDescriptor) MarshalToSizedBuffer 

func (m *UnsafeUpsertDescriptor) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnsafeUpsertDescriptor) ProtoMessage 

func (*UnsafeUpsertDescriptor) ProtoMessage()

func (*UnsafeUpsertDescriptor) Reset 

func (m *UnsafeUpsertDescriptor) Reset()

func (*UnsafeUpsertDescriptor) Size 

func (m *UnsafeUpsertDescriptor) Size() (n int)

func (*UnsafeUpsertDescriptor) String 

func (m *UnsafeUpsertDescriptor) String() string

func (*UnsafeUpsertDescriptor) Unmarshal 

func (m *UnsafeUpsertDescriptor) Unmarshal(dAtA []byte) error

func (*UnsafeUpsertDescriptor) XXX_DiscardUnknown 

func (m *UnsafeUpsertDescriptor) XXX_DiscardUnknown()

func (*UnsafeUpsertDescriptor) XXX_Marshal 

func (m *UnsafeUpsertDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnsafeUpsertDescriptor) XXX_Merge 

func (m *UnsafeUpsertDescriptor) XXX_Merge(src proto.Message)

func (*UnsafeUpsertDescriptor) XXX_Size 

func (m *UnsafeUpsertDescriptor) XXX_Size() int

func (*UnsafeUpsertDescriptor) XXX_Unmarshal 

func (m *UnsafeUpsertDescriptor) XXX_Unmarshal(b []byte) error

type UnsafeUpsertNamespaceEntry 

type UnsafeUpsertNamespaceEntry struct {
	CommonEventDetails    `protobuf:"bytes,1,opt,name=common,proto3,embedded=common" json:""`
	CommonSQLEventDetails `protobuf:"bytes,2,opt,name=sql,proto3,embedded=sql" json:""`
	ParentID              uint32 `protobuf:"varint,3,opt,name=parent_id,json=parentId,proto3" json:",omitempty"`
	ParentSchemaID        uint32 `protobuf:"varint,4,opt,name=parent_schema_id,json=parentSchemaId,proto3" json:",omitempty"`
	Name                  string `protobuf:"bytes,5,opt,name=name,proto3" json:",omitempty"`
	PreviousID            uint32 `protobuf:"varint,6,opt,name=previous_id,json=previousId,proto3" json:",omitempty"`
	Force                 bool   `protobuf:"varint,7,opt,name=force,proto3" json:",omitempty"`
	FailedValidation      bool   `protobuf:"varint,8,opt,name=failed_validation,json=failedValidation,proto3" json:",omitempty"`
	ValidationErrors      string `protobuf:"bytes,9,opt,name=validation_errors,json=validationErrors,proto3" json:",omitempty"`
}

UnsafeUpsertNamespaceEntry is recorded when a namespace entry is written using crdb_internal.unsafe_upsert_namespace_entry().

The fields of this event type are reserved and can change across patch releases without advance notice.

func (*UnsafeUpsertNamespaceEntry) AppendJSONFields 

func (m *UnsafeUpsertNamespaceEntry) AppendJSONFields(printComma bool, b redact.RedactableBytes) (bool, redact.RedactableBytes)

AppendJSONFields implements the EventPayload interface.

func (*UnsafeUpsertNamespaceEntry) Descriptor 

func (*UnsafeUpsertNamespaceEntry) Descriptor() ([]byte, []int)

func (*UnsafeUpsertNamespaceEntry) LoggingChannel 

func (m *UnsafeUpsertNamespaceEntry) LoggingChannel() logpb.Channel

LoggingChannel implements the EventPayload interface.

func (*UnsafeUpsertNamespaceEntry) Marshal 

func (m *UnsafeUpsertNamespaceEntry) Marshal() (dAtA []byte, err error)

func (*UnsafeUpsertNamespaceEntry) MarshalTo 

func (m *UnsafeUpsertNamespaceEntry) MarshalTo(dAtA []byte) (int, error)

func (*UnsafeUpsertNamespaceEntry) MarshalToSizedBuffer 

func (m *UnsafeUpsertNamespaceEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnsafeUpsertNamespaceEntry) ProtoMessage 

func (*UnsafeUpsertNamespaceEntry) ProtoMessage()

func (*UnsafeUpsertNamespaceEntry) Reset 

func (m *UnsafeUpsertNamespaceEntry) Reset()

func (*UnsafeUpsertNamespaceEntry) Size 

func (m *UnsafeUpsertNamespaceEntry) Size() (n int)

func (*UnsafeUpsertNamespaceEntry) String 

func (m *UnsafeUpsertNamespaceEntry) String() string

func (*UnsafeUpsertNamespaceEntry) Unmarshal 

func (m *UnsafeUpsertNamespaceEntry) Unmarshal(dAtA []byte) error

func (*UnsafeUpsertNamespaceEntry) XXX_DiscardUnknown 

func (m *UnsafeUpsertNamespaceEntry) XXX_DiscardUnknown()

func (*UnsafeUpsertNamespaceEntry) XXX_Marshal 

func (m *UnsafeUpsertNamespaceEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnsafeUpsertNamespaceEntry) XXX_Merge 

func (m *UnsafeUpsertNamespaceEntry) XXX_Merge(src proto.Message)

func (*UnsafeUpsertNamespaceEntry) XXX_Size 

func (m *UnsafeUpsertNamespaceEntry) XXX_Size() int

func (*UnsafeUpsertNamespaceEntry) XXX_Unmarshal 

func (m *UnsafeUpsertNamespaceEntry) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.