Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ArchiveGossip ¶
type ArchiveGossip interface {
// Accept returns a channel that emits messages
Accept() <-chan *proto.GossipMessage
// Gossip gossips a message to other peers
Gossip(msg *proto.GossipMessage)
Stop()
}
func NewGossipImpl ¶
func NewGossipImpl(g gossip, channel string) ArchiveGossip
type ArchiveService ¶
type ArchiveService struct {
// contains filtered or unexported fields
}
func New ¶
func New(g gossip, ledgerMgr *ledgermgmt.LedgerMgr, channel string, peerId string, conf *archive.Config) (*ArchiveService, error)
New construction function to create and initialize archive service instance. It tries to establish connection to the specified dfs name node, in case it fails to dial to it, return nil
func (*ArchiveService) StartTickerForChannel ¶
func (a *ArchiveService) StartTickerForChannel(chainID string) error
StartTickerForChannel starts a ticker to trigger the block files transfer for channel
func (*ArchiveService) Stop ¶
func (a *ArchiveService) Stop()
func (*ArchiveService) StopTickerForChannel ¶
func (a *ArchiveService) StopTickerForChannel(chainID string) error
Source Files
Click to show internal directories.
Click to hide internal directories.