deliverservice

type Config struct {
	ConnFactory func(channelID string) func(endpoint string, connectionTimeout time.Duration) (*grpc.ClientConn, error)

	ABCFactory func(*grpc.ClientConn) orderer.AtomicBroadcastClient

	CryptoSvc api.MessageCryptoService

	Gossip blocksprovider.GossipServiceAdapter

	Endpoints []string

	Signer identity.SignerSerializer

	CredentialSupport *comm.CredentialSupport

	DeliverClientDialOpts []grpc.DialOption

	DeliverServiceConfig *DeliverServiceConfig
}

type ConnectionCriteria struct {
	OrdererEndpoints []string

	Organizations []string

	OrdererEndpointsByOrg map[string][]string
}

type CredSupportDialerFactory struct {
	CredentialSupport *comm.CredentialSupport
	KeepaliveOptions  comm.KeepaliveOptions
	TLSEnabled        bool
}

type DeliverService interface {
	StartDeliverForChannel(chainID string, ledgerInfo blocksprovider.LedgerInfo, finalizer func()) error

	StopDeliverForChannel(chainID string) error

	UpdateEndpoints(chainID string, endpoints []string) error

	Stop()
}

type DeliverServiceConfig struct {
	PeerTLSEnabled bool

	ReConnectBackoffThreshold float64

	ReconnectTotalTimeThreshold time.Duration

	ConnectionTimeout time.Duration

	KeepaliveOptions comm.KeepaliveOptions
}