go-vitess.v1: gopkg.in/src-d/go-vitess.v1/vt/proto/binlogservice Index | Files

package binlogservice

import "gopkg.in/src-d/go-vitess.v1/vt/proto/binlogservice"

Index

Package Files

binlogservice.pb.go

func RegisterUpdateStreamServer Uses

func RegisterUpdateStreamServer(s *grpc.Server, srv UpdateStreamServer)

type UpdateStreamClient Uses

type UpdateStreamClient interface {
    // StreamKeyRange returns the binlog transactions related to
    // the specified Keyrange.
    StreamKeyRange(ctx context.Context, in *binlogdata.StreamKeyRangeRequest, opts ...grpc.CallOption) (UpdateStream_StreamKeyRangeClient, error)
    // StreamTables returns the binlog transactions related to
    // the specified Tables.
    StreamTables(ctx context.Context, in *binlogdata.StreamTablesRequest, opts ...grpc.CallOption) (UpdateStream_StreamTablesClient, error)
}

UpdateStreamClient is the client API for UpdateStream service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewUpdateStreamClient Uses

func NewUpdateStreamClient(cc *grpc.ClientConn) UpdateStreamClient

type UpdateStreamServer Uses

type UpdateStreamServer interface {
    // StreamKeyRange returns the binlog transactions related to
    // the specified Keyrange.
    StreamKeyRange(*binlogdata.StreamKeyRangeRequest, UpdateStream_StreamKeyRangeServer) error
    // StreamTables returns the binlog transactions related to
    // the specified Tables.
    StreamTables(*binlogdata.StreamTablesRequest, UpdateStream_StreamTablesServer) error
}

UpdateStreamServer is the server API for UpdateStream service.

type UpdateStream_StreamKeyRangeClient Uses

type UpdateStream_StreamKeyRangeClient interface {
    Recv() (*binlogdata.StreamKeyRangeResponse, error)
    grpc.ClientStream
}

type UpdateStream_StreamKeyRangeServer Uses

type UpdateStream_StreamKeyRangeServer interface {
    Send(*binlogdata.StreamKeyRangeResponse) error
    grpc.ServerStream
}

type UpdateStream_StreamTablesClient Uses

type UpdateStream_StreamTablesClient interface {
    Recv() (*binlogdata.StreamTablesResponse, error)
    grpc.ClientStream
}

type UpdateStream_StreamTablesServer Uses

type UpdateStream_StreamTablesServer interface {
    Send(*binlogdata.StreamTablesResponse) error
    grpc.ServerStream
}

Package binlogservice imports 6 packages (graph) and is imported by 4 packages. Updated 2019-06-13. Refresh now. Tools for package owners.