gen

Documentation

Index

• Variables
• type BindingState
  • func (*BindingState) Descriptor() ([]byte, []int)
  • func (m *BindingState) Marshal() (dAtA []byte, err error)
  • func (m *BindingState) MarshalTo(dAtA []byte) (int, error)
  • func (*BindingState) ProtoMessage()
  • func (m *BindingState) Reset()
  • func (m *BindingState) Size() (n int)
  • func (m *BindingState) String() string
  • func (m *BindingState) Unmarshal(dAtA []byte) error
  • func (m *BindingState) XXX_DiscardUnknown()
  • func (m *BindingState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *BindingState) XXX_Merge(src proto.Message)
  • func (m *BindingState) XXX_Size() int
  • func (m *BindingState) XXX_Unmarshal(b []byte) error
• type ExchangeState
  • func (*ExchangeState) Descriptor() ([]byte, []int)
  • func (m *ExchangeState) Marshal() (dAtA []byte, err error)
  • func (m *ExchangeState) MarshalTo(dAtA []byte) (int, error)
  • func (*ExchangeState) ProtoMessage()
  • func (m *ExchangeState) Reset()
  • func (m *ExchangeState) Size() (n int)
  • func (m *ExchangeState) String() string
  • func (m *ExchangeState) Unmarshal(dAtA []byte) error
  • func (m *ExchangeState) XXX_DiscardUnknown()
  • func (m *ExchangeState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ExchangeState) XXX_Merge(src proto.Message)
  • func (m *ExchangeState) XXX_Size() int
  • func (m *ExchangeState) XXX_Unmarshal(b []byte) error
• type QueueState
  • func (*QueueState) Descriptor() ([]byte, []int)
  • func (m *QueueState) Marshal() (dAtA []byte, err error)
  • func (m *QueueState) MarshalTo(dAtA []byte) (int, error)
  • func (*QueueState) ProtoMessage()
  • func (m *QueueState) Reset()
  • func (m *QueueState) Size() (n int)
  • func (m *QueueState) String() string
  • func (m *QueueState) Unmarshal(dAtA []byte) error
  • func (m *QueueState) XXX_DiscardUnknown()
  • func (m *QueueState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *QueueState) XXX_Merge(src proto.Message)
  • func (m *QueueState) XXX_Size() int
  • func (m *QueueState) XXX_Unmarshal(b []byte) error

Variables

var (
	ErrInvalidLengthServer = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowServer   = fmt.Errorf("proto: integer overflow")
)

Types

type BindingState

type BindingState struct {
	Id                   []byte      `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	QueueName            string      `protobuf:"bytes,2,opt,name=queue_name,json=queueName" json:"queue_name"`
	ExchangeName         string      `protobuf:"bytes,3,opt,name=exchange_name,json=exchangeName" json:"exchange_name"`
	Key                  string      `protobuf:"bytes,4,opt,name=key" json:"key"`
	Arguments            *amqp.Table `protobuf:"bytes,5,opt,name=arguments" json:"arguments,omitempty"`
	Topic                bool        `protobuf:"varint,6,opt,name=topic" json:"topic"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*BindingState) Descriptor

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

func (*BindingState) Marshal

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

func (*BindingState) MarshalTo

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

func (*BindingState) ProtoMessage

func (*BindingState) ProtoMessage()

func (*BindingState) Reset

func (m *BindingState) Reset()

func (*BindingState) Size

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

func (*BindingState) String

func (m *BindingState) String() string

func (*BindingState) Unmarshal

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

func (*BindingState) XXX_DiscardUnknown

func (m *BindingState) XXX_DiscardUnknown()

func (*BindingState) XXX_Marshal

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

func (*BindingState) XXX_Merge

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

func (*BindingState) XXX_Size

func (m *BindingState) XXX_Size() int

func (*BindingState) XXX_Unmarshal

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

type ExchangeState

type ExchangeState struct {
	Name                 string      `protobuf:"bytes,1,opt,name=name" json:"name"`
	ExType               uint8       `protobuf:"varint,2,opt,name=ex_type,json=exType,casttype=uint8" json:"ex_type"`
	Passive              bool        `protobuf:"varint,3,opt,name=passive" json:"passive"`
	Durable              bool        `protobuf:"varint,4,opt,name=durable" json:"durable"`
	AutoDelete           bool        `protobuf:"varint,5,opt,name=auto_delete,json=autoDelete" json:"auto_delete"`
	Internal             bool        `protobuf:"varint,6,opt,name=internal" json:"internal"`
	System               bool        `protobuf:"varint,7,opt,name=system" json:"system"`
	Arguments            *amqp.Table `protobuf:"bytes,8,opt,name=arguments" json:"arguments,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ExchangeState) Descriptor

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

func (*ExchangeState) Marshal

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

func (*ExchangeState) MarshalTo

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

func (*ExchangeState) ProtoMessage

func (*ExchangeState) ProtoMessage()

func (*ExchangeState) Reset

func (m *ExchangeState) Reset()

func (*ExchangeState) Size

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

func (*ExchangeState) String

func (m *ExchangeState) String() string

func (*ExchangeState) Unmarshal

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

func (*ExchangeState) XXX_DiscardUnknown

func (m *ExchangeState) XXX_DiscardUnknown()

func (*ExchangeState) XXX_Marshal

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

func (*ExchangeState) XXX_Merge

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

func (*ExchangeState) XXX_Size

func (m *ExchangeState) XXX_Size() int

func (*ExchangeState) XXX_Unmarshal

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

type QueueState

type QueueState struct {
	Name                 string      `protobuf:"bytes,1,opt,name=name" json:"name"`
	Durable              bool        `protobuf:"varint,2,opt,name=durable" json:"durable"`
	Arguments            *amqp.Table `protobuf:"bytes,3,opt,name=arguments" json:"arguments,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*QueueState) Descriptor

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

func (*QueueState) Marshal

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

func (*QueueState) MarshalTo

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

func (*QueueState) ProtoMessage

func (*QueueState) ProtoMessage()

func (*QueueState) Reset

func (m *QueueState) Reset()

func (*QueueState) Size

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

func (*QueueState) String

func (m *QueueState) String() string

func (*QueueState) Unmarshal

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

func (*QueueState) XXX_DiscardUnknown

func (m *QueueState) XXX_DiscardUnknown()

func (*QueueState) XXX_Marshal

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

func (*QueueState) XXX_Merge

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

func (*QueueState) XXX_Size

func (m *QueueState) XXX_Size() int

func (*QueueState) XXX_Unmarshal

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