ordering

type BFTBroadcaster struct {
	ConfigService driver.ConfigService
	ClientFactory Services
	// contains filtered or unexported fields
}

type Broadcast interface {
	Send(m *common.Envelope) error
	Recv() (*ab.BroadcastResponse, error)
	CloseSend() error
}

type BroadcastFnc = func(context context.Context, env *common2.Envelope) error

type CFTBroadcaster struct {
	NetworkID     string
	ConfigService driver.ConfigService
	ClientFactory Services
	// contains filtered or unexported fields
}

type Client = services.OrdererClient

type Connection struct {
	Stream Broadcast
	Client Client
	// contains filtered or unexported fields
}

type ConsensusType = string

type GetEndorserTransactionServiceFunc = func(channelID string) (driver.EndorserTransactionService, error)

type Service struct {
	GetEndorserTransactionService GetEndorserTransactionServiceFunc
	SigService                    driver.SignerService
	ConfigService                 driver.ConfigService
	Metrics                       *metrics.Metrics

	Broadcasters   map[ConsensusType]BroadcastFnc
	BroadcastMutex sync.RWMutex
	Broadcaster    BroadcastFnc
}

type Services interface {
	NewOrdererClient(cc grpc.ConnectionConfig) (Client, error)
}

type Transaction interface {
	Channel() string
	ID() string
	Creator() view.Identity
	Proposal() driver.Proposal
	ProposalResponses() ([]driver.ProposalResponse, error)
	Bytes() ([]byte, error)
	Envelope() (driver.Envelope, error)
}

type TransactionWithEnvelope interface {
	Envelope() *common2.Envelope
}