ordering

Documentation

Index

• type BFTBroadcaster
  • func NewBFTBroadcaster(configService driver.ConfigService, cf Services, metrics *metrics.Metrics) *BFTBroadcaster
  • func (o *BFTBroadcaster) Broadcast(context context.Context, env *common2.Envelope) error
• type Broadcast
• type BroadcastFnc
• type CFTBroadcaster
  • func NewCFTBroadcaster(configService driver.ConfigService, clientFactory Services, ...) *CFTBroadcaster
  • func (o *CFTBroadcaster) Broadcast(context context.Context, env *common2.Envelope) error
• type Client
• type Connection
  • func (c *Connection) Recv() (*ab.BroadcastResponse, error)
  • func (c *Connection) Send(m *common.Envelope) error
• type ConsensusType
• type GetEndorserTransactionServiceFunc
• type Service
  • func NewService(getEndorserTransactionService GetEndorserTransactionServiceFunc, ...) *Service
  • func (o *Service) Broadcast(ctx context2.Context, blob interface{}) error
  • func (f *Service) Configure(consensusType string, orderers []*grpc.ConnectionConfig) error
  • func (o *Service) SetConsensusType(consensusType ConsensusType) error
• type Services
• type Transaction
• type TransactionWithEnvelope

Types

type BFTBroadcaster

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

func NewBFTBroadcaster

func NewBFTBroadcaster(configService driver.ConfigService, cf Services, metrics *metrics.Metrics) *BFTBroadcaster

func (*BFTBroadcaster) Broadcast

func (o *BFTBroadcaster) Broadcast(context context.Context, env *common2.Envelope) error

type Broadcast

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

Broadcast defines the interface that abstracts grpc calls to broadcast transactions to orderer

type BroadcastFnc

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

type CFTBroadcaster

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

func NewCFTBroadcaster

func NewCFTBroadcaster(configService driver.ConfigService, clientFactory Services, metrics *metrics.Metrics) *CFTBroadcaster

func (*CFTBroadcaster) Broadcast

func (o *CFTBroadcaster) Broadcast(context context.Context, env *common2.Envelope) error

type Client

type Client = services.OrdererClient

type Connection

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

func (*Connection) Recv

func (c *Connection) Recv() (*ab.BroadcastResponse, error)

func (*Connection) Send

func (c *Connection) Send(m *common.Envelope) error

type ConsensusType

type ConsensusType = string

const (
	BFT  ConsensusType = "BFT"
	Raft ConsensusType = "etcdraft"
	Solo ConsensusType = "solo"
)

type GetEndorserTransactionServiceFunc

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

type Service

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

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

func NewService

func NewService(
	getEndorserTransactionService GetEndorserTransactionServiceFunc,
	sigService driver.SignerService,
	configService driver.ConfigService,
	metrics *metrics.Metrics,
	services Services,
) *Service

func (*Service) Broadcast

func (o *Service) Broadcast(ctx context2.Context, blob interface{}) error

func (*Service) Configure

func (f *Service) Configure(consensusType string, orderers []*grpc.ConnectionConfig) error

func (*Service) SetConsensusType

func (o *Service) SetConsensusType(consensusType ConsensusType) error

type Services

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

type Transaction

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

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