protocol

Jan 31, 2014

Changes in this version

type FieldValue

+ IsNull *bool

+ func (m *FieldValue) GetIsNull() bool

Jan 30, 2014

Changes in this version

type Request

+ IsDbUser *bool

+ func (m *Request) GetIsDbUser() bool

Jan 17, 2014

Changes in this version

+ var Response_ErrorCode_name = map[int32]string

+ var Response_ErrorCode_value = map[string]int32

+ type ByPointTimeAsc struct

+ func (s ByPointTimeAsc) Less(i, j int) bool

+ type ByPointTimeDesc struct

+ func (s ByPointTimeDesc) Less(i, j int) bool

type Point

+ func DecodePoint(buff *bytes.Buffer) (point *Point, err error)

+ func (point *Point) Encode() (data []byte, err error)

+ type PointsCollection []*Point

+ func (s PointsCollection) Len() int

+ func (s PointsCollection) Swap(i, j int)

+ type QueryResponseChunk struct

+ Done *bool

+ Series *Series

+ XXX_unrecognized []byte

+ func (*QueryResponseChunk) ProtoMessage()

+ func (m *QueryResponseChunk) GetDone() bool

+ func (m *QueryResponseChunk) GetSeries() *Series

+ func (m *QueryResponseChunk) Reset()

+ func (m *QueryResponseChunk) String() string

type Request

+ ClusterVersion *uint32

+ Database *string

+ LastKnownSequenceNumber *uint64

+ OriginatingServerId *uint32

+ OwnerServerId *uint32

+ Query *string

+ ReplicationFactor *uint32

+ RingLocationsToQuery *uint32

+ SequenceNumber *uint64

+ Series *Series

+ UserName *string

+ func DecodeRequest(buff *bytes.Buffer) (request *Request, err error)

+ func (m *Request) GetClusterVersion() uint32

+ func (m *Request) GetDatabase() string

+ func (m *Request) GetLastKnownSequenceNumber() uint64

+ func (m *Request) GetOriginatingServerId() uint32

+ func (m *Request) GetOwnerServerId() uint32

+ func (m *Request) GetQuery() string

+ func (m *Request) GetReplicationFactor() uint32

+ func (m *Request) GetRingLocationsToQuery() uint32

+ func (m *Request) GetSequenceNumber() uint64

+ func (m *Request) GetSeries() *Series

+ func (m *Request) GetUserName() string

+ func (self *Request) Encode() (data []byte, err error)

type Request_Type

+ const Request_LIST_SERIES

+ const Request_PROXY_DELETE

+ const Request_PROXY_DROP_DATABASE

+ const Request_PROXY_DROP_SERIES

+ const Request_PROXY_WRITE

+ const Request_REPLICATION_DELETE

+ const Request_REPLICATION_DROP_DATABASE

+ const Request_REPLICATION_DROP_SERIES

+ const Request_REPLICATION_REPLAY

+ const Request_REPLICATION_WRITE

+ const Request_SEQUENCE_NUMBER

type Response

+ ErrorCode *Response_ErrorCode

+ ErrorMessage *string

+ NextPointTime *int64

+ Request *Request

+ RequestId *uint32

+ Type *Response_Type

+ func DecodeResponse(buff *bytes.Buffer) (response *Response, err error)

+ func (m *Response) GetErrorCode() Response_ErrorCode

+ func (m *Response) GetErrorMessage() string

+ func (m *Response) GetNextPointTime() int64

+ func (m *Response) GetRequest() *Request

+ func (m *Response) GetRequestId() uint32

+ func (m *Response) GetType() Response_Type

+ func (self *Response) Encode() (data []byte, err error)

+ type Response_ErrorCode int32

+ const Response_INTERNAL_ERROR

+ const Response_REQUEST_TOO_LARGE

+ func (x *Response_ErrorCode) UnmarshalJSON(data []byte) error

+ func (x Response_ErrorCode) Enum() *Response_ErrorCode

+ func (x Response_ErrorCode) String() string

type Response_Type

+ const Response_LIST_SERIES

+ const Response_REPLICATION_REPLAY

+ const Response_REPLICATION_REPLAY_END

+ const Response_SEQUENCE_NUMBER

type Series

+ func (self *Series) SortPointsTimeAscending()

+ func (self *Series) SortPointsTimeDescending()

Oct 24, 2013

Changes in this version

+ var Request_Type_name = map[int32]string

+ var Request_Type_value = map[string]int32

+ var Response_Type_name = map[int32]string

+ var Response_Type_value = map[string]int32

+ func MarshalPoint(point *Point) (data []byte, err error)

+ type FieldValue struct

+ BoolValue *bool

+ DoubleValue *float64

+ Int64Value *int64

+ StringValue *string

+ XXX_unrecognized []byte

+ func (*FieldValue) ProtoMessage()

+ func (m *FieldValue) GetBoolValue() bool

+ func (m *FieldValue) GetDoubleValue() float64

+ func (m *FieldValue) GetInt64Value() int64

+ func (m *FieldValue) GetStringValue() string

+ func (m *FieldValue) Reset()

+ func (m *FieldValue) String() string

+ func (self *FieldValue) GetValue() interface{}

+ type Point struct

+ SequenceNumber *uint32

+ Timestamp *int64

+ Values []*FieldValue

+ XXX_unrecognized []byte

+ func UnmarshalPoint(data []byte) (point *Point, err error)

+ func (*Point) ProtoMessage()

+ func (m *Point) GetSequenceNumber() uint32

+ func (m *Point) GetTimestamp() int64

+ func (m *Point) GetValues() []*FieldValue

+ func (m *Point) Reset()

+ func (m *Point) String() string

+ func (self *Point) GetFieldValue(idx int) interface{}

+ func (self *Point) GetTimestampInMicroseconds() *int64

+ func (self *Point) SetTimestampInMicroseconds(t int64)

+ type Request struct

+ Id *int32

+ Type *Request_Type

+ XXX_unrecognized []byte

+ func (*Request) ProtoMessage()

+ func (m *Request) GetId() int32

+ func (m *Request) GetType() Request_Type

+ func (m *Request) Reset()

+ func (m *Request) String() string

+ type Request_Type int32

+ const Request_GET_SERVERS

+ const Request_QUERY

+ const Request_WRITE

+ func (x *Request_Type) UnmarshalJSON(data []byte) error

+ func (x Request_Type) Enum() *Request_Type

+ func (x Request_Type) MarshalJSON() ([]byte, error)

+ func (x Request_Type) String() string

+ type Response struct

+ Id *int32

+ Series *Series

+ Servers []string

+ XXX_unrecognized []byte

+ func (*Response) ProtoMessage()

+ func (m *Response) GetId() int32

+ func (m *Response) GetSeries() *Series

+ func (m *Response) GetServers() []string

+ func (m *Response) Reset()

+ func (m *Response) String() string

+ type Response_Type int32

+ const Response_END_STREAM

+ const Response_QUERY

+ const Response_WRITE_OK

+ func (x *Response_Type) UnmarshalJSON(data []byte) error

+ func (x Response_Type) Enum() *Response_Type

+ func (x Response_Type) MarshalJSON() ([]byte, error)

+ func (x Response_Type) String() string

+ type Series struct

+ Fields []string

+ Name *string

+ Points []*Point

+ XXX_unrecognized []byte

+ func (*Series) ProtoMessage()

+ func (m *Series) GetFields() []string

+ func (m *Series) GetName() string

+ func (m *Series) GetPoints() []*Point

+ func (m *Series) Reset()

+ func (m *Series) String() string