handler

Documentation

Index

• type CheckForCommitHandler
  • func NewCheckForCommitHandler(rwSetIgnoreNameSpace []api.Namespace, callback api.EndorsedCallback, ...) *CheckForCommitHandler
  • func (c *CheckForCommitHandler) Handle(requestContext *invoke.RequestContext, clientContext *invoke.ClientContext)
• type CommitTxHandler
  • func NewCommitTxHandler(registerTxEvent bool, channelID string, next ...invoke.Handler) *CommitTxHandler
  • func (l *CommitTxHandler) Handle(requestContext *invoke.RequestContext, clientContext *invoke.ClientContext)
• type PeerFilterHandler
  • func NewPeerFilterHandler(chaincodeIDs []string, config api.Config, next ...invoke.Handler) *PeerFilterHandler
  • func (p *PeerFilterHandler) Handle(requestContext *invoke.RequestContext, clientContext *invoke.ClientContext)

Types

type CheckForCommitHandler

type CheckForCommitHandler struct {
	ShouldCommit bool
	// contains filtered or unexported fields
}

CheckForCommitHandler for checking need to commit

func NewCheckForCommitHandler

func NewCheckForCommitHandler(rwSetIgnoreNameSpace []api.Namespace, callback api.EndorsedCallback, commitType api.CommitType, next ...invoke.Handler) *CheckForCommitHandler

NewCheckForCommitHandler returns a handler that check if there is need to commit

func (*CheckForCommitHandler) Handle

func (c *CheckForCommitHandler) Handle(requestContext *invoke.RequestContext, clientContext *invoke.ClientContext)

Handle for endorsing transactions

type CommitTxHandler

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

CommitTxHandler for commit txn

func NewCommitTxHandler

func NewCommitTxHandler(registerTxEvent bool, channelID string, next ...invoke.Handler) *CommitTxHandler

NewCommitTxHandler returns a handler that commit txn

func (*CommitTxHandler) Handle

func (l *CommitTxHandler) Handle(requestContext *invoke.RequestContext, clientContext *invoke.ClientContext)

Handle for endorsing transactions

type PeerFilterHandler

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

PeerFilterHandler for handling peers filter

func NewPeerFilterHandler

func NewPeerFilterHandler(chaincodeIDs []string, config api.Config, next ...invoke.Handler) *PeerFilterHandler

NewPeerFilterHandler returns a handler that filter peers

func (*PeerFilterHandler) Handle

func (p *PeerFilterHandler) Handle(requestContext *invoke.RequestContext, clientContext *invoke.ClientContext)

Handle selects proposal processors