performance

Mar 15, 2018

Changes in this version

+ const Kilo

+ func CreateChannel(server *BenchmarkServer, channelProfile *genesisconfig.Profile) string

+ func Halt(server *BenchmarkServer)

+ func InitializeServerPool(number int)

+ func MakeNormalTx(channelID string, size int) *cb.Envelope

+ func OrdererExec(f func(s *BenchmarkServer))

+ func OrdererExecWithArgs(f func(s *BenchmarkServer, i ...interface{}), i ...interface{})

+ func RandomID(num int) string

+ func SeekAllBlocks(c *DeliverClient, channelID string, number uint64) (status cb.Status, err error)

+ func WaitForChannels(server *BenchmarkServer, channelIDs ...interface{})

+ func WaitForService(server *BenchmarkServer)

+ type BenchmarkServer struct

+ func GetBenchmarkServer() *BenchmarkServer

+ func GetBenchmarkServerPool() []*BenchmarkServer

+ func (server *BenchmarkServer) CreateBroadcastClient() *BroadcastClient

+ func (server *BenchmarkServer) CreateDeliverClient() *DeliverClient

+ func (server *BenchmarkServer) Halt()

+ func (server *BenchmarkServer) RegisterService(s ab.AtomicBroadcastServer)

+ func (server *BenchmarkServer) Start()

+ func (server *BenchmarkServer) WaitForService()

+ type BroadcastClient struct

+ func (BroadcastClient) Context() context.Context

+ func (bc *BroadcastClient) Close()

+ func (bc *BroadcastClient) Errors() <-chan error

+ func (bc *BroadcastClient) GetResponse() *ab.BroadcastResponse

+ func (bc *BroadcastClient) Recv() (*cb.Envelope, error)

+ func (bc *BroadcastClient) Send(br *ab.BroadcastResponse) error

+ func (bc *BroadcastClient) SendRequest(request *cb.Envelope)

+ type DeliverClient struct

+ ResponseChan chan *ab.DeliverResponse

+ ResultChan chan error

+ func (DeliverClient) Context() context.Context

+ func (bc *DeliverClient) Close()

+ func (bc *DeliverClient) GetResponse() *ab.DeliverResponse

+ func (bc *DeliverClient) Recv() (*cb.Envelope, error)

+ func (bc *DeliverClient) Send(br *ab.DeliverResponse) error

+ func (bc *DeliverClient) SendRequest(request *cb.Envelope)