go: cloud.google.com/go/spanner/internal/benchwrapper/proto Index | Files

package spanner_bench

import "cloud.google.com/go/spanner/internal/benchwrapper/proto"

Index

Package Files

spanner.pb.go

func RegisterSpannerBenchWrapperServer Uses

func RegisterSpannerBenchWrapperServer(s *grpc.Server, srv SpannerBenchWrapperServer)

type EmptyResponse Uses

type EmptyResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*EmptyResponse) Descriptor Uses

func (*EmptyResponse) Descriptor() ([]byte, []int)

func (*EmptyResponse) ProtoMessage Uses

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) Reset Uses

func (m *EmptyResponse) Reset()

func (*EmptyResponse) String Uses

func (m *EmptyResponse) String() string

func (*EmptyResponse) XXX_DiscardUnknown Uses

func (m *EmptyResponse) XXX_DiscardUnknown()

func (*EmptyResponse) XXX_Marshal Uses

func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EmptyResponse) XXX_Merge Uses

func (m *EmptyResponse) XXX_Merge(src proto.Message)

func (*EmptyResponse) XXX_Size Uses

func (m *EmptyResponse) XXX_Size() int

func (*EmptyResponse) XXX_Unmarshal Uses

func (m *EmptyResponse) XXX_Unmarshal(b []byte) error

type InsertQuery Uses

type InsertQuery struct {
    // The query to use in the insert call.
    Users                []*User  `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*InsertQuery) Descriptor Uses

func (*InsertQuery) Descriptor() ([]byte, []int)

func (*InsertQuery) GetUsers Uses

func (m *InsertQuery) GetUsers() []*User

func (*InsertQuery) ProtoMessage Uses

func (*InsertQuery) ProtoMessage()

func (*InsertQuery) Reset Uses

func (m *InsertQuery) Reset()

func (*InsertQuery) String Uses

func (m *InsertQuery) String() string

func (*InsertQuery) XXX_DiscardUnknown Uses

func (m *InsertQuery) XXX_DiscardUnknown()

func (*InsertQuery) XXX_Marshal Uses

func (m *InsertQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InsertQuery) XXX_Merge Uses

func (m *InsertQuery) XXX_Merge(src proto.Message)

func (*InsertQuery) XXX_Size Uses

func (m *InsertQuery) XXX_Size() int

func (*InsertQuery) XXX_Unmarshal Uses

func (m *InsertQuery) XXX_Unmarshal(b []byte) error

type ReadQuery Uses

type ReadQuery struct {
    // The query to use in the read call.
    Query                string   `protobuf:"bytes,1,opt,name=Query,proto3" json:"Query,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ReadQuery) Descriptor Uses

func (*ReadQuery) Descriptor() ([]byte, []int)

func (*ReadQuery) GetQuery Uses

func (m *ReadQuery) GetQuery() string

func (*ReadQuery) ProtoMessage Uses

func (*ReadQuery) ProtoMessage()

func (*ReadQuery) Reset Uses

func (m *ReadQuery) Reset()

func (*ReadQuery) String Uses

func (m *ReadQuery) String() string

func (*ReadQuery) XXX_DiscardUnknown Uses

func (m *ReadQuery) XXX_DiscardUnknown()

func (*ReadQuery) XXX_Marshal Uses

func (m *ReadQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadQuery) XXX_Merge Uses

func (m *ReadQuery) XXX_Merge(src proto.Message)

func (*ReadQuery) XXX_Size Uses

func (m *ReadQuery) XXX_Size() int

func (*ReadQuery) XXX_Unmarshal Uses

func (m *ReadQuery) XXX_Unmarshal(b []byte) error

type SpannerBenchWrapperClient Uses

type SpannerBenchWrapperClient interface {
    // Read represents operations like Go's ReadOnlyTransaction.Query, Java's
    // ReadOnlyTransaction.executeQuery, Python's snapshot.read, and Node's
    // Transaction.Read.
    //
    // It will typically be used to read many items.
    Read(ctx context.Context, in *ReadQuery, opts ...grpc.CallOption) (*EmptyResponse, error)
    // Insert represents operations like Go's Client.Apply, Java's
    // DatabaseClient.writeAtLeastOnce, Python's transaction.commit, and Node's
    // Transaction.Commit.
    //
    // It will typically be used to insert many items.
    Insert(ctx context.Context, in *InsertQuery, opts ...grpc.CallOption) (*EmptyResponse, error)
    // Update represents operations like Go's ReadWriteTransaction.BatchUpdate,
    // Java's TransactionRunner.run, Python's Batch.update, and Node's
    // Transaction.BatchUpdate.
    //
    // It will typically be used to update many items.
    Update(ctx context.Context, in *UpdateQuery, opts ...grpc.CallOption) (*EmptyResponse, error)
}

SpannerBenchWrapperClient is the client API for SpannerBenchWrapper service.

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

func NewSpannerBenchWrapperClient Uses

func NewSpannerBenchWrapperClient(cc *grpc.ClientConn) SpannerBenchWrapperClient

type SpannerBenchWrapperServer Uses

type SpannerBenchWrapperServer interface {
    // Read represents operations like Go's ReadOnlyTransaction.Query, Java's
    // ReadOnlyTransaction.executeQuery, Python's snapshot.read, and Node's
    // Transaction.Read.
    //
    // It will typically be used to read many items.
    Read(context.Context, *ReadQuery) (*EmptyResponse, error)
    // Insert represents operations like Go's Client.Apply, Java's
    // DatabaseClient.writeAtLeastOnce, Python's transaction.commit, and Node's
    // Transaction.Commit.
    //
    // It will typically be used to insert many items.
    Insert(context.Context, *InsertQuery) (*EmptyResponse, error)
    // Update represents operations like Go's ReadWriteTransaction.BatchUpdate,
    // Java's TransactionRunner.run, Python's Batch.update, and Node's
    // Transaction.BatchUpdate.
    //
    // It will typically be used to update many items.
    Update(context.Context, *UpdateQuery) (*EmptyResponse, error)
}

SpannerBenchWrapperServer is the server API for SpannerBenchWrapper service.

type UnimplementedSpannerBenchWrapperServer Uses

type UnimplementedSpannerBenchWrapperServer struct {
}

UnimplementedSpannerBenchWrapperServer can be embedded to have forward compatible implementations.

func (*UnimplementedSpannerBenchWrapperServer) Insert Uses

func (*UnimplementedSpannerBenchWrapperServer) Insert(ctx context.Context, req *InsertQuery) (*EmptyResponse, error)

func (*UnimplementedSpannerBenchWrapperServer) Read Uses

func (*UnimplementedSpannerBenchWrapperServer) Read(ctx context.Context, req *ReadQuery) (*EmptyResponse, error)

func (*UnimplementedSpannerBenchWrapperServer) Update Uses

func (*UnimplementedSpannerBenchWrapperServer) Update(ctx context.Context, req *UpdateQuery) (*EmptyResponse, error)

type UpdateQuery Uses

type UpdateQuery struct {
    // The queries to use in the update call.
    Queries              []string `protobuf:"bytes,1,rep,name=Queries,proto3" json:"Queries,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*UpdateQuery) Descriptor Uses

func (*UpdateQuery) Descriptor() ([]byte, []int)

func (*UpdateQuery) GetQueries Uses

func (m *UpdateQuery) GetQueries() []string

func (*UpdateQuery) ProtoMessage Uses

func (*UpdateQuery) ProtoMessage()

func (*UpdateQuery) Reset Uses

func (m *UpdateQuery) Reset()

func (*UpdateQuery) String Uses

func (m *UpdateQuery) String() string

func (*UpdateQuery) XXX_DiscardUnknown Uses

func (m *UpdateQuery) XXX_DiscardUnknown()

func (*UpdateQuery) XXX_Marshal Uses

func (m *UpdateQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateQuery) XXX_Merge Uses

func (m *UpdateQuery) XXX_Merge(src proto.Message)

func (*UpdateQuery) XXX_Size Uses

func (m *UpdateQuery) XXX_Size() int

func (*UpdateQuery) XXX_Unmarshal Uses

func (m *UpdateQuery) XXX_Unmarshal(b []byte) error

type User Uses

type User struct {
    Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    Age                  int64    `protobuf:"varint,2,opt,name=age,proto3" json:"age,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*User) Descriptor Uses

func (*User) Descriptor() ([]byte, []int)

func (*User) GetAge Uses

func (m *User) GetAge() int64

func (*User) GetName Uses

func (m *User) GetName() string

func (*User) ProtoMessage Uses

func (*User) ProtoMessage()

func (*User) Reset Uses

func (m *User) Reset()

func (*User) String Uses

func (m *User) String() string

func (*User) XXX_DiscardUnknown Uses

func (m *User) XXX_DiscardUnknown()

func (*User) XXX_Marshal Uses

func (m *User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*User) XXX_Merge Uses

func (m *User) XXX_Merge(src proto.Message)

func (*User) XXX_Size Uses

func (m *User) XXX_Size() int

func (*User) XXX_Unmarshal Uses

func (m *User) XXX_Unmarshal(b []byte) error

Package spanner_bench imports 7 packages (graph) and is imported by 2 packages. Updated 2020-10-25. Refresh now. Tools for package owners.