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

package vtgateservice

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

Index

Package Files

vtgateservice.pb.go

func RegisterVitessServer Uses

func RegisterVitessServer(s *grpc.Server, srv VitessServer)

type VitessClient Uses

type VitessClient interface {
    // Execute tries to route the query to the right shard.
    // It depends on the query and bind variables to provide enough
    // information in conjunction with the vindexes to route the query.
    // API group: v3
    Execute(ctx context.Context, in *vtgate.ExecuteRequest, opts ...grpc.CallOption) (*vtgate.ExecuteResponse, error)
    // ExecuteBatch tries to route the list of queries on the right shards.
    // It depends on the query and bind variables to provide enough
    // information in conjunction with the vindexes to route the query.
    // API group: v3
    ExecuteBatch(ctx context.Context, in *vtgate.ExecuteBatchRequest, opts ...grpc.CallOption) (*vtgate.ExecuteBatchResponse, error)
    // StreamExecute executes a streaming query based on shards.
    // It depends on the query and bind variables to provide enough
    // information in conjunction with the vindexes to route the query.
    // Use this method if the query returns a large number of rows.
    // API group: v3
    StreamExecute(ctx context.Context, in *vtgate.StreamExecuteRequest, opts ...grpc.CallOption) (Vitess_StreamExecuteClient, error)
    // ExecuteShards executes the query on the specified shards.
    // API group: Custom Sharding
    ExecuteShards(ctx context.Context, in *vtgate.ExecuteShardsRequest, opts ...grpc.CallOption) (*vtgate.ExecuteShardsResponse, error)
    // ExecuteKeyspaceIds executes the query based on the specified keyspace ids.
    // API group: Range-based Sharding
    ExecuteKeyspaceIds(ctx context.Context, in *vtgate.ExecuteKeyspaceIdsRequest, opts ...grpc.CallOption) (*vtgate.ExecuteKeyspaceIdsResponse, error)
    // ExecuteKeyRanges executes the query based on the specified key ranges.
    // API group: Range-based Sharding
    ExecuteKeyRanges(ctx context.Context, in *vtgate.ExecuteKeyRangesRequest, opts ...grpc.CallOption) (*vtgate.ExecuteKeyRangesResponse, error)
    // ExecuteEntityIds executes the query based on the specified external id to keyspace id map.
    // API group: Range-based Sharding
    ExecuteEntityIds(ctx context.Context, in *vtgate.ExecuteEntityIdsRequest, opts ...grpc.CallOption) (*vtgate.ExecuteEntityIdsResponse, error)
    // ExecuteBatchShards executes the list of queries on the specified shards.
    // API group: Custom Sharding
    ExecuteBatchShards(ctx context.Context, in *vtgate.ExecuteBatchShardsRequest, opts ...grpc.CallOption) (*vtgate.ExecuteBatchShardsResponse, error)
    // ExecuteBatchKeyspaceIds executes the list of queries based on the specified keyspace ids.
    // API group: Range-based Sharding
    ExecuteBatchKeyspaceIds(ctx context.Context, in *vtgate.ExecuteBatchKeyspaceIdsRequest, opts ...grpc.CallOption) (*vtgate.ExecuteBatchKeyspaceIdsResponse, error)
    // StreamExecuteShards executes a streaming query based on shards.
    // Use this method if the query returns a large number of rows.
    // API group: Custom Sharding
    StreamExecuteShards(ctx context.Context, in *vtgate.StreamExecuteShardsRequest, opts ...grpc.CallOption) (Vitess_StreamExecuteShardsClient, error)
    // StreamExecuteKeyspaceIds executes a streaming query based on keyspace ids.
    // Use this method if the query returns a large number of rows.
    // API group: Range-based Sharding
    StreamExecuteKeyspaceIds(ctx context.Context, in *vtgate.StreamExecuteKeyspaceIdsRequest, opts ...grpc.CallOption) (Vitess_StreamExecuteKeyspaceIdsClient, error)
    // StreamExecuteKeyRanges executes a streaming query based on key ranges.
    // Use this method if the query returns a large number of rows.
    // API group: Range-based Sharding
    StreamExecuteKeyRanges(ctx context.Context, in *vtgate.StreamExecuteKeyRangesRequest, opts ...grpc.CallOption) (Vitess_StreamExecuteKeyRangesClient, error)
    // Begin a transaction.
    // API group: Transactions
    Begin(ctx context.Context, in *vtgate.BeginRequest, opts ...grpc.CallOption) (*vtgate.BeginResponse, error)
    // Commit a transaction.
    // API group: Transactions
    Commit(ctx context.Context, in *vtgate.CommitRequest, opts ...grpc.CallOption) (*vtgate.CommitResponse, error)
    // Rollback a transaction.
    // API group: Transactions
    Rollback(ctx context.Context, in *vtgate.RollbackRequest, opts ...grpc.CallOption) (*vtgate.RollbackResponse, error)
    // ResolveTransaction resolves a transaction.
    // API group: Transactions
    ResolveTransaction(ctx context.Context, in *vtgate.ResolveTransactionRequest, opts ...grpc.CallOption) (*vtgate.ResolveTransactionResponse, error)
    // MessageStream streams messages from a message table.
    MessageStream(ctx context.Context, in *vtgate.MessageStreamRequest, opts ...grpc.CallOption) (Vitess_MessageStreamClient, error)
    // MessageAck acks messages for a table.
    MessageAck(ctx context.Context, in *vtgate.MessageAckRequest, opts ...grpc.CallOption) (*query.MessageAckResponse, error)
    // MessageAckKeyspaceIds routes Message Acks using the associated
    // keyspace ids.
    MessageAckKeyspaceIds(ctx context.Context, in *vtgate.MessageAckKeyspaceIdsRequest, opts ...grpc.CallOption) (*query.MessageAckResponse, error)
    // Split a query into non-overlapping sub queries
    // API group: Map Reduce
    SplitQuery(ctx context.Context, in *vtgate.SplitQueryRequest, opts ...grpc.CallOption) (*vtgate.SplitQueryResponse, error)
    // GetSrvKeyspace returns a SrvKeyspace object (as seen by this vtgate).
    // This method is provided as a convenient way for clients to take a
    // look at the sharding configuration for a Keyspace. Looking at the
    // sharding information should not be used for routing queries (as the
    // information may change, use the Execute calls for that).
    // It is convenient for monitoring applications for instance, or if
    // using custom sharding.
    // API group: Topology
    GetSrvKeyspace(ctx context.Context, in *vtgate.GetSrvKeyspaceRequest, opts ...grpc.CallOption) (*vtgate.GetSrvKeyspaceResponse, error)
    // UpdateStream asks the server for a stream of StreamEvent objects.
    // API group: Update Stream
    UpdateStream(ctx context.Context, in *vtgate.UpdateStreamRequest, opts ...grpc.CallOption) (Vitess_UpdateStreamClient, error)
}

VitessClient is the client API for Vitess service.

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

func NewVitessClient Uses

func NewVitessClient(cc *grpc.ClientConn) VitessClient

type VitessServer Uses

type VitessServer interface {
    // Execute tries to route the query to the right shard.
    // It depends on the query and bind variables to provide enough
    // information in conjunction with the vindexes to route the query.
    // API group: v3
    Execute(context.Context, *vtgate.ExecuteRequest) (*vtgate.ExecuteResponse, error)
    // ExecuteBatch tries to route the list of queries on the right shards.
    // It depends on the query and bind variables to provide enough
    // information in conjunction with the vindexes to route the query.
    // API group: v3
    ExecuteBatch(context.Context, *vtgate.ExecuteBatchRequest) (*vtgate.ExecuteBatchResponse, error)
    // StreamExecute executes a streaming query based on shards.
    // It depends on the query and bind variables to provide enough
    // information in conjunction with the vindexes to route the query.
    // Use this method if the query returns a large number of rows.
    // API group: v3
    StreamExecute(*vtgate.StreamExecuteRequest, Vitess_StreamExecuteServer) error
    // ExecuteShards executes the query on the specified shards.
    // API group: Custom Sharding
    ExecuteShards(context.Context, *vtgate.ExecuteShardsRequest) (*vtgate.ExecuteShardsResponse, error)
    // ExecuteKeyspaceIds executes the query based on the specified keyspace ids.
    // API group: Range-based Sharding
    ExecuteKeyspaceIds(context.Context, *vtgate.ExecuteKeyspaceIdsRequest) (*vtgate.ExecuteKeyspaceIdsResponse, error)
    // ExecuteKeyRanges executes the query based on the specified key ranges.
    // API group: Range-based Sharding
    ExecuteKeyRanges(context.Context, *vtgate.ExecuteKeyRangesRequest) (*vtgate.ExecuteKeyRangesResponse, error)
    // ExecuteEntityIds executes the query based on the specified external id to keyspace id map.
    // API group: Range-based Sharding
    ExecuteEntityIds(context.Context, *vtgate.ExecuteEntityIdsRequest) (*vtgate.ExecuteEntityIdsResponse, error)
    // ExecuteBatchShards executes the list of queries on the specified shards.
    // API group: Custom Sharding
    ExecuteBatchShards(context.Context, *vtgate.ExecuteBatchShardsRequest) (*vtgate.ExecuteBatchShardsResponse, error)
    // ExecuteBatchKeyspaceIds executes the list of queries based on the specified keyspace ids.
    // API group: Range-based Sharding
    ExecuteBatchKeyspaceIds(context.Context, *vtgate.ExecuteBatchKeyspaceIdsRequest) (*vtgate.ExecuteBatchKeyspaceIdsResponse, error)
    // StreamExecuteShards executes a streaming query based on shards.
    // Use this method if the query returns a large number of rows.
    // API group: Custom Sharding
    StreamExecuteShards(*vtgate.StreamExecuteShardsRequest, Vitess_StreamExecuteShardsServer) error
    // StreamExecuteKeyspaceIds executes a streaming query based on keyspace ids.
    // Use this method if the query returns a large number of rows.
    // API group: Range-based Sharding
    StreamExecuteKeyspaceIds(*vtgate.StreamExecuteKeyspaceIdsRequest, Vitess_StreamExecuteKeyspaceIdsServer) error
    // StreamExecuteKeyRanges executes a streaming query based on key ranges.
    // Use this method if the query returns a large number of rows.
    // API group: Range-based Sharding
    StreamExecuteKeyRanges(*vtgate.StreamExecuteKeyRangesRequest, Vitess_StreamExecuteKeyRangesServer) error
    // Begin a transaction.
    // API group: Transactions
    Begin(context.Context, *vtgate.BeginRequest) (*vtgate.BeginResponse, error)
    // Commit a transaction.
    // API group: Transactions
    Commit(context.Context, *vtgate.CommitRequest) (*vtgate.CommitResponse, error)
    // Rollback a transaction.
    // API group: Transactions
    Rollback(context.Context, *vtgate.RollbackRequest) (*vtgate.RollbackResponse, error)
    // ResolveTransaction resolves a transaction.
    // API group: Transactions
    ResolveTransaction(context.Context, *vtgate.ResolveTransactionRequest) (*vtgate.ResolveTransactionResponse, error)
    // MessageStream streams messages from a message table.
    MessageStream(*vtgate.MessageStreamRequest, Vitess_MessageStreamServer) error
    // MessageAck acks messages for a table.
    MessageAck(context.Context, *vtgate.MessageAckRequest) (*query.MessageAckResponse, error)
    // MessageAckKeyspaceIds routes Message Acks using the associated
    // keyspace ids.
    MessageAckKeyspaceIds(context.Context, *vtgate.MessageAckKeyspaceIdsRequest) (*query.MessageAckResponse, error)
    // Split a query into non-overlapping sub queries
    // API group: Map Reduce
    SplitQuery(context.Context, *vtgate.SplitQueryRequest) (*vtgate.SplitQueryResponse, error)
    // GetSrvKeyspace returns a SrvKeyspace object (as seen by this vtgate).
    // This method is provided as a convenient way for clients to take a
    // look at the sharding configuration for a Keyspace. Looking at the
    // sharding information should not be used for routing queries (as the
    // information may change, use the Execute calls for that).
    // It is convenient for monitoring applications for instance, or if
    // using custom sharding.
    // API group: Topology
    GetSrvKeyspace(context.Context, *vtgate.GetSrvKeyspaceRequest) (*vtgate.GetSrvKeyspaceResponse, error)
    // UpdateStream asks the server for a stream of StreamEvent objects.
    // API group: Update Stream
    UpdateStream(*vtgate.UpdateStreamRequest, Vitess_UpdateStreamServer) error
}

VitessServer is the server API for Vitess service.

type Vitess_MessageStreamClient Uses

type Vitess_MessageStreamClient interface {
    Recv() (*query.MessageStreamResponse, error)
    grpc.ClientStream
}

type Vitess_MessageStreamServer Uses

type Vitess_MessageStreamServer interface {
    Send(*query.MessageStreamResponse) error
    grpc.ServerStream
}

type Vitess_StreamExecuteClient Uses

type Vitess_StreamExecuteClient interface {
    Recv() (*vtgate.StreamExecuteResponse, error)
    grpc.ClientStream
}

type Vitess_StreamExecuteKeyRangesClient Uses

type Vitess_StreamExecuteKeyRangesClient interface {
    Recv() (*vtgate.StreamExecuteKeyRangesResponse, error)
    grpc.ClientStream
}

type Vitess_StreamExecuteKeyRangesServer Uses

type Vitess_StreamExecuteKeyRangesServer interface {
    Send(*vtgate.StreamExecuteKeyRangesResponse) error
    grpc.ServerStream
}

type Vitess_StreamExecuteKeyspaceIdsClient Uses

type Vitess_StreamExecuteKeyspaceIdsClient interface {
    Recv() (*vtgate.StreamExecuteKeyspaceIdsResponse, error)
    grpc.ClientStream
}

type Vitess_StreamExecuteKeyspaceIdsServer Uses

type Vitess_StreamExecuteKeyspaceIdsServer interface {
    Send(*vtgate.StreamExecuteKeyspaceIdsResponse) error
    grpc.ServerStream
}

type Vitess_StreamExecuteServer Uses

type Vitess_StreamExecuteServer interface {
    Send(*vtgate.StreamExecuteResponse) error
    grpc.ServerStream
}

type Vitess_StreamExecuteShardsClient Uses

type Vitess_StreamExecuteShardsClient interface {
    Recv() (*vtgate.StreamExecuteShardsResponse, error)
    grpc.ClientStream
}

type Vitess_StreamExecuteShardsServer Uses

type Vitess_StreamExecuteShardsServer interface {
    Send(*vtgate.StreamExecuteShardsResponse) error
    grpc.ServerStream
}

type Vitess_UpdateStreamClient Uses

type Vitess_UpdateStreamClient interface {
    Recv() (*vtgate.UpdateStreamResponse, error)
    grpc.ClientStream
}

type Vitess_UpdateStreamServer Uses

type Vitess_UpdateStreamServer interface {
    Send(*vtgate.UpdateStreamResponse) error
    grpc.ServerStream
}

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