benchmarkv1

Documentation

Overview

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Index

• Constants
• Variables
• func RegisterMsgServer(s grpc.ServiceRegistrar, srv MsgServer)
• type MsgClient
  • func NewMsgClient(cc grpc.ClientConnInterface) MsgClient
• type MsgLoadTest
  • func (*MsgLoadTest) Descriptor() ([]byte, []int)
  • func (x *MsgLoadTest) GetCaller() []byte
  • func (x *MsgLoadTest) GetOps() []*Op
  • func (*MsgLoadTest) ProtoMessage()
  • func (x *MsgLoadTest) ProtoReflect() protoreflect.Message
  • func (x *MsgLoadTest) Reset()
  • func (x *MsgLoadTest) String() string
• type MsgLoadTestResponse
  • func (*MsgLoadTestResponse) Descriptor() ([]byte, []int)
  • func (x *MsgLoadTestResponse) GetTotalErrors() uint64
  • func (x *MsgLoadTestResponse) GetTotalTime() uint64
  • func (*MsgLoadTestResponse) ProtoMessage()
  • func (x *MsgLoadTestResponse) ProtoReflect() protoreflect.Message
  • func (x *MsgLoadTestResponse) Reset()
  • func (x *MsgLoadTestResponse) String() string
• type MsgServer
• type Op
  • func (*Op) Descriptor() ([]byte, []int)
  • func (x *Op) GetActor() string
  • func (x *Op) GetDelete() bool
  • func (x *Op) GetExists() bool
  • func (x *Op) GetIterations() uint32
  • func (x *Op) GetKeyLength() uint64
  • func (x *Op) GetSeed() uint64
  • func (x *Op) GetValueLength() uint64
  • func (*Op) ProtoMessage()
  • func (x *Op) ProtoReflect() protoreflect.Message
  • func (x *Op) Reset()
  • func (x *Op) String() string
• type UnimplementedMsgServer
  • func (UnimplementedMsgServer) LoadTest(context.Context, *MsgLoadTest) (*MsgLoadTestResponse, error)
• type UnsafeMsgServer

Constants

const (
	Msg_LoadTest_FullMethodName = "/cosmos.benchmark.v1.Msg/LoadTest"
)

Variables

var File_cosmos_benchmark_v1_benchmark_proto protoreflect.FileDescriptor

var File_cosmos_benchmark_v1_tx_proto protoreflect.FileDescriptor

var Msg_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cosmos.benchmark.v1.Msg",
	HandlerType: (*MsgServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LoadTest",
			Handler:    _Msg_LoadTest_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cosmos/benchmark/v1/tx.proto",
}

Msg_ServiceDesc is the grpc.ServiceDesc for Msg service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMsgServer

func RegisterMsgServer(s grpc.ServiceRegistrar, srv MsgServer)

Types

type MsgClient

type MsgClient interface {
	// LoadTest defines a method for executing a sequence of load test operations.
	LoadTest(ctx context.Context, in *MsgLoadTest, opts ...grpc.CallOption) (*MsgLoadTestResponse, error)
}

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

Msg defines the benchmark Msg service.

func NewMsgClient

func NewMsgClient(cc grpc.ClientConnInterface) MsgClient

type MsgLoadTest

type MsgLoadTest struct {
	Caller []byte `protobuf:"bytes,1,opt,name=caller,proto3" json:"caller,omitempty"`
	Ops    []*Op  `protobuf:"bytes,2,rep,name=ops,proto3" json:"ops,omitempty"`
	// contains filtered or unexported fields
}

MsgLoadTestOps defines a message containing a sequence of load test operations.

func (*MsgLoadTest) Descriptor

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

Deprecated: Use MsgLoadTest.ProtoReflect.Descriptor instead.

func (*MsgLoadTest) GetCaller

func (x *MsgLoadTest) GetCaller() []byte

func (*MsgLoadTest) GetOps

func (x *MsgLoadTest) GetOps() []*Op

func (*MsgLoadTest) ProtoMessage

func (*MsgLoadTest) ProtoMessage()

func (*MsgLoadTest) ProtoReflect

func (x *MsgLoadTest) ProtoReflect() protoreflect.Message

func (*MsgLoadTest) Reset

func (x *MsgLoadTest) Reset()

func (*MsgLoadTest) String

func (x *MsgLoadTest) String() string

type MsgLoadTestResponse

type MsgLoadTestResponse struct {
	TotalTime   uint64 `protobuf:"varint,1,opt,name=total_time,json=totalTime,proto3" json:"total_time,omitempty"`
	TotalErrors uint64 `protobuf:"varint,2,opt,name=total_errors,json=totalErrors,proto3" json:"total_errors,omitempty"`
	// contains filtered or unexported fields
}

MsgLoadTestResponse defines a message containing the results of a load test operation.

func (*MsgLoadTestResponse) Descriptor

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

Deprecated: Use MsgLoadTestResponse.ProtoReflect.Descriptor instead.

func (*MsgLoadTestResponse) GetTotalErrors

func (x *MsgLoadTestResponse) GetTotalErrors() uint64

func (*MsgLoadTestResponse) GetTotalTime

func (x *MsgLoadTestResponse) GetTotalTime() uint64

func (*MsgLoadTestResponse) ProtoMessage

func (*MsgLoadTestResponse) ProtoMessage()

func (*MsgLoadTestResponse) ProtoReflect

func (x *MsgLoadTestResponse) ProtoReflect() protoreflect.Message

func (*MsgLoadTestResponse) Reset

func (x *MsgLoadTestResponse) Reset()

func (*MsgLoadTestResponse) String

func (x *MsgLoadTestResponse) String() string

type MsgServer

type MsgServer interface {
	// LoadTest defines a method for executing a sequence of load test operations.
	LoadTest(context.Context, *MsgLoadTest) (*MsgLoadTestResponse, error)
	// contains filtered or unexported methods
}

MsgServer is the server API for Msg service. All implementations must embed UnimplementedMsgServer for forward compatibility.

Msg defines the benchmark Msg service.

type Op

type Op struct {
	Seed        uint64 `protobuf:"varint,1,opt,name=seed,proto3" json:"seed,omitempty"`
	Actor       string `protobuf:"bytes,2,opt,name=actor,proto3" json:"actor,omitempty"`
	KeyLength   uint64 `protobuf:"varint,3,opt,name=key_length,json=keyLength,proto3" json:"key_length,omitempty"`
	ValueLength uint64 `protobuf:"varint,4,opt,name=value_length,json=valueLength,proto3" json:"value_length,omitempty"`
	Iterations  uint32 `protobuf:"varint,5,opt,name=iterations,proto3" json:"iterations,omitempty"`
	Delete      bool   `protobuf:"varint,6,opt,name=delete,proto3" json:"delete,omitempty"`
	Exists      bool   `protobuf:"varint,7,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

Op is a message describing a benchmark operation.

func (*Op) Descriptor

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

Deprecated: Use Op.ProtoReflect.Descriptor instead.

func (*Op) GetActor

func (x *Op) GetActor() string

func (*Op) GetDelete

func (x *Op) GetDelete() bool

func (*Op) GetExists

func (x *Op) GetExists() bool

func (*Op) GetIterations

func (x *Op) GetIterations() uint32

func (*Op) GetKeyLength

func (x *Op) GetKeyLength() uint64

func (*Op) GetSeed

func (x *Op) GetSeed() uint64

func (*Op) GetValueLength

func (x *Op) GetValueLength() uint64

func (*Op) ProtoMessage

func (*Op) ProtoMessage()

func (*Op) ProtoReflect

func (x *Op) ProtoReflect() protoreflect.Message

func (*Op) Reset

func (x *Op) Reset()

func (*Op) String

func (x *Op) String() string

type UnimplementedMsgServer

type UnimplementedMsgServer struct{}

UnimplementedMsgServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedMsgServer) LoadTest

func (UnimplementedMsgServer) LoadTest(context.Context, *MsgLoadTest) (*MsgLoadTestResponse, error)

type UnsafeMsgServer

type UnsafeMsgServer interface {
	// contains filtered or unexported methods
}

UnsafeMsgServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MsgServer will result in compilation errors.