deliver

type Chain interface {
	//sequence返回当前配置序列号，可用于检测配置更改
	Sequence() uint64

	//policyManager返回由链配置指定的当前策略管理器
	PolicyManager() policies.Manager

	//读卡器返回链的链读卡器
	Reader() blockledger.Reader

	//出错返回一个通道，当支持同意者出错时该通道关闭。
	Errored() <-chan struct{}
}

type ChainManager interface {
	GetChain(chainID string) Chain
}

type ConfigSequencer interface {
	Sequence() uint64
}

type ExpiresAtFunc func(identityBytes []byte) time.Time

type Filtered interface {
	IsFiltered() bool
}

type Handler struct {
	ChainManager     ChainManager
	TimeWindow       time.Duration
	BindingInspector Inspector
	Metrics          *Metrics
}

type Inspector interface {
	Inspect(context.Context, proto.Message) error
}

type InspectorFunc func(context.Context, proto.Message) error

type Metrics struct {
	StreamsOpened     metrics.Counter
	StreamsClosed     metrics.Counter
	RequestsReceived  metrics.Counter
	RequestsCompleted metrics.Counter
	BlocksSent        metrics.Counter
}

type PolicyChecker interface {
	CheckPolicy(envelope *cb.Envelope, channelID string) error
}

type PolicyCheckerFunc func(envelope *cb.Envelope, channelID string) error

type Receiver interface {
	Recv() (*cb.Envelope, error)
}

type ResponseSender interface {
	SendStatusResponse(status cb.Status) error
	SendBlockResponse(block *cb.Block) error
}

type Server struct {
	Receiver
	PolicyChecker
	ResponseSender
}

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