mock

Documentation

Index

• type FakeServicePubSub
  • func (m *FakeServicePubSub) AddEngagementPubsubNameSpace(topic string) string
  • func (m *FakeServicePubSub) AddPubSubNamespace(topicName string) string
  • func (m *FakeServicePubSub) EnsureSubscriptionsExist(ctx context.Context) error
  • func (m *FakeServicePubSub) EnsureTopicsExist(ctx context.Context, topicIDs []string) error
  • func (m *FakeServicePubSub) PublishToPubsub(ctx context.Context, topicID string, payload []byte) error
  • func (m *FakeServicePubSub) ReceivePubSubPushMessages(w http.ResponseWriter, r *http.Request)
  • func (m *FakeServicePubSub) SubscriptionIDs() map[string]string
  • func (m *FakeServicePubSub) TopicIDs() []string

Types

type FakeServicePubSub

type FakeServicePubSub struct {
	TopicIDsFn           func() []string
	AddPubSubNamespaceFn func(topicName string) string
	PublishToPubsubFn    func(
		ctx context.Context,
		topicID string,
		payload []byte,
	) error
	EnsureTopicsExistFn func(
		ctx context.Context,
		topicIDs []string,
	) error
	EnsureSubscriptionsExistFn func(
		ctx context.Context,
	) error
	SubscriptionIDsFn           func() map[string]string
	ReceivePubSubPushMessagesFn func(
		w http.ResponseWriter,
		r *http.Request,
	)
	AddEngagementPubsubNameSpaceFn func(topic string) string
}

FakeServicePubSub ...

func (*FakeServicePubSub) AddEngagementPubsubNameSpace

func (m *FakeServicePubSub) AddEngagementPubsubNameSpace(topic string) string

AddEngagementPubsubNameSpace ...

func (*FakeServicePubSub) AddPubSubNamespace

func (m *FakeServicePubSub) AddPubSubNamespace(topicName string) string

AddPubSubNamespace ...

func (*FakeServicePubSub) EnsureSubscriptionsExist

func (m *FakeServicePubSub) EnsureSubscriptionsExist(
	ctx context.Context,
) error

EnsureSubscriptionsExist ..

func (*FakeServicePubSub) EnsureTopicsExist

func (m *FakeServicePubSub) EnsureTopicsExist(
	ctx context.Context,
	topicIDs []string,
) error

EnsureTopicsExist ...

func (*FakeServicePubSub) PublishToPubsub

func (m *FakeServicePubSub) PublishToPubsub(
	ctx context.Context,
	topicID string,
	payload []byte,
) error

PublishToPubsub ..

func (*FakeServicePubSub) ReceivePubSubPushMessages

func (m *FakeServicePubSub) ReceivePubSubPushMessages(
	w http.ResponseWriter,
	r *http.Request,
)

ReceivePubSubPushMessages ...

func (*FakeServicePubSub) SubscriptionIDs

func (m *FakeServicePubSub) SubscriptionIDs() map[string]string

SubscriptionIDs ..

func (*FakeServicePubSub) TopicIDs

func (m *FakeServicePubSub) TopicIDs() []string

TopicIDs returns the known (registered) topic IDs