- // times with different `request_id`s.
- RequestId uint64 `protobuf:"varint,7,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
- ExtraOp kvrpcpb.ExtraOp `protobuf:"varint,8,opt,name=extra_op,json=extraOp,proto3,enum=kvrpcpb.ExtraOp" json:"extra_op,omitempty"`
- // Types that are valid to be assigned to Request:
- // *ChangeDataRequest_Register_
- // *ChangeDataRequest_NotifyTxnStatus_
- // *ChangeDataRequest_Deregister_
- Request isChangeDataRequest_Request `protobuf_oneof:"request"`
- KvApi ChangeDataRequest_KvAPI `protobuf:"varint,11,opt,name=kv_api,json=kvApi,proto3,enum=cdcpb.ChangeDataRequest_KvAPI" json:"kv_api,omitempty"`
- // Whether to filter out the value write by cdc itself.
- FilterLoop bool `protobuf:"varint,12,opt,name=filter_loop,json=filterLoop,proto3" json:"filter_loop,omitempty"`
- XXX_NoUnkeyedLiteral struct{} `json:"-"`
- XXX_unrecognized []byte `json:"-"`
- XXX_sizecache int32 `json:"-"`
- }
- func (m *ChangeDataRequest) Reset() { *m = ChangeDataRequest{} }
- func (m *ChangeDataRequest) String() string { return proto.CompactTextString(m) }
- func (*ChangeDataRequest) ProtoMessage() {}
- func (*ChangeDataRequest) Descriptor() ([]byte, []int) {
- return fileDescriptor_911209a1d38ef245, []int{10}
