Documentation ¶
Index ¶
- Variables
- func LoadAllBindings(db *bolt.DB) (map[string]*Binding, error)
- type Binding
- func (binding *Binding) Depersist(db *bolt.DB) error
- func (binding *Binding) DepersistBoltTx(tx *bolt.Tx) error
- func (binding *Binding) Equals(other *Binding) bool
- func (binding *Binding) MarshalJSON() ([]byte, error)
- func (b *Binding) MatchDirect(message *amqp.BasicPublish) bool
- func (b *Binding) MatchFanout(message *amqp.BasicPublish) bool
- func (b *Binding) MatchTopic(message *amqp.BasicPublish) bool
- func (b *Binding) Persist(db *bolt.DB) error
- type BindingStateFactory
Constants ¶
This section is empty.
Variables ¶
View Source
var BINDINGS_BUCKET_NAME = []byte("bindings")
Functions ¶
Types ¶
type Binding ¶
type Binding struct { gen.BindingState // contains filtered or unexported fields }
func NewBinding ¶
func (*Binding) MarshalJSON ¶
func (*Binding) MatchDirect ¶
func (b *Binding) MatchDirect(message *amqp.BasicPublish) bool
func (*Binding) MatchFanout ¶
func (b *Binding) MatchFanout(message *amqp.BasicPublish) bool
func (*Binding) MatchTopic ¶
func (b *Binding) MatchTopic(message *amqp.BasicPublish) bool
type BindingStateFactory ¶
type BindingStateFactory struct{}
func (*BindingStateFactory) New ¶
func (bsf *BindingStateFactory) New() proto.Unmarshaler
Click to show internal directories.
Click to hide internal directories.