spanner_bench

package
v1.23.0 Latest Latest
Warning

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

 Go to latest Published: Jul 8, 2021 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) Insert(ctx context.Context, req *InsertQuery) (*EmptyResponse, error)

func (*UnimplementedSpannerBenchWrapperServer) Read 

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

func (*UnimplementedSpannerBenchWrapperServer) Update 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.