Merge pull request #26 from LaPetiteSouris/master

Support stream level configuration

Makefile

@@ -4,7 +4,6 @@ all: go py
 .PHONY: go
 go:
 	protoc --gofast_out=plugins=grpc:go api.proto
-
 .PHONY: py
 py:
 	python -m grpc_tools.protoc -I. --python_out=py --grpc_python_out=py api.proto

api.proto

@@ -3,13 +3,34 @@ package proto;
 
 option java_package = "io.liftbridge.proto";
 
+
+message NullableInt64 {
+    int64 value = 1; 
+}
+
+message NullableInt32 {
+    int32 value = 1; 
+}
+
+message NullableBool {
+    bool value = 1; 
+}
+
 // CreateStreamRequest is sent to create a new stream.
 message CreateStreamRequest {
-    string subject           = 1; // Stream NATS subject
-    string name              = 2; // Stream name (unique per subject)
-    string group             = 3; // Partitions NATS subject amongst group members
-    int32  replicationFactor = 4; // Number of stream replicas
-    int32  partitions        = 5; // Number of stream partitions
+    string                  subject              = 1; // Stream NATS subject
+    string                  name                 = 2;  // Stream name (unique per subject)
+    string                  group                = 3;  // Partitions NATS subject amongst group members
+    int32                   replicationFactor    = 4;  // Number of stream replicas
+    int32                   partitions           = 5;  // Number of stream partitions
+    NullableInt64           RetentionMaxBytes    = 6;  // The maximum size a stream's log can grow to, in bytes.
+    NullableInt64           RetentionMaxMessages = 7;  // The maximum size a stream's log can grow to, in messages
+    NullableInt64           RetentionMaxAge      = 8;  // The TTL for stream log segment files 
+    NullableInt64           CleanerInterval      = 9;  // The frequency to check for log cleaner
+    NullableInt64           SegmentMaxBytes      = 10; // The maximum size of a single stream log segment file in bytes
+    NullableInt64           SegmentMaxAge        = 11; // The maximum time before a new stream log segment is rolled out
+    NullableInt32           CompactMaxGoroutines = 12; // The maximum number of concurrent goroutines to use for compaction on a stream log
+    NullableBool            CompactEnabled       = 13; // CompactEnabled controls compaction for a stream.
 }
 
 // CreateStreamResponse is sent by server after creating a stream.