delivery

type DeliverClient interface {

	// NewDeliverFiltered returns a DeliverFiltered
	NewDeliverFiltered(ctx context.Context, opts ...grpc.CallOption) (DeliverFiltered, error)

	// NewDeliver returns a DeliverStream
	NewDeliver(ctx context.Context, opts ...grpc.CallOption) (DeliverStream, error)

	// Certificate returns tls certificate for the deliver client to peer
	Certificate() *tls.Certificate
}

type DeliverFiltered interface {
	Send(*common.Envelope) error
	Recv() (*pb.DeliverResponse, error)
	CloseSend() error
}

type DeliverStream interface {
	Send(*common.Envelope) error
	Recv() (*pb.DeliverResponse, error)
	CloseSend() error
}

type Delivery struct {
	NetworkName     string
	LocalMembership driver.LocalMembership
	ConfigService   driver.ConfigService
	Services        Services
	Ledger          driver.Ledger
	// contains filtered or unexported fields
}

type Hasher interface {
	Hash(msg []byte) (hash []byte, err error)
}

type Service struct {
	NetworkName     string
	LocalMembership driver.LocalMembership
	ConfigService   driver.ConfigService
	PeerManager     Services
	Ledger          driver.Ledger
	// contains filtered or unexported fields
}

type Services interface {
	NewPeerClient(cc grpc.ConnectionConfig) (services.PeerClient, error)
}

type TxEvent struct {
	TxID         string
	Committed    bool
	Block        uint64
	IndexInBlock int
	CommitPeer   string
	Err          error
}

type ValidationFlags []uint8

type Vault interface {
	// GetLastTxID returns the last transaction id committed
	GetLastTxID(ctx context.Context) (string, error)
	GetLastBlock(context.Context) (uint64, error)
}