actions

type CreateChannelRequest struct {
	Type string `json:"type"`
	Name string `json:"name"`
}

type PurgeQueueChannelRequest struct {
	Channel string `json:"channel"`
}

type PurgeQueueChannelResponse struct {
	Count uint64 `json:"count"`
}

type ReceiveCQRSResponse struct {
	Metadata  string `json:"metadata,omitempty"`
	Body      any    `json:"body,omitempty"`
	Tags      string `json:"tags,omitempty"`
	Timestamp int64  `json:"timestamp,omitempty"`
	Executed  bool   `json:"executed"`
	Error     string `json:"error,omitempty"`
}

type ReceiveQueueMessageResponse struct {
	MessageId     string `json:"messageId"`
	ClientId      string `json:"clientId"`
	Metadata      string `json:"metadata"`
	Body          any    `json:"body"`
	Timestamp     int64  `json:"timestamp"`
	Sequence      int64  `json:"sequence"`
	Tags          string `json:"tags"`
	ReceivedCount int64  `json:"receivedCount"`
	ReRoutedFrom  string `json:"reRoutedFrom"`
	ExpirationAt  int64  `json:"expirationAt"`
	DelayedTo     int64  `json:"delayedTo"`
}

type ReceiveQueueMessagesRequest struct {
	Channel string `json:"channel"`
	IsPeek  bool   `json:"isPeek"`
	Count   int    `json:"count"`
}

type Request struct {
	Type string                 `json:"type"`
	Data map[string]interface{} `json:"data"`
}

type Response struct {
	Error string `json:"error,omitempty"`
	Data  any    `json:"data"`
}

type SendCQRSMessageRequest struct {
	RequestId  string `json:"requestId"`
	Channel    string `json:"channel"`
	Metadata   string `json:"metadata,omitempty"`
	Body       any    `json:"body"`
	Tags       string `json:"tags,omitempty"`
	IsCommands bool   `json:"isCommands"`
	Timeout    int    `json:"timeout"`
	// contains filtered or unexported fields
}

type SendCQRSMessageResponse struct {
	RequestId    string `json:"requestId"`
	ReplyChannel string `json:"replyChannel"`
	Metadata     string `json:"metadata,omitempty"`
	Body         any    `json:"body"`
	Tags         string `json:"tags,omitempty"`
	Executed     bool   `json:"executed"`
	Error        string `json:"error,omitempty"`
	// contains filtered or unexported fields
}

type SendPubSubMessageRequest struct {
	MessageId string `json:"messageId,omitempty"`
	Channel   string `json:"channel"`
	ClientId  string `json:"clientId,omitempty"`
	Metadata  string `json:"metadata,omitempty"`
	Body      any    `json:"body"`
	Tags      string `json:"tags,omitempty"`
	IsEvents  bool   `json:"isEvents,omitempty"`
	// contains filtered or unexported fields
}

type SendQueueMessageRequest struct {
	MessageId       string `json:"messageId,omitempty"`
	Channel         string `json:"channel"`
	ClientId        string `json:"clientId,omitempty"`
	Metadata        string `json:"metadata,omitempty"`
	Body            any    `json:"body"`
	Tags            string `json:"tags,omitempty"`
	MaxReceiveCount int    `json:"maxReceiveCount,omitempty"`
	MaxReceiveQueue string `json:"maxReceiveQueue,omitempty"`
	ExpirationAt    int    `json:"expirationAt,omitempty"`
	DelayedTo       int    `json:"delayedTo,omitempty"`
	// contains filtered or unexported fields
}

type SendQueueMessageResponse struct {
	MessageId string `json:"messageId,omitempty"`
	SentAt    string `json:"sentAt,omitempty"`
	ExpiresAt string `json:"expiresAt,omitempty"`
	DelayedTo string `json:"delayedTo,omitempty"`
}

type StreamQueueMessagesRequest struct {
	RequestType       StreamQueueMessagesRequestType `json:"requestType"`
	Channel           string                         `json:"channel"`
	VisibilitySeconds int                            `json:"visibilitySeconds"`
	WaitSeconds       int                            `json:"waitSeconds"`
	RefSequence       int64                          `json:"refSequence"`
}

type StreamQueueMessagesRequestType string

type StreamQueueMessagesResponse struct {
	RequestType StreamQueueMessagesRequestType `json:"requestType"`
	Message     *ReceiveQueueMessageResponse   `json:"message"`
	Error       string                         `json:"error"`
	IsError     bool                           `json:"isError"`
}

type SubscribeCQRSRequestMessage struct {
	RequestId    string `json:"requestId"`
	Metadata     string `json:"metadata"`
	Body         any    `json:"body"`
	Timestamp    int64  `json:"timestamp"`
	ReplyChannel string `json:"replyChannel"`
	Tags         string `json:"tags"`
	IsCommand    bool   `json:"isCommand"`
}

type SubscribePubSubMessage struct {
	MessageId string `json:"messageId"`
	Metadata  string `json:"metadata"`
	Body      any    `json:"body"`
	Timestamp int64  `json:"timestamp"`
	Tags      string `json:"tags,omitempty"`
	Sequence  int64  `json:"sequence,omitempty"`
}