Documentation
¶
Index ¶
Constants ¶
const SubscriptionsProbeName = "gcppubsub-subscriptions"
SubscriptionsProbeName is the name of the GCP pub/sub subscriptions probe.
const TopicsProbeName = "gcppubsub-topics"
TopicsProbeName is the name of the GCP pub/sub topics probe.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GcpPubSubSubscriptionsProbe ¶
type GcpPubSubSubscriptionsProbe struct {
// contains filtered or unexported fields
}
GcpPubSubSubscriptionsProbe is a probe compatible with the healthcheck module.
func NewGcpPubSubSubscriptionsProbe ¶
func NewGcpPubSubSubscriptionsProbe(config *config.Config, client *pubsub.Client) *GcpPubSubSubscriptionsProbe
NewGcpPubSubSubscriptionsProbe returns a new GcpPubSubSubscriptionsProbe.
func (*GcpPubSubSubscriptionsProbe) Check ¶
func (p *GcpPubSubSubscriptionsProbe) Check(ctx context.Context) *healthcheck.CheckerProbeResult
Check returns a successful healthcheck.CheckerProbeResult if all configured subscriptions exist.
func (*GcpPubSubSubscriptionsProbe) Name ¶
func (p *GcpPubSubSubscriptionsProbe) Name() string
Name returns the name of the GcpPubSubSubscriptionsProbe.
type GcpPubSubTopicsProbe ¶
type GcpPubSubTopicsProbe struct {
// contains filtered or unexported fields
}
GcpPubSubTopicsProbe is a probe compatible with the healthcheck module.
func NewGcpPubSubTopicsProbe ¶
func NewGcpPubSubTopicsProbe(config *config.Config, client *pubsub.Client) *GcpPubSubTopicsProbe
NewGcpPubSubTopicsProbe returns a new GcpPubSubTopicsProbe.
func (*GcpPubSubTopicsProbe) Check ¶
func (p *GcpPubSubTopicsProbe) Check(ctx context.Context) *healthcheck.CheckerProbeResult
Check returns a successful healthcheck.CheckerProbeResult if all configured topics exist.
func (*GcpPubSubTopicsProbe) Name ¶
func (p *GcpPubSubTopicsProbe) Name() string
Name returns the name of the GcpPubSubTopicsProbe.
Source Files