benchmark

package

Go to main page

Versions in this module

v0

v0.11.0

Jan 4, 2026

Changes in this version

+ func Multicast(ctx *gorums.ConfigContext, in *TimedMsg, opts ...gorums.CallOption) error

+ func QuorumCall(ctx *gorums.ConfigContext, in *Echo, opts ...gorums.CallOption) *gorums.Responses[*Echo]

+ func SlowServer(ctx *gorums.ConfigContext, in *Echo, opts ...gorums.CallOption) *gorums.Responses[*Echo]

+ func StartBenchmark(ctx *gorums.ConfigContext, in *StartRequest, opts ...gorums.CallOption) *gorums.Responses[*StartResponse]

+ func StartServerBenchmark(ctx *gorums.ConfigContext, in *StartRequest, opts ...gorums.CallOption) *gorums.Responses[*StartResponse]

+ func StopBenchmark(ctx *gorums.ConfigContext, in *StopRequest, opts ...gorums.CallOption) *gorums.Responses[*MemoryStat]

+ func StopServerBenchmark(ctx *gorums.ConfigContext, in *StopRequest, opts ...gorums.CallOption) *gorums.Responses[*Result]

+ type AsyncMemoryStat = *gorums.Async[*MemoryStat]

+ type AsyncResult = *gorums.Async[*Result]

+ type AsyncStartResponse = *gorums.Async[*StartResponse]

type Configuration

+ func NewConfiguration(mgr *Manager, opt gorums.NodeListOption) (Configuration, error)

+ type CorrectableEcho = *gorums.Correctable[*Echo]

+ type CorrectableMemoryStat = *gorums.Correctable[*MemoryStat]

+ type CorrectableResult = *gorums.Correctable[*Result]

+ type CorrectableStartResponse = *gorums.Correctable[*StartResponse]

type Result

+ func StopServerBenchmarkQF(replies map[uint32]*Result) (*Result, error)

v0.10.0

Nov 14, 2025

v0.9.0

Apr 7, 2025

v0.8.1

Mar 5, 2025

v0.8.0

Mar 5, 2025

Changes in this version

type BenchmarkClient

+ AsyncQuorumCall func(ctx context.Context, in *Echo) *AsyncEcho

+ QuorumCall func(ctx context.Context, in *Echo) (resp *Echo, err error)

+ SlowServer func(ctx context.Context, in *Echo) (resp *Echo, err error)

type BenchmarkServer

+ AsyncQuorumCall func(ctx gorums.ServerCtx, request *Echo) (response *Echo, err error)

+ QuorumCall func(ctx gorums.ServerCtx, request *Echo) (response *Echo, err error)

+ SlowServer func(ctx gorums.ServerCtx, request *Echo) (response *Echo, err error)

type Echo

+ func (x *Echo) SetPayload(v []byte)

+ type Echo_builder struct

+ Payload []byte

+ func (b0 Echo_builder) Build() *Echo

type MemoryStat

+ func (x *MemoryStat) SetAllocs(v uint64)

+ func (x *MemoryStat) SetMemory(v uint64)

type MemoryStatList

+ func (x *MemoryStatList) SetMemoryStats(v []*MemoryStat)

+ type MemoryStatList_builder struct

+ MemoryStats []*MemoryStat

+ func (b0 MemoryStatList_builder) Build() *MemoryStatList

+ type MemoryStat_builder struct

+ Allocs uint64

+ Memory uint64

+ func (b0 MemoryStat_builder) Build() *MemoryStat

type Result

+ func (x *Result) SetAllocsPerOp(v uint64)

+ func (x *Result) SetLatencyAvg(v float64)

+ func (x *Result) SetLatencyVar(v float64)

+ func (x *Result) SetMemPerOp(v uint64)

+ func (x *Result) SetName(v string)

+ func (x *Result) SetServerStats(v []*MemoryStat)

+ func (x *Result) SetThroughput(v float64)

+ func (x *Result) SetTotalOps(v uint64)

+ func (x *Result) SetTotalTime(v int64)

+ type Result_builder struct

+ AllocsPerOp uint64

+ LatencyAvg float64

+ LatencyVar float64

+ MemPerOp uint64

+ Name string

+ ServerStats []*MemoryStat

+ Throughput float64

+ TotalOps uint64

+ TotalTime int64

+ func (b0 Result_builder) Build() *Result

+ type StartRequest_builder struct

+ func (b0 StartRequest_builder) Build() *StartRequest

+ type StartResponse_builder struct

+ func (b0 StartResponse_builder) Build() *StartResponse

+ type StopRequest_builder struct

+ func (b0 StopRequest_builder) Build() *StopRequest

type TimedMsg

+ func (x *TimedMsg) SetPayload(v []byte)

+ func (x *TimedMsg) SetSendTime(v int64)

+ type TimedMsg_builder struct

+ Payload []byte

+ SendTime int64

+ func (b0 TimedMsg_builder) Build() *TimedMsg

v0.7.0

Jan 6, 2022

Changes in this version

type Configuration

+ func ConfigurationFromRaw(rawCfg gorums.RawConfiguration, qspec QuorumSpec) *Configuration

v0.6.1

Dec 18, 2021

v0.6.0

Dec 13, 2021

v0.5.0

May 10, 2021

v0.4.0

Mar 27, 2021

Changes in this version

type Configuration

+ func (c Configuration) And(d *Configuration) gorums.NodeListOption

+ func (c Configuration) Except(rm *Configuration) gorums.NodeListOption

v0.3.0

Feb 26, 2021

Changes in this version

+ type AsyncEcho struct

+ func (f *AsyncEcho) Get() (*Echo, error)

type Benchmark

+ AsyncQuorumCall func(context.Context, *Echo, func(*Echo, error))

+ QuorumCall func(context.Context, *Echo, func(*Echo, error))

+ SlowServer func(context.Context, *Echo, func(*Echo, error))

type Configuration

+ func (c *Configuration) AsyncQuorumCall(ctx context.Context, in *Echo) *AsyncEcho

+ func (c *Configuration) QuorumCall(ctx context.Context, in *Echo) (resp *Echo, err error)

+ func (c *Configuration) SlowServer(ctx context.Context, in *Echo) (resp *Echo, err error)

type QSpec

+ func (qspec *QSpec) AsyncQuorumCallQF(_ *Echo, replies map[uint32]*Echo) (*Echo, bool)

+ func (qspec *QSpec) QuorumCallQF(_ *Echo, replies map[uint32]*Echo) (*Echo, bool)

+ func (qspec *QSpec) SlowServerQF(_ *Echo, replies map[uint32]*Echo) (*Echo, bool)

type QuorumSpec

+ AsyncQuorumCallQF func(in *Echo, replies map[uint32]*Echo) (*Echo, bool)

+ QuorumCallQF func(in *Echo, replies map[uint32]*Echo) (*Echo, bool)

+ SlowServerQF func(in *Echo, replies map[uint32]*Echo) (*Echo, bool)

type Server

+ func NewBenchServer(opts ...gorums.ServerOption) *Server

v0.2.2

Jul 20, 2020

v0.2.1

Jul 20, 2020

Changes in this version

type ManagerOption

+ func WithMetadata(md metadata.MD) ManagerOption

+ func WithNodeList(addrsList []string) ManagerOption

+ func WithNodeMap(idMap map[string]uint32) ManagerOption

+ func WithPerNodeMetadata(f func(uint32) metadata.MD) ManagerOption

v0.2.0

Jun 29, 2020

Changes in this version

+ const LevelNotSet

+ var Error = func(n1, n2 *Node) bool

+ var File_benchmark_benchmark_proto protoreflect.FileDescriptor

+ var ID = func(n1, n2 *Node) bool

+ var Latency = func(n1, n2 *Node) bool

+ var Port = func(n1, n2 *Node) bool

+ func Equal(a, b *Configuration) bool

+ func ManagerCreationError(err error) error

+ func RegisterBenchmarkServer(s *grpc.Server, srv BenchmarkServer)

+ func StartLocalServers(ctx context.Context, n int, opts ...ServerOption) []string

+ type Bench struct

+ Description string

+ Name string

+ func GetBenchmarks(cfg *Configuration) []Bench

+ type Benchmark interface

+ ConcurrentAsync func(*Echo) *Echo

+ ConcurrentMulticast func(*TimedMsg)

+ ConcurrentQC func(*Echo) *Echo

+ ConcurrentSlowServer func(*Echo) *Echo

+ Multicast func(*TimedMsg)

+ OrderedAsync func(*Echo) *Echo

+ OrderedQC func(*Echo) *Echo

+ OrderedSlowServer func(*Echo) *Echo

+ StartBenchmark func(*StartRequest) *StartResponse

+ StartServerBenchmark func(*StartRequest) *StartResponse

+ StopBenchmark func(*StopRequest) *MemoryStat

+ StopServerBenchmark func(*StopRequest) *Result

+ type BenchmarkClient interface

+ ConcurrentAsync func(ctx context.Context, in *Echo, opts ...grpc.CallOption) (*Echo, error)

+ ConcurrentMulticast func(ctx context.Context, in *TimedMsg, opts ...grpc.CallOption) (*empty.Empty, error)

+ ConcurrentQC func(ctx context.Context, in *Echo, opts ...grpc.CallOption) (*Echo, error)

+ ConcurrentSlowServer func(ctx context.Context, in *Echo, opts ...grpc.CallOption) (*Echo, error)

+ Multicast func(ctx context.Context, in *TimedMsg, opts ...grpc.CallOption) (*empty.Empty, error)

+ OrderedAsync func(ctx context.Context, in *Echo, opts ...grpc.CallOption) (*Echo, error)

+ OrderedQC func(ctx context.Context, in *Echo, opts ...grpc.CallOption) (*Echo, error)

+ OrderedSlowServer func(ctx context.Context, in *Echo, opts ...grpc.CallOption) (*Echo, error)

+ StartBenchmark func(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)

+ StartServerBenchmark func(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)

+ StopBenchmark func(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*MemoryStat, error)

+ StopServerBenchmark func(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*Result, error)

+ UnorderedAsync func(ctx context.Context, in *Echo, opts ...grpc.CallOption) (*Echo, error)

+ UnorderedQC func(ctx context.Context, in *Echo, opts ...grpc.CallOption) (*Echo, error)

+ UnorderedSlowServer func(ctx context.Context, in *Echo, opts ...grpc.CallOption) (*Echo, error)

+ func NewBenchmarkClient(cc grpc.ClientConnInterface) BenchmarkClient

+ type BenchmarkServer interface

+ ConcurrentAsync func(context.Context, *Echo) (*Echo, error)

+ ConcurrentMulticast func(context.Context, *TimedMsg) (*empty.Empty, error)

+ ConcurrentQC func(context.Context, *Echo) (*Echo, error)

+ ConcurrentSlowServer func(context.Context, *Echo) (*Echo, error)

+ Multicast func(context.Context, *TimedMsg) (*empty.Empty, error)

+ OrderedAsync func(context.Context, *Echo) (*Echo, error)

+ OrderedQC func(context.Context, *Echo) (*Echo, error)

+ OrderedSlowServer func(context.Context, *Echo) (*Echo, error)

+ StartBenchmark func(context.Context, *StartRequest) (*StartResponse, error)

+ StartServerBenchmark func(context.Context, *StartRequest) (*StartResponse, error)

+ StopBenchmark func(context.Context, *StopRequest) (*MemoryStat, error)

+ StopServerBenchmark func(context.Context, *StopRequest) (*Result, error)

+ UnorderedAsync func(context.Context, *Echo) (*Echo, error)

+ UnorderedQC func(context.Context, *Echo) (*Echo, error)

+ UnorderedSlowServer func(context.Context, *Echo) (*Echo, error)

+ type ConfigNotFoundError uint32

+ func (e ConfigNotFoundError) Error() string

+ type Configuration struct

+ func NewConfig(addrs []string, qspec QuorumSpec, opts ...ManagerOption) (*Configuration, func(), error)

+ func (c *Configuration) ConcurrentAsync(ctx context.Context, in *Echo) *FutureEcho

+ func (c *Configuration) ConcurrentMulticast(in *TimedMsg) error

+ func (c *Configuration) ConcurrentQC(ctx context.Context, in *Echo) (resp *Echo, err error)

+ func (c *Configuration) ConcurrentSlowServer(ctx context.Context, in *Echo) (resp *Echo, err error)

+ func (c *Configuration) ID() uint32

+ func (c *Configuration) Multicast(in *TimedMsg) error

+ func (c *Configuration) NodeIDs() []uint32

+ func (c *Configuration) Nodes() []*Node

+ func (c *Configuration) OrderedAsync(ctx context.Context, in *Echo) *FutureEcho

+ func (c *Configuration) OrderedQC(ctx context.Context, in *Echo) (resp *Echo, err error)

+ func (c *Configuration) OrderedSlowServer(ctx context.Context, in *Echo) (resp *Echo, err error)

+ func (c *Configuration) Size() int

+ func (c *Configuration) StartBenchmark(ctx context.Context, in *StartRequest) (resp *StartResponse, err error)

+ func (c *Configuration) StartServerBenchmark(ctx context.Context, in *StartRequest) (resp *StartResponse, err error)

+ func (c *Configuration) StopBenchmark(ctx context.Context, in *StopRequest) (resp *MemoryStatList, err error)

+ func (c *Configuration) StopServerBenchmark(ctx context.Context, in *StopRequest) (resp *Result, err error)

+ func (c *Configuration) String() string

+ func (c *Configuration) SubError() <-chan GRPCError

+ func (c *Configuration) UnorderedAsync(ctx context.Context, in *Echo, opts ...grpc.CallOption) *FutureEcho

+ func (c *Configuration) UnorderedQC(ctx context.Context, in *Echo, opts ...grpc.CallOption) (resp *Echo, err error)

+ func (c *Configuration) UnorderedSlowServer(ctx context.Context, in *Echo, opts ...grpc.CallOption) (resp *Echo, err error)

+ type Echo struct

+ Payload []byte

+ func (*Echo) Descriptor() ([]byte, []int)

+ func (*Echo) ProtoMessage()

+ func (x *Echo) GetPayload() []byte

+ func (x *Echo) ProtoReflect() protoreflect.Message

+ func (x *Echo) Reset()

+ func (x *Echo) String() string

+ type FutureEcho struct

+ NodeIDs []uint32

+ func (f *FutureEcho) Done() bool

+ func (f *FutureEcho) Get() (*Echo, error)

+ type GRPCError struct

+ Cause error

+ NodeID uint32

+ func (e GRPCError) Error() string

+ type GorumsServer struct

+ func NewGorumsServer(opts ...ServerOption) *GorumsServer

+ func (s *GorumsServer) GracefulStop()

+ func (s *GorumsServer) RegisterBenchmarkServer(srv Benchmark)

+ func (s *GorumsServer) Serve(listener net.Listener) error

+ func (s *GorumsServer) Stop()

+ type IllegalConfigError string

+ func (e IllegalConfigError) Error() string

+ type Manager struct

+ func NewManager(nodeAddrs []string, opts ...ManagerOption) (*Manager, error)

+ func (m *Manager) AddNode(addr string) error

+ func (m *Manager) Close()

+ func (m *Manager) Configuration(id uint32) (config *Configuration, found bool)

+ func (m *Manager) ConfigurationIDs() []uint32

+ func (m *Manager) Configurations() []*Configuration

+ func (m *Manager) NewConfiguration(ids []uint32, qspec QuorumSpec) (*Configuration, error)

+ func (m *Manager) Node(id uint32) (node *Node, found bool)

+ func (m *Manager) NodeIDs() []uint32

+ func (m *Manager) Nodes() []*Node

+ func (m *Manager) Size() (nodes, configs int)

+ type ManagerOption func(*managerOptions)

+ func WithBackoff(backoff backoff.Config) ManagerOption

+ func WithDialTimeout(timeout time.Duration) ManagerOption

+ func WithGrpcDialOptions(opts ...grpc.DialOption) ManagerOption

+ func WithLogger(logger *log.Logger) ManagerOption

+ func WithNoConnect() ManagerOption

+ func WithSendBufferSize(size uint) ManagerOption

+ func WithTracing() ManagerOption

+ type MemoryStat struct

+ Allocs uint64

+ Memory uint64

+ func (*MemoryStat) Descriptor() ([]byte, []int)

+ func (*MemoryStat) ProtoMessage()

+ func (x *MemoryStat) GetAllocs() uint64

+ func (x *MemoryStat) GetMemory() uint64

+ func (x *MemoryStat) ProtoReflect() protoreflect.Message

+ func (x *MemoryStat) Reset()

+ func (x *MemoryStat) String() string

+ type MemoryStatList struct

+ MemoryStats []*MemoryStat

+ func (*MemoryStatList) Descriptor() ([]byte, []int)

+ func (*MemoryStatList) ProtoMessage()

+ func (x *MemoryStatList) GetMemoryStats() []*MemoryStat

+ func (x *MemoryStatList) ProtoReflect() protoreflect.Message

+ func (x *MemoryStatList) Reset()

+ func (x *MemoryStatList) String() string

+ type MultiSorter struct

+ func OrderedBy(less ...lessFunc) *MultiSorter

+ func (ms *MultiSorter) Len() int

+ func (ms *MultiSorter) Less(i, j int) bool

+ func (ms *MultiSorter) Sort(nodes []*Node)

+ func (ms *MultiSorter) Swap(i, j int)

+ type Node struct

+ func (n *Node) Address() string

+ func (n *Node) FullString() string

+ func (n *Node) ID() uint32

+ func (n *Node) LastErr() error

+ func (n *Node) Latency() time.Duration

+ func (n *Node) Port() string

+ func (n *Node) String() string

+ func (n *Node) UnorderedAsync(ctx context.Context, in *Echo, replyChan chan<- internalEcho)

+ func (n *Node) UnorderedQC(ctx context.Context, in *Echo, replyChan chan<- internalEcho)

+ func (n *Node) UnorderedSlowServer(ctx context.Context, in *Echo, replyChan chan<- internalEcho)

+ type NodeNotFoundError uint32

+ func (e NodeNotFoundError) Error() string

+ type Options struct

+ Concurrent int

+ Duration time.Duration

+ MaxAsync int

+ NumNodes int

+ Payload int

+ QuorumSize int

+ Remote bool

+ Warmup time.Duration

+ type QSpec struct

+ CfgSize int

+ QSize int

+ func (qspec *QSpec) ConcurrentAsyncQF(_ *Echo, replies []*Echo) (*Echo, bool)

+ func (qspec *QSpec) ConcurrentQCQF(_ *Echo, replies []*Echo) (*Echo, bool)

+ func (qspec *QSpec) ConcurrentSlowServerQF(_ *Echo, replies []*Echo) (*Echo, bool)

+ func (qspec *QSpec) OrderedAsyncQF(_ *Echo, replies []*Echo) (*Echo, bool)

+ func (qspec *QSpec) OrderedQCQF(_ *Echo, replies []*Echo) (*Echo, bool)

+ func (qspec *QSpec) OrderedSlowServerQF(_ *Echo, replies []*Echo) (*Echo, bool)

+ func (qspec *QSpec) StartBenchmarkQF(_ *StartRequest, replies []*StartResponse) (*StartResponse, bool)

+ func (qspec *QSpec) StartServerBenchmarkQF(_ *StartRequest, replies []*StartResponse) (*StartResponse, bool)

+ func (qspec *QSpec) StopBenchmarkQF(_ *StopRequest, replies []*MemoryStat) (*MemoryStatList, bool)

+ func (qspec *QSpec) StopServerBenchmarkQF(_ *StopRequest, replies []*Result) (*Result, bool)

+ func (qspec *QSpec) UnorderedAsyncQF(_ *Echo, replies []*Echo) (*Echo, bool)

+ func (qspec *QSpec) UnorderedQCQF(_ *Echo, replies []*Echo) (*Echo, bool)

+ func (qspec *QSpec) UnorderedSlowServerQF(_ *Echo, replies []*Echo) (*Echo, bool)

+ type QuorumCallError struct

+ Errors []GRPCError

+ Reason string

+ ReplyCount int

+ func (e QuorumCallError) Error() string

+ type QuorumSpec interface

+ ConcurrentAsyncQF func(in *Echo, replies []*Echo) (*Echo, bool)

+ ConcurrentQCQF func(in *Echo, replies []*Echo) (*Echo, bool)

+ ConcurrentSlowServerQF func(in *Echo, replies []*Echo) (*Echo, bool)

+ OrderedAsyncQF func(in *Echo, replies []*Echo) (*Echo, bool)

+ OrderedQCQF func(in *Echo, replies []*Echo) (*Echo, bool)

+ OrderedSlowServerQF func(in *Echo, replies []*Echo) (*Echo, bool)

+ StartBenchmarkQF func(in *StartRequest, replies []*StartResponse) (*StartResponse, bool)

+ StartServerBenchmarkQF func(in *StartRequest, replies []*StartResponse) (*StartResponse, bool)

+ StopBenchmarkQF func(in *StopRequest, replies []*MemoryStat) (*MemoryStatList, bool)

+ StopServerBenchmarkQF func(in *StopRequest, replies []*Result) (*Result, bool)

+ UnorderedAsyncQF func(in *Echo, replies []*Echo) (*Echo, bool)

+ UnorderedQCQF func(in *Echo, replies []*Echo) (*Echo, bool)

+ UnorderedSlowServerQF func(in *Echo, replies []*Echo) (*Echo, bool)

+ type Result struct

+ AllocsPerOp uint64

+ LatencyAvg float64

+ LatencyVar float64

+ MemPerOp uint64

+ Name string

+ ServerStats []*MemoryStat

+ Throughput float64

+ TotalOps uint64

+ TotalTime int64

+ func RunBenchmarks(benchRegex *regexp.Regexp, options Options, manager *Manager) ([]*Result, error)

+ func (*Result) Descriptor() ([]byte, []int)

+ func (*Result) ProtoMessage()

+ func (r *Result) Format() string

+ func (x *Result) GetAllocsPerOp() uint64

+ func (x *Result) GetLatencyAvg() float64

+ func (x *Result) GetLatencyVar() float64

+ func (x *Result) GetMemPerOp() uint64

+ func (x *Result) GetName() string

+ func (x *Result) GetServerStats() []*MemoryStat

+ func (x *Result) GetThroughput() float64

+ func (x *Result) GetTotalOps() uint64

+ func (x *Result) GetTotalTime() int64

+ func (x *Result) ProtoReflect() protoreflect.Message

+ func (x *Result) Reset()

+ func (x *Result) String() string

+ type Server struct

+ func NewServer(opts ...ServerOption) *Server

+ type ServerOption func(*serverOptions)

+ func WithGRPCServerOptions(opts ...grpc.ServerOption) ServerOption

+ func WithServerBufferSize(size uint) ServerOption

+ type StartRequest struct

+ func (*StartRequest) Descriptor() ([]byte, []int)

+ func (*StartRequest) ProtoMessage()

+ func (x *StartRequest) ProtoReflect() protoreflect.Message

+ func (x *StartRequest) Reset()

+ func (x *StartRequest) String() string

+ type StartResponse struct

+ func (*StartResponse) Descriptor() ([]byte, []int)

+ func (*StartResponse) ProtoMessage()

+ func (x *StartResponse) ProtoReflect() protoreflect.Message

+ func (x *StartResponse) Reset()

+ func (x *StartResponse) String() string

+ type Stats struct

+ func (s *Stats) AddLatency(l time.Duration)

+ func (s *Stats) Clear()

+ func (s *Stats) End()

+ func (s *Stats) GetResult() *Result

+ func (s *Stats) Start()

+ type StopRequest struct

+ func (*StopRequest) Descriptor() ([]byte, []int)

+ func (*StopRequest) ProtoMessage()

+ func (x *StopRequest) ProtoReflect() protoreflect.Message

+ func (x *StopRequest) Reset()

+ func (x *StopRequest) String() string

+ type TimedMsg struct

+ Payload []byte

+ SendTime int64

+ func (*TimedMsg) Descriptor() ([]byte, []int)

+ func (*TimedMsg) ProtoMessage()

+ func (x *TimedMsg) GetPayload() []byte

+ func (x *TimedMsg) GetSendTime() int64

+ func (x *TimedMsg) ProtoReflect() protoreflect.Message

+ func (x *TimedMsg) Reset()

+ func (x *TimedMsg) String() string

+ type UnimplementedBenchmarkServer struct

+ func (*UnimplementedBenchmarkServer) ConcurrentAsync(context.Context, *Echo) (*Echo, error)

+ func (*UnimplementedBenchmarkServer) ConcurrentMulticast(context.Context, *TimedMsg) (*empty.Empty, error)

+ func (*UnimplementedBenchmarkServer) ConcurrentQC(context.Context, *Echo) (*Echo, error)

+ func (*UnimplementedBenchmarkServer) ConcurrentSlowServer(context.Context, *Echo) (*Echo, error)

+ func (*UnimplementedBenchmarkServer) Multicast(context.Context, *TimedMsg) (*empty.Empty, error)

+ func (*UnimplementedBenchmarkServer) OrderedAsync(context.Context, *Echo) (*Echo, error)

+ func (*UnimplementedBenchmarkServer) OrderedQC(context.Context, *Echo) (*Echo, error)

+ func (*UnimplementedBenchmarkServer) OrderedSlowServer(context.Context, *Echo) (*Echo, error)

+ func (*UnimplementedBenchmarkServer) StartBenchmark(context.Context, *StartRequest) (*StartResponse, error)

+ func (*UnimplementedBenchmarkServer) StartServerBenchmark(context.Context, *StartRequest) (*StartResponse, error)

+ func (*UnimplementedBenchmarkServer) StopBenchmark(context.Context, *StopRequest) (*MemoryStat, error)

+ func (*UnimplementedBenchmarkServer) StopServerBenchmark(context.Context, *StopRequest) (*Result, error)

+ func (*UnimplementedBenchmarkServer) UnorderedAsync(context.Context, *Echo) (*Echo, error)

+ func (*UnimplementedBenchmarkServer) UnorderedQC(context.Context, *Echo) (*Echo, error)

+ func (*UnimplementedBenchmarkServer) UnorderedSlowServer(context.Context, *Echo) (*Echo, error)

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