gcpclient

type Bucket struct {
	Name string
}

type Function struct {
	Name string `json:"name"`
}

type GCP interface {
	ListBuckets(ctx context.Context) ([]*Bucket, error)
	ListFunctions(ctx context.Context) ([]*Function, error)
	Listen(ctx context.Context, handler ListenerFunc) error
	Close() error
}

type GCPConfig struct {
	ProjectID          string
	AckDeadlineSeconds int
	TopicName          string
	SubscriptionID     string
	CredentialsJSON    string
}

type ListenerFunc func(ctx context.Context, data []byte) error

type MockPubSub struct {
	ListenError  error
	ListenAssert func(ctx context.Context, handler ListenerFunc)

	CloseError error

	ListBucketsResult []*Bucket
	ListBucketsError  error

	ListFunctionsResult []*Function
	ListFunctionsError  error
	// contains filtered or unexported fields
}