deliverservice

Documentation

Index

• Constants
• func DefaultABCFactory(conn *grpc.ClientConn) orderer.AtomicBroadcastClient
• func NewBroadcastClient(prod comm.ConnectionProducer, clFactory clientFactory, ...) *broadcastClient
• type Config
• type ConnectionCriteria
• type CredSupportDialerFactory
  • func (c *CredSupportDialerFactory) Dialer(channelID string) ...
• type DeliverService
  • func NewDeliverService(conf *Config) (DeliverService, error)
• type DeliverServiceConfig
  • func GlobalConfig() *DeliverServiceConfig

Constants

const (
	DefaultReConnectBackoffThreshold   = float64(time.Hour)
	DefaultReConnectTotalTimeThreshold = time.Second * 60 * 60
	DefaultConnectionTimeout           = time.Second * 3
)

Functions

func DefaultABCFactory

func DefaultABCFactory(conn *grpc.ClientConn) orderer.AtomicBroadcastClient

func NewBroadcastClient

func NewBroadcastClient(prod comm.ConnectionProducer, clFactory clientFactory, onConnect broadcastSetup, bos retryPolicy) *broadcastClient

Types

type Config

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

type ConnectionCriteria struct {
	OrdererEndpoints []string

	Organizations []string

	OrdererEndpointsByOrg map[string][]string
}

type CredSupportDialerFactory

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

func (*CredSupportDialerFactory) Dialer

func (c *CredSupportDialerFactory) Dialer(channelID string) func(endpoint string, connectionTimeout time.Duration) (*grpc.ClientConn, error)

type DeliverService

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

	StopDeliverForChannel(chainID string) error

	UpdateEndpoints(chainID string, endpoints []string) error

	Stop()
}

func NewDeliverService

func NewDeliverService(conf *Config) (DeliverService, error)

type DeliverServiceConfig

type DeliverServiceConfig struct {
	PeerTLSEnabled bool

	ReConnectBackoffThreshold float64

	ReconnectTotalTimeThreshold time.Duration

	ConnectionTimeout time.Duration

	KeepaliveOptions comm.KeepaliveOptions
}

func GlobalConfig

func GlobalConfig() *DeliverServiceConfig