go-vitess.v1: gopkg.in/src-d/go-vitess.v1/vt/binlog/grpcbinlogstreamer Index | Files

package grpcbinlogstreamer

import "gopkg.in/src-d/go-vitess.v1/vt/binlog/grpcbinlogstreamer"

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


Package Files


type UpdateStream Uses

type UpdateStream struct {
    // contains filtered or unexported fields

UpdateStream is the gRPC UpdateStream server

func New Uses

func New(updateStream binlog.UpdateStream) *UpdateStream

New returns a new go rpc server implementation stub for UpdateStream

func (*UpdateStream) StreamKeyRange Uses

func (server *UpdateStream) StreamKeyRange(req *binlogdatapb.StreamKeyRangeRequest, stream binlogservicepb.UpdateStream_StreamKeyRangeServer) (err error)

StreamKeyRange is part of the binlogservicepb.UpdateStreamServer interface

func (*UpdateStream) StreamTables Uses

func (server *UpdateStream) StreamTables(req *binlogdatapb.StreamTablesRequest, stream binlogservicepb.UpdateStream_StreamTablesServer) (err error)

StreamTables is part of the binlogservicepb.UpdateStreamServer interface

Package grpcbinlogstreamer imports 4 packages (graph). Updated 2019-06-13. Refresh now. Tools for package owners.