pubsub

Documentation

Index

• type Dumper
  • func NewDumper(outDir string) *Dumper
  • func (x *Dumper) Publish(ctx context.Context, data []byte) (types.PubSubMessageID, error)
• type Mock
  • func NewMock() *Mock
  • func (x *Mock) Publish(ctx context.Context, data []byte) (types.PubSubMessageID, error)
• type MockResult
• type SubscriptionClient
  • func NewSubscriptionClient(ctx context.Context) (*SubscriptionClient, error)
  • func (x *SubscriptionClient) Acknowledge(ctx context.Context, subName string, ackID string) error
  • func (x *SubscriptionClient) Close() error
  • func (x *SubscriptionClient) ModifyAckDeadline(ctx context.Context, subName string, ackID string, deadline time.Duration) error
  • func (x *SubscriptionClient) Pull(ctx context.Context, subName string) ([]*pubsubpb.ReceivedMessage, error)
• type TopicClient
  • func NewTopic(ctx context.Context, projectID types.GoogleProjectID, ...) (*TopicClient, error)
  • func (x *TopicClient) Close()
  • func (x *TopicClient) Publish(ctx context.Context, data []byte) (types.PubSubMessageID, error)

Types

type Dumper

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

func NewDumper

func NewDumper(outDir string) *Dumper

func (*Dumper) Publish

func (x *Dumper) Publish(ctx context.Context, data []byte) (types.PubSubMessageID, error)

type Mock

type Mock struct {
	MockPublish func(ctx context.Context, data []byte) (types.PubSubMessageID, error)
	Results     []*MockResult
}

func NewMock

func NewMock() *Mock

func (*Mock) Publish

func (x *Mock) Publish(ctx context.Context, data []byte) (types.PubSubMessageID, error)

type MockResult

type MockResult struct {
	ID   types.PubSubMessageID
	Data []byte
}

type SubscriptionClient

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

func NewSubscriptionClient

func NewSubscriptionClient(ctx context.Context) (*SubscriptionClient, error)

func (*SubscriptionClient) Acknowledge

func (x *SubscriptionClient) Acknowledge(ctx context.Context, subName string, ackID string) error

func (*SubscriptionClient) Close

func (x *SubscriptionClient) Close() error

func (*SubscriptionClient) ModifyAckDeadline

func (x *SubscriptionClient) ModifyAckDeadline(ctx context.Context, subName string, ackID string, deadline time.Duration) error

func (*SubscriptionClient) Pull

func (x *SubscriptionClient) Pull(ctx context.Context, subName string) ([]*pubsubpb.ReceivedMessage, error)

type TopicClient

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

func NewTopic

func NewTopic(ctx context.Context, projectID types.GoogleProjectID, topicID types.PubSubTopicID) (*TopicClient, error)

func (*TopicClient) Close

func (x *TopicClient) Close()

func (*TopicClient) Publish

func (x *TopicClient) Publish(ctx context.Context, data []byte) (types.PubSubMessageID, error)