websocketOutportDriver

Nov 11, 2022

Changes in this version

+ func NewWebSocketPayloadParser(uint64ByteSliceConverter Uint64ByteSliceConverter) (*websocketPayloadParser, error)

+ func NewWebsocketOutportDriverNodePart(args WebsocketOutportDriverNodePartArgs) (*websocketOutportDriverNodePart, error)

+ type Driver interface

+ Close func() error

+ FinalizedBlock func(headerHash []byte) error

+ IsInterfaceNil func() bool

+ RevertIndexedBlock func(header data.HeaderHandler, body data.BodyHandler) error

+ SaveAccounts func(blockTimestamp uint64, acc map[string]*outport.AlteredAccount, shardID uint32) error

+ SaveBlock func(args *outport.ArgsSaveBlockData) error

+ SaveRoundsInfo func(roundsInfos []*outport.RoundInfo) error

+ SaveValidatorsPubKeys func(validatorsPubKeys map[uint32][][]byte, epoch uint32) error

+ SaveValidatorsRating func(indexID string, infoRating []*outport.ValidatorRatingInfo) error

+ type PayloadData struct

+ Counter uint64

+ OperationType data.OperationType

+ Payload []byte

+ WithAcknowledge bool

+ type Uint64ByteSliceConverter interface

+ IsInterfaceNil func() bool

+ ToByteSlice func(uint64) []byte

+ ToUint64 func([]byte) (uint64, error)

+ type WebSocketSenderHandler interface

+ AddClient func(wss outportSenderData.WSConn, remoteAddr string)

+ Close func() error

+ IsInterfaceNil func() bool

+ Send func(args outportSenderData.WsSendArgs) error

+ type WebsocketOutportDriverNodePartArgs struct

+ Enabled bool

+ Log core.Logger

+ Marshaller marshal.Marshalizer

+ Uint64ByteSliceConverter Uint64ByteSliceConverter

+ WebSocketConfig outportSenderData.WebSocketConfig

+ WebsocketSender WebSocketSenderHandler