deliver

Documentation

Index

• func ExtractChannelHeaderCertHash(msg proto.Message) []byte
• type Chain
• type ChainManager
• type ConfigSequencer
• type ExpiresAtFunc
• type Filtered
• type Handler
  • func NewHandler(cm ChainManager, timeWindow time.Duration, mutualTLS bool, metrics *Metrics) *Handler
  • func (h *Handler) Handle(ctx context.Context, srv *Server) error
• type Inspector
• type InspectorFunc
  • func (inspector InspectorFunc) Inspect(ctx context.Context, p proto.Message) error
• type Metrics
  • func NewMetrics(p metrics.Provider) *Metrics
• type PolicyChecker
• type PolicyCheckerFunc
  • func (pcf PolicyCheckerFunc) CheckPolicy(envelope *cb.Envelope, channelID string) error
• type Receiver
• type ResponseSender
• type Server
• type SessionAccessControl
  • func NewSessionAC(chain ConfigSequencer, env *common.Envelope, policyChecker PolicyChecker, ...) (*SessionAccessControl, error)
  • func (ac *SessionAccessControl) Evaluate() error

Functions

func ExtractChannelHeaderCertHash

func ExtractChannelHeaderCertHash(msg proto.Message) []byte

ExtractChannelHeaderCertHash从通道头提取TLS证书哈希。

Types

type Chain

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

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

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

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

链封装了链操作和数据。

type ChainManager

type ChainManager interface {
	GetChain(chainID string) Chain
}

ChainManager为处理程序提供了查找链的方法。

type ConfigSequencer

type ConfigSequencer interface {
	Sequence() uint64
}

configSequencer提供当前配置块的序列号。

type ExpiresAtFunc

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

expiresatfunc用于提取标识过期的时间。

type Filtered

type Filtered interface {
	IsFiltered() bool
}

筛选是指示响应发送者的标记接口 配置为发送筛选的块

type Handler

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

func NewHandler

func NewHandler(cm ChainManager, timeWindow time.Duration, mutualTLS bool, metrics *Metrics) *Handler

newhandler创建处理程序接口的实现。

func (*Handler) Handle

func (h *Handler) Handle(ctx context.Context, srv *Server) error

句柄接收传入的传递请求。

type Inspector

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

检查器验证消息和上下文之间的适当绑定。

type InspectorFunc

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

inspectorfunc是一个适配器，允许使用普通的 作为检查员。

func (InspectorFunc) Inspect

func (inspector InspectorFunc) Inspect(ctx context.Context, p proto.Message) error

检查呼叫检查员（CTX，P）

type Metrics

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

func NewMetrics

func NewMetrics(p metrics.Provider) *Metrics

type PolicyChecker

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

policyChecker根据提供的策略逻辑检查信封 功能。

type PolicyCheckerFunc

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

policycheckerfnc是一个适配器，允许使用普通的 作为策略检查器。

func (PolicyCheckerFunc) CheckPolicy

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

checkpolicy调用pcf（信封，channelid）

type Receiver

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

接收器用于接收封装的寻道请求。

type ResponseSender

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

ResponseSender定义处理程序必须实现以发送的接口 响应。

type Server

type Server struct {
	Receiver
	PolicyChecker
	ResponseSender
}

服务器是一个多态结构，支持此处理程序的泛化。 能够提供不同类型的响应。

type SessionAccessControl

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

sessionaccesscontrol为公共信封保存与访问控制相关的数据

与请求信封关联。

func NewSessionAC

func NewSessionAC(chain ConfigSequencer, env *common.Envelope, policyChecker PolicyChecker, channelID string, expiresAt ExpiresAtFunc) (*SessionAccessControl, error)

如果无法从信封中提取签名头，则返回错误。

func (*SessionAccessControl) Evaluate

func (ac *SessionAccessControl) Evaluate() error

变化。