amqpb

type AMQClient interface {
	// Client management
	RegisterClient(ctx context.Context, in *RegisterClientRequest, opts ...grpc.CallOption) (*RegisterClientResponse, error)
	UnregisterClient(ctx context.Context, in *UnregisterClientRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Queue management
	CreateQueue(ctx context.Context, in *CreateQueueRequest, opts ...grpc.CallOption) (*CreateQueueResponse, error)
	DeleteQueue(ctx context.Context, in *DeleteQueueRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListQueues(ctx context.Context, in *ListQueuesRequest, opts ...grpc.CallOption) (*ListQueuesResponse, error)
	GetQueueStats(ctx context.Context, in *GetQueueStatsRequest, opts ...grpc.CallOption) (*GetQueueStatsResponse, error)
	// Subscription management
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Unsubscribe(ctx context.Context, in *UnsubscribeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Message operations
	SubmitTask(ctx context.Context, in *SubmitTaskRequest, opts ...grpc.CallOption) (*SubmitTaskResponse, error)
	SendDirect(ctx context.Context, in *SendDirectRequest, opts ...grpc.CallOption) (*SendDirectResponse, error)
	ReceiveMessages(ctx context.Context, in *ReceiveMessagesRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Message], error)
	AckMessage(ctx context.Context, in *AckMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	NackMessage(ctx context.Context, in *NackMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Batch operations for performance
	SubmitTaskBatch(ctx context.Context, in *SubmitTaskBatchRequest, opts ...grpc.CallOption) (*SubmitTaskBatchResponse, error)
	AckMessageBatch(ctx context.Context, in *AckMessageBatchRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Monitoring
	GetClientInfo(ctx context.Context, in *GetClientInfoRequest, opts ...grpc.CallOption) (*ClientInfo, error)
	ListClients(ctx context.Context, in *ListClientsRequest, opts ...grpc.CallOption) (*ListClientsResponse, error)
	GetMetrics(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*MetricsResponse, error)
}

type AMQServer interface {
	// Client management
	RegisterClient(context.Context, *RegisterClientRequest) (*RegisterClientResponse, error)
	UnregisterClient(context.Context, *UnregisterClientRequest) (*emptypb.Empty, error)
	Heartbeat(context.Context, *HeartbeatRequest) (*emptypb.Empty, error)
	// Queue management
	CreateQueue(context.Context, *CreateQueueRequest) (*CreateQueueResponse, error)
	DeleteQueue(context.Context, *DeleteQueueRequest) (*emptypb.Empty, error)
	ListQueues(context.Context, *ListQueuesRequest) (*ListQueuesResponse, error)
	GetQueueStats(context.Context, *GetQueueStatsRequest) (*GetQueueStatsResponse, error)
	// Subscription management
	Subscribe(context.Context, *SubscribeRequest) (*emptypb.Empty, error)
	Unsubscribe(context.Context, *UnsubscribeRequest) (*emptypb.Empty, error)
	// Message operations
	SubmitTask(context.Context, *SubmitTaskRequest) (*SubmitTaskResponse, error)
	SendDirect(context.Context, *SendDirectRequest) (*SendDirectResponse, error)
	ReceiveMessages(*ReceiveMessagesRequest, grpc.ServerStreamingServer[Message]) error
	AckMessage(context.Context, *AckMessageRequest) (*emptypb.Empty, error)
	NackMessage(context.Context, *NackMessageRequest) (*emptypb.Empty, error)
	// Batch operations for performance
	SubmitTaskBatch(context.Context, *SubmitTaskBatchRequest) (*SubmitTaskBatchResponse, error)
	AckMessageBatch(context.Context, *AckMessageBatchRequest) (*emptypb.Empty, error)
	// Monitoring
	GetClientInfo(context.Context, *GetClientInfoRequest) (*ClientInfo, error)
	ListClients(context.Context, *ListClientsRequest) (*ListClientsResponse, error)
	GetMetrics(context.Context, *GetMetricsRequest) (*MetricsResponse, error)
	// contains filtered or unexported methods
}

type AMQ_ReceiveMessagesClient = grpc.ServerStreamingClient[Message]

type AMQ_ReceiveMessagesServer = grpc.ServerStreamingServer[Message]

type AckMessageBatchRequest struct {
	ClientId   string   `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	MessageIds []string `protobuf:"bytes,2,rep,name=message_ids,json=messageIds,proto3" json:"message_ids,omitempty"`
	// contains filtered or unexported fields
}

type AckMessageRequest struct {
	ClientId  string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	MessageId string `protobuf:"bytes,2,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// contains filtered or unexported fields
}

type ClientCapabilities struct {
	MaxConcurrentMessages int32    `` /* 127-byte string literal not displayed */
	SupportedEncodings    []string `protobuf:"bytes,2,rep,name=supported_encodings,json=supportedEncodings,proto3" json:"supported_encodings,omitempty"`
	SupportsBatch         bool     `protobuf:"varint,3,opt,name=supports_batch,json=supportsBatch,proto3" json:"supports_batch,omitempty"`
	PrefetchCount         int32    `protobuf:"varint,4,opt,name=prefetch_count,json=prefetchCount,proto3" json:"prefetch_count,omitempty"`
	// contains filtered or unexported fields
}

type ClientInfo struct {
	Id               string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Metadata         map[string]string      `` /* 143-byte string literal not displayed */
	RegisteredAt     *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=registered_at,json=registeredAt,proto3" json:"registered_at,omitempty"`
	LastSeen         *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	Subscriptions    []string               `protobuf:"bytes,5,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	MessagesSent     int64                  `protobuf:"varint,6,opt,name=messages_sent,json=messagesSent,proto3" json:"messages_sent,omitempty"`
	MessagesReceived int64                  `protobuf:"varint,7,opt,name=messages_received,json=messagesReceived,proto3" json:"messages_received,omitempty"`
	Capabilities     *ClientCapabilities    `protobuf:"bytes,8,opt,name=capabilities,proto3" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

type CreateQueueRequest struct {
	Name   string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type   QueueType    `protobuf:"varint,2,opt,name=type,proto3,enum=amq.v1.QueueType" json:"type,omitempty"`
	Config *QueueConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type CreateQueueResponse struct {
	QueueId   string                 `protobuf:"bytes,1,opt,name=queue_id,json=queueId,proto3" json:"queue_id,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

type DeleteQueueRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Force bool   `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"` // Delete even if not empty
	// contains filtered or unexported fields
}

type GetClientInfoRequest struct {
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

type GetMetricsRequest struct {
	MetricNames []string `protobuf:"bytes,1,rep,name=metric_names,json=metricNames,proto3" json:"metric_names,omitempty"`
	// contains filtered or unexported fields
}

type GetQueueStatsRequest struct {
	QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	// contains filtered or unexported fields
}

type GetQueueStatsResponse struct {
	MessageCount     int64                  `protobuf:"varint,1,opt,name=message_count,json=messageCount,proto3" json:"message_count,omitempty"`
	MessagesInFlight int64                  `protobuf:"varint,2,opt,name=messages_in_flight,json=messagesInFlight,proto3" json:"messages_in_flight,omitempty"`
	SubscriberCount  int32                  `protobuf:"varint,3,opt,name=subscriber_count,json=subscriberCount,proto3" json:"subscriber_count,omitempty"`
	EnqueueRate      float64                `protobuf:"fixed64,4,opt,name=enqueue_rate,json=enqueueRate,proto3" json:"enqueue_rate,omitempty"` // messages per second
	DequeueRate      float64                `protobuf:"fixed64,5,opt,name=dequeue_rate,json=dequeueRate,proto3" json:"dequeue_rate,omitempty"` // messages per second
	TotalEnqueued    int64                  `protobuf:"varint,6,opt,name=total_enqueued,json=totalEnqueued,proto3" json:"total_enqueued,omitempty"`
	TotalDequeued    int64                  `protobuf:"varint,7,opt,name=total_dequeued,json=totalDequeued,proto3" json:"total_dequeued,omitempty"`
	TotalAcked       int64                  `protobuf:"varint,8,opt,name=total_acked,json=totalAcked,proto3" json:"total_acked,omitempty"`
	OldestMessage    *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=oldest_message,json=oldestMessage,proto3" json:"oldest_message,omitempty"`
	// contains filtered or unexported fields
}

type HeartbeatRequest struct {
	ClientId string             `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Metrics  map[string]float64 `` // CPU usage, memory, etc
	/* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ListClientsRequest struct {
	FilterMetadata map[string]string `` /* 177-byte string literal not displayed */
	PageSize       int32             `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken      string            `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListClientsResponse struct {
	Clients       []*ClientInfo `protobuf:"bytes,1,rep,name=clients,proto3" json:"clients,omitempty"`
	NextPageToken string        `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListQueuesRequest struct {
	Filter    string `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	PageSize  int32  `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListQueuesResponse struct {
	Queues        []*QueueInfo `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"`
	NextPageToken string       `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

type Message struct {
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	FromClientId  string                 `protobuf:"bytes,2,opt,name=from_client_id,json=fromClientId,proto3" json:"from_client_id,omitempty"`
	Topic         string                 `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	Payload       []byte                 `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	Status        MessageStatus          `protobuf:"varint,5,opt,name=status,proto3,enum=amq.v1.MessageStatus" json:"status,omitempty"`
	Priority      int32                  `protobuf:"varint,6,opt,name=priority,proto3" json:"priority,omitempty"`
	RetryCount    int32                  `protobuf:"varint,7,opt,name=retry_count,json=retryCount,proto3" json:"retry_count,omitempty"`
	Metadata      map[string]string      `` /* 143-byte string literal not displayed */
	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ExpiresAt     *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	CorrelationId string                 `protobuf:"bytes,11,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	ReplyTo       string                 `protobuf:"bytes,12,opt,name=reply_to,json=replyTo,proto3" json:"reply_to,omitempty"`
	// contains filtered or unexported fields
}

type MessageOptions struct {
	Priority      int32                `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"` // 0-9, higher is more important
	Ttl           *durationpb.Duration `protobuf:"bytes,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
	MaxRetries    int32                `protobuf:"varint,3,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	Metadata      map[string]string    `` /* 143-byte string literal not displayed */
	CorrelationId string               `protobuf:"bytes,5,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	ReplyTo       string               `protobuf:"bytes,6,opt,name=reply_to,json=replyTo,proto3" json:"reply_to,omitempty"`
	// contains filtered or unexported fields
}

type MessageStatus int32

type MetricValue struct {

	// Types that are valid to be assigned to Value:
	//
	//	*MetricValue_IntValue
	//	*MetricValue_DoubleValue
	//	*MetricValue_StringValue
	Value isMetricValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

type MetricValue_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,2,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type MetricValue_IntValue struct {
	IntValue int64 `protobuf:"varint,1,opt,name=int_value,json=intValue,proto3,oneof"`
}

type MetricValue_StringValue struct {
	StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type MetricsResponse struct {
	Metrics   map[string]*MetricValue `` /* 141-byte string literal not displayed */
	Timestamp *timestamppb.Timestamp  `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type NackMessageRequest struct {
	ClientId  string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	MessageId string `protobuf:"bytes,2,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Requeue   bool   `protobuf:"varint,3,opt,name=requeue,proto3" json:"requeue,omitempty"`
	Reason    string `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

type QueueConfig struct {
	MaxDepth         int32                `protobuf:"varint,1,opt,name=max_depth,json=maxDepth,proto3" json:"max_depth,omitempty"`
	MessageTtl       *durationpb.Duration `protobuf:"bytes,2,opt,name=message_ttl,json=messageTtl,proto3" json:"message_ttl,omitempty"`
	MaxRetries       int32                `protobuf:"varint,3,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	EnableDeadLetter bool                 `protobuf:"varint,4,opt,name=enable_dead_letter,json=enableDeadLetter,proto3" json:"enable_dead_letter,omitempty"`
	DeadLetterQueue  string               `protobuf:"bytes,5,opt,name=dead_letter_queue,json=deadLetterQueue,proto3" json:"dead_letter_queue,omitempty"`
	// contains filtered or unexported fields
}

type QueueInfo struct {
	Name            string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type            QueueType              `protobuf:"varint,2,opt,name=type,proto3,enum=amq.v1.QueueType" json:"type,omitempty"`
	MessageCount    int64                  `protobuf:"varint,3,opt,name=message_count,json=messageCount,proto3" json:"message_count,omitempty"`
	SubscriberCount int32                  `protobuf:"varint,4,opt,name=subscriber_count,json=subscriberCount,proto3" json:"subscriber_count,omitempty"`
	CreatedAt       *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

type QueueType int32

type ReceiveMessagesRequest struct {
	ClientId    string               `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	MaxMessages int32                `protobuf:"varint,2,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	WaitTime    *durationpb.Duration `protobuf:"bytes,3,opt,name=wait_time,json=waitTime,proto3" json:"wait_time,omitempty"` // Long polling
	AutoAck     bool                 `protobuf:"varint,4,opt,name=auto_ack,json=autoAck,proto3" json:"auto_ack,omitempty"`
	// contains filtered or unexported fields
}

type RegisterClientRequest struct {
	ClientId     string              `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Metadata     map[string]string   `` /* 143-byte string literal not displayed */
	Capabilities *ClientCapabilities `protobuf:"bytes,3,opt,name=capabilities,proto3" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

type RegisterClientResponse struct {
	SessionId    string                 `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	RegisteredAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=registered_at,json=registeredAt,proto3" json:"registered_at,omitempty"`
	// contains filtered or unexported fields
}

type SendDirectRequest struct {
	FromClientId string          `protobuf:"bytes,1,opt,name=from_client_id,json=fromClientId,proto3" json:"from_client_id,omitempty"`
	ToClientId   string          `protobuf:"bytes,2,opt,name=to_client_id,json=toClientId,proto3" json:"to_client_id,omitempty"`
	Payload      []byte          `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	Options      *MessageOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

type SendDirectResponse struct {
	MessageId string                 `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	SentAt    *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
	// contains filtered or unexported fields
}

type SubmitTaskBatchRequest struct {
	ClientId string      `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Items    []*TaskItem `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

type SubmitTaskBatchResponse struct {
	Results []*TaskResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

type SubmitTaskRequest struct {
	ClientId string          `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Topic    string          `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Payload  []byte          `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	Options  *MessageOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

type SubmitTaskResponse struct {
	MessageId   string                 `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	SubmittedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=submitted_at,json=submittedAt,proto3" json:"submitted_at,omitempty"`
	// contains filtered or unexported fields
}

type SubscribeRequest struct {
	ClientId string               `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Topics   []string             `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics,omitempty"`
	Options  *SubscriptionOptions `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

type SubscriptionOptions struct {
	Priority         int32  `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"`                                        // Higher priority clients get messages first
	FilterExpression string `protobuf:"bytes,2,opt,name=filter_expression,json=filterExpression,proto3" json:"filter_expression,omitempty"` // Optional message filter
	Exclusive        bool   `protobuf:"varint,3,opt,name=exclusive,proto3" json:"exclusive,omitempty"`                                      // Only one client receives each message
	// contains filtered or unexported fields
}

type TaskItem struct {
	Topic   string          `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Payload []byte          `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Options *MessageOptions `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

type TaskResult struct {
	MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Success   bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Error     string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedAMQServer struct{}

type UnregisterClientRequest struct {
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

type UnsafeAMQServer interface {
	// contains filtered or unexported methods
}

type UnsubscribeRequest struct {
	ClientId string   `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Topics   []string `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}