Documentation ¶
Index ¶
- func MustMakeTestServices(ctx context.Context, project, serviceName string, opts ...testServicesOption) *server
- func WithErrorReportCallback(f ReportErrorFunc) testServicesOption
- func WithErrorReportChannel(evs chan<- *errorreportingpb.ReportedErrorEvent) testServicesOption
- type FakeSetup
- type PubSubStream
- type ReportErrorFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MustMakeTestServices ¶ added in v0.0.25
func WithErrorReportCallback ¶ added in v0.0.38
func WithErrorReportCallback(f ReportErrorFunc) testServicesOption
func WithErrorReportChannel ¶ added in v0.0.36
func WithErrorReportChannel(evs chan<- *errorreportingpb.ReportedErrorEvent) testServicesOption
Types ¶
type PubSubStream ¶ added in v0.0.29
type PubSubStream struct { Topic *pubsub.Topic Subscription *pubsub.Subscription // contains filtered or unexported fields }
func NewPubSubStreamWithContext ¶ added in v0.0.29
func (*PubSubStream) Close ¶ added in v0.0.29
func (s *PubSubStream) Close() error
type ReportErrorFunc ¶ added in v0.0.38
type ReportErrorFunc func(ctx context.Context, req *errorreportingpb.ReportErrorEventRequest) (*errorreportingpb.ReportErrorEventResponse, error)
Click to show internal directories.
Click to hide internal directories.