metainformation

package
v1.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 12, 2020 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ModeQueue    int = 1
	ModeExchange int = 2
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Bind

type Bind struct {
	Exchange string  `yaml:"exchange"`
	Key      *string `yaml:"key"`
	NoWait   *bool   `yaml:"noWait"`
	Headers  *Header `yaml:"header"`
}

type Exchange

type Exchange struct {
	Name         string
	Type         *string  `yaml:"type"`
	IsDurable    *bool    `yaml:"durable"`
	IsAutoDelete *bool    `yaml:"autoDelete"`
	IsInternal   *bool    `yaml:"internal"`
	NoWait       *bool    `yaml:"noWait"`
	Bind         *[]*Bind `yaml:"bind"`
}

type File

type File struct {
	Schema Schema `yaml:"schema"`
}

func (File) FromFile

func (file File) FromFile(filename string) (result *File, err error)
type Header struct {
	Match *string            `yaml:"match"`
	Keys  *map[string]string `yaml:"keys"`
}

type Queue

type Queue struct {
	Name         string
	IsDurable    *bool    `yaml:"durable"`
	IsAutoDelete *bool    `yaml:"autoDelete"`
	IsExclusive  *bool    `yaml:"exclusive"`
	NoWait       *bool    `yaml:"noWait"`
	MaxPriority  *int     `yaml:"maxPriority"`
	Bind         *[]*Bind `yaml:"bind"`
	// contains filtered or unexported fields
}

type Schema

type Schema struct {
	Exchange map[string]*Exchange `yaml:"exchange"`
	Queue    map[string]*Queue    `yaml:"queue"`
}

func (Schema) Build

func (schema Schema) Build(channel *amqp.Channel)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL