Documentation
¶
Index ¶
- type UpdateStream
- func (server *UpdateStream) ServeUpdateStream(req *proto.UpdateStreamRequest, sendReply func(reply interface{}) error) (err error)
- func (server *UpdateStream) StreamKeyRange(req *proto.KeyRangeRequest, sendReply func(reply interface{}) error) (err error)
- func (server *UpdateStream) StreamTables(req *proto.TablesRequest, sendReply func(reply interface{}) error) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type UpdateStream ¶
type UpdateStream struct {
// contains filtered or unexported fields
}
func (*UpdateStream) ServeUpdateStream ¶
func (server *UpdateStream) ServeUpdateStream(req *proto.UpdateStreamRequest, sendReply func(reply interface{}) error) (err error)
func (*UpdateStream) StreamKeyRange ¶
func (server *UpdateStream) StreamKeyRange(req *proto.KeyRangeRequest, sendReply func(reply interface{}) error) (err error)
func (*UpdateStream) StreamTables ¶
func (server *UpdateStream) StreamTables(req *proto.TablesRequest, sendReply func(reply interface{}) error) (err error)
Source Files
Click to show internal directories.
Click to hide internal directories.