pubsub

Documentation

Index

• type Client
  • func NewClient(opts ...ClientOption) (*Client, error)
  • func (client *Client) Close()
  • func (client *Client) Topic(name string) *Topic
• type ClientOption
  • func DisableLocalEmulator() ClientOption
  • func WithProject(project string) ClientOption
• type Handler
• type LocalSubscribeOption
  • func WithFilter(filter string) LocalSubscribeOption
• type Message
  • func (msg *Message) ReadJSON(dest interface{}) error
  • func (msg *Message) ReadProto(dest proto.Message) error
• type PublishOption
  • func WithAttribute(key, value string) PublishOption
• type PushRequest
• type Server
  • func NewServer(r *hosting.WebServer, opts ...ServerOption) (*Server, error)
  • func (s *Server) Subscribe(subscription string, handler Handler)
• type ServerOption
  • func WithAudience(audience string) ServerOption
  • func WithServiceAccount(serviceAccount string) ServerOption
• type Topic
  • func (topic *Topic) LocalAssertSubscription(ctx context.Context, name string, opts ...LocalSubscribeOption) error
  • func (topic *Topic) PublishBytes(ctx context.Context, value []byte, opts ...PublishOption) error
  • func (topic *Topic) PublishJSON(ctx context.Context, value interface{}, opts ...PublishOption) error
  • func (topic *Topic) PublishProto(ctx context.Context, data proto.Message, opts ...PublishOption) error

Types

type Client

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

func NewClient

func NewClient(opts ...ClientOption) (*Client, error)

func (*Client) Close

func (client *Client) Close()

func (*Client) Topic

func (client *Client) Topic(name string) *Topic

type ClientOption

type ClientOption func(client *Client)

func DisableLocalEmulator

func DisableLocalEmulator() ClientOption

func WithProject

func WithProject(project string) ClientOption

type Handler

type Handler func(ctx context.Context, message *Message) error

type LocalSubscribeOption

type LocalSubscribeOption func(cnf *pubsub.SubscriptionConfig)

func WithFilter

func WithFilter(filter string) LocalSubscribeOption

type Message

type Message struct {
	ID         string            `json:"messageId"`
	Attributes map[string]string `json:"attributes"`

	RawData []byte `json:"data"`
}

func (*Message) ReadJSON

func (msg *Message) ReadJSON(dest interface{}) error

func (*Message) ReadProto

func (msg *Message) ReadProto(dest proto.Message) error

type PublishOption

type PublishOption func(msg *pubsub.Message)

func WithAttribute

func WithAttribute(key, value string) PublishOption

type PushRequest

type PushRequest struct {
	Subscription string   `json:"subscription"`
	Message      *Message `json:"message"`
}

type Server

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

func NewServer

func NewServer(r *hosting.WebServer, opts ...ServerOption) (*Server, error)

func (*Server) Subscribe

func (s *Server) Subscribe(subscription string, handler Handler)

type ServerOption

type ServerOption func(s *Server)

func WithAudience

func WithAudience(audience string) ServerOption

func WithServiceAccount

func WithServiceAccount(serviceAccount string) ServerOption

type Topic

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

func (*Topic) LocalAssertSubscription

func (topic *Topic) LocalAssertSubscription(ctx context.Context, name string, opts ...LocalSubscribeOption) error

func (*Topic) PublishBytes

func (topic *Topic) PublishBytes(ctx context.Context, value []byte, opts ...PublishOption) error

func (*Topic) PublishJSON

func (topic *Topic) PublishJSON(ctx context.Context, value interface{}, opts ...PublishOption) error

func (*Topic) PublishProto

func (topic *Topic) PublishProto(ctx context.Context, data proto.Message, opts ...PublishOption) error