queue

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

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

type Client struct {
	ClientId         string `json:"client_id"`
	Active           bool   `json:"active"`
	LastSequenceSent int64  `json:"last_sequence_sent"`
	IsStalled        bool   `json:"is_stalled"`
	Pending          int64  `json:"pending"`
}

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

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

type Queue struct {
	Name          string    `json:"name"`
	Messages      int64     `json:"messages"`
	Bytes         int64     `json:"bytes"`
	FirstSequence int64     `json:"first_sequence"`
	LastSequence  int64     `json:"last_sequence"`
	Clients       []*Client `json:"clients"`
}

type Queues struct {
	Now    time.Time `json:"now"`
	Total  int       `json:"total"`
	Queues []*Queue  `json:"queues"`
}

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

type Response struct {
	Node        string          `json:"node"`
	Error       bool            `json:"error"`
	ErrorString string          `json:"error_string"`
	Data        json.RawMessage `json:"data"`
}

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

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