api

type AckMessagesFromTopicRequest struct {
	// AckIds List of ids to acknowledge.
	AckIds []string `json:"ackIds"`
}

type AckMessagesJSONRequestBody = AckMessagesFromTopicRequest

type AckMessagesResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type Client struct {
	// The endpoint of the server conforming to this interface, with scheme,
	// https://api.deepmap.com for example. This can contain a path relative
	// to the server, such as https://api.deepmap.com/dev-test, and all the
	// paths in the swagger spec will be appended to the server.
	Server string

	// Doer for performing requests, typically a *http.Client with any
	// customized settings, such as certificate chains.
	Client HttpRequestDoer

	// A list of callbacks for modifying requests which are generated before sending over
	// the network.
	RequestEditors []RequestEditorFn
}

type ClientInterface interface {
	// PublishMessagesWithBody request with any body
	PublishMessagesWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	PublishMessages(ctx context.Context, body PublishMessagesJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// PurgeTopic request
	PurgeTopic(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// AckMessagesWithBody request with any body
	AckMessagesWithBody(ctx context.Context, subscriptionId SubscriptionId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	AckMessages(ctx context.Context, subscriptionId SubscriptionId, body AckMessagesJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// NackMessagesWithBody request with any body
	NackMessagesWithBody(ctx context.Context, subscriptionId SubscriptionId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	NackMessages(ctx context.Context, subscriptionId SubscriptionId, body NackMessagesJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// PullMessages request
	PullMessages(ctx context.Context, subscriptionId SubscriptionId, params *PullMessagesParams, reqEditors ...RequestEditorFn) (*http.Response, error)
}

type ClientOption func(*Client) error

type ClientWithResponses struct {
	ClientInterface
}

type ClientWithResponsesInterface interface {
	// PublishMessagesWithBodyWithResponse request with any body
	PublishMessagesWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PublishMessagesResponse, error)

	PublishMessagesWithResponse(ctx context.Context, body PublishMessagesJSONRequestBody, reqEditors ...RequestEditorFn) (*PublishMessagesResponse, error)

	// PurgeTopicWithResponse request
	PurgeTopicWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*PurgeTopicResponse, error)

	// AckMessagesWithBodyWithResponse request with any body
	AckMessagesWithBodyWithResponse(ctx context.Context, subscriptionId SubscriptionId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*AckMessagesResponse, error)

	AckMessagesWithResponse(ctx context.Context, subscriptionId SubscriptionId, body AckMessagesJSONRequestBody, reqEditors ...RequestEditorFn) (*AckMessagesResponse, error)

	// NackMessagesWithBodyWithResponse request with any body
	NackMessagesWithBodyWithResponse(ctx context.Context, subscriptionId SubscriptionId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*NackMessagesResponse, error)

	NackMessagesWithResponse(ctx context.Context, subscriptionId SubscriptionId, body NackMessagesJSONRequestBody, reqEditors ...RequestEditorFn) (*NackMessagesResponse, error)

	// PullMessagesWithResponse request
	PullMessagesWithResponse(ctx context.Context, subscriptionId SubscriptionId, params *PullMessagesParams, reqEditors ...RequestEditorFn) (*PullMessagesResponse, error)
}

type HttpRequestDoer interface {
	Do(req *http.Request) (*http.Response, error)
}

type Message struct {
	// AckId An auto generated unique id for acknowledging the message.
	AckId string `json:"ackId"`

	// CreateTime The point in time the resource was created.
	CreateTime time.Time `json:"createTime"`

	// Data Base64 encoded messages.
	Data []byte `json:"data"`

	// DeliveryAttempts Number of times the message has been tried to be delivered.
	DeliveryAttempts uint64 `json:"deliveryAttempts"`
}

type Messages struct {
	Messages []Message `json:"messages"`
}

type NackMessagesFromTopicRequest struct {
	// NackIds List of ids to not acknowledge.
	NackIds []string `json:"nackIds"`
}

type NackMessagesJSONRequestBody = NackMessagesFromTopicRequest

type NackMessagesResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type PublishMessage struct {
	// Data Base64 encoded message payload.
	Data []byte `json:"data"`
}

type PublishMessageToTopicRequest struct {
	// Messages The messages to publish.
	Messages []PublishMessage `json:"messages"`
}

type PublishMessagesJSONRequestBody = PublishMessageToTopicRequest

type PublishMessagesResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type PullMessagesParams struct {
	// PubSubMaxMessages The maximum number of messages to pull.
	PubSubMaxMessages *int32 `json:"PubSub-Max-Messages,omitempty"`

	// PubSubLongPullDuration The maximum amount of milliseconds to keep an connection open, awaiting a new message on the server.
	PubSubLongPullDuration *int32 `json:"PubSub-Long-Pull-Duration,omitempty"`
}

type PullMessagesResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *Messages
}

type PurgeTopicResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

type RequestEditorFn func(ctx context.Context, req *http.Request) error

type SubscriptionId = openapi_types.UUID