Documentation
¶
Index ¶
- Constants
- func BytesToStrings(bytes [][]byte) []string
- func Contains(s string, a []string) bool
- 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 SetDuration(key string, val time.Duration)
- func SetupTestLogging()
- func StringsToBytes(strings []string) [][]byte
- type Equals
- type Logger
- type 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
- type PrivateRWSetWithConfig
- type PubSub
- type PvtDataCollections
- type Set
- 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.
Variables ¶
This section is empty.
Functions ¶
func BytesToStrings ¶
func GetDurationOrDefault ¶
GetDurationOrDefault returns the Duration value from config if present otherwise default value
func GetFloat64OrDefault ¶
GetFloat64OrDefault returns the float64 value from config if present otherwise default value
func GetIntOrDefault ¶
GetIntOrDefault returns the int value from config if present otherwise default value
func GetRandomIndices ¶
GetRandomIndices returns a slice of random indices from 0 to given highestIndex
func IndexInSlice ¶
IndexInSlice returns the index of given object o in array
func PrivateRWSets ¶
func PrivateRWSets(rwsets ...PrivateRWSet) [][]byte
PrivateRWSets creates an aggregated slice of RWSets
func RandomInt ¶
RandomInt returns, as an int, a non-negative pseudo-random integer in [0,n) It panics if n <= 0
func SetDuration ¶
SetDuration stores duration key value to viper
func SetupTestLogging ¶
func SetupTestLogging()
SetupTestLogging sets the default log levels for gossip unit tests
func StringsToBytes ¶
Types ¶
type Equals ¶
type Equals func(a interface{}, b interface{}) bool
Equals returns whether a and b are the same
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 }
type MembershipStore ¶
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) 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 PrivateRWSetWithConfig ¶
type PrivateRWSetWithConfig struct { RWSet []PrivateRWSet CollectionConfig *common.CollectionConfig }
PrivateRWSetWithConfig encapsulates private read-write set among with relevant to collections config information
type PubSub ¶
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
type PvtDataCollections ¶
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
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