mysql

package
v0.0.0-...-726f7ef Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_mysql_proto protoreflect.FileDescriptor
View Source 
var PublishUpdates_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mysql.PublishUpdates",
	HandlerType: (*PublishUpdatesServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeToUpdates",
			Handler:       _PublishUpdates_SubscribeToUpdates_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "mysql.proto",
}

PublishUpdates_ServiceDesc is the grpc.ServiceDesc for PublishUpdates service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterPublishUpdatesServer 

func RegisterPublishUpdatesServer(s grpc.ServiceRegistrar, srv PublishUpdatesServer)

Types

type AckMsg 

type AckMsg struct {
	SequenceId int64 `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AckMsg) Descriptor deprecated 

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

Deprecated: Use AckMsg.ProtoReflect.Descriptor instead.

func (*AckMsg) GetSequenceId 

func (x *AckMsg) GetSequenceId() int64

func (*AckMsg) ProtoMessage 

func (*AckMsg) ProtoMessage()

func (*AckMsg) ProtoReflect 

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

func (*AckMsg) Reset 

func (x *AckMsg) Reset()

func (*AckMsg) String 

func (x *AckMsg) String() string

type Attributes 

type Attributes struct {
	Key      string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	ValueOld string `protobuf:"bytes,2,opt,name=ValueOld,proto3" json:"ValueOld,omitempty"`
	ValueNew string `protobuf:"bytes,3,opt,name=ValueNew,proto3" json:"ValueNew,omitempty"`
	// contains filtered or unexported fields
}

func (*Attributes) Descriptor deprecated 

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

Deprecated: Use Attributes.ProtoReflect.Descriptor instead.

func (*Attributes) GetKey 

func (x *Attributes) GetKey() string

func (*Attributes) GetValueNew 

func (x *Attributes) GetValueNew() string

func (*Attributes) GetValueOld 

func (x *Attributes) GetValueOld() string

func (*Attributes) ProtoMessage 

func (*Attributes) ProtoMessage()

func (*Attributes) ProtoReflect 

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

func (*Attributes) Reset 

func (x *Attributes) Reset()

func (*Attributes) String 

func (x *Attributes) String() string

type PublishUpdatesClient 

type PublishUpdatesClient interface {
	SubscribeToUpdates(ctx context.Context, opts ...grpc.CallOption) (PublishUpdates_SubscribeToUpdatesClient, error)
}

PublishUpdatesClient is the client API for PublishUpdates service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPublishUpdatesClient 

func NewPublishUpdatesClient(cc grpc.ClientConnInterface) PublishUpdatesClient

type PublishUpdatesServer 

type PublishUpdatesServer interface {
	SubscribeToUpdates(PublishUpdates_SubscribeToUpdatesServer) error
	// contains filtered or unexported methods
}

PublishUpdatesServer is the server API for PublishUpdates service. All implementations must embed UnimplementedPublishUpdatesServer for forward compatibility

type PublishUpdates_SubscribeToUpdatesClient 

type PublishUpdates_SubscribeToUpdatesClient interface {
	Send(*Request) error
	Recv() (*UpdateRecord, error)
	grpc.ClientStream
}

type PublishUpdates_SubscribeToUpdatesServer 

type PublishUpdates_SubscribeToUpdatesServer interface {
	Send(*UpdateRecord) error
	Recv() (*Request, error)
	grpc.ServerStream
}

type Request 

type Request struct {

	// Types that are assignable to Val:
	//	*Request_Request
	//	*Request_Ack
	Val isRequest_Val `protobuf_oneof:"val"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated 

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetAck 

func (x *Request) GetAck() *AckMsg

func (*Request) GetRequest 

func (x *Request) GetRequest() *SubRequest

func (*Request) GetVal 

func (m *Request) GetVal() isRequest_Val

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

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

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

type Request_Ack 

type Request_Ack struct {
	Ack *AckMsg `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

type Request_Request 

type Request_Request struct {
	Request *SubRequest `protobuf:"bytes,1,opt,name=request,proto3,oneof"`
}

type SubRequest 

type SubRequest struct {
	Timestamp *timestamp.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Sync      bool                 `protobuf:"varint,2,opt,name=sync,proto3" json:"sync,omitempty"`
	Table     string               `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

func (*SubRequest) Descriptor deprecated 

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

Deprecated: Use SubRequest.ProtoReflect.Descriptor instead.

func (*SubRequest) GetSync 

func (x *SubRequest) GetSync() bool

func (*SubRequest) GetTable 

func (x *SubRequest) GetTable() string

func (*SubRequest) GetTimestamp 

func (x *SubRequest) GetTimestamp() *timestamp.Timestamp

func (*SubRequest) ProtoMessage 

func (*SubRequest) ProtoMessage()

func (*SubRequest) ProtoReflect 

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

func (*SubRequest) Reset 

func (x *SubRequest) Reset()

func (*SubRequest) String 

func (x *SubRequest) String() string

type UnimplementedPublishUpdatesServer 

type UnimplementedPublishUpdatesServer struct {
}

UnimplementedPublishUpdatesServer must be embedded to have forward compatible implementations.

func (UnimplementedPublishUpdatesServer) SubscribeToUpdates 

func (UnimplementedPublishUpdatesServer) SubscribeToUpdates(PublishUpdates_SubscribeToUpdatesServer) error

type UnsafePublishUpdatesServer 

type UnsafePublishUpdatesServer interface {
	// contains filtered or unexported methods
}

UnsafePublishUpdatesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PublishUpdatesServer will result in compilation errors.

type UpdateRecord 

type UpdateRecord struct {
	SequenceId int64                `protobuf:"varint,1,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"`
	RecordID   string               `protobuf:"bytes,2,opt,name=recordID,proto3" json:"recordID,omitempty"`
	Table      string               `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	Attributes []*Attributes        `protobuf:"bytes,4,rep,name=attributes,proto3" json:"attributes,omitempty"`
	Timestamp  *timestamp.Timestamp `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRecord) Descriptor deprecated 

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

Deprecated: Use UpdateRecord.ProtoReflect.Descriptor instead.

func (*UpdateRecord) GetAttributes 

func (x *UpdateRecord) GetAttributes() []*Attributes

func (*UpdateRecord) GetRecordID 

func (x *UpdateRecord) GetRecordID() string

func (*UpdateRecord) GetSequenceId 

func (x *UpdateRecord) GetSequenceId() int64

func (*UpdateRecord) GetTable 

func (x *UpdateRecord) GetTable() string

func (*UpdateRecord) GetTimestamp 

func (x *UpdateRecord) GetTimestamp() *timestamp.Timestamp

func (*UpdateRecord) ProtoMessage 

func (*UpdateRecord) ProtoMessage()

func (*UpdateRecord) ProtoReflect 

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

func (*UpdateRecord) Reset 

func (x *UpdateRecord) Reset()

func (*UpdateRecord) String 

func (x *UpdateRecord) String() string

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.