gorpcbinlogstreamer

package
v2.0.0-alpha4+incompat... Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 7, 2015 License: BSD-3-Clause Imports: 4 Imported by: 0

Documentation

Index

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
}

UpdateStream is the go rpc UpdateStream server

func New

func New(updateStream proto.UpdateStream) *UpdateStream

New returns a new go rpc server implementation stub for UpdateStream

func (*UpdateStream) ServeUpdateStream

func (server *UpdateStream) ServeUpdateStream(req *proto.UpdateStreamRequest, sendReply func(reply interface{}) error) (err error)

ServeUpdateStream is part of the gorpc UpdateStream service

func (*UpdateStream) StreamKeyRange

func (server *UpdateStream) StreamKeyRange(req *proto.KeyRangeRequest, sendReply func(reply interface{}) error) (err error)

StreamKeyRange is part of the gorpc UpdateStream service

func (*UpdateStream) StreamTables

func (server *UpdateStream) StreamTables(req *proto.TablesRequest, sendReply func(reply interface{}) error) (err error)

StreamTables is part of the gorpc UpdateStream service

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL