Documentation
¶
Index ¶
- Constants
- 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
- 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
- func (bc *BroadcastClient) Close()
- func (BroadcastClient) Context() context.Context
- 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
- func (bc *DeliverClient) Close()
- func (DeliverClient) Context() context.Context
- 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)
Constants ¶
View Source
const (
Kilo = 1024
)
Variables ¶
This section is empty.
Functions ¶
func CreateChannel ¶
func CreateChannel(server *BenchmarkServer, channelProfile *genesisconfig.Profile) string
func Halt ¶
func Halt(server *BenchmarkServer)
func InitializeServerPool ¶
func InitializeServerPool(number int)
func OrdererExec ¶
func OrdererExec(f func(s *BenchmarkServer))
func OrdererExecWithArgs ¶
func OrdererExecWithArgs(f func(s *BenchmarkServer, i ...interface{}), i ...interface{})
func SeekAllBlocks ¶
func WaitForChannels ¶
func WaitForChannels(server *BenchmarkServer, channelIDs ...interface{})
func WaitForService ¶
func WaitForService(server *BenchmarkServer)
Types ¶
type BenchmarkServer ¶
type BenchmarkServer struct {
// contains filtered or unexported fields
}
func GetBenchmarkServer ¶
func GetBenchmarkServer() *BenchmarkServer
func GetBenchmarkServerPool ¶
func GetBenchmarkServerPool() []*BenchmarkServer
func (*BenchmarkServer) CreateBroadcastClient ¶
func (server *BenchmarkServer) CreateBroadcastClient() *BroadcastClient
func (*BenchmarkServer) CreateDeliverClient ¶
func (server *BenchmarkServer) CreateDeliverClient() *DeliverClient
func (*BenchmarkServer) Halt ¶
func (server *BenchmarkServer) Halt()
func (*BenchmarkServer) RegisterService ¶
func (server *BenchmarkServer) RegisterService(s ab.AtomicBroadcastServer)
func (*BenchmarkServer) Start ¶
func (server *BenchmarkServer) Start()
func (*BenchmarkServer) WaitForService ¶
func (server *BenchmarkServer) WaitForService()
type BroadcastClient ¶
type BroadcastClient struct {
grpc.ServerStream
// contains filtered or unexported fields
}
func (*BroadcastClient) Close ¶
func (bc *BroadcastClient) Close()
func (BroadcastClient) Context ¶
func (BroadcastClient) Context() context.Context
func (*BroadcastClient) Errors ¶
func (bc *BroadcastClient) Errors() <-chan error
func (*BroadcastClient) GetResponse ¶
func (bc *BroadcastClient) GetResponse() *ab.BroadcastResponse
func (*BroadcastClient) Send ¶
func (bc *BroadcastClient) Send(br *ab.BroadcastResponse) error
func (*BroadcastClient) SendRequest ¶
func (bc *BroadcastClient) SendRequest(request *cb.Envelope)
type DeliverClient ¶
type DeliverClient struct {
grpc.ServerStream
ResponseChan chan *ab.DeliverResponse
ResultChan chan error
// contains filtered or unexported fields
}
func (*DeliverClient) Close ¶
func (bc *DeliverClient) Close()
func (DeliverClient) Context ¶
func (DeliverClient) Context() context.Context
func (*DeliverClient) GetResponse ¶
func (bc *DeliverClient) GetResponse() *ab.DeliverResponse
func (*DeliverClient) Send ¶
func (bc *DeliverClient) Send(br *ab.DeliverResponse) error
func (*DeliverClient) SendRequest ¶
func (bc *DeliverClient) SendRequest(request *cb.Envelope)
Source Files
Click to show internal directories.
Click to hide internal directories.