Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

msgprocessor

package

Go to main page

Versions in this module

v1

v1.1.0

Mar 15, 2018

Changes in this version

+ var AcceptRule = Rule(acceptRule{})

+ var EmptyRejectRule = Rule(emptyRejectRule{})

+ var ErrChannelDoesNotExist = errors.New("channel does not exist")

+ var ErrEmptyMessage = errors.New("Message was empty")

+ var ErrPermissionDenied = errors.New("permission denied")

+ type ChainCreator interface

+ ChannelsCount func() int

+ CreateBundle func(channelID string, config *cb.Config) (channelconfig.Resources, error)

+ NewChannelConfig func(envConfigUpdate *cb.Envelope) (channelconfig.Resources, error)

+ type ChannelConfigTemplator interface

+ NewChannelConfig func(env *cb.Envelope) (channelconfig.Resources, error)

+ type Classification int

+ const ConfigMsg

+ const ConfigUpdateMsg

+ const NormalMsg

+ type DefaultTemplator struct

+ func NewDefaultTemplator(support DefaultTemplatorSupport) *DefaultTemplator

+ func (dt *DefaultTemplator) NewChannelConfig(envConfigUpdate *cb.Envelope) (channelconfig.Resources, error)

+ type DefaultTemplatorSupport interface

+ ConfigtxValidator func() configtx.Validator

+ ConsortiumsConfig func() (channelconfig.Consortiums, bool)

+ OrdererConfig func() (channelconfig.Orderer, bool)

+ Signer func() crypto.LocalSigner

+ type LimitedSupport interface

+ OrdererConfig func() (channelconfig.Orderer, bool)

+ type MaxBytesRule struct

+ func NewSizeFilter(support Support) *MaxBytesRule

+ func (r *MaxBytesRule) Apply(message *cb.Envelope) error

+ type Processor interface

+ ClassifyMsg func(chdr *cb.ChannelHeader) Classification

+ ProcessConfigMsg func(env *cb.Envelope) (*cb.Envelope, uint64, error)

+ ProcessConfigUpdateMsg func(env *cb.Envelope) (config *cb.Envelope, configSeq uint64, err error)

+ ProcessNormalMsg func(env *cb.Envelope) (configSeq uint64, err error)

+ type Rule interface

+ Apply func(message *ab.Envelope) error

+ func NewExpirationRejectRule(filterSupport resources) Rule

+ type RuleSet struct

+ func CreateStandardChannelFilters(filterSupport channelconfig.Resources) *RuleSet

+ func CreateSystemChannelFilters(chainCreator ChainCreator, ledgerResources channelconfig.Resources) *RuleSet

+ func NewRuleSet(rules []Rule) *RuleSet

+ func (rs *RuleSet) Apply(message *ab.Envelope) error

+ type SigFilter struct

+ func NewSigFilter(policyName string, support SigFilterSupport) *SigFilter

+ func (sf *SigFilter) Apply(message *cb.Envelope) error

+ type SigFilterSupport interface

+ PolicyManager func() policies.Manager

+ type StandardChannel struct

+ func NewStandardChannel(support StandardChannelSupport, filters *RuleSet) *StandardChannel

+ func (s *StandardChannel) ClassifyMsg(chdr *cb.ChannelHeader) Classification

+ func (s *StandardChannel) ProcessConfigMsg(env *cb.Envelope) (config *cb.Envelope, configSeq uint64, err error)

+ func (s *StandardChannel) ProcessConfigUpdateMsg(env *cb.Envelope) (config *cb.Envelope, configSeq uint64, err error)

+ func (s *StandardChannel) ProcessNormalMsg(env *cb.Envelope) (configSeq uint64, err error)

+ type StandardChannelSupport interface

+ ChainID func() string

+ ProposeConfigUpdate func(configtx *cb.Envelope) (*cb.ConfigEnvelope, error)

+ Sequence func() uint64

+ Signer func() crypto.LocalSigner

+ type Support interface

+ BatchSize func() *ab.BatchSize

+ type SystemChainFilter struct

+ func NewSystemChannelFilter(ls LimitedSupport, cc ChainCreator) *SystemChainFilter

+ func (scf *SystemChainFilter) Apply(env *cb.Envelope) error

+ type SystemChannel struct

+ func NewSystemChannel(support StandardChannelSupport, templator ChannelConfigTemplator, ...) *SystemChannel

+ func (s *SystemChannel) ProcessConfigMsg(env *cb.Envelope) (*cb.Envelope, uint64, error)

+ func (s *SystemChannel) ProcessConfigUpdateMsg(envConfigUpdate *cb.Envelope) (config *cb.Envelope, configSeq uint64, err error)

+ func (s *SystemChannel) ProcessNormalMsg(msg *cb.Envelope) (configSeq uint64, err error)

v1.1.0-rc1

Mar 1, 2018

v1.1.0-preview

Nov 1, 2017

v1.1.0-alpha

Jan 26, 2018