pubsubv1sdk

Documentation

Index

• func NewPubsubServiceClient(uri string, options ...connect.ClientOption) pubsubv1.PubsubServiceClient
• type PubsubServiceClient
  • func (x *PubsubServiceClient) PushPubsubMessage(ctx context.Context, m *pubsubv1.PubsubMessage) error
• type PubsubServiceHandler
  • func (x *PubsubServiceHandler) Mount(r chi.Router)
  • func (x *PubsubServiceHandler) PushPubsubMessage(ctx context.Context, r *connect.Request[pubsubv1.PushPubsubMessageRequest]) (*connect.Response[pubsubv1.PushPubsubMessageResponse], error)

Functions

func NewPubsubServiceClient

func NewPubsubServiceClient(uri string, options ...connect.ClientOption) pubsubv1.PubsubServiceClient

NewPubsubServiceClient creates a new the google.pubsub.v1.PubsubServiceClient client.

Types

type PubsubServiceClient

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

PubsubServiceClient is a client for the google.pubsub.v1.PubsubService service.

func (*PubsubServiceClient) PushPubsubMessage

func (x *PubsubServiceClient) PushPubsubMessage(ctx context.Context, m *pubsubv1.PubsubMessage) error

PushPubsubMessage implements google.pubsub.v1.PubsubServiceClient.

type PubsubServiceHandler

type PubsubServiceHandler struct {
	// PubsubService contains an instance of google.pubsub.v1.PubsubService handler.
	PubsubService pubsubv1.PubsubService
}

PubsubServiceHandler represents an instance of google.pubsub.v1.PubsubServiceHandler handler.

func (*PubsubServiceHandler) Mount

func (x *PubsubServiceHandler) Mount(r chi.Router)

Mount mounts the controller to a given router.

func (*PubsubServiceHandler) PushPubsubMessage

func (x *PubsubServiceHandler) PushPubsubMessage(ctx context.Context, r *connect.Request[pubsubv1.PushPubsubMessageRequest]) (*connect.Response[pubsubv1.PushPubsubMessageResponse], error)

PushMessage implements MessageServiceHandler.