← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/message/replication.proto

  • Committer: Jay Pipes
  • Date: 2009-10-07 23:59:47 UTC
  • mto: (1234.1.1 push) (1237.2.10 push)
  • mto: This revision was merged to the branch mainline in revision 1193.
  • Revision ID: jpipes@serialcoder-20091007235947-18simrecnzwv8t1q
Phase 2 new replication work:

* Removes old replication.proto file, old command_transform library
* Removes use of korr.h macro calls in favor of GPB's CodedOutputStream
  API.
* Updates transaction_log, default_replicator, and filtered_replicator module
  to use new Transaction message.
* Updates ReplicationServices to construct the new Transaction messages and
  associated Statement sub-messages
* Corrects transaction boundaries.  AUTOCOMMIT now works properly, and I have
  added a new test case to verify AUTOCOMMIT variable modification of the way
  in which Transaction messages are bundled up and sent across to replicators.

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/message/replication.proto
1
 
import "table.proto";
2
 
 
3
 
package drizzled.message;
4
 
option optimize_for = SPEED;
5
 
 
6
 
/*
7
 
  Context for a transaction.
8
 
*/
9
 
message TransactionContext
10
 
{
11
 
  required int32 server_id = 1;
12
 
  required uint64 transaction_id = 2; /* Globally-unique transaction ID */
13
 
}
14
 
 
15
 
/*
16
 
  Insert one record into a single table.
17
 
*/
18
 
message InsertRecord
19
 
{
20
 
  repeated Table.Field insert_field = 3;
21
 
  repeated bytes insert_value = 4;
22
 
}
23
 
 
24
 
/*
25
 
  Update one record in a single table.
26
 
*/
27
 
message UpdateRecord
28
 
{
29
 
  repeated Table.Field update_field = 3;
30
 
  repeated bytes before_value = 4;
31
 
  repeated bytes after_value = 5;
32
 
  repeated Table.Field where_field = 6;
33
 
  repeated bytes where_value = 7;
34
 
}
35
 
 
36
 
/*
37
 
  Deletes one record in a single table
38
 
*/
39
 
message DeleteRecord
40
 
{
41
 
  repeated Table.Field where_field = 3;
42
 
  repeated bytes where_value = 4;
43
 
}
44
 
 
45
 
/*
46
 
  A component of a transaction -- a single instruction or command
47
 
*/
48
 
message Command
49
 
{
50
 
  enum Type 
51
 
  {
52
 
    START_TRANSACTION = 0;        /* A START TRANSACTION statement */
53
 
    COMMIT = 1;                   /* A COMMIT statement */
54
 
    ROLLBACK = 2;                 /* A ROLLBACK statement */
55
 
    INSERT = 3;                   /* An insert of a single record */
56
 
    DELETE = 4;                   /* A delete of a single record */
57
 
    UPDATE = 5;                   /* An update of a single record */
58
 
    RAW_SQL = 6;                  /* A raw SQL statement */
59
 
  }
60
 
  required Type type = 1;
61
 
  required uint64 timestamp = 2;  /* A nanosecond precision timestamp */
62
 
  /* 
63
 
    Transaction Context is duplicated here so that ChangeRecords may
64
 
    be sent over the wire separately from the rest of the records in
65
 
    a transaction.
66
 
  */
67
 
  required TransactionContext transaction_context = 3;
68
 
  optional string schema = 4;     /* The schema affected */
69
 
  optional string table = 5;      /* The table affected */
70
 
 
71
 
  optional string sql = 6;  /* May contain the actual SQL supplied for the original statement */
72
 
 
73
 
  /* 
74
 
    The below implement the actual change.  Each ChangeRecord will 
75
 
    have zero or one of the below sub-messages defined. 
76
 
  */
77
 
  optional InsertRecord      insert_record = 7;
78
 
  optional DeleteRecord      delete_record = 8;
79
 
  optional UpdateRecord      update_record = 9;
80
 
 
81
 
  optional uint32 session_id = 30; /* Optionally stores the ID of the session which executed this command */
82
 
}
83
 
 
84
 
message Transaction
85
 
{
86
 
  required TransactionContext transaction_context = 1;
87
 
  required uint64 start_timestamp = 2;
88
 
  required uint64 end_timestamp = 3;
89
 
  repeated Command command = 4;
90
 
}
91
 
 
92
 
/*
93
 
 * Describes a server used in replication.  This message
94
 
 * class is passed in the Publisher::registerSubscriber()
95
 
 * and Subscriber::subscribe() methods.
96
 
 */
97
 
message Server
98
 
{
99
 
  /* A unique numeric identifier for this server */
100
 
  required int32 server_id = 1;
101
 
  /* A valid IP address */
102
 
  required string ip_address = 2;
103
 
  /* Port that this server is listening for replication events */
104
 
  required uint32 port = 3;
105
 
  /* Optional name for the server */
106
 
  optional string name = 4;
107
 
}
108
 
 
109
 
/*
110
 
 * A subscriber manifest describes the state of
111
 
 * a subscriber in replication.  This message class
112
 
 * is passed in the replication API in the 
113
 
 * drizzled::plugin::Publisher's findSubscriptionState() call
114
 
 */
115
 
message SubscriberManifest
116
 
{
117
 
  /* Only need to pass the ID...not the whole Server message */
118
 
  required int32 server_id = 1;
119
 
  /* 
120
 
   * The timestamp of the last time this subscriber 
121
 
   * communicated with the publisher 
122
 
   */
123
 
  required uint64 last_applied_timestamp = 2;
124
 
  /* The globally unique transaction ID of last applied command */ 
125
 
  required uint64 last_applied_transaction_id = 3;
126
 
}