Versions in this module Expand all Collapse all v0 v0.0.2 Aug 16, 2023 Changes in this version + func PrepareArgsSaveBlock(args outport.ArgsSaveBlockData) outport.ArgsSaveBlockData v0.0.1 Aug 16, 2023 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