util

package

v0.0.0-...-95b87ed Latest Latest Go to latest Published: Sep 16, 2019 License: Apache-2.0 Imports: 28 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mcc-github/blockchain

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
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
type Logger
- func GetLogger(name string, peerID string) Logger
type MembershipStore
- func NewMembershipStore() *MembershipStore
- func (m *MembershipStore) MsgByID(pkiID common.PKIidType) *protoext.SignedGossipMessage
- func (m *MembershipStore) Put(pkiID common.PKIidType, msg *protoext.SignedGossipMessage)
- func (m *MembershipStore) Remove(pkiID common.PKIidType)
- func (m *MembershipStore) Size() int
- func (m *MembershipStore) ToSlice() []*protoext.SignedGossipMessage
type PrivateRWSet
- func (rws PrivateRWSet) Digest() string
type PrivateRWSetWithConfig
type PubSub
- func NewPubSub() *PubSub
- func (ps *PubSub) Publish(topic string, item interface{}) error
- func (ps *PubSub) Subscribe(topic string, ttl time.Duration) Subscription
type PvtDataCollections
- func (pvt *PvtDataCollections) Marshal() ([][]byte, error)
- func (pvt *PvtDataCollections) Unmarshal(data [][]byte) error
type Set
- 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

Constants ¶

View Source

const (
	ChannelLogger     = "gossip.channel"
	CommLogger        = "gossip.comm"
	DiscoveryLogger   = "gossip.discovery"
	ElectionLogger    = "gossip.election"
	GossipLogger      = "gossip.gossip"
	CommMockLogger    = "gossip.comm.mock"
	PullLogger        = "gossip.pull"
	ServiceLogger     = "gossip.service"
	StateLogger       = "gossip.state"
	PrivateDataLogger = "gossip.privdata"
)

Variables ¶

This section is empty.

Functions ¶

func BytesToStrings ¶

func BytesToStrings(bytes [][]byte) []string

func Contains ¶

func Contains(s string, a []string) bool

func CreateGRPCLayer ¶

func CreateGRPCLayer() (port int, gRPCServer *comm.GRPCServer, certs *common.TLSCertificates,
	secureDialOpts api.PeerSecureDialOpts, dialOpts []grpc.DialOption)

func GetDurationOrDefault ¶

func GetDurationOrDefault(key string, defVal time.Duration) time.Duration

func GetFloat64OrDefault ¶

func GetFloat64OrDefault(key string, defVal float64) float64

func GetIntOrDefault ¶

func GetIntOrDefault(key string, defVal int) int

func GetRandomIndices ¶

func GetRandomIndices(indiceCount, highestIndex int) []int

func IndexInSlice ¶

func IndexInSlice(array interface{}, o interface{}, equals Equals) int

func PrintStackTrace ¶

func PrintStackTrace()

func PrivateRWSets ¶

func PrivateRWSets(rwsets ...PrivateRWSet) [][]byte

func RandomInt ¶

func RandomInt(n int) int

func RandomUInt64 ¶

func RandomUInt64() uint64

func SetVal ¶

func SetVal(key string, val interface{})

func SetupTestLogging ¶

func SetupTestLogging()

func StringsToBytes ¶

func StringsToBytes(strings []string) [][]byte

Types ¶

type Equals ¶

type Equals func(a interface{}, b interface{}) bool

type Logger ¶

type Logger interface {
	Debug(args ...interface{})
	Debugf(format string, args ...interface{})
	Error(args ...interface{})
	Errorf(format string, args ...interface{})
	Fatal(args ...interface{})
	Fatalf(format string, args ...interface{})
	Info(args ...interface{})
	Infof(format string, args ...interface{})
	Panic(args ...interface{})
	Panicf(format string, args ...interface{})
	Warning(args ...interface{})
	Warningf(format string, args ...interface{})
	IsEnabledFor(l zapcore.Level) bool
}

func GetLogger ¶

func GetLogger(name string, peerID string) Logger

type MembershipStore ¶

type MembershipStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMembershipStore ¶

func NewMembershipStore() *MembershipStore

func (*MembershipStore) MsgByID ¶

func (m *MembershipStore) MsgByID(pkiID common.PKIidType) *protoext.SignedGossipMessage

func (*MembershipStore) Put ¶

func (m *MembershipStore) Put(pkiID common.PKIidType, msg *protoext.SignedGossipMessage)

func (*MembershipStore) Remove ¶

func (m *MembershipStore) Remove(pkiID common.PKIidType)

func (*MembershipStore) Size ¶

func (m *MembershipStore) Size() int

func (*MembershipStore) ToSlice ¶

func (m *MembershipStore) ToSlice() []*protoext.SignedGossipMessage

type PrivateRWSet ¶

type PrivateRWSet []byte

func (PrivateRWSet) Digest ¶

func (rws PrivateRWSet) Digest() string

type PrivateRWSetWithConfig ¶

type PrivateRWSetWithConfig struct {
	RWSet            []PrivateRWSet
	CollectionConfig *common.CollectionConfig
}

type PubSub ¶

type PubSub struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewPubSub ¶

func NewPubSub() *PubSub

func (*PubSub) Publish ¶

func (ps *PubSub) Publish(topic string, item interface{}) error

func (ps *PubSub) Subscribe(topic string, ttl time.Duration) Subscription

type PvtDataCollections ¶

type PvtDataCollections []*ledger.TxPvtData

func (*PvtDataCollections) Marshal ¶

func (pvt *PvtDataCollections) Marshal() ([][]byte, error)

func (*PvtDataCollections) Unmarshal ¶

func (pvt *PvtDataCollections) Unmarshal(data [][]byte) error

type Set ¶

type Set struct {
	// contains filtered or unexported fields
}

func NewSet ¶

func NewSet() *Set

func (*Set) Add ¶

func (s *Set) Add(item interface{})

func (*Set) Clear ¶

func (s *Set) Clear()

func (*Set) Exists ¶

func (s *Set) Exists(item interface{}) bool

func (*Set) Remove ¶

func (s *Set) Remove(item interface{})

func (*Set) Size ¶

func (s *Set) Size() int

func (*Set) ToArray ¶

func (s *Set) ToArray() []interface{}

type Subscription ¶

type Subscription interface {
	Listen() (interface{}, error)
}

Source Files ¶

View all Source files

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

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func BytesToStrings ¶

func Contains ¶

func CreateGRPCLayer ¶

func GetDurationOrDefault ¶

func GetFloat64OrDefault ¶

func GetIntOrDefault ¶

func GetRandomIndices ¶

func IndexInSlice ¶

func PrintStackTrace ¶

func PrivateRWSets ¶

func RandomInt ¶

func RandomUInt64 ¶

func SetVal ¶

func SetupTestLogging ¶

func StringsToBytes ¶

Types ¶

type Equals ¶

type Logger ¶

func GetLogger ¶

type MembershipStore ¶

func NewMembershipStore ¶

func (*MembershipStore) MsgByID ¶

func (*MembershipStore) Put ¶

func (*MembershipStore) Remove ¶

func (*MembershipStore) Size ¶

func (*MembershipStore) ToSlice ¶

type PrivateRWSet ¶

func (PrivateRWSet) Digest ¶

type PrivateRWSetWithConfig ¶

type PubSub ¶

func NewPubSub ¶

func (*PubSub) Publish ¶

func (*PubSub) Subscribe ¶

type PvtDataCollections ¶

func (*PvtDataCollections) Marshal ¶

func (*PvtDataCollections) Unmarshal ¶

type Set ¶

func NewSet ¶

func (*Set) Add ¶

func (*Set) Clear ¶

func (*Set) Exists ¶

func (*Set) Remove ¶

func (*Set) Size ¶

func (*Set) ToArray ¶

type Subscription ¶

Source Files ¶