riggerAmqp

package
v0.0.0-...-3dee317 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const AppName = "go-rigger-amqp-app"

Variables

View Source 
var (
	ErrInvalidLengthMessages = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessages   = fmt.Errorf("proto: integer overflow")
)

Functions

This section is empty.

Types

type Ack 

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

type App 

type App struct {
}

func (*App) OnGetSupFlag 

func (a *App) OnGetSupFlag(ctx actor.Context) (supFlag rigger.SupervisorFlag, childSpecs []*rigger.SpawnSpec)

func (*App) OnPostStarted 

func (a *App) OnPostStarted(ctx actor.Context, args interface{})

func (*App) OnRestarting 

func (a *App) OnRestarting(ctx actor.Context)

func (*App) OnStarted 

func (a *App) OnStarted(ctx actor.Context, args interface{}) error

func (*App) OnStopped 

func (a *App) OnStopped(ctx actor.Context)

func (*App) OnStopping 

func (a *App) OnStopping(ctx actor.Context)

type CancelConsume 

type CancelConsume struct {
	Consumer string `protobuf:"bytes,1,opt,name=consumer,proto3" json:"consumer,omitempty"`
	NoWait   bool   `protobuf:"varint,2,opt,name=noWait,proto3" json:"noWait,omitempty"`
}

func (*CancelConsume) Descriptor 

func (*CancelConsume) Descriptor() ([]byte, []int)

func (*CancelConsume) Equal 

func (this *CancelConsume) Equal(that interface{}) bool

func (*CancelConsume) GetConsumer 

func (m *CancelConsume) GetConsumer() string

func (*CancelConsume) GetNoWait 

func (m *CancelConsume) GetNoWait() bool

func (*CancelConsume) GoString 

func (this *CancelConsume) GoString() string

func (*CancelConsume) Marshal 

func (m *CancelConsume) Marshal() (dAtA []byte, err error)

func (*CancelConsume) MarshalTo 

func (m *CancelConsume) MarshalTo(dAtA []byte) (int, error)

func (*CancelConsume) ProtoMessage 

func (*CancelConsume) ProtoMessage()

func (*CancelConsume) Reset 

func (m *CancelConsume) Reset()

func (*CancelConsume) Size 

func (m *CancelConsume) Size() (n int)

func (*CancelConsume) String 

func (this *CancelConsume) String() string

func (*CancelConsume) Unmarshal 

func (m *CancelConsume) Unmarshal(dAtA []byte) error

func (*CancelConsume) XXX_DiscardUnknown 

func (m *CancelConsume) XXX_DiscardUnknown()

func (*CancelConsume) XXX_Marshal 

func (m *CancelConsume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelConsume) XXX_Merge 

func (m *CancelConsume) XXX_Merge(src proto.Message)

func (*CancelConsume) XXX_Size 

func (m *CancelConsume) XXX_Size() int

func (*CancelConsume) XXX_Unmarshal 

func (m *CancelConsume) XXX_Unmarshal(b []byte) error

type Channel 

type Channel struct {
	Pid *actor.PID `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
}

func (*Channel) Ack 

func (channel *Channel) Ack(tag uint64, multiple bool) error

func (*Channel) CancelConsume 

func (channel *Channel) CancelConsume(consumer string, noWait bool) error

停止消费消息

func (*Channel) Close 

func (channel *Channel) Close() error

MQ 信道, 定义在messages.proto中

关闭频道

func (*Channel) Consume 

func (channel *Channel) Consume(config ConsumeConfig) error

开始消费消息

func (*Channel) Descriptor 

func (*Channel) Descriptor() ([]byte, []int)

func (*Channel) Equal 

func (this *Channel) Equal(that interface{}) bool

func (*Channel) ExchangeBind 

func (channel *Channel) ExchangeBind(config *ExchangeBindConfig) error

func (*Channel) ExchangeDeclare 

func (channel *Channel) ExchangeDeclare(config *ExchangeDeclareConfig) error

func (*Channel) ExchangeDelete 

func (channel *Channel) ExchangeDelete(config *ExchangeDeleteConfig) error

func (*Channel) ExchangeUnbind 

func (channel *Channel) ExchangeUnbind(config *ExchangeUnbindConfig) error

func (*Channel) GetPid 

func (m *Channel) GetPid() *actor.PID

func (*Channel) GoString 

func (this *Channel) GoString() string

func (*Channel) Marshal 

func (m *Channel) Marshal() (dAtA []byte, err error)

func (*Channel) MarshalTo 

func (m *Channel) MarshalTo(dAtA []byte) (int, error)

func (*Channel) Nack 

func (channel *Channel) Nack(tag uint64, multiple bool, requeue bool) error

func (*Channel) NotifyClosed 

func (channel *Channel) NotifyClosed(ctx actor.Context)

注册频道的关闭监听, 监听后,如果频道关闭,监控进程会收到 *actor.Terminated 和监控连接关闭不一样, 监听通道实际上是监听的通道进程是否关闭 如果监听时, 通道已经关闭,则会立即收到一条 *actor.Terminated 消息

func (*Channel) ProtoMessage 

func (*Channel) ProtoMessage()

func (*Channel) Publish 

func (channel *Channel) Publish(publish *Publish) error

同步发送

func (*Channel) PublishAsync 

func (channel *Channel) PublishAsync(publish *Publish)

异步发送

func (*Channel) QueueBind 

func (channel *Channel) QueueBind(config *QueueBindConfig) error

func (*Channel) QueueDeclare 

func (channel *Channel) QueueDeclare(config *QueueDeclareConfig) (*QueueInspection, error)

func (*Channel) QueueDelete 

func (channel *Channel) QueueDelete(config *QueueDeleteConfig) (int, error)

func (*Channel) QueueInspect 

func (channel *Channel) QueueInspect(config *QueueInspectConfig) (*QueueInspection, error)

func (*Channel) QueuePurge 

func (channel *Channel) QueuePurge(config *QueuePurgeConfig) (int, error)

func (*Channel) QueueUnbind 

func (channel *Channel) QueueUnbind(config *QueueUnbindConfig) error

func (*Channel) Reject 

func (channel *Channel) Reject(tag uint64, requeue bool) error

func (*Channel) Reset 

func (m *Channel) Reset()

func (*Channel) Size 

func (m *Channel) Size() (n int)

func (*Channel) String 

func (this *Channel) String() string

func (*Channel) Unmarshal 

func (m *Channel) Unmarshal(dAtA []byte) error

func (*Channel) XXX_DiscardUnknown 

func (m *Channel) XXX_DiscardUnknown()

func (*Channel) XXX_Marshal 

func (m *Channel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Channel) XXX_Merge 

func (m *Channel) XXX_Merge(src proto.Message)

func (*Channel) XXX_Size 

func (m *Channel) XXX_Size() int

func (*Channel) XXX_Unmarshal 

func (m *Channel) XXX_Unmarshal(b []byte) error

type Closed 

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

type ConnectConfig 

type ConnectConfig struct {
	Tag         string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Host        string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Port        int32  `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	VirtualHost string `protobuf:"bytes,4,opt,name=virtualHost,proto3" json:"virtualHost,omitempty"`
	User        string `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	Password    string `protobuf:"bytes,6,opt,name=password,proto3" json:"password,omitempty"`
}

func (*ConnectConfig) Descriptor 

func (*ConnectConfig) Descriptor() ([]byte, []int)

func (*ConnectConfig) Equal 

func (this *ConnectConfig) Equal(that interface{}) bool

func (*ConnectConfig) GetHost 

func (m *ConnectConfig) GetHost() string

func (*ConnectConfig) GetPassword 

func (m *ConnectConfig) GetPassword() string

func (*ConnectConfig) GetPort 

func (m *ConnectConfig) GetPort() int32

func (*ConnectConfig) GetTag 

func (m *ConnectConfig) GetTag() string

func (*ConnectConfig) GetUser 

func (m *ConnectConfig) GetUser() string

func (*ConnectConfig) GetVirtualHost 

func (m *ConnectConfig) GetVirtualHost() string

func (*ConnectConfig) GoString 

func (this *ConnectConfig) GoString() string

func (*ConnectConfig) Marshal 

func (m *ConnectConfig) Marshal() (dAtA []byte, err error)

func (*ConnectConfig) MarshalTo 

func (m *ConnectConfig) MarshalTo(dAtA []byte) (int, error)

func (*ConnectConfig) ProtoMessage 

func (*ConnectConfig) ProtoMessage()

func (*ConnectConfig) Reset 

func (m *ConnectConfig) Reset()

func (*ConnectConfig) Size 

func (m *ConnectConfig) Size() (n int)

func (*ConnectConfig) String 

func (this *ConnectConfig) String() string

func (*ConnectConfig) Unmarshal 

func (m *ConnectConfig) Unmarshal(dAtA []byte) error

func (*ConnectConfig) Uri 

func (config *ConnectConfig) Uri() string

* 连接配置

根据配置信息生成uri

func (*ConnectConfig) XXX_DiscardUnknown 

func (m *ConnectConfig) XXX_DiscardUnknown()

func (*ConnectConfig) XXX_Marshal 

func (m *ConnectConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectConfig) XXX_Merge 

func (m *ConnectConfig) XXX_Merge(src proto.Message)

func (*ConnectConfig) XXX_Size 

func (m *ConnectConfig) XXX_Size() int

func (*ConnectConfig) XXX_Unmarshal 

func (m *ConnectConfig) XXX_Unmarshal(b []byte) error

type ConnectResp 

type ConnectResp struct {
	Error string      `protobuf:"bytes,1,opt,name=Error,proto3" json:"Error,omitempty"`
	Conn  *Connection `protobuf:"bytes,2,opt,name=conn,proto3" json:"conn,omitempty"`
}

func (*ConnectResp) Descriptor 

func (*ConnectResp) Descriptor() ([]byte, []int)

func (*ConnectResp) Equal 

func (this *ConnectResp) Equal(that interface{}) bool

func (*ConnectResp) GetConn 

func (m *ConnectResp) GetConn() *Connection

func (*ConnectResp) GetError 

func (m *ConnectResp) GetError() string

func (*ConnectResp) GoString 

func (this *ConnectResp) GoString() string

func (*ConnectResp) Marshal 

func (m *ConnectResp) Marshal() (dAtA []byte, err error)

func (*ConnectResp) MarshalTo 

func (m *ConnectResp) MarshalTo(dAtA []byte) (int, error)

func (*ConnectResp) ProtoMessage 

func (*ConnectResp) ProtoMessage()

func (*ConnectResp) Reset 

func (m *ConnectResp) Reset()

func (*ConnectResp) Size 

func (m *ConnectResp) Size() (n int)

func (*ConnectResp) String 

func (this *ConnectResp) String() string

func (*ConnectResp) Unmarshal 

func (m *ConnectResp) Unmarshal(dAtA []byte) error

func (*ConnectResp) XXX_DiscardUnknown 

func (m *ConnectResp) XXX_DiscardUnknown()

func (*ConnectResp) XXX_Marshal 

func (m *ConnectResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectResp) XXX_Merge 

func (m *ConnectResp) XXX_Merge(src proto.Message)

func (*ConnectResp) XXX_Size 

func (m *ConnectResp) XXX_Size() int

func (*ConnectResp) XXX_Unmarshal 

func (m *ConnectResp) XXX_Unmarshal(b []byte) error

type Connected 

type Connected struct {
	Connection  *Connection // 连接
	IsReconnect bool        // 是否是重连
}

连接成功的消息

type Connection 

type Connection struct {
	Tag string     `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Pid *actor.PID `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"`
}

func Connect 

func Connect(config ConnectConfig) (*Connection, error)

连接MQ

func (*Connection) Close 

func (conn *Connection) Close() error

(同步)关闭连接

func (*Connection) Descriptor 

func (*Connection) Descriptor() ([]byte, []int)

func (*Connection) Equal 

func (this *Connection) Equal(that interface{}) bool

func (*Connection) GetPid 

func (m *Connection) GetPid() *actor.PID

func (*Connection) GetTag 

func (m *Connection) GetTag() string

func (*Connection) GoString 

func (this *Connection) GoString() string

func (*Connection) Marshal 

func (m *Connection) Marshal() (dAtA []byte, err error)

func (*Connection) MarshalTo 

func (m *Connection) MarshalTo(dAtA []byte) (int, error)

func (*Connection) NotifyClosed 

func (conn *Connection) NotifyClosed(pid *actor.PID) error

注册连接的关闭事件, 注册后,连接关闭时,会向监听进程发送消息: *riggerAmqp.ConnectionClosed 如果使用此函数注册监听时, 连接已经关闭, 则会立即触发一次事件

func (*Connection) NotifyConnected 

func (conn *Connection) NotifyConnected(pid *actor.PID) error

注册连接连接成功的事件, 注册后,如果连接连接成功, 则监听进程会收到消息: *riggerAmqp.Connected 如果注册时, 连接已经连接成功, 则会立即触发一次事件

func (*Connection) OpenChannel 

func (conn *Connection) OpenChannel() (*Channel, error)

在连接上打开一个频道

func (*Connection) ProtoMessage 

func (*Connection) ProtoMessage()

func (*Connection) Reset 

func (m *Connection) Reset()

func (*Connection) Size 

func (m *Connection) Size() (n int)

func (*Connection) String 

func (this *Connection) String() string

func (*Connection) UnNotifyClosed 

func (conn *Connection) UnNotifyClosed(pid *actor.PID)

func (*Connection) UnNotifyConnected 

func (conn *Connection) UnNotifyConnected(pid *actor.PID)

func (*Connection) Unmarshal 

func (m *Connection) Unmarshal(dAtA []byte) error

func (*Connection) XXX_DiscardUnknown 

func (m *Connection) XXX_DiscardUnknown()

func (*Connection) XXX_Marshal 

func (m *Connection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Connection) XXX_Merge 

func (m *Connection) XXX_Merge(src proto.Message)

func (*Connection) XXX_Size 

func (m *Connection) XXX_Size() int

func (*Connection) XXX_Unmarshal 

func (m *Connection) XXX_Unmarshal(b []byte) error

type ConnectionClosed 

type ConnectionClosed struct {
	Connection *Connection // 哪个连接断开了
	Error      error       //  如果错误为空
}

连接关闭时的消息

type ConsumeConfig 

type ConsumeConfig struct {
	Pid       *actor.PID // 消费者进程id
	Queue     string     // 队列名称
	Consumer  string     // 消费者名称
	AutoAck   bool
	Exclusive bool
	NoLocal   bool
	NoWait    bool
	Args      amqp.Table
}

type Delivery 

type Delivery struct {
	*amqp.Delivery
	// contains filtered or unexported fields
}

如果通过 riggerAmqp.Channel.Consume 接口消费消息, 则当有消费时,消费进程会收到 *riggerAmqp.Delivery 消息

func (*Delivery) Ack 

func (d *Delivery) Ack(multiple bool) error

确认消息

func (*Delivery) Nack 

func (d *Delivery) Nack(multiple, requeue bool) error

消息处理失败

func (*Delivery) Reject 

func (d *Delivery) Reject(requeue bool) error

拒绝消息

type ErrorConnInvalid 

type ErrorConnInvalid string

func (ErrorConnInvalid) Error 

func (e ErrorConnInvalid) Error() string

type ErrorFindNoPid 

type ErrorFindNoPid string

找不到进程ID

func (ErrorFindNoPid) Error 

func (e ErrorFindNoPid) Error() string

type ExchangeBindConfig 

type ExchangeBindConfig struct {
	Destination string
	Key         string
	Source      string
	NoWait      bool
	Args        amqp.Table
}

type ExchangeDeclareConfig 

type ExchangeDeclareConfig struct {
	Name       string
	Kind       ExchangeKind
	IsPassive  bool // 是否为passive模式,默认为false,如果为passive模式,则假定Exchange已经存在
	Durable    bool
	AutoDelete bool
	Internal   bool
	NoWait     bool
	Args       amqp.Table
}

type ExchangeDeleteConfig 

type ExchangeDeleteConfig struct {
	Name     string
	IfUnused bool
	NoWait   bool
}

type ExchangeKind 

type ExchangeKind string
const (
	ExchangeKindDirect  ExchangeKind = "direct"
	ExchangeKindFanout  ExchangeKind = "fanout"
	ExchangeKindTopic   ExchangeKind = "topic"
	ExchangeKindHeaders ExchangeKind = "headers"
)

The common types are "direct", "fanout", "topic" and "headers".

type ExchangeUnbindConfig 

type ExchangeUnbindConfig struct {
	Destination string
	Key         string
	Source      string
	NoWait      bool
	Args        amqp.Table
}

type Nack 

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

type OpenChannel 

type OpenChannel struct {
}

打开频道

func (*OpenChannel) Descriptor 

func (*OpenChannel) Descriptor() ([]byte, []int)

func (*OpenChannel) Equal 

func (this *OpenChannel) Equal(that interface{}) bool

func (*OpenChannel) GoString 

func (this *OpenChannel) GoString() string

func (*OpenChannel) Marshal 

func (m *OpenChannel) Marshal() (dAtA []byte, err error)

func (*OpenChannel) MarshalTo 

func (m *OpenChannel) MarshalTo(dAtA []byte) (int, error)

func (*OpenChannel) ProtoMessage 

func (*OpenChannel) ProtoMessage()

func (*OpenChannel) Reset 

func (m *OpenChannel) Reset()

func (*OpenChannel) Size 

func (m *OpenChannel) Size() (n int)

func (*OpenChannel) String 

func (this *OpenChannel) String() string

func (*OpenChannel) Unmarshal 

func (m *OpenChannel) Unmarshal(dAtA []byte) error

func (*OpenChannel) XXX_DiscardUnknown 

func (m *OpenChannel) XXX_DiscardUnknown()

func (*OpenChannel) XXX_Marshal 

func (m *OpenChannel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpenChannel) XXX_Merge 

func (m *OpenChannel) XXX_Merge(src proto.Message)

func (*OpenChannel) XXX_Size 

func (m *OpenChannel) XXX_Size() int

func (*OpenChannel) XXX_Unmarshal 

func (m *OpenChannel) XXX_Unmarshal(b []byte) error

type OpenChannelResp 

type OpenChannelResp struct {
	Error   string   `protobuf:"bytes,1,opt,name=Error,proto3" json:"Error,omitempty"`
	Channel *Channel `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
}

func (*OpenChannelResp) Descriptor 

func (*OpenChannelResp) Descriptor() ([]byte, []int)

func (*OpenChannelResp) Equal 

func (this *OpenChannelResp) Equal(that interface{}) bool

func (*OpenChannelResp) GetChannel 

func (m *OpenChannelResp) GetChannel() *Channel

func (*OpenChannelResp) GetError 

func (m *OpenChannelResp) GetError() string

func (*OpenChannelResp) GoString 

func (this *OpenChannelResp) GoString() string

func (*OpenChannelResp) Marshal 

func (m *OpenChannelResp) Marshal() (dAtA []byte, err error)

func (*OpenChannelResp) MarshalTo 

func (m *OpenChannelResp) MarshalTo(dAtA []byte) (int, error)

func (*OpenChannelResp) ProtoMessage 

func (*OpenChannelResp) ProtoMessage()

func (*OpenChannelResp) Reset 

func (m *OpenChannelResp) Reset()

func (*OpenChannelResp) Size 

func (m *OpenChannelResp) Size() (n int)

func (*OpenChannelResp) String 

func (this *OpenChannelResp) String() string

func (*OpenChannelResp) Unmarshal 

func (m *OpenChannelResp) Unmarshal(dAtA []byte) error

func (*OpenChannelResp) XXX_DiscardUnknown 

func (m *OpenChannelResp) XXX_DiscardUnknown()

func (*OpenChannelResp) XXX_Marshal 

func (m *OpenChannelResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpenChannelResp) XXX_Merge 

func (m *OpenChannelResp) XXX_Merge(src proto.Message)

func (*OpenChannelResp) XXX_Size 

func (m *OpenChannelResp) XXX_Size() int

func (*OpenChannelResp) XXX_Unmarshal 

func (m *OpenChannelResp) XXX_Unmarshal(b []byte) error

type Publish 

type Publish struct {
	Exchange  string
	Key       string
	Mandatory bool
	Immediate bool
	Message   *amqp.Publishing
}

type QueueBindConfig 

type QueueBindConfig struct {
	// name, key, exchange string, noWait bool, args Table
	Name     string
	Key      string
	Exchange string
	NoWait   bool
	Args     amqp.Table
}

type QueueDeclareConfig 

type QueueDeclareConfig struct {
	Name       string
	Durable    bool
	IsPassive  bool // 是否为passive模式,默认为false,如果为passive模式,则假定Exchange已经存在
	AutoDelete bool
	Exclusive  bool
	NoWait     bool
	Args       amqp.Table
}

type QueueDeleteConfig 

type QueueDeleteConfig struct {
	Name    string
	IfUsed  bool
	IfEmpty bool
	NoWait  bool
}

type QueueDeleteResp 

type QueueDeleteResp struct {
	Error  string `protobuf:"bytes,1,opt,name=Error,proto3" json:"Error,omitempty"`
	Purged int32  `protobuf:"varint,2,opt,name=purged,proto3" json:"purged,omitempty"`
}

func (*QueueDeleteResp) Descriptor 

func (*QueueDeleteResp) Descriptor() ([]byte, []int)

func (*QueueDeleteResp) Equal 

func (this *QueueDeleteResp) Equal(that interface{}) bool

func (*QueueDeleteResp) GetError 

func (m *QueueDeleteResp) GetError() string

func (*QueueDeleteResp) GetPurged 

func (m *QueueDeleteResp) GetPurged() int32

func (*QueueDeleteResp) GoString 

func (this *QueueDeleteResp) GoString() string

func (*QueueDeleteResp) Marshal 

func (m *QueueDeleteResp) Marshal() (dAtA []byte, err error)

func (*QueueDeleteResp) MarshalTo 

func (m *QueueDeleteResp) MarshalTo(dAtA []byte) (int, error)

func (*QueueDeleteResp) ProtoMessage 

func (*QueueDeleteResp) ProtoMessage()

func (*QueueDeleteResp) Reset 

func (m *QueueDeleteResp) Reset()

func (*QueueDeleteResp) Size 

func (m *QueueDeleteResp) Size() (n int)

func (*QueueDeleteResp) String 

func (this *QueueDeleteResp) String() string

func (*QueueDeleteResp) Unmarshal 

func (m *QueueDeleteResp) Unmarshal(dAtA []byte) error

func (*QueueDeleteResp) XXX_DiscardUnknown 

func (m *QueueDeleteResp) XXX_DiscardUnknown()

func (*QueueDeleteResp) XXX_Marshal 

func (m *QueueDeleteResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueDeleteResp) XXX_Merge 

func (m *QueueDeleteResp) XXX_Merge(src proto.Message)

func (*QueueDeleteResp) XXX_Size 

func (m *QueueDeleteResp) XXX_Size() int

func (*QueueDeleteResp) XXX_Unmarshal 

func (m *QueueDeleteResp) XXX_Unmarshal(b []byte) error

type QueueInspectConfig 

type QueueInspectConfig struct {
	Name string
}

type QueueInspection 

type QueueInspection struct {
	Error     string `protobuf:"bytes,1,opt,name=Error,proto3" json:"Error,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Messages  int32  `protobuf:"varint,3,opt,name=messages,proto3" json:"messages,omitempty"`
	Consumers int32  `protobuf:"varint,4,opt,name=consumers,proto3" json:"consumers,omitempty"`
}

func (*QueueInspection) Descriptor 

func (*QueueInspection) Descriptor() ([]byte, []int)

func (*QueueInspection) Equal 

func (this *QueueInspection) Equal(that interface{}) bool

func (*QueueInspection) GetConsumers 

func (m *QueueInspection) GetConsumers() int32

func (*QueueInspection) GetError 

func (m *QueueInspection) GetError() string

func (*QueueInspection) GetMessages 

func (m *QueueInspection) GetMessages() int32

func (*QueueInspection) GetName 

func (m *QueueInspection) GetName() string

func (*QueueInspection) GoString 

func (this *QueueInspection) GoString() string

func (*QueueInspection) Marshal 

func (m *QueueInspection) Marshal() (dAtA []byte, err error)

func (*QueueInspection) MarshalTo 

func (m *QueueInspection) MarshalTo(dAtA []byte) (int, error)

func (*QueueInspection) ProtoMessage 

func (*QueueInspection) ProtoMessage()

func (*QueueInspection) Reset 

func (m *QueueInspection) Reset()

func (*QueueInspection) Size 

func (m *QueueInspection) Size() (n int)

func (*QueueInspection) String 

func (this *QueueInspection) String() string

func (*QueueInspection) Unmarshal 

func (m *QueueInspection) Unmarshal(dAtA []byte) error

func (*QueueInspection) XXX_DiscardUnknown 

func (m *QueueInspection) XXX_DiscardUnknown()

func (*QueueInspection) XXX_Marshal 

func (m *QueueInspection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueueInspection) XXX_Merge 

func (m *QueueInspection) XXX_Merge(src proto.Message)

func (*QueueInspection) XXX_Size 

func (m *QueueInspection) XXX_Size() int

func (*QueueInspection) XXX_Unmarshal 

func (m *QueueInspection) XXX_Unmarshal(b []byte) error

type QueuePurgeConfig 

type QueuePurgeConfig struct {
	Name   string
	NoWait bool
}

type QueueUnbindConfig 

type QueueUnbindConfig struct {
	Name     string
	Key      string
	Exchange string
	Args     amqp.Table
}

type Reject 

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

type Session 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.