mysqlxpb_notice

package
v0.0.0-...-86f4e66 Latest Latest
Warning

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

 Go to latest Published: Jan 7, 2021 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Default_Frame_Scope = Frame_GLOBAL
)

Default values for Frame fields.

View Source 
const (
	Default_Warning_Level = Warning_WARNING
)

Default values for Warning fields.

Variables

View Source 
var (
	Frame_Scope_name = map[int32]string{
		1: "GLOBAL",
		2: "LOCAL",
	}
	Frame_Scope_value = map[string]int32{
		"GLOBAL": 1,
		"LOCAL":  2,
	}
)

Enum value maps for Frame_Scope.

View Source 
var (
	Frame_Type_name = map[int32]string{
		1: "WARNING",
		2: "SESSION_VARIABLE_CHANGED",
		3: "SESSION_STATE_CHANGED",
		4: "GROUP_REPLICATION_STATE_CHANGED",
		5: "SERVER_HELLO",
	}
	Frame_Type_value = map[string]int32{
		"WARNING":                         1,
		"SESSION_VARIABLE_CHANGED":        2,
		"SESSION_STATE_CHANGED":           3,
		"GROUP_REPLICATION_STATE_CHANGED": 4,
		"SERVER_HELLO":                    5,
	}
)

Enum value maps for Frame_Type.

View Source 
var (
	Warning_Level_name = map[int32]string{
		1: "NOTE",
		2: "WARNING",
		3: "ERROR",
	}
	Warning_Level_value = map[string]int32{
		"NOTE":    1,
		"WARNING": 2,
		"ERROR":   3,
	}
)

Enum value maps for Warning_Level.

View Source 
var (
	SessionStateChanged_Parameter_name = map[int32]string{
		1:  "CURRENT_SCHEMA",
		2:  "ACCOUNT_EXPIRED",
		3:  "GENERATED_INSERT_ID",
		4:  "ROWS_AFFECTED",
		5:  "ROWS_FOUND",
		6:  "ROWS_MATCHED",
		7:  "TRX_COMMITTED",
		9:  "TRX_ROLLEDBACK",
		10: "PRODUCED_MESSAGE",
		11: "CLIENT_ID_ASSIGNED",
		12: "GENERATED_DOCUMENT_IDS",
	}
	SessionStateChanged_Parameter_value = map[string]int32{
		"CURRENT_SCHEMA":         1,
		"ACCOUNT_EXPIRED":        2,
		"GENERATED_INSERT_ID":    3,
		"ROWS_AFFECTED":          4,
		"ROWS_FOUND":             5,
		"ROWS_MATCHED":           6,
		"TRX_COMMITTED":          7,
		"TRX_ROLLEDBACK":         9,
		"PRODUCED_MESSAGE":       10,
		"CLIENT_ID_ASSIGNED":     11,
		"GENERATED_DOCUMENT_IDS": 12,
	}
)

Enum value maps for SessionStateChanged_Parameter.

View Source 
var (
	GroupReplicationStateChanged_Type_name = map[int32]string{
		1: "MEMBERSHIP_QUORUM_LOSS",
		2: "MEMBERSHIP_VIEW_CHANGE",
		3: "MEMBER_ROLE_CHANGE",
		4: "MEMBER_STATE_CHANGE",
	}
	GroupReplicationStateChanged_Type_value = map[string]int32{
		"MEMBERSHIP_QUORUM_LOSS": 1,
		"MEMBERSHIP_VIEW_CHANGE": 2,
		"MEMBER_ROLE_CHANGE":     3,
		"MEMBER_STATE_CHANGE":    4,
	}
)

Enum value maps for GroupReplicationStateChanged_Type.

View Source 
var File_mysqlx_notice_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Frame 

type Frame struct {

	//* the type of the payload
	Type *uint32 `protobuf:"varint,1,req,name=type" json:"type,omitempty"`
	//* global or local notification
	Scope *Frame_Scope `protobuf:"varint,2,opt,name=scope,enum=Mysqlx.Notice.Frame_Scope,def=1" json:"scope,omitempty"`
	//* the payload of the notification
	Payload []byte `protobuf:"bytes,3,opt,name=payload" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

* Common frame for all notices

| “.type“ | Value | |---------------------------------------------------|------ | | @ref Mysqlx::Notice::Warning | 1 | | @ref Mysqlx::Notice::SessionVariableChanged | 2 | | @ref Mysqlx::Notice::SessionStateChanged | 3 | | @ref Mysqlx::Notice::GroupReplicationStateChanged | 4 | | @ref Mysqlx::Notice::ServerHello | 5 |

func (*Frame) Descriptor deprecated 

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

Deprecated: Use Frame.ProtoReflect.Descriptor instead.

func (*Frame) GetPayload 

func (x *Frame) GetPayload() []byte

func (*Frame) GetScope 

func (x *Frame) GetScope() Frame_Scope

func (*Frame) GetType 

func (x *Frame) GetType() uint32

func (*Frame) ProtoMessage 

func (*Frame) ProtoMessage()

func (*Frame) ProtoReflect 

func (x *Frame) ProtoReflect() protoreflect.Message

func (*Frame) Reset 

func (x *Frame) Reset()

func (*Frame) String 

func (x *Frame) String() string

type Frame_Scope 

type Frame_Scope int32

* scope of notice 

const (
	Frame_GLOBAL Frame_Scope = 1
	Frame_LOCAL  Frame_Scope = 2
)

func (Frame_Scope) Descriptor 

func (Frame_Scope) Descriptor() protoreflect.EnumDescriptor

func (Frame_Scope) Enum 

func (x Frame_Scope) Enum() *Frame_Scope

func (Frame_Scope) EnumDescriptor deprecated 

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

Deprecated: Use Frame_Scope.Descriptor instead.

func (Frame_Scope) Number 

func (x Frame_Scope) Number() protoreflect.EnumNumber

func (Frame_Scope) String 

func (x Frame_Scope) String() string

func (Frame_Scope) Type 

func (Frame_Scope) Type() protoreflect.EnumType

func (*Frame_Scope) UnmarshalJSON deprecated 

func (x *Frame_Scope) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type Frame_Type 

type Frame_Type int32

* type of notice payload 

const (
	Frame_WARNING                         Frame_Type = 1
	Frame_SESSION_VARIABLE_CHANGED        Frame_Type = 2
	Frame_SESSION_STATE_CHANGED           Frame_Type = 3
	Frame_GROUP_REPLICATION_STATE_CHANGED Frame_Type = 4
	Frame_SERVER_HELLO                    Frame_Type = 5
)

func (Frame_Type) Descriptor 

func (Frame_Type) Descriptor() protoreflect.EnumDescriptor

func (Frame_Type) Enum 

func (x Frame_Type) Enum() *Frame_Type

func (Frame_Type) EnumDescriptor deprecated 

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

Deprecated: Use Frame_Type.Descriptor instead.

func (Frame_Type) Number 

func (x Frame_Type) Number() protoreflect.EnumNumber

func (Frame_Type) String 

func (x Frame_Type) String() string

func (Frame_Type) Type 

func (Frame_Type) Type() protoreflect.EnumType

func (*Frame_Type) UnmarshalJSON deprecated 

func (x *Frame_Type) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type GroupReplicationStateChanged 

type GroupReplicationStateChanged struct {

	//* type of group replication event
	Type *uint32 `protobuf:"varint,1,req,name=type" json:"type,omitempty"`
	//* view identifier
	ViewId *string `protobuf:"bytes,2,opt,name=view_id,json=viewId" json:"view_id,omitempty"`
	// contains filtered or unexported fields
}

* Notify clients about group replication state changes

| @ref Mysqlx::Notice::Frame Field | Value | |-----------------------------------|------------| |“.type“ | 4 | |“.scope“ | “global“ |

func (*GroupReplicationStateChanged) Descriptor deprecated 

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

Deprecated: Use GroupReplicationStateChanged.ProtoReflect.Descriptor instead.

func (*GroupReplicationStateChanged) GetType 

func (x *GroupReplicationStateChanged) GetType() uint32

func (*GroupReplicationStateChanged) GetViewId 

func (x *GroupReplicationStateChanged) GetViewId() string

func (*GroupReplicationStateChanged) ProtoMessage 

func (*GroupReplicationStateChanged) ProtoMessage()

func (*GroupReplicationStateChanged) ProtoReflect 

func (x *GroupReplicationStateChanged) ProtoReflect() protoreflect.Message

func (*GroupReplicationStateChanged) Reset 

func (x *GroupReplicationStateChanged) Reset()

func (*GroupReplicationStateChanged) String 

func (x *GroupReplicationStateChanged) String() string

type GroupReplicationStateChanged_Type 

type GroupReplicationStateChanged_Type int32
const (
	GroupReplicationStateChanged_MEMBERSHIP_QUORUM_LOSS GroupReplicationStateChanged_Type = 1
	GroupReplicationStateChanged_MEMBERSHIP_VIEW_CHANGE GroupReplicationStateChanged_Type = 2
	GroupReplicationStateChanged_MEMBER_ROLE_CHANGE     GroupReplicationStateChanged_Type = 3
	GroupReplicationStateChanged_MEMBER_STATE_CHANGE    GroupReplicationStateChanged_Type = 4
)

func (GroupReplicationStateChanged_Type) Descriptor 

func (GroupReplicationStateChanged_Type) Descriptor() protoreflect.EnumDescriptor

func (GroupReplicationStateChanged_Type) Enum 

func (x GroupReplicationStateChanged_Type) Enum() *GroupReplicationStateChanged_Type

func (GroupReplicationStateChanged_Type) EnumDescriptor deprecated 

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

Deprecated: Use GroupReplicationStateChanged_Type.Descriptor instead.

func (GroupReplicationStateChanged_Type) Number 

func (x GroupReplicationStateChanged_Type) Number() protoreflect.EnumNumber

func (GroupReplicationStateChanged_Type) String 

func (x GroupReplicationStateChanged_Type) String() string

func (GroupReplicationStateChanged_Type) Type 

func (GroupReplicationStateChanged_Type) Type() protoreflect.EnumType

func (*GroupReplicationStateChanged_Type) UnmarshalJSON deprecated 

func (x *GroupReplicationStateChanged_Type) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type ServerHello 

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

* Notify clients about connection to X Protocol server

| @ref Mysqlx::Notice::Frame Field | Value | |-----------------------------------|------------| |“.type“ | 5 | |“.scope“ | “global“ |

func (*ServerHello) Descriptor deprecated 

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

Deprecated: Use ServerHello.ProtoReflect.Descriptor instead.

func (*ServerHello) ProtoMessage 

func (*ServerHello) ProtoMessage()

func (*ServerHello) ProtoReflect 

func (x *ServerHello) ProtoReflect() protoreflect.Message

func (*ServerHello) Reset 

func (x *ServerHello) Reset()

func (*ServerHello) String 

func (x *ServerHello) String() string

type SessionStateChanged 

type SessionStateChanged struct {

	//* parameter key
	Param *SessionStateChanged_Parameter `protobuf:"varint,1,req,name=param,enum=Mysqlx.Notice.SessionStateChanged_Parameter" json:"param,omitempty"`
	//* updated value
	Value []*mysqlxpb_datatypes.Scalar `protobuf:"bytes,2,rep,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionStateChanged) Descriptor deprecated 

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

Deprecated: Use SessionStateChanged.ProtoReflect.Descriptor instead.

func (*SessionStateChanged) GetParam 

func (x *SessionStateChanged) GetParam() SessionStateChanged_Parameter

func (*SessionStateChanged) GetValue 

func (x *SessionStateChanged) GetValue() []*mysqlxpb_datatypes.Scalar

func (*SessionStateChanged) ProtoMessage 

func (*SessionStateChanged) ProtoMessage()

func (*SessionStateChanged) ProtoReflect 

func (x *SessionStateChanged) ProtoReflect() protoreflect.Message

func (*SessionStateChanged) Reset 

func (x *SessionStateChanged) Reset()

func (*SessionStateChanged) String 

func (x *SessionStateChanged) String() string

type SessionStateChanged_Parameter 

type SessionStateChanged_Parameter int32
const (
	SessionStateChanged_CURRENT_SCHEMA         SessionStateChanged_Parameter = 1
	SessionStateChanged_ACCOUNT_EXPIRED        SessionStateChanged_Parameter = 2
	SessionStateChanged_GENERATED_INSERT_ID    SessionStateChanged_Parameter = 3
	SessionStateChanged_ROWS_AFFECTED          SessionStateChanged_Parameter = 4
	SessionStateChanged_ROWS_FOUND             SessionStateChanged_Parameter = 5
	SessionStateChanged_ROWS_MATCHED           SessionStateChanged_Parameter = 6
	SessionStateChanged_TRX_COMMITTED          SessionStateChanged_Parameter = 7
	SessionStateChanged_TRX_ROLLEDBACK         SessionStateChanged_Parameter = 9
	SessionStateChanged_PRODUCED_MESSAGE       SessionStateChanged_Parameter = 10
	SessionStateChanged_CLIENT_ID_ASSIGNED     SessionStateChanged_Parameter = 11
	SessionStateChanged_GENERATED_DOCUMENT_IDS SessionStateChanged_Parameter = 12 // .. more to be added
)

func (SessionStateChanged_Parameter) Descriptor 

func (SessionStateChanged_Parameter) Descriptor() protoreflect.EnumDescriptor

func (SessionStateChanged_Parameter) Enum 

func (x SessionStateChanged_Parameter) Enum() *SessionStateChanged_Parameter

func (SessionStateChanged_Parameter) EnumDescriptor deprecated 

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

Deprecated: Use SessionStateChanged_Parameter.Descriptor instead.

func (SessionStateChanged_Parameter) Number 

func (x SessionStateChanged_Parameter) Number() protoreflect.EnumNumber

func (SessionStateChanged_Parameter) String 

func (x SessionStateChanged_Parameter) String() string

func (SessionStateChanged_Parameter) Type 

func (SessionStateChanged_Parameter) Type() protoreflect.EnumType

func (*SessionStateChanged_Parameter) UnmarshalJSON deprecated 

func (x *SessionStateChanged_Parameter) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type SessionVariableChanged 

type SessionVariableChanged struct {

	//* name of the variable
	Param *string `protobuf:"bytes,1,req,name=param" json:"param,omitempty"`
	//* the changed value of param
	Value *mysqlxpb_datatypes.Scalar `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

* Notify clients about changes to the current session variables.

Every change to a variable that is accessible through:

@code{sql} SHOW SESSION VARIABLES @endcode

| @ref Mysqlx::Notice::Frame Field | Value | |-----------------------------------|----------| | “.type“ | 2 | | “.scope“ | “local“|

func (*SessionVariableChanged) Descriptor deprecated 

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

Deprecated: Use SessionVariableChanged.ProtoReflect.Descriptor instead.

func (*SessionVariableChanged) GetParam 

func (x *SessionVariableChanged) GetParam() string

func (*SessionVariableChanged) GetValue 

func (x *SessionVariableChanged) GetValue() *mysqlxpb_datatypes.Scalar

func (*SessionVariableChanged) ProtoMessage 

func (*SessionVariableChanged) ProtoMessage()

func (*SessionVariableChanged) ProtoReflect 

func (x *SessionVariableChanged) ProtoReflect() protoreflect.Message

func (*SessionVariableChanged) Reset 

func (x *SessionVariableChanged) Reset()

func (*SessionVariableChanged) String 

func (x *SessionVariableChanged) String() string

type Warning 

type Warning struct {

	//* Note or Warning
	Level *Warning_Level `protobuf:"varint,1,opt,name=level,enum=Mysqlx.Notice.Warning_Level,def=2" json:"level,omitempty"`
	//* warning code
	Code *uint32 `protobuf:"varint,2,req,name=code" json:"code,omitempty"`
	//* warning message
	Msg *string `protobuf:"bytes,3,req,name=msg" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

* Server-side warnings and notes

@par “.scope“ == “local“ “.level“, “.code“ and “.msg“ map the content of: @code{sql} SHOW WARNINGS @endcode

@par “.scope“ == “global“ (undefined) Will be used for global, unstructured messages like: - server is shutting down - a node disconnected from group - schema or table dropped

| @ref Mysqlx::Notice::Frame Field | Value | |-----------------------------------|-------------------------| | “.type“ | 1 | | “.scope“ | “local“ or “global“ |

func (*Warning) Descriptor deprecated 

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

Deprecated: Use Warning.ProtoReflect.Descriptor instead.

func (*Warning) GetCode 

func (x *Warning) GetCode() uint32

func (*Warning) GetLevel 

func (x *Warning) GetLevel() Warning_Level

func (*Warning) GetMsg 

func (x *Warning) GetMsg() string

func (*Warning) ProtoMessage 

func (*Warning) ProtoMessage()

func (*Warning) ProtoReflect 

func (x *Warning) ProtoReflect() protoreflect.Message

func (*Warning) Reset 

func (x *Warning) Reset()

func (*Warning) String 

func (x *Warning) String() string

type Warning_Level 

type Warning_Level int32
const (
	Warning_NOTE    Warning_Level = 1
	Warning_WARNING Warning_Level = 2
	Warning_ERROR   Warning_Level = 3
)

func (Warning_Level) Descriptor 

func (Warning_Level) Descriptor() protoreflect.EnumDescriptor

func (Warning_Level) Enum 

func (x Warning_Level) Enum() *Warning_Level

func (Warning_Level) EnumDescriptor deprecated 

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

Deprecated: Use Warning_Level.Descriptor instead.

func (Warning_Level) Number 

func (x Warning_Level) Number() protoreflect.EnumNumber

func (Warning_Level) String 

func (x Warning_Level) String() string

func (Warning_Level) Type 

func (Warning_Level) Type() protoreflect.EnumType

func (*Warning_Level) UnmarshalJSON deprecated 

func (x *Warning_Level) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

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.