ordering

type BFTBroadcaster struct {
	Network Network
	// 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 {
	Network Network
	// contains filtered or unexported fields
}

type Client struct {
	// contains filtered or unexported fields
}

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

type Network interface {
	Name() string
	PickOrderer() *grpc.ConnectionConfig
	Orderers() []*grpc.ConnectionConfig
	LocalMembership() driver.LocalMembership
	// Broadcast sends the passed blob to the ordering Service to be ordered
	Broadcast(context context2.Context, blob interface{}) error
	Channel(name string) (driver.Channel, error)
	SignerService() driver.SignerService
	Config() *config.Config
}

type OrdererClient interface {
	// NewBroadcast returns a Broadcast
	NewBroadcast(ctx context.Context, opts ...grpc.CallOption) (Broadcast, error)

	// Certificate returns tls certificate for the orderer client
	Certificate() *tls.Certificate

	Close()
}

type Service struct {
	SP      view2.ServiceProvider
	Network Network
	Metrics *metrics.Metrics

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

type Signer interface {
	// Sign the message
	Sign(msg []byte) ([]byte, error)
}

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

type ViewManager interface {
	InitiateView(view view.View) (interface{}, error)
}