mock_pubsub

Documentation

Index

• Constants
• type MockBaseClient
  • func (m MockBaseClient) Acknowledge(ctx context.Context, req *pubsubpb.AcknowledgeRequest, opts ...gax.CallOption) error
  • func (m MockBaseClient) Close() error
  • func (m MockBaseClient) Pull(ctx context.Context, req *pubsubpb.PullRequest, opts ...gax.CallOption) (*pubsubpb.PullResponse, error)
• type MockPublishResult
  • func (s *MockPublishResult) Get(context.Context) (string, error)
• type MockPubsubClient
  • func NewMockPubsubClient(opts MockPubsubOptions) *MockPubsubClient
  • func (s *MockPubsubClient) Topic(name string) ifaces_pubsub.Topic
  • func (s *MockPubsubClient) Topics(context.Context) ifaces_pubsub.TopicIterator
• type MockPubsubMessage
  • func (m MockPubsubMessage) Ack()
  • func (m MockPubsubMessage) Attributes() map[string]string
  • func (m MockPubsubMessage) Data() []byte
  • func (m MockPubsubMessage) ID() string
  • func (m MockPubsubMessage) Nack()
  • func (m MockPubsubMessage) PublishTime() time.Time
• type MockPubsubOptions
• type MockPubsubTopic
  • func (s *MockPubsubTopic) Exists(ctx context.Context) (bool, error)
  • func (s *MockPubsubTopic) ID() string
  • func (s *MockPubsubTopic) Publish(ctx context.Context, msg ifaces_pubsub.Message) ifaces_pubsub.PublishResult
  • func (s *MockPubsubTopic) String() string
  • func (s *MockPubsubTopic) Subscriptions(ctx context.Context) ifaces_pubsub.SubscriptionIterator
• type MockSubscription
  • func (m MockSubscription) ID() string
  • func (m MockSubscription) String() string
• type MockSubscriptionIterator
  • func (s *MockSubscriptionIterator) Next() (ifaces_pubsub.Subscription, error)
• type MockTopicIterator
  • func (s *MockTopicIterator) Next() (ifaces_pubsub.Topic, error)

Constants

const MockProjectID = "mock-project"

Types

type MockBaseClient

type MockBaseClient struct {
	Messages      map[string][]ifaces_pubsub.Message
	CompleteError error
}

func (MockBaseClient) Acknowledge

func (m MockBaseClient) Acknowledge(ctx context.Context, req *pubsubpb.AcknowledgeRequest, opts ...gax.CallOption) error

func (MockBaseClient) Close

func (m MockBaseClient) Close() error

func (MockBaseClient) Pull

func (m MockBaseClient) Pull(ctx context.Context, req *pubsubpb.PullRequest, opts ...gax.CallOption) (*pubsubpb.PullResponse, error)

type MockPublishResult

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

func (*MockPublishResult) Get

func (s *MockPublishResult) Get(context.Context) (string, error)

type MockPubsubClient

type MockPubsubClient struct {
	ifaces_pubsub.PubsubClient

	PublishedMessages map[string][]ifaces_pubsub.Message
	// contains filtered or unexported fields
}

func NewMockPubsubClient

func NewMockPubsubClient(opts MockPubsubOptions) *MockPubsubClient

func (*MockPubsubClient) Topic

func (s *MockPubsubClient) Topic(name string) ifaces_pubsub.Topic

func (*MockPubsubClient) Topics

func (s *MockPubsubClient) Topics(context.Context) ifaces_pubsub.TopicIterator

type MockPubsubMessage

type MockPubsubMessage struct {
	Id        string
	AckId     string
	DataBytes []byte
}

func (MockPubsubMessage) Ack

func (m MockPubsubMessage) Ack()

func (MockPubsubMessage) Attributes

func (m MockPubsubMessage) Attributes() map[string]string

func (MockPubsubMessage) Data

func (m MockPubsubMessage) Data() []byte

func (MockPubsubMessage) ID

func (m MockPubsubMessage) ID() string

func (MockPubsubMessage) Nack

func (m MockPubsubMessage) Nack()

func (MockPubsubMessage) PublishTime

func (m MockPubsubMessage) PublishTime() time.Time

type MockPubsubOptions

type MockPubsubOptions struct {
	Topics   []string
	Messages map[string][]ifaces_pubsub.Message
}

type MockPubsubTopic

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

func (*MockPubsubTopic) Exists

func (s *MockPubsubTopic) Exists(ctx context.Context) (bool, error)

func (*MockPubsubTopic) ID

func (s *MockPubsubTopic) ID() string

func (*MockPubsubTopic) Publish

func (s *MockPubsubTopic) Publish(ctx context.Context, msg ifaces_pubsub.Message) ifaces_pubsub.PublishResult

func (*MockPubsubTopic) String

func (s *MockPubsubTopic) String() string

func (*MockPubsubTopic) Subscriptions

func (s *MockPubsubTopic) Subscriptions(ctx context.Context) ifaces_pubsub.SubscriptionIterator

type MockSubscription

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

func (MockSubscription) ID

func (m MockSubscription) ID() string

func (MockSubscription) String

func (m MockSubscription) String() string

Return the full unique name for the subscription, in the format "projects/{project}/subscriptions/{subscription}"

type MockSubscriptionIterator

type MockSubscriptionIterator struct {
	Subscriptions []ifaces_pubsub.Subscription
	// contains filtered or unexported fields
}

func (*MockSubscriptionIterator) Next

func (s *MockSubscriptionIterator) Next() (ifaces_pubsub.Subscription, error)

type MockTopicIterator

type MockTopicIterator struct {
	ifaces_pubsub.TopicIterator
	// contains filtered or unexported fields
}

func (*MockTopicIterator) Next

func (s *MockTopicIterator) Next() (ifaces_pubsub.Topic, error)