spanner_bench

package
v1.5.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 17, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

README

Regenerating protos

cd spanner/internal/benchwrapper/proto
protoc --go_out=plugins=grpc:. *.proto

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterSpannerBenchWrapperServer

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

Types

type EmptyResponse

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

func (*EmptyResponse) Descriptor

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

func (*EmptyResponse) ProtoMessage

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) Reset

func (m *EmptyResponse) Reset()

func (*EmptyResponse) String

func (m *EmptyResponse) String() string

func (*EmptyResponse) XXX_DiscardUnknown

func (m *EmptyResponse) XXX_DiscardUnknown()

func (*EmptyResponse) XXX_Marshal

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

func (*EmptyResponse) XXX_Merge

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

func (*EmptyResponse) XXX_Size

func (m *EmptyResponse) XXX_Size() int

func (*EmptyResponse) XXX_Unmarshal

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

type InsertQuery

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

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

func (*InsertQuery) GetUsers

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

func (*InsertQuery) ProtoMessage

func (*InsertQuery) ProtoMessage()

func (*InsertQuery) Reset

func (m *InsertQuery) Reset()

func (*InsertQuery) String

func (m *InsertQuery) String() string

func (*InsertQuery) XXX_DiscardUnknown

func (m *InsertQuery) XXX_DiscardUnknown()

func (*InsertQuery) XXX_Marshal

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

func (*InsertQuery) XXX_Merge

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

func (*InsertQuery) XXX_Size

func (m *InsertQuery) XXX_Size() int

func (*InsertQuery) XXX_Unmarshal

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

type ReadQuery

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

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

func (*ReadQuery) GetQuery

func (m *ReadQuery) GetQuery() string

func (*ReadQuery) ProtoMessage

func (*ReadQuery) ProtoMessage()

func (*ReadQuery) Reset

func (m *ReadQuery) Reset()

func (*ReadQuery) String

func (m *ReadQuery) String() string

func (*ReadQuery) XXX_DiscardUnknown

func (m *ReadQuery) XXX_DiscardUnknown()

func (*ReadQuery) XXX_Marshal

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

func (*ReadQuery) XXX_Merge

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

func (*ReadQuery) XXX_Size

func (m *ReadQuery) XXX_Size() int

func (*ReadQuery) XXX_Unmarshal

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

type SpannerBenchWrapperClient

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

func NewSpannerBenchWrapperClient(cc *grpc.ClientConn) SpannerBenchWrapperClient

type SpannerBenchWrapperServer

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

type UnimplementedSpannerBenchWrapperServer struct {
}

UnimplementedSpannerBenchWrapperServer can be embedded to have forward compatible implementations.

func (*UnimplementedSpannerBenchWrapperServer) Insert

func (*UnimplementedSpannerBenchWrapperServer) Read

func (*UnimplementedSpannerBenchWrapperServer) Update

type UpdateQuery

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

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

func (*UpdateQuery) GetQueries

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

func (*UpdateQuery) ProtoMessage

func (*UpdateQuery) ProtoMessage()

func (*UpdateQuery) Reset

func (m *UpdateQuery) Reset()

func (*UpdateQuery) String

func (m *UpdateQuery) String() string

func (*UpdateQuery) XXX_DiscardUnknown

func (m *UpdateQuery) XXX_DiscardUnknown()

func (*UpdateQuery) XXX_Marshal

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

func (*UpdateQuery) XXX_Merge

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

func (*UpdateQuery) XXX_Size

func (m *UpdateQuery) XXX_Size() int

func (*UpdateQuery) XXX_Unmarshal

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

type User

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

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

func (*User) GetAge

func (m *User) GetAge() int64

func (*User) GetName

func (m *User) GetName() string

func (*User) ProtoMessage

func (*User) ProtoMessage()

func (*User) Reset

func (m *User) Reset()

func (*User) String

func (m *User) String() string

func (*User) XXX_DiscardUnknown

func (m *User) XXX_DiscardUnknown()

func (*User) XXX_Marshal

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

func (*User) XXX_Merge

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

func (*User) XXX_Size

func (m *User) XXX_Size() int

func (*User) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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