package storage_bench

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

Index ¶

• func RegisterStorageBenchWrapperServer(s *grpc.Server, srv StorageBenchWrapperServer)
• type EmptyResponse
• func (*EmptyResponse) Descriptor() ([]byte, []int)
• func (*EmptyResponse) ProtoMessage()
• func (m *EmptyResponse) Reset()
• func (m *EmptyResponse) String() string
• func (m *EmptyResponse) XXX_DiscardUnknown()
• func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
• func (m *EmptyResponse) XXX_Merge(src proto.Message)
• func (m *EmptyResponse) XXX_Size() int
• func (m *EmptyResponse) XXX_Unmarshal(b []byte) error
• type ObjectRead
• func (*ObjectRead) Descriptor() ([]byte, []int)
• func (m *ObjectRead) GetBucketName() string
• func (m *ObjectRead) GetObjectName() string
• func (*ObjectRead) ProtoMessage()
• func (m *ObjectRead) Reset()
• func (m *ObjectRead) String() string
• func (m *ObjectRead) XXX_DiscardUnknown()
• func (m *ObjectRead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
• func (m *ObjectRead) XXX_Merge(src proto.Message)
• func (m *ObjectRead) XXX_Size() int
• func (m *ObjectRead) XXX_Unmarshal(b []byte) error
• type ObjectWrite
• func (*ObjectWrite) Descriptor() ([]byte, []int)
• func (m *ObjectWrite) GetBucketName() string
• func (m *ObjectWrite) GetDestination() string
• func (m *ObjectWrite) GetObjectName() string
• func (*ObjectWrite) ProtoMessage()
• func (m *ObjectWrite) Reset()
• func (m *ObjectWrite) String() string
• func (m *ObjectWrite) XXX_DiscardUnknown()
• func (m *ObjectWrite) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
• func (m *ObjectWrite) XXX_Merge(src proto.Message)
• func (m *ObjectWrite) XXX_Size() int
• func (m *ObjectWrite) XXX_Unmarshal(b []byte) error
• type StorageBenchWrapperClient
• func NewStorageBenchWrapperClient(cc *grpc.ClientConn) StorageBenchWrapperClient
• type StorageBenchWrapperServer

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.

Source Files ¶

storage.pb.go