Documentation ¶
Index ¶
- func ExtractChannelHeaderCertHash(msg proto.Message) []byte
- type Chain
- type ChainManager
- type ConfigSequencer
- type ExpiresAtFunc
- type Filtered
- type Handler
- type Inspector
- type InspectorFunc
- type Metrics
- type PolicyChecker
- type PolicyCheckerFunc
- type Receiver
- type ResponseSender
- type Server
- type SessionAccessControl
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Chain ¶
type Chain interface { Sequence() uint64 PolicyManager() policies.Manager Reader() blockledger.Reader Errored() <-chan struct{} }
type ChainManager ¶
type ConfigSequencer ¶
type ConfigSequencer interface {
Sequence() uint64
}
type ExpiresAtFunc ¶
type Handler ¶
type Handler struct { ExpirationCheckFunc func(identityBytes []byte) time.Time ChainManager ChainManager TimeWindow time.Duration BindingInspector Inspector Metrics *Metrics }
func NewHandler ¶
type InspectorFunc ¶
type Metrics ¶
type Metrics struct { StreamsOpened metrics.Counter StreamsClosed metrics.Counter RequestsReceived metrics.Counter RequestsCompleted metrics.Counter BlocksSent metrics.Counter }
func NewMetrics ¶
type PolicyChecker ¶
type PolicyCheckerFunc ¶
func (PolicyCheckerFunc) CheckPolicy ¶
func (pcf PolicyCheckerFunc) CheckPolicy(envelope *cb.Envelope, channelID string) error
type ResponseSender ¶
type Server ¶
type Server struct { Receiver PolicyChecker ResponseSender }
type SessionAccessControl ¶
type SessionAccessControl struct {
// contains filtered or unexported fields
}
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
Click to show internal directories.
Click to hide internal directories.