storage_bench

package
v1.24.0 Latest Latest
Warning

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

Go to latest
Published: Jul 20, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

README

Regenerating protos

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterStorageBenchWrapperServer

func RegisterStorageBenchWrapperServer(s *grpc.Server, srv StorageBenchWrapperServer)

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 ObjectRead

type ObjectRead struct {
	// The bucket string identifier.
	BucketName string `protobuf:"bytes,1,opt,name=bucketName,proto3" json:"bucketName,omitempty"`
	// The object/blob string identifier.
	ObjectName           string   `protobuf:"bytes,2,opt,name=objectName,proto3" json:"objectName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ObjectRead) Descriptor

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

func (*ObjectRead) GetBucketName

func (m *ObjectRead) GetBucketName() string

func (*ObjectRead) GetObjectName

func (m *ObjectRead) GetObjectName() string

func (*ObjectRead) ProtoMessage

func (*ObjectRead) ProtoMessage()

func (*ObjectRead) Reset

func (m *ObjectRead) Reset()

func (*ObjectRead) String

func (m *ObjectRead) String() string

func (*ObjectRead) XXX_DiscardUnknown

func (m *ObjectRead) XXX_DiscardUnknown()

func (*ObjectRead) XXX_Marshal

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

func (*ObjectRead) XXX_Merge

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

func (*ObjectRead) XXX_Size

func (m *ObjectRead) XXX_Size() int

func (*ObjectRead) XXX_Unmarshal

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

type ObjectWrite

type ObjectWrite struct {
	// The bucket string identifier.
	BucketName string `protobuf:"bytes,1,opt,name=bucketName,proto3" json:"bucketName,omitempty"`
	// The object/blob string identifiers.
	ObjectName string `protobuf:"bytes,2,opt,name=objectName,proto3" json:"objectName,omitempty"`
	// The string containing the destination path.
	Destination          string   `protobuf:"bytes,3,opt,name=destination,proto3" json:"destination,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ObjectWrite) Descriptor

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

func (*ObjectWrite) GetBucketName

func (m *ObjectWrite) GetBucketName() string

func (*ObjectWrite) GetDestination

func (m *ObjectWrite) GetDestination() string

func (*ObjectWrite) GetObjectName

func (m *ObjectWrite) GetObjectName() string

func (*ObjectWrite) ProtoMessage

func (*ObjectWrite) ProtoMessage()

func (*ObjectWrite) Reset

func (m *ObjectWrite) Reset()

func (*ObjectWrite) String

func (m *ObjectWrite) String() string

func (*ObjectWrite) XXX_DiscardUnknown

func (m *ObjectWrite) XXX_DiscardUnknown()

func (*ObjectWrite) XXX_Marshal

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

func (*ObjectWrite) XXX_Merge

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

func (*ObjectWrite) XXX_Size

func (m *ObjectWrite) XXX_Size() int

func (*ObjectWrite) XXX_Unmarshal

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

type StorageBenchWrapperClient

type StorageBenchWrapperClient interface {
	// Performs an upload from a specific object.
	Write(ctx context.Context, in *ObjectWrite, opts ...grpc.CallOption) (*EmptyResponse, error)
	// Read a specific object.
	Read(ctx context.Context, in *ObjectRead, opts ...grpc.CallOption) (*EmptyResponse, error)
}

StorageBenchWrapperClient is the client API for StorageBenchWrapper service.

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

func NewStorageBenchWrapperClient

func NewStorageBenchWrapperClient(cc *grpc.ClientConn) StorageBenchWrapperClient

type StorageBenchWrapperServer

type StorageBenchWrapperServer interface {
	// Performs an upload from a specific object.
	Write(context.Context, *ObjectWrite) (*EmptyResponse, error)
	// Read a specific object.
	Read(context.Context, *ObjectRead) (*EmptyResponse, error)
}

StorageBenchWrapperServer is the server API for StorageBenchWrapper service.

Jump to

Keyboard shortcuts

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