Versions in this module Expand all Collapse all v1 v1.4.10 Dec 9, 2020 Changes in this version + const ChannelLogger + const CommLogger + const CommMockLogger + const DiscoveryLogger + const ElectionLogger + const GossipLogger + const PrivateDataLogger + const PullLogger + const ServiceLogger + const StateLogger + func BytesToStrings(bytes [][]byte) []string + func Contains(s string, a []string) bool + func CreateGRPCLayer() (port int, gRPCServer *comm.GRPCServer, certs *common.TLSCertificates, ...) + func GetDurationOrDefault(key string, defVal time.Duration) time.Duration + func GetFloat64OrDefault(key string, defVal float64) float64 + func GetIntOrDefault(key string, defVal int) int + func GetRandomIndices(indiceCount, highestIndex int) []int + func IndexInSlice(array interface{}, o interface{}, equals Equals) int + func PrintStackTrace() + func PrivateRWSets(rwsets ...PrivateRWSet) [][]byte + func RandomInt(n int) int + func RandomUInt64() uint64 + func SetVal(key string, val interface{}) + func SetupTestLogging() + func StringsToBytes(strings []string) [][]byte + type Equals func(a interface{}, b interface{}) bool + type Logger interface + Debug func(args ...interface{}) + Debugf func(format string, args ...interface{}) + Error func(args ...interface{}) + Errorf func(format string, args ...interface{}) + Fatal func(args ...interface{}) + Fatalf func(format string, args ...interface{}) + Info func(args ...interface{}) + Infof func(format string, args ...interface{}) + IsEnabledFor func(l zapcore.Level) bool + Panic func(args ...interface{}) + Panicf func(format string, args ...interface{}) + Warning func(args ...interface{}) + Warningf func(format string, args ...interface{}) + func GetLogger(name string, peerID string) Logger + type MembershipStore struct + func NewMembershipStore() *MembershipStore + func (m *MembershipStore) MsgByID(pkiID common.PKIidType) *proto.SignedGossipMessage + func (m *MembershipStore) Put(pkiID common.PKIidType, msg *proto.SignedGossipMessage) + func (m *MembershipStore) Remove(pkiID common.PKIidType) + func (m *MembershipStore) Size() int + func (m *MembershipStore) ToSlice() []*proto.SignedGossipMessage + type PrivateRWSet []byte + func (rws PrivateRWSet) Digest() string + type PrivateRWSetWithConfig struct + CollectionConfig *common.CollectionConfig + RWSet []PrivateRWSet + type PubSub struct + func NewPubSub() *PubSub + func (ps *PubSub) Publish(topic string, item interface{}) error + func (ps *PubSub) Subscribe(topic string, ttl time.Duration) Subscription + type PvtDataCollections []*ledger.TxPvtData + func (pvt *PvtDataCollections) Marshal() ([][]byte, error) + func (pvt *PvtDataCollections) Unmarshal(data [][]byte) error + type Set struct + func NewSet() *Set + func (s *Set) Add(item interface{}) + func (s *Set) Clear() + func (s *Set) Exists(item interface{}) bool + func (s *Set) Remove(item interface{}) + func (s *Set) Size() int + func (s *Set) ToArray() []interface{} + type Subscription interface + Listen func() (interface{}, error)
Go to main page