deliver

package
v0.0.0-...-523a819 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 21, 2019 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

变化。

Directories

Path Synopsis
此源码被清华学神尹成大魔王专业翻译分析并修改 尹成QQ77025077 尹成微信18510341407 尹成所在QQ群721929980 尹成邮箱 yinc13@mails.tsinghua.edu.cn 尹成毕业于清华大学,微软区块链领域全球最有价值专家 https://mvp.microsoft.com/zh-cn/PublicProfile/4033620 伪造者生成的代码。
此源码被清华学神尹成大魔王专业翻译分析并修改 尹成QQ77025077 尹成微信18510341407 尹成所在QQ群721929980 尹成邮箱 yinc13@mails.tsinghua.edu.cn 尹成毕业于清华大学,微软区块链领域全球最有价值专家 https://mvp.microsoft.com/zh-cn/PublicProfile/4033620 伪造者生成的代码。

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL