deliver

Jan 9, 2019

Changes in this version

+ type Filtered interface

+ IsFiltered func() bool

type Handler

+ Metrics *Metrics

+ type Metrics struct

+ BlocksSent metrics.Counter

+ RequestsCompleted metrics.Counter

+ RequestsReceived metrics.Counter

+ StreamsClosed metrics.Counter

+ StreamsOpened metrics.Counter

+ func NewMetrics(p metrics.Provider) *Metrics

Jul 3, 2018

Changes in this version

+ func ExtractChannelHeaderCertHash(msg proto.Message) []byte

+ type Chain interface

+ Errored func() <-chan struct{}

+ PolicyManager func() policies.Manager

+ Reader func() blockledger.Reader

+ Sequence func() uint64

+ type ChainManager interface

+ GetChain func(chainID string) (Chain, bool)

+ type ConfigSequencer interface

+ Sequence func() uint64

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

type Handler

+ BindingInspector Inspector

+ ChainManager ChainManager

+ TimeWindow time.Duration

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

+ type Inspector interface

+ Inspect func(context.Context, proto.Message) error

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

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

type PolicyChecker

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

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

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

+ type Receiver interface

+ Recv func() (*cb.Envelope, error)

+ type ResponseSender interface

+ SendBlockResponse func(block *cb.Block) error

+ SendStatusResponse func(status cb.Status) error

+ type Server struct

+ type SessionAccessControl struct

+ func NewSessionAC(chain ConfigSequencer, env *common.Envelope, policyChecker PolicyChecker, ...) (*SessionAccessControl, error)

+ func (ac *SessionAccessControl) Evaluate() error

Mar 15, 2018

Changes in this version

+ type DeliverServer struct

+ Send func(msg proto.Message) error

+ func NewDeliverServer(support DeliverSupport, policyChecker PolicyChecker, ...) *DeliverServer

+ type DeliverSupport interface

+ Context func() context.Context

+ CreateBlockReply func(block *cb.Block) proto.Message

+ CreateStatusReply func(status cb.Status) proto.Message

+ Recv func() (*cb.Envelope, error)

+ type Handler interface

+ Handle func(srv *DeliverServer) error

+ func NewHandlerImpl(sm SupportManager, timeWindow time.Duration, mutualTLS bool) Handler

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

+ type Support interface

+ Errored func() <-chan struct{}

+ PolicyManager func() policies.Manager

+ Reader func() blockledger.Reader

+ Sequence func() uint64

+ type SupportManager interface

+ GetChain func(chainID string) (Support, bool)