Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

api

package

Go to main page

Versions in this module

v0

v0.1.0

Oct 14, 2026

Changes in this version

+ func NewAckMessagesRequest(server string, subscriptionId SubscriptionId, body AckMessagesJSONRequestBody) (*http.Request, error)

+ func NewAckMessagesRequestWithBody(server string, subscriptionId SubscriptionId, contentType string, ...) (*http.Request, error)

+ func NewNackMessagesRequest(server string, subscriptionId SubscriptionId, body NackMessagesJSONRequestBody) (*http.Request, error)

+ func NewNackMessagesRequestWithBody(server string, subscriptionId SubscriptionId, contentType string, ...) (*http.Request, error)

+ func NewPublishMessagesRequest(server string, body PublishMessagesJSONRequestBody) (*http.Request, error)

+ func NewPublishMessagesRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

+ func NewPullMessagesRequest(server string, subscriptionId SubscriptionId, params *PullMessagesParams) (*http.Request, error)

+ func NewPurgeTopicRequest(server string) (*http.Request, error)

+ type AckMessagesFromTopicRequest struct

+ AckIds []string

+ type AckMessagesJSONRequestBody = AckMessagesFromTopicRequest

+ type AckMessagesResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParseAckMessagesResponse(rsp *http.Response) (*AckMessagesResponse, error)

+ func (r AckMessagesResponse) ContentType() string

+ func (r AckMessagesResponse) Status() string

+ func (r AckMessagesResponse) StatusCode() int

+ type Client struct

+ Client HttpRequestDoer

+ RequestEditors []RequestEditorFn

+ Server string

+ func NewClient(server string, opts ...ClientOption) (*Client, error)

+ func (c *Client) AckMessages(ctx context.Context, subscriptionId SubscriptionId, ...) (*http.Response, error)

+ func (c *Client) AckMessagesWithBody(ctx context.Context, subscriptionId SubscriptionId, contentType string, ...) (*http.Response, error)

+ func (c *Client) NackMessages(ctx context.Context, subscriptionId SubscriptionId, ...) (*http.Response, error)

+ func (c *Client) NackMessagesWithBody(ctx context.Context, subscriptionId SubscriptionId, contentType string, ...) (*http.Response, error)

+ func (c *Client) PublishMessages(ctx context.Context, body PublishMessagesJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) PublishMessagesWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ func (c *Client) PullMessages(ctx context.Context, subscriptionId SubscriptionId, params *PullMessagesParams, ...) (*http.Response, error)

+ func (c *Client) PurgeTopic(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ type ClientInterface interface

+ AckMessages func(ctx context.Context, subscriptionId SubscriptionId, ...) (*http.Response, error)

+ AckMessagesWithBody func(ctx context.Context, subscriptionId SubscriptionId, contentType string, ...) (*http.Response, error)

+ NackMessages func(ctx context.Context, subscriptionId SubscriptionId, ...) (*http.Response, error)

+ NackMessagesWithBody func(ctx context.Context, subscriptionId SubscriptionId, contentType string, ...) (*http.Response, error)

+ PublishMessages func(ctx context.Context, body PublishMessagesJSONRequestBody, ...) (*http.Response, error)

+ PublishMessagesWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ PullMessages func(ctx context.Context, subscriptionId SubscriptionId, params *PullMessagesParams, ...) (*http.Response, error)

+ PurgeTopic func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ type ClientOption func(*Client) error

+ func WithBaseURL(baseURL string) ClientOption

+ func WithHTTPClient(doer HttpRequestDoer) ClientOption

+ func WithRequestEditorFn(fn RequestEditorFn) ClientOption

+ type ClientWithResponses struct

+ func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, error)

+ func (c *ClientWithResponses) AckMessagesWithBodyWithResponse(ctx context.Context, subscriptionId SubscriptionId, contentType string, ...) (*AckMessagesResponse, error)

+ func (c *ClientWithResponses) AckMessagesWithResponse(ctx context.Context, subscriptionId SubscriptionId, ...) (*AckMessagesResponse, error)

+ func (c *ClientWithResponses) NackMessagesWithBodyWithResponse(ctx context.Context, subscriptionId SubscriptionId, contentType string, ...) (*NackMessagesResponse, error)

+ func (c *ClientWithResponses) NackMessagesWithResponse(ctx context.Context, subscriptionId SubscriptionId, ...) (*NackMessagesResponse, error)

+ func (c *ClientWithResponses) PublishMessagesWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*PublishMessagesResponse, error)

+ func (c *ClientWithResponses) PublishMessagesWithResponse(ctx context.Context, body PublishMessagesJSONRequestBody, ...) (*PublishMessagesResponse, error)

+ func (c *ClientWithResponses) PullMessagesWithResponse(ctx context.Context, subscriptionId SubscriptionId, params *PullMessagesParams, ...) (*PullMessagesResponse, error)

+ func (c *ClientWithResponses) PurgeTopicWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*PurgeTopicResponse, error)

+ type ClientWithResponsesInterface interface

+ AckMessagesWithBodyWithResponse func(ctx context.Context, subscriptionId SubscriptionId, contentType string, ...) (*AckMessagesResponse, error)

+ AckMessagesWithResponse func(ctx context.Context, subscriptionId SubscriptionId, ...) (*AckMessagesResponse, error)

+ NackMessagesWithBodyWithResponse func(ctx context.Context, subscriptionId SubscriptionId, contentType string, ...) (*NackMessagesResponse, error)

+ NackMessagesWithResponse func(ctx context.Context, subscriptionId SubscriptionId, ...) (*NackMessagesResponse, error)

+ PublishMessagesWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*PublishMessagesResponse, error)

+ PublishMessagesWithResponse func(ctx context.Context, body PublishMessagesJSONRequestBody, ...) (*PublishMessagesResponse, error)

+ PullMessagesWithResponse func(ctx context.Context, subscriptionId SubscriptionId, params *PullMessagesParams, ...) (*PullMessagesResponse, error)

+ PurgeTopicWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*PurgeTopicResponse, error)

+ type HttpRequestDoer interface

+ Do func(req *http.Request) (*http.Response, error)

+ type Message struct

+ AckId string

+ CreateTime time.Time

+ Data []byte

+ DeliveryAttempts uint64

+ type Messages struct

+ Messages []Message

+ type NackMessagesFromTopicRequest struct

+ NackIds []string

+ type NackMessagesJSONRequestBody = NackMessagesFromTopicRequest

+ type NackMessagesResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParseNackMessagesResponse(rsp *http.Response) (*NackMessagesResponse, error)

+ func (r NackMessagesResponse) ContentType() string

+ func (r NackMessagesResponse) Status() string

+ func (r NackMessagesResponse) StatusCode() int

+ type PublishMessage struct

+ Data []byte

+ type PublishMessageToTopicRequest struct

+ Messages []PublishMessage

+ type PublishMessagesJSONRequestBody = PublishMessageToTopicRequest

+ type PublishMessagesResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParsePublishMessagesResponse(rsp *http.Response) (*PublishMessagesResponse, error)

+ func (r PublishMessagesResponse) ContentType() string

+ func (r PublishMessagesResponse) Status() string

+ func (r PublishMessagesResponse) StatusCode() int

+ type PullMessagesParams struct

+ PubSubLongPullDuration *int32

+ PubSubMaxMessages *int32

+ type PullMessagesResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *Messages

+ func ParsePullMessagesResponse(rsp *http.Response) (*PullMessagesResponse, error)

+ func (r PullMessagesResponse) ContentType() string

+ func (r PullMessagesResponse) Status() string

+ func (r PullMessagesResponse) StatusCode() int

+ type PurgeTopicResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParsePurgeTopicResponse(rsp *http.Response) (*PurgeTopicResponse, error)

+ func (r PurgeTopicResponse) ContentType() string

+ func (r PurgeTopicResponse) Status() string

+ func (r PurgeTopicResponse) StatusCode() int

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

+ type SubscriptionId = openapi_types.UUID

v0.0.5

Aug 11, 2026

v0.0.4

Aug 6, 2026

v0.0.3

Jul 7, 2026

v0.0.2

May 29, 2026

v0.0.1

May 18, 2026