unifrost: github.com/unifrost/unifrost/drivers/gcpdriver Index | Files

package gcpdriver

import "github.com/unifrost/unifrost/drivers/gcpdriver"


Package Files


type Client Uses

type Client struct {
    // contains filtered or unexported fields

Client handles the subscriptions to the GCP PubSub broker topics

func NewClient Uses

func NewClient(ctx context.Context, conn *grpc.ClientConn, projectID gcp.ProjectID, opts ...Option) (*Client, error)

NewClient returns *gcpdriver.Client, also creates a GCP pub-sub broker client.

conn is the client connection returned by gcppubsub.Dial for connecting to GCP pub-sub broker, projectID is the project ID for your GCP project. Additional configuration options can be added with gcppubsub.Option functions.

func (*Client) Close Uses

func (client *Client) Close(ctx context.Context) error

Close closes the GRPC connection to GCP PubSub broker

func (*Client) Subscribe Uses

func (client *Client) Subscribe(ctx context.Context, subscription string) (*pubsub.Subscription, error)

Subscribe method subscribes to the GCP PubSub subscription

type Option Uses

type Option func(*Client) error

Option is a self-refrential function for configuration parameters

Package gcpdriver imports 6 packages (graph). Updated 2020-01-31. Refresh now. Tools for package owners.