grpcbinlogstreamer

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: 7 Imported by: 0

Documentation

Overview

Package grpcbinlogstreamer contains the gRPC implementation of the binlog streamer server component.

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 gRPC UpdateStream server

func New

func New(updateStream proto.UpdateStream) *UpdateStream

New returns a new go rpc server implementation stub for UpdateStream

func (*UpdateStream) StreamKeyRange

func (server *UpdateStream) StreamKeyRange(req *pb.StreamKeyRangeRequest, stream pbs.UpdateStream_StreamKeyRangeServer) (err error)

StreamKeyRange is part of the pbs.UpdateStreamServer interface

func (*UpdateStream) StreamTables

func (server *UpdateStream) StreamTables(req *pb.StreamTablesRequest, stream pbs.UpdateStream_StreamTablesServer) (err error)

StreamTables is part of the pbs.UpdateStreamServer interface

func (*UpdateStream) StreamUpdate

func (server *UpdateStream) StreamUpdate(req *pb.StreamUpdateRequest, stream pbs.UpdateStream_StreamUpdateServer) (err error)

StreamUpdate is part of the pbs.UpdateStreamServer interface

Jump to

Keyboard shortcuts

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