service

Documentation

Index

• type ArchiveGossip
  • func NewGossipImpl(g gossip, channel string) ArchiveGossip
• type ArchiveService
  • func New(g gossip, ledgerMgr *ledgermgmt.LedgerMgr, channel string, peerId string, ...) (*ArchiveService, error)
  • func (a *ArchiveService) StartTickerForChannel(chainID string) error
  • func (a *ArchiveService) Stop()
  • func (a *ArchiveService) StopTickerForChannel(chainID string) error

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