util

Documentation

Index

• Constants
• func Contains(s string, a []string) bool
• func GetDurationOrDefault(key string, defVal time.Duration) time.Duration
• func GetIntOrDefault(key string, defVal int) int
• func GetLogger(module string, peerID string) *logging.Logger
• 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 SetDuration(key string, val time.Duration)
• func SetupTestLogging()
• type Equals
• type MembershipStore
  • 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
  • func (rws PrivateRWSet) Digest() string
• 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

const (
	LoggingChannelModule   = "gossip/channel"
	LoggingCommModule      = "gossip/comm"
	LoggingDiscoveryModule = "gossip/discovery"
	LoggingElectionModule  = "gossip/election"
	LoggingGossipModule    = "gossip/gossip"
	LoggingMockModule      = "gossip/comm/mock"
	LoggingPullModule      = "gossip/pull"
	LoggingServiceModule   = "gossip/service"
	LoggingStateModule     = "gossip/state"
	LoggingPrivModule      = "gossip/privdata"
)

Module names for logger initialization.

Functions

func Contains

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

Contains returns whether a given slice a contains a string s

func GetDurationOrDefault

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

GetDurationOrDefault returns the Duration value from config if present otherwise default value

func GetIntOrDefault

func GetIntOrDefault(key string, defVal int) int

GetIntOrDefault returns the int value from config if present otherwise default value

func GetLogger

func GetLogger(module string, peerID string) *logging.Logger

GetLogger returns a logger for given gossip module and peerID

func GetRandomIndices

func GetRandomIndices(indiceCount, highestIndex int) []int

GetRandomIndices returns a slice of random indices from 0 to given highestIndex

func IndexInSlice

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

IndexInSlice returns the index of given object o in array

func PrintStackTrace

func PrintStackTrace()

PrintStackTrace prints to stdout all goroutines

func PrivateRWSets

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

PrivateRWSets creates an aggregated slice of RWSets

func RandomInt

func RandomInt(n int) int

RandomInt returns, as an int, a non-negative pseudo-random integer in [0,n) It panics if n <= 0

func RandomUInt64

func RandomUInt64() uint64

RandomUInt64 returns a random uint64

func SetDuration

func SetDuration(key string, val time.Duration)

SetDuration stores duration key value to viper

func SetupTestLogging

func SetupTestLogging()

SetupTestLogging sets the default log levels for gossip unit tests

Types

type Equals

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

Equals returns whether a and b are the same

type MembershipStore

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

MembershipStore struct which encapsulates membership message store abstraction

func NewMembershipStore

func NewMembershipStore() *MembershipStore

NewMembershipStore creates new membership store instance

func (*MembershipStore) MsgByID

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

MsgByID returns a message stored by a certain ID, or nil if such an ID isn't found

func (*MembershipStore) Put

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

Put associates msg with the given pkiID

func (*MembershipStore) Remove

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

Remove removes a message with a given pkiID

func (*MembershipStore) Size

func (m *MembershipStore) Size() int

Size of the membership store

func (*MembershipStore) ToSlice

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

ToSlice returns a slice backed by the elements of the MembershipStore

type PrivateRWSet

type PrivateRWSet []byte

PrivateRWSet contains the bytes of CollectionPvtReadWriteSet

func (PrivateRWSet) Digest

func (rws PrivateRWSet) Digest() string

Digest returns a deterministic and collision-free representation of the PrivateRWSet

type PubSub

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

PubSub defines a struct that one can use to: - publish items to a topic to multiple subscribers - and subscribe to items from a topic The subscriptions have a TTL and are cleaned when it passes.

func NewPubSub

func NewPubSub() *PubSub

NewPubSub creates a new PubSub with an empty set of subscriptions

func (*PubSub) Publish

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

Publish publishes an item to all subscribers on the topic

func (*PubSub) Subscribe

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

Subscribe returns a subscription to a topic that expires when given TTL passes

type PvtDataCollections

type PvtDataCollections []*ledger.TxPvtData

PvtDataCollections data type to encapsulate collections of private data

func (*PvtDataCollections) Marshal

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

Marshal encodes private collection into bytes array

func (*PvtDataCollections) Unmarshal

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

Unmarshal read and unmarshal collection of private data from given bytes array

type Set

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

Set is a generic and thread-safe set container

func NewSet

func NewSet() *Set

NewSet returns a new set

func (*Set) Add

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

Add adds given item to the set

func (*Set) Clear

func (s *Set) Clear()

Clear removes all elements from set

func (*Set) Exists

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

Exists returns true whether given item is in the set

func (*Set) Remove

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

Remove removes a given item from the set

func (*Set) Size

func (s *Set) Size() int

Size returns the size of the set

func (*Set) ToArray

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

ToArray returns a slice with items at the point in time the method was invoked

type Subscription

type Subscription interface {
	// Listen blocks until a publish was made
	// to the subscription, or an error if the
	// subscription's TTL passed
	Listen() (interface{}, error)
}

Subscription defines a subscription to a topic that can be used to receive publishes on