synthetic_monitoring

package
v0.23.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 14, 2024 License: Apache-2.0 Imports: 21 Imported by: 9

Documentation

Overview

Package synthetic_monitoring provides access to types and methods that allow for the production and consumption of protocol buffer messages used to communicate with synthetic-monitoring-api.

Index

Constants

View Source 
const (
	HealthCheckInterval = 90 * time.Second
	HealthCheckTimeout  = 30 * time.Second
)
View Source 
const (
	MaxMetricLabels = 20 // Prometheus allows for 32 labels, but limit to 20.
	MaxLogLabels    = 15 // Loki allows a maximum of 15 labels.
	MaxCheckLabels  = 10 // Allow 10 user labels for checks,
	MaxProbeLabels  = 3  // 3 for probes, leaving 7 for internal use.

	MaxLabelValueLength    = 128 // Keep this number low so that the UI remains usable.
	MaxPingPackets         = 10  // Allow 10 packets per ping.
	MaxMultiHttpTargets    = 10  // Max targets per multi-http check.
	MaxMultiHttpAssertions = 5   // Max assertions per multi-http target.
	MaxMultiHttpVariables  = 5   // Max variables per multi-http target.

	// Frequencies (in milliseconds)
	MaxCheckFrequency = 1 * 60 * 60 * 1000 // Maximum value for the check's frequency (1 hour).

	MaxCheckTimeout = 1 * 60 * 1000 // Maximum value for the check's timeout (1 minute).

)
View Source 
const (
	// MaxRegions is the maximum number of regions supported.
	MaxRegions = 1000

	// MinRegionID is the minimum valid region ID.
	MinRegionID = 1

	// MaxRegionID is the maximum valid region ID.
	MaxRegionID = MaxRegions - 1

	// BadID is the ID value that is not valid in any case
	// (as global, local or region ID).
	BadID = 0

	// MinLocalID is the smallest local ID, as 0 is not valid.
	MinLocalID = 1

	// MaxLocalID is the maximum value allowed for a local ID.
	// This is the largest positive integer that can be multiplied
	// by 1000 and 999 added to it and still fit in an int64.
	// MaxLocalID = 9_223_372_036_854_774
	MaxLocalID = (math.MaxInt64 / MaxRegions) - 1

	// MaxGlobalID is the maximum value a global ID can hold.
	// It is the equivalent to (MinLocalID, MinRegionID)
	// MaxGlobalID = -1001
	MaxGlobalID = -(MinLocalID*MaxRegions + MinRegionID)

	// MinGlobalID is the minimum value a GlobalID can hold.
	// MinGlobalID = -9_223_372_036_854_774_999
	MinGlobalID = -(MaxLocalID*MaxRegions + MaxRegionID)
)

This file contains methods for converting IDs for Synthetic Monitoring objects (checks, tenants) from single-region (local) to region-aware IDs (global). This is needed for agents that run checks for multiple regions.

As IDs are only unique within their region, we create a new space of IDs (global IDs) that avoids collisions when objects from different regions are handled.

At the same time, it is necessary to undo the process and obtain the region and local ID from a global ID, so that results can be associated with their respective regions.

How this works:

Local IDs are positive, non-zero integers, assigned sequentially.

Global IDs are negative, non-zero integers. This allows to tell them apart from Local IDs easily and for both to coexist with some safety. They are constructed by multiplying the original ID by 1000 (MaxRegions) and then adding a unique regionID (<1000).

For example, check with ID 1234 in region 3 will have a global ID of -1234003.

This reduces the space of IDs available by a factor of 1000, from 63 bits to 53, which is still more than enough.

Variables

View Source 
var (
	ErrInvalidLengthChecks        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowChecks          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupChecks = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidTenantId        = errors.New("invalid tenant ID")
	ErrInvalidCheckProbes     = errors.New("invalid check probes")
	ErrInvalidCheckTarget     = errors.New("invalid check target")
	ErrInvalidCheckJob        = errors.New("invalid check job")
	ErrInvalidCheckFrequency  = errors.New("invalid check frequency")
	ErrInvalidCheckTimeout    = errors.New("invalid check timeout")
	ErrInvalidCheckLabelName  = errors.New("invalid check label name")
	ErrTooManyCheckLabels     = errors.New("too many check labels")
	ErrInvalidCheckLabelValue = errors.New("invalid check label value")
	ErrInvalidLabelName       = errors.New("invalid label name")
	ErrInvalidLabelValue      = errors.New("invalid label value")
	ErrDuplicateLabelName     = errors.New("duplicate label name")
	ErrInvalidTargetValue     = errors.New("invalid target value")

	ErrInvalidCheckSettings = errors.New("invalid check settings")

	ErrInvalidFQDNLength        = errors.New("invalid FQHN length")
	ErrInvalidFQHNElements      = errors.New("invalid number of elements in FQHN")
	ErrInvalidFQDNElementLength = errors.New("invalid FQHN element length")
	ErrInvalidFQHNElement       = errors.New("invalid FQHN element")

	ErrInvalidPingHostname    = errors.New("invalid ping hostname")
	ErrInvalidPingPayloadSize = errors.New("invalid ping payload size")
	ErrInvalidPingPacketCount = errors.New("invalid ping packet count")

	ErrInvalidDnsName             = errors.New("invalid DNS name")
	ErrInvalidDnsNameElement      = errors.New("invalid DNS name element")
	ErrInvalidDnsServer           = errors.New("invalid DNS server")
	ErrInvalidDnsPort             = errors.New("invalid DNS port")
	ErrInvalidDnsProtocolString   = errors.New("invalid DNS protocol string")
	ErrInvalidDnsProtocolValue    = errors.New("invalid DNS protocol value")
	ErrInvalidDnsRecordTypeString = errors.New("invalid DNS record type string")
	ErrInvalidDnsRecordTypeValue  = errors.New("invalid DNS record type value")

	ErrInvalidHttpUrl                          = errors.New("invalid HTTP URL")
	ErrInvalidHttpMethodString                 = errors.New("invalid HTTP method string")
	ErrInvalidHttpMethodValue                  = errors.New("invalid HTTP method value")
	ErrInvalidHttpUrlHost                      = errors.New("invalid HTTP URL host")
	ErrInvalidHttpHeaders                      = errors.New("invalid HTTP headers")
	ErrInvalidHttpFailIfBodyMatchesRegexp      = errors.New("invalid HTTP fail if body matches regexp")
	ErrInvalidHttpFailIfBodyNotMatchesRegexp   = errors.New("invalid HTTP fail if body not matches regexp")
	ErrInvalidHttpFailIfHeaderMatchesRegexp    = errors.New("invalid HTTP fail if header matches regexp")
	ErrInvalidHttpFailIfHeaderNotMatchesRegexp = errors.New("invalid HTTP fail if header not matches regexp")
	ErrHttpUrlContainsPassword                 = errors.New("HTTP URL contains username and password")
	ErrHttpUrlContainsUsername                 = errors.New("HTTP URL contains username")
	ErrInvalidProxyConnectHeaders              = errors.New("invalid HTTP proxy connect headers")
	ErrInvalidProxyUrl                         = errors.New("invalid proxy URL")
	ErrInvalidProxySettings                    = errors.New("invalid proxy settings")

	ErrInvalidTracerouteHostname = errors.New("invalid traceroute hostname")

	ErrInvalidK6Script = errors.New("invalid K6 script")

	ErrInvalidMultiHttpTargets = errors.New("invalid multi-http targets")

	ErrTooManyMultiHttpTargets         = errors.New("too many multi-http targets")
	ErrTooManyMultiHttpAssertions      = errors.New("too many multi-http assertions")
	ErrTooManyMultiHttpVariables       = errors.New("too many multi-http variables")
	ErrMultiHttpVariableNamesNotUnique = errors.New("multi-http variable names must be unique")

	ErrInvalidHostname = errors.New("invalid hostname")
	ErrInvalidPort     = errors.New("invalid port")

	ErrInvalidIpVersionString = errors.New("invalid ip version string")
	ErrInvalidIpVersionValue  = errors.New("invalid ip version value")

	ErrInvalidCompressionAlgorithmString = errors.New("invalid compression algorithm string")
	ErrInvalidCompressionAlgorithmValue  = errors.New("invalid compression algorithm value")

	ErrInvalidProbeName              = errors.New("invalid probe name")
	ErrInvalidProbeReservedLabelName = errors.New("invalid probe, reserved label name")
	ErrInvalidProbeLabelName         = errors.New("invalid probe label name")
	ErrInvalidProbeLabelValue        = errors.New("invalid probe label value")
	ErrTooManyProbeLabels            = errors.New("too many probe labels")
	ErrInvalidProbeLatitude          = errors.New("invalid probe latitude")
	ErrInvalidProbeLongitude         = errors.New("invalid probe longitude")

	ErrInvalidHttpRequestBodyContentType = errors.New("invalid HTTP request body content type")
	ErrInvalidHttpRequestBodyPayload     = errors.New("invalid HTTP request body payload")
	ErrInvalidQueryFieldName             = errors.New("invalid query field name")

	ErrInvalidMultiHttpAssertion                     = errors.New("invalid multi-http assertion")
	ErrInvalidMultiHttpEntryVariable                 = errors.New("invalid multi-http variable")
	ErrInvalidMultiHttpAssertionMissingValue         = errors.New("invalid multi-http assertion, missing value")
	ErrInvalidMultiHttpAssertionExpressionNotAllowed = errors.New("invalid multi-http assertion, expression not allowed")
	ErrInvalidMultiHttpAssertionMissingHeaderName    = errors.New("invalid multi-http assertion, missing header name")
)
View Source 
var CheckClass_name = map[int32]string{
	0: "PROTOCOL",
	1: "SCRIPTED",
}
View Source 
var CheckClass_value = map[string]int32{
	"PROTOCOL": 0,
	"SCRIPTED": 1,
}
View Source 
var CheckOperation_name = map[int32]string{
	0: "CHECK_ADD",
	1: "CHECK_UPDATE",
	2: "CHECK_DELETE",
}
View Source 
var CheckOperation_value = map[string]int32{
	"CHECK_ADD":    0,
	"CHECK_UPDATE": 1,
	"CHECK_DELETE": 2,
}
View Source 
var CompressionAlgorithm_name = map[int32]string{
	0: "none",
	1: "identity",
	2: "gzip",
	3: "br",
	4: "deflate",
}
View Source 
var CompressionAlgorithm_value = map[string]int32{
	"none":     0,
	"identity": 1,
	"gzip":     2,
	"br":       3,
	"deflate":  4,
}
View Source 
var DnsProtocol_name = map[int32]string{
	0: "TCP",
	1: "UDP",
}
View Source 
var DnsProtocol_value = map[string]int32{
	"TCP": 0,
	"UDP": 1,
}
View Source 
var DnsRecordType_name = map[int32]string{
	0: "ANY",
	1: "A",
	2: "AAAA",
	3: "CNAME",
	4: "MX",
	5: "NS",
	6: "PTR",
	7: "SOA",
	8: "SRV",
	9: "TXT",
}
View Source 
var DnsRecordType_value = map[string]int32{
	"ANY":   0,
	"A":     1,
	"AAAA":  2,
	"CNAME": 3,
	"MX":    4,
	"NS":    5,
	"PTR":   6,
	"SOA":   7,
	"SRV":   8,
	"TXT":   9,
}
View Source 
var HttpMethod_name = map[int32]string{
	0: "GET",
	1: "CONNECT",
	2: "DELETE",
	3: "HEAD",
	4: "OPTIONS",
	5: "POST",
	6: "PUT",
	7: "TRACE",
}
View Source 
var HttpMethod_value = map[string]int32{
	"GET":     0,
	"CONNECT": 1,
	"DELETE":  2,
	"HEAD":    3,
	"OPTIONS": 4,
	"POST":    5,
	"PUT":     6,
	"TRACE":   7,
}
View Source 
var IpVersion_name = map[int32]string{
	0: "Any",
	1: "V4",
	2: "V6",
}
View Source 
var IpVersion_value = map[string]int32{
	"Any": 0,
	"V4":  1,
	"V6":  2,
}
View Source 
var MultiHttpEntryAssertionConditionVariant_name = map[int32]string{
	0: "DEFAULT_CONDITION",
	1: "NOT_CONTAINS",
	2: "EQUALS",
	3: "STARTS_WITH",
	4: "ENDS_WITH",
	5: "TYPE_OF",
	6: "CONTAINS",
}
View Source 
var MultiHttpEntryAssertionConditionVariant_value = map[string]int32{
	"DEFAULT_CONDITION": 0,
	"NOT_CONTAINS":      1,
	"EQUALS":            2,
	"STARTS_WITH":       3,
	"ENDS_WITH":         4,
	"TYPE_OF":           5,
	"CONTAINS":          6,
}
View Source 
var MultiHttpEntryAssertionSubjectVariant_name = map[int32]string{
	0: "DEFAULT_SUBJECT",
	1: "RESPONSE_HEADERS",
	2: "HTTP_STATUS_CODE",
	3: "RESPONSE_BODY",
}
View Source 
var MultiHttpEntryAssertionSubjectVariant_value = map[string]int32{
	"DEFAULT_SUBJECT":  0,
	"RESPONSE_HEADERS": 1,
	"HTTP_STATUS_CODE": 2,
	"RESPONSE_BODY":    3,
}
View Source 
var MultiHttpEntryAssertionType_name = map[int32]string{
	0: "TEXT",
	1: "JSON_PATH_VALUE",
	2: "JSON_PATH_ASSERTION",
	3: "REGEX_ASSERTION",
}
View Source 
var MultiHttpEntryAssertionType_value = map[string]int32{
	"TEXT":                0,
	"JSON_PATH_VALUE":     1,
	"JSON_PATH_ASSERTION": 2,
	"REGEX_ASSERTION":     3,
}
View Source 
var MultiHttpEntryVariableType_name = map[int32]string{
	0: "JSON_PATH",
	1: "REGEX",
	2: "CSS_SELECTOR",
}
View Source 
var MultiHttpEntryVariableType_value = map[string]int32{
	"JSON_PATH":    0,
	"REGEX":        1,
	"CSS_SELECTOR": 2,
}
View Source 
var StatusCode_name = map[int32]string{
	0: "OK",
	1: "NOT_FOUND",
	2: "INVALID_ARGUMENT",
	3: "ALREADY_EXISTS",
	4: "INTERNAL_ERROR",
	5: "NOT_AUTHORIZED",
}
View Source 
var StatusCode_value = map[string]int32{
	"OK":               0,
	"NOT_FOUND":        1,
	"INVALID_ARGUMENT": 2,
	"ALREADY_EXISTS":   3,
	"INTERNAL_ERROR":   4,
	"NOT_AUTHORIZED":   5,
}
View Source 
var TenantStatus_name = map[int32]string{
	0: "ACTIVE",
	1: "DISABLED",
}
View Source 
var TenantStatus_value = map[string]int32{
	"ACTIVE":   0,
	"DISABLED": 1,
}

Functions

func CheckTypeStrings added in v0.16.0 

func CheckTypeStrings() []string

CheckTypeStrings returns a slice of all String values of the enum

func GlobalIDToLocalID added in v0.14.0 

func GlobalIDToLocalID(globalID int64) (localID int64, regionID int, err error)

GlobalIDToLocalID converts a globalID back to a (local ID, region ID) pair.

func IsGlobalIDValid added in v0.14.0 

func IsGlobalIDValid(id int64) bool

IsGlobalIDValid returns true if an ID is Global, false otherwise.

func IsLocalIDValid added in v0.14.0 

func IsLocalIDValid(id int64) bool

func IsRegionIDValid added in v0.14.0 

func IsRegionIDValid(id int) bool

IsRegionIDValid checks that a region ID is within bounds.

func LocalIDToGlobalID added in v0.14.0 

func LocalIDToGlobalID(localID int64, regionID int) (int64, error)

LocalIDToGlobalID converts the given localID to a global ID using the given region ID.

func MultiHttpEntryAssertionConditionVariantStrings added in v0.18.2 

func MultiHttpEntryAssertionConditionVariantStrings() []string

MultiHttpEntryAssertionConditionVariantStrings returns a slice of all String values of the enum

func MultiHttpEntryAssertionSubjectVariantStrings added in v0.18.2 

func MultiHttpEntryAssertionSubjectVariantStrings() []string

MultiHttpEntryAssertionSubjectVariantStrings returns a slice of all String values of the enum

func MultiHttpEntryAssertionTypeStrings added in v0.18.2 

func MultiHttpEntryAssertionTypeStrings() []string

MultiHttpEntryAssertionTypeStrings returns a slice of all String values of the enum

func MultiHttpEntryVariableTypeStrings added in v0.18.2 

func MultiHttpEntryVariableTypeStrings() []string

MultiHttpEntryVariableTypeStrings returns a slice of all String values of the enum

func RegisterAdHocChecksServer added in v0.8.0 

func RegisterAdHocChecksServer(s *grpc.Server, srv AdHocChecksServer)

func RegisterChecksServer 

func RegisterChecksServer(s *grpc.Server, srv ChecksServer)

func RegisterTelemetryServer added in v0.21.0 

func RegisterTelemetryServer(s *grpc.Server, srv TelemetryServer)

func RegisterTenantsServer 

func RegisterTenantsServer(s *grpc.Server, srv TenantsServer)

Types

type AdHocCheck added in v0.8.0 

type AdHocCheck struct {
	Id       string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
	TenantId int64         `protobuf:"varint,2,opt,name=tenantId,proto3" json:"tenantId"`
	Timeout  int64         `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout"`
	Settings CheckSettings `protobuf:"bytes,4,opt,name=settings,proto3" json:"settings"`
	Probes   []int64       `protobuf:"varint,5,rep,packed,name=probes,proto3" json:"probes"`
	Target   string        `protobuf:"bytes,6,opt,name=target,proto3" json:"target"`
}

func (*AdHocCheck) Descriptor added in v0.8.0 

func (*AdHocCheck) Descriptor() ([]byte, []int)

func (*AdHocCheck) Marshal added in v0.8.0 

func (m *AdHocCheck) Marshal() (dAtA []byte, err error)

func (*AdHocCheck) MarshalTo added in v0.8.0 

func (m *AdHocCheck) MarshalTo(dAtA []byte) (int, error)

func (*AdHocCheck) MarshalToSizedBuffer added in v0.8.0 

func (m *AdHocCheck) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AdHocCheck) ProtoMessage added in v0.8.0 

func (*AdHocCheck) ProtoMessage()

func (*AdHocCheck) Reset added in v0.8.0 

func (m *AdHocCheck) Reset()

func (*AdHocCheck) Size added in v0.8.0 

func (m *AdHocCheck) Size() (n int)

func (*AdHocCheck) String added in v0.8.0 

func (m *AdHocCheck) String() string

func (AdHocCheck) Type added in v0.8.0 

func (c AdHocCheck) Type() CheckType

func (*AdHocCheck) Unmarshal added in v0.8.0 

func (m *AdHocCheck) Unmarshal(dAtA []byte) error

func (AdHocCheck) Validate added in v0.8.0 

func (c AdHocCheck) Validate() error

func (*AdHocCheck) XXX_DiscardUnknown added in v0.8.0 

func (m *AdHocCheck) XXX_DiscardUnknown()

func (*AdHocCheck) XXX_Marshal added in v0.8.0 

func (m *AdHocCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AdHocCheck) XXX_Merge added in v0.8.0 

func (m *AdHocCheck) XXX_Merge(src proto.Message)

func (*AdHocCheck) XXX_Size added in v0.8.0 

func (m *AdHocCheck) XXX_Size() int

func (*AdHocCheck) XXX_Unmarshal added in v0.8.0 

func (m *AdHocCheck) XXX_Unmarshal(b []byte) error

type AdHocChecksClient added in v0.8.0 

type AdHocChecksClient interface {
	// RegisterProbe causes this probe to be reported as available
	// with synthetic-monitoring-api.
	//
	// The probe is identified via an authentication token provided
	// through a different channel by synthetic-monitoring-api.
	RegisterProbe(ctx context.Context, in *ProbeInfo, opts ...grpc.CallOption) (*RegisterProbeResult, error)
	// GetAdHocChecks returns a list of checks to be run immediately.
	GetAdHocChecks(ctx context.Context, in *Void, opts ...grpc.CallOption) (AdHocChecks_GetAdHocChecksClient, error)
}

AdHocChecksClient is the client API for AdHocChecks service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAdHocChecksClient added in v0.8.0 

func NewAdHocChecksClient(cc *grpc.ClientConn) AdHocChecksClient

type AdHocChecksServer added in v0.8.0 

type AdHocChecksServer interface {
	// RegisterProbe causes this probe to be reported as available
	// with synthetic-monitoring-api.
	//
	// The probe is identified via an authentication token provided
	// through a different channel by synthetic-monitoring-api.
	RegisterProbe(context.Context, *ProbeInfo) (*RegisterProbeResult, error)
	// GetAdHocChecks returns a list of checks to be run immediately.
	GetAdHocChecks(*Void, AdHocChecks_GetAdHocChecksServer) error
}

AdHocChecksServer is the server API for AdHocChecks service.

type AdHocChecks_GetAdHocChecksClient added in v0.8.0 

type AdHocChecks_GetAdHocChecksClient interface {
	Recv() (*AdHocRequest, error)
	grpc.ClientStream
}

type AdHocChecks_GetAdHocChecksServer added in v0.8.0 

type AdHocChecks_GetAdHocChecksServer interface {
	Send(*AdHocRequest) error
	grpc.ServerStream
}

type AdHocRequest added in v0.8.0 

type AdHocRequest struct {
	AdHocCheck AdHocCheck `protobuf:"bytes,1,opt,name=adHocCheck,proto3" json:"adHocCheck"`
	Tenant     *Tenant    `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant"`
}

func (*AdHocRequest) Descriptor added in v0.8.0 

func (*AdHocRequest) Descriptor() ([]byte, []int)

func (*AdHocRequest) Marshal added in v0.8.0 

func (m *AdHocRequest) Marshal() (dAtA []byte, err error)

func (*AdHocRequest) MarshalTo added in v0.8.0 

func (m *AdHocRequest) MarshalTo(dAtA []byte) (int, error)

func (*AdHocRequest) MarshalToSizedBuffer added in v0.8.0 

func (m *AdHocRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AdHocRequest) ProtoMessage added in v0.8.0 

func (*AdHocRequest) ProtoMessage()

func (*AdHocRequest) Reset added in v0.8.0 

func (m *AdHocRequest) Reset()

func (*AdHocRequest) Size added in v0.8.0 

func (m *AdHocRequest) Size() (n int)

func (*AdHocRequest) String added in v0.8.0 

func (m *AdHocRequest) String() string

func (*AdHocRequest) Unmarshal added in v0.8.0 

func (m *AdHocRequest) Unmarshal(dAtA []byte) error

func (*AdHocRequest) XXX_DiscardUnknown added in v0.8.0 

func (m *AdHocRequest) XXX_DiscardUnknown()

func (*AdHocRequest) XXX_Marshal added in v0.8.0 

func (m *AdHocRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AdHocRequest) XXX_Merge added in v0.8.0 

func (m *AdHocRequest) XXX_Merge(src proto.Message)

func (*AdHocRequest) XXX_Size added in v0.8.0 

func (m *AdHocRequest) XXX_Size() int

func (*AdHocRequest) XXX_Unmarshal added in v0.8.0 

func (m *AdHocRequest) XXX_Unmarshal(b []byte) error

type BadGlobalIDError added in v0.14.0 

type BadGlobalIDError int64

BadGlobalIDError type is returned when an invalid global ID is used.

func (BadGlobalIDError) Error added in v0.14.0 

func (n BadGlobalIDError) Error() string

Error implements the error interface.

func (BadGlobalIDError) ID added in v0.14.0 

func (n BadGlobalIDError) ID() int64

ID returns the ID that caused the error.

type BadLocalIDError added in v0.14.0 

type BadLocalIDError int64

BadLocalIDError type is returned when an invalid local ID is used.

func (BadLocalIDError) Error added in v0.14.0 

func (n BadLocalIDError) Error() string

Error implements the error interface.

func (BadLocalIDError) ID added in v0.14.0 

func (n BadLocalIDError) ID() int64

ID returns the ID that caused the error.

type BadRegionIDError added in v0.14.0 

type BadRegionIDError int

BadRegionIDError type is returned when an invalid region ID is used.

func (BadRegionIDError) Error added in v0.14.0 

func (n BadRegionIDError) Error() string

Error implements the error interface.

func (BadRegionIDError) ID added in v0.14.0 

func (n BadRegionIDError) ID() int

ID returns the ID that caused the error.

type BasicAuth 

type BasicAuth struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
}

BasicAuth represents the basic authentication credentials to be used when talking to HTTP servers.

func (*BasicAuth) Descriptor 

func (*BasicAuth) Descriptor() ([]byte, []int)

func (*BasicAuth) Marshal 

func (m *BasicAuth) Marshal() (dAtA []byte, err error)

func (*BasicAuth) MarshalTo 

func (m *BasicAuth) MarshalTo(dAtA []byte) (int, error)

func (*BasicAuth) MarshalToSizedBuffer 

func (m *BasicAuth) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BasicAuth) ProtoMessage 

func (*BasicAuth) ProtoMessage()

func (*BasicAuth) Reset 

func (m *BasicAuth) Reset()

func (*BasicAuth) Size 

func (m *BasicAuth) Size() (n int)

func (*BasicAuth) String 

func (m *BasicAuth) String() string

func (*BasicAuth) Unmarshal 

func (m *BasicAuth) Unmarshal(dAtA []byte) error

func (*BasicAuth) XXX_DiscardUnknown 

func (m *BasicAuth) XXX_DiscardUnknown()

func (*BasicAuth) XXX_Marshal 

func (m *BasicAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BasicAuth) XXX_Merge 

func (m *BasicAuth) XXX_Merge(src proto.Message)

func (*BasicAuth) XXX_Size 

func (m *BasicAuth) XXX_Size() int

func (*BasicAuth) XXX_Unmarshal 

func (m *BasicAuth) XXX_Unmarshal(b []byte) error

type Changes added in v0.0.14 

type Changes struct {
	Checks  []CheckChange `protobuf:"bytes,1,rep,name=checks,proto3" json:"checks"`
	Tenants []Tenant      `protobuf:"bytes,2,rep,name=tenants,proto3" json:"tenants"`
	// This field is used to signal that the list of changes should be interpreted as a diff
	// against the existing changes in the probe. For backwards compatibility, this will be
	// false if the probe didn't send a list of known changes.
	IsDeltaFirstBatch bool `protobuf:"varint,3,opt,name=isDeltaFirstBatch,proto3" json:"isDeltaFirstBatch"`
}

Changes represents a series of changes to be applied to the workloads running on the probe.

When a probe connects, it will get a sequence of changes describing all the checks associated to that probe. After the initial batch, it will continue getting changes as they happen.

When a tenant's credentials change, this message will contain the new information for that tenant.

func (*Changes) Descriptor added in v0.0.14 

func (*Changes) Descriptor() ([]byte, []int)

func (*Changes) Marshal added in v0.0.14 

func (m *Changes) Marshal() (dAtA []byte, err error)

func (*Changes) MarshalTo added in v0.0.14 

func (m *Changes) MarshalTo(dAtA []byte) (int, error)

func (*Changes) MarshalToSizedBuffer added in v0.0.14 

func (m *Changes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Changes) ProtoMessage added in v0.0.14 

func (*Changes) ProtoMessage()

func (*Changes) Reset added in v0.0.14 

func (m *Changes) Reset()

func (*Changes) Size added in v0.0.14 

func (m *Changes) Size() (n int)

func (*Changes) String added in v0.0.14 

func (m *Changes) String() string

func (*Changes) Unmarshal added in v0.0.14 

func (m *Changes) Unmarshal(dAtA []byte) error

func (*Changes) XXX_DiscardUnknown added in v0.0.14 

func (m *Changes) XXX_DiscardUnknown()

func (*Changes) XXX_Marshal added in v0.0.14 

func (m *Changes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Changes) XXX_Merge added in v0.0.14 

func (m *Changes) XXX_Merge(src proto.Message)

func (*Changes) XXX_Size added in v0.0.14 

func (m *Changes) XXX_Size() int

func (*Changes) XXX_Unmarshal added in v0.0.14 

func (m *Changes) XXX_Unmarshal(b []byte) error

type Check 

type Check struct {
	Id               int64         `protobuf:"varint,1,opt,name=id,proto3" json:"id"`
	TenantId         int64         `protobuf:"varint,2,opt,name=tenantId,proto3" json:"tenantId"`
	Frequency        int64         `protobuf:"varint,3,opt,name=frequency,proto3" json:"frequency"`
	Offset           int64         `protobuf:"varint,4,opt,name=offset,proto3" json:"offset"`
	Timeout          int64         `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout"`
	Enabled          bool          `protobuf:"varint,6,opt,name=enabled,proto3" json:"enabled"`
	Labels           []Label       `protobuf:"bytes,7,rep,name=labels,proto3" json:"labels"`
	Settings         CheckSettings `protobuf:"bytes,8,opt,name=settings,proto3" json:"settings"`
	Probes           []int64       `protobuf:"varint,9,rep,packed,name=probes,proto3" json:"probes"`
	Target           string        `protobuf:"bytes,10,opt,name=target,proto3" json:"target"`
	Job              string        `protobuf:"bytes,11,opt,name=job,proto3" json:"job"`
	BasicMetricsOnly bool          `protobuf:"varint,12,opt,name=basicMetricsOnly,proto3" json:"basicMetricsOnly"`
	AlertSensitivity string        `protobuf:"bytes,13,opt,name=alertSensitivity,proto3" json:"alertSensitivity"`
	Created          float64       `protobuf:"fixed64,100,opt,name=created,proto3" json:"created"`
	Modified         float64       `protobuf:"fixed64,101,opt,name=modified,proto3" json:"modified"`
}

Check represents a check.

The "settings" field defines the type of check.

func (Check) Class added in v0.16.0 

func (c Check) Class() CheckClass

func (Check) ConfigVersion 

func (c Check) ConfigVersion() string

func (*Check) Descriptor 

func (*Check) Descriptor() ([]byte, []int)

func (*Check) Marshal 

func (m *Check) Marshal() (dAtA []byte, err error)

func (*Check) MarshalTo 

func (m *Check) MarshalTo(dAtA []byte) (int, error)

func (*Check) MarshalToSizedBuffer 

func (m *Check) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Check) ProtoMessage 

func (*Check) ProtoMessage()

func (*Check) Reset 

func (m *Check) Reset()

func (*Check) Size 

func (m *Check) Size() (n int)

func (*Check) String 

func (m *Check) String() string

func (Check) Type added in v0.0.18 

func (c Check) Type() CheckType

func (*Check) Unmarshal 

func (m *Check) Unmarshal(dAtA []byte) error

func (Check) Validate 

func (c Check) Validate() error

func (*Check) XXX_DiscardUnknown 

func (m *Check) XXX_DiscardUnknown()

func (*Check) XXX_Marshal 

func (m *Check) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Check) XXX_Merge 

func (m *Check) XXX_Merge(src proto.Message)

func (*Check) XXX_Size 

func (m *Check) XXX_Size() int

func (*Check) XXX_Unmarshal 

func (m *Check) XXX_Unmarshal(b []byte) error

type CheckChange 

type CheckChange struct {
	Operation CheckOperation `protobuf:"varint,1,opt,name=operation,proto3,enum=synthetic_monitoring.CheckOperation" json:"operation,omitempty"`
	Check     Check          `protobuf:"bytes,2,opt,name=check,proto3" json:"check"`
}

CheckChange represents one change operation for a given check.

func (*CheckChange) Descriptor 

func (*CheckChange) Descriptor() ([]byte, []int)

func (*CheckChange) Marshal 

func (m *CheckChange) Marshal() (dAtA []byte, err error)

func (*CheckChange) MarshalTo 

func (m *CheckChange) MarshalTo(dAtA []byte) (int, error)

func (*CheckChange) MarshalToSizedBuffer 

func (m *CheckChange) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckChange) ProtoMessage 

func (*CheckChange) ProtoMessage()

func (*CheckChange) Reset 

func (m *CheckChange) Reset()

func (*CheckChange) Size 

func (m *CheckChange) Size() (n int)

func (*CheckChange) String 

func (m *CheckChange) String() string

func (*CheckChange) Unmarshal 

func (m *CheckChange) Unmarshal(dAtA []byte) error

func (*CheckChange) XXX_DiscardUnknown 

func (m *CheckChange) XXX_DiscardUnknown()

func (*CheckChange) XXX_Marshal 

func (m *CheckChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckChange) XXX_Merge 

func (m *CheckChange) XXX_Merge(src proto.Message)

func (*CheckChange) XXX_Size 

func (m *CheckChange) XXX_Size() int

func (*CheckChange) XXX_Unmarshal 

func (m *CheckChange) XXX_Unmarshal(b []byte) error

type CheckClass added in v0.16.0 

type CheckClass int32

CheckClass represents the supported check classes. 

const (
	CheckClass_PROTOCOL CheckClass = 0
	CheckClass_SCRIPTED CheckClass = 1
)

func (CheckClass) EnumDescriptor added in v0.21.0 

func (CheckClass) EnumDescriptor() ([]byte, []int)

func (CheckClass) String added in v0.16.0 

func (x CheckClass) String() string

type CheckClassTelemetry added in v0.21.0 

type CheckClassTelemetry struct {
	CheckClass        CheckClass `protobuf:"varint,1,opt,name=checkClass,proto3,enum=synthetic_monitoring.CheckClass" json:"checkClass"`
	Executions        int32      `protobuf:"varint,2,opt,name=executions,proto3" json:"executions"`
	Duration          float32    `protobuf:"fixed32,3,opt,name=duration,proto3" json:"duration"`
	SampledExecutions int32      `protobuf:"varint,4,opt,name=sampledExecutions,proto3" json:"sampledExecutions"`
}

CheckClassTelemetry represents the telemetry data for a specific check class.

func (*CheckClassTelemetry) Descriptor added in v0.21.0 

func (*CheckClassTelemetry) Descriptor() ([]byte, []int)

func (*CheckClassTelemetry) Marshal added in v0.21.0 

func (m *CheckClassTelemetry) Marshal() (dAtA []byte, err error)

func (*CheckClassTelemetry) MarshalTo added in v0.21.0 

func (m *CheckClassTelemetry) MarshalTo(dAtA []byte) (int, error)

func (*CheckClassTelemetry) MarshalToSizedBuffer added in v0.21.0 

func (m *CheckClassTelemetry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckClassTelemetry) ProtoMessage added in v0.21.0 

func (*CheckClassTelemetry) ProtoMessage()

func (*CheckClassTelemetry) Reset added in v0.21.0 

func (m *CheckClassTelemetry) Reset()

func (*CheckClassTelemetry) Size added in v0.21.0 

func (m *CheckClassTelemetry) Size() (n int)

func (*CheckClassTelemetry) String added in v0.21.0 

func (m *CheckClassTelemetry) String() string

func (*CheckClassTelemetry) Unmarshal added in v0.21.0 

func (m *CheckClassTelemetry) Unmarshal(dAtA []byte) error

func (*CheckClassTelemetry) XXX_DiscardUnknown added in v0.21.0 

func (m *CheckClassTelemetry) XXX_DiscardUnknown()

func (*CheckClassTelemetry) XXX_Marshal added in v0.21.0 

func (m *CheckClassTelemetry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckClassTelemetry) XXX_Merge added in v0.21.0 

func (m *CheckClassTelemetry) XXX_Merge(src proto.Message)

func (*CheckClassTelemetry) XXX_Size added in v0.21.0 

func (m *CheckClassTelemetry) XXX_Size() int

func (*CheckClassTelemetry) XXX_Unmarshal added in v0.21.0 

func (m *CheckClassTelemetry) XXX_Unmarshal(b []byte) error

type CheckOperation 

type CheckOperation int32

CheckOperation represents an operation to be performed on a particular check. 

const (
	CheckOperation_CHECK_ADD    CheckOperation = 0
	CheckOperation_CHECK_UPDATE CheckOperation = 1
	CheckOperation_CHECK_DELETE CheckOperation = 2
)

func (CheckOperation) EnumDescriptor 

func (CheckOperation) EnumDescriptor() ([]byte, []int)

func (CheckOperation) String 

func (x CheckOperation) String() string

type CheckSettings 

type CheckSettings struct {
	Ping       *PingSettings       `protobuf:"bytes,1,opt,name=ping,proto3" json:"ping,omitempty"`
	Http       *HttpSettings       `protobuf:"bytes,2,opt,name=http,proto3" json:"http,omitempty"`
	Dns        *DnsSettings        `protobuf:"bytes,3,opt,name=dns,proto3" json:"dns,omitempty"`
	Tcp        *TcpSettings        `protobuf:"bytes,4,opt,name=tcp,proto3" json:"tcp,omitempty"`
	Traceroute *TracerouteSettings `protobuf:"bytes,5,opt,name=traceroute,proto3" json:"traceroute,omitempty"`
	Scripted   *ScriptedSettings   `protobuf:"bytes,6,opt,name=scripted,proto3" json:"scripted,omitempty"`
	Multihttp  *MultiHttpSettings  `protobuf:"bytes,7,opt,name=multihttp,proto3" json:"multihttp,omitempty"`
	Grpc       *GrpcSettings       `protobuf:"bytes,8,opt,name=grpc,proto3" json:"grpc,omitempty"`
}

CheckSettings provides the settings for exactly one type of check.

func (*CheckSettings) Descriptor 

func (*CheckSettings) Descriptor() ([]byte, []int)

func (*CheckSettings) GetValue 

func (this *CheckSettings) GetValue() interface{}

func (*CheckSettings) Marshal 

func (m *CheckSettings) Marshal() (dAtA []byte, err error)

func (*CheckSettings) MarshalTo 

func (m *CheckSettings) MarshalTo(dAtA []byte) (int, error)

func (*CheckSettings) MarshalToSizedBuffer 

func (m *CheckSettings) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckSettings) ProtoMessage 

func (*CheckSettings) ProtoMessage()

func (*CheckSettings) Reset 

func (m *CheckSettings) Reset()

func (*CheckSettings) SetValue 

func (this *CheckSettings) SetValue(value interface{}) bool

func (*CheckSettings) Size 

func (m *CheckSettings) Size() (n int)

func (*CheckSettings) String 

func (m *CheckSettings) String() string

func (*CheckSettings) Unmarshal 

func (m *CheckSettings) Unmarshal(dAtA []byte) error

func (CheckSettings) Validate added in v0.2.0 

func (s CheckSettings) Validate() error

func (*CheckSettings) XXX_DiscardUnknown 

func (m *CheckSettings) XXX_DiscardUnknown()

func (*CheckSettings) XXX_Marshal 

func (m *CheckSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckSettings) XXX_Merge 

func (m *CheckSettings) XXX_Merge(src proto.Message)

func (*CheckSettings) XXX_Size 

func (m *CheckSettings) XXX_Size() int

func (*CheckSettings) XXX_Unmarshal 

func (m *CheckSettings) XXX_Unmarshal(b []byte) error

type CheckType added in v0.0.18 

type CheckType int32

CheckType represents the type of the associated check 

const (
	CheckTypeDns        CheckType = 0
	CheckTypeHttp       CheckType = 1
	CheckTypePing       CheckType = 2
	CheckTypeTcp        CheckType = 3
	CheckTypeTraceroute CheckType = 4
	CheckTypeScripted   CheckType = 5
	CheckTypeMultiHttp  CheckType = 6
	CheckTypeGrpc       CheckType = 7
)

func CheckTypeFromString added in v0.0.18 

func CheckTypeFromString(in string) (CheckType, bool)

func CheckTypeString added in v0.16.0 

func CheckTypeString(s string) (CheckType, error)

CheckTypeString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func CheckTypeValues added in v0.16.0 

func CheckTypeValues() []CheckType

CheckTypeValues returns all values of the enum

func (CheckType) Class added in v0.16.2 

func (c CheckType) Class() CheckClass

func (CheckType) IsACheckType added in v0.16.0 

func (i CheckType) IsACheckType() bool

IsACheckType returns "true" if the value is listed in the enum definition. "false" otherwise

func (CheckType) String added in v0.0.18 

func (i CheckType) String() string

type ChecksClient 

type ChecksClient interface {
	// RegisterProbe causes this probe to be reported as online with
	// synthetic-monitoring-api.
	//
	// The probe is identified via an authentication token provided
	// through a different channel by synthetic-monitoring-api.
	RegisterProbe(ctx context.Context, in *ProbeInfo, opts ...grpc.CallOption) (*RegisterProbeResult, error)
	// GetChanges returns a list of check operations, specifying
	// whether to add, update or delete checks.
	GetChanges(ctx context.Context, in *ProbeState, opts ...grpc.CallOption) (Checks_GetChangesClient, error)
	// Ping sends a ping to the server and receives an
	// acknowledgement back.
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PongResponse, error)
}

ChecksClient is the client API for Checks service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewChecksClient 

func NewChecksClient(cc *grpc.ClientConn) ChecksClient

type ChecksServer 

type ChecksServer interface {
	// RegisterProbe causes this probe to be reported as online with
	// synthetic-monitoring-api.
	//
	// The probe is identified via an authentication token provided
	// through a different channel by synthetic-monitoring-api.
	RegisterProbe(context.Context, *ProbeInfo) (*RegisterProbeResult, error)
	// GetChanges returns a list of check operations, specifying
	// whether to add, update or delete checks.
	GetChanges(*ProbeState, Checks_GetChangesServer) error
	// Ping sends a ping to the server and receives an
	// acknowledgement back.
	Ping(context.Context, *PingRequest) (*PongResponse, error)
}

ChecksServer is the server API for Checks service.

type Checks_GetChangesClient 

type Checks_GetChangesClient interface {
	Recv() (*Changes, error)
	grpc.ClientStream
}

type Checks_GetChangesServer 

type Checks_GetChangesServer interface {
	Send(*Changes) error
	grpc.ServerStream
}

type CompressionAlgorithm added in v0.0.20 

type CompressionAlgorithm int32

CompressionAlgorithm represents the compression algorithm to use. 

const (
	CompressionAlgorithm_none     CompressionAlgorithm = 0
	CompressionAlgorithm_identity CompressionAlgorithm = 1
	CompressionAlgorithm_gzip     CompressionAlgorithm = 2
	CompressionAlgorithm_br       CompressionAlgorithm = 3
	CompressionAlgorithm_deflate  CompressionAlgorithm = 4
)

func (CompressionAlgorithm) EnumDescriptor added in v0.0.20 

func (CompressionAlgorithm) EnumDescriptor() ([]byte, []int)

func (CompressionAlgorithm) MarshalJSON added in v0.0.20 

func (v CompressionAlgorithm) MarshalJSON() ([]byte, error)

func (CompressionAlgorithm) String added in v0.0.20 

func (x CompressionAlgorithm) String() string

func (*CompressionAlgorithm) UnmarshalJSON added in v0.0.20 

func (out *CompressionAlgorithm) UnmarshalJSON(b []byte) error

type DNSRRValidator 

type DNSRRValidator struct {
	FailIfMatchesRegexp    []string `protobuf:"bytes,1,rep,name=failIfMatchesRegexp,proto3" json:"failIfMatchesRegexp,omitempty"`
	FailIfNotMatchesRegexp []string `protobuf:"bytes,2,rep,name=failIfNotMatchesRegexp,proto3" json:"failIfNotMatchesRegexp,omitempty"`
}

DNSRRValidator represents the DNS resource record validations.

func (*DNSRRValidator) Descriptor 

func (*DNSRRValidator) Descriptor() ([]byte, []int)

func (*DNSRRValidator) Marshal 

func (m *DNSRRValidator) Marshal() (dAtA []byte, err error)

func (*DNSRRValidator) MarshalTo 

func (m *DNSRRValidator) MarshalTo(dAtA []byte) (int, error)

func (*DNSRRValidator) MarshalToSizedBuffer 

func (m *DNSRRValidator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DNSRRValidator) ProtoMessage 

func (*DNSRRValidator) ProtoMessage()

func (*DNSRRValidator) Reset 

func (m *DNSRRValidator) Reset()

func (*DNSRRValidator) Size 

func (m *DNSRRValidator) Size() (n int)

func (*DNSRRValidator) String 

func (m *DNSRRValidator) String() string

func (*DNSRRValidator) Unmarshal 

func (m *DNSRRValidator) Unmarshal(dAtA []byte) error

func (*DNSRRValidator) XXX_DiscardUnknown 

func (m *DNSRRValidator) XXX_DiscardUnknown()

func (*DNSRRValidator) XXX_Marshal 

func (m *DNSRRValidator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DNSRRValidator) XXX_Merge 

func (m *DNSRRValidator) XXX_Merge(src proto.Message)

func (*DNSRRValidator) XXX_Size 

func (m *DNSRRValidator) XXX_Size() int

func (*DNSRRValidator) XXX_Unmarshal 

func (m *DNSRRValidator) XXX_Unmarshal(b []byte) error

type DnsProtocol 

type DnsProtocol int32

DnsProtocol represents the IP protocol to use for DNS queries. 

const (
	DnsProtocol_TCP DnsProtocol = 0
	DnsProtocol_UDP DnsProtocol = 1
)

func (DnsProtocol) EnumDescriptor 

func (DnsProtocol) EnumDescriptor() ([]byte, []int)

func (DnsProtocol) MarshalJSON 

func (v DnsProtocol) MarshalJSON() ([]byte, error)

func (DnsProtocol) String 

func (x DnsProtocol) String() string

func (*DnsProtocol) UnmarshalJSON 

func (out *DnsProtocol) UnmarshalJSON(b []byte) error

type DnsRecordType 

type DnsRecordType int32

DnsRecordType represents the DNS record types to be queried in DNS checks. 

const (
	DnsRecordType_ANY   DnsRecordType = 0
	DnsRecordType_A     DnsRecordType = 1
	DnsRecordType_AAAA  DnsRecordType = 2
	DnsRecordType_CNAME DnsRecordType = 3
	DnsRecordType_MX    DnsRecordType = 4
	DnsRecordType_NS    DnsRecordType = 5
	DnsRecordType_PTR   DnsRecordType = 6
	DnsRecordType_SOA   DnsRecordType = 7
	DnsRecordType_SRV   DnsRecordType = 8
	DnsRecordType_TXT   DnsRecordType = 9
)

func (DnsRecordType) EnumDescriptor 

func (DnsRecordType) EnumDescriptor() ([]byte, []int)

func (DnsRecordType) MarshalJSON 

func (v DnsRecordType) MarshalJSON() ([]byte, error)

func (DnsRecordType) String 

func (x DnsRecordType) String() string

func (*DnsRecordType) UnmarshalJSON 

func (out *DnsRecordType) UnmarshalJSON(b []byte) error

type DnsSettings 

type DnsSettings struct {
	IpVersion          IpVersion       `protobuf:"varint,1,opt,name=ipVersion,proto3,enum=synthetic_monitoring.IpVersion" json:"ipVersion"`
	SourceIpAddress    string          `protobuf:"bytes,2,opt,name=sourceIpAddress,proto3" json:"sourceIpAddress,omitempty"`
	Server             string          `protobuf:"bytes,3,opt,name=server,proto3" json:"server"`
	Port               int32           `protobuf:"varint,4,opt,name=port,proto3" json:"port"`
	RecordType         DnsRecordType   `protobuf:"varint,5,opt,name=recordType,proto3,enum=synthetic_monitoring.DnsRecordType" json:"recordType"`
	Protocol           DnsProtocol     `protobuf:"varint,6,opt,name=protocol,proto3,enum=synthetic_monitoring.DnsProtocol" json:"protocol"`
	ValidRCodes        []string        `protobuf:"bytes,200,rep,name=validRCodes,proto3" json:"validRCodes,omitempty"`
	ValidateAnswer     *DNSRRValidator `protobuf:"bytes,201,opt,name=validateAnswer,proto3" json:"validateAnswerRRS,omitempty"`
	ValidateAuthority  *DNSRRValidator `protobuf:"bytes,202,opt,name=validateAuthority,proto3" json:"validateAuthorityRRS,omitempty"`
	ValidateAdditional *DNSRRValidator `protobuf:"bytes,203,opt,name=validateAdditional,proto3" json:"validateAdditionalRRS,omitempty"`
}

DnsSettings provides the settings for a DNS check.

The way blackbox-exporter works, a DNS check tests a _server_, so the _target_ of the check is a server address, and the check itself contains the record to check.

"ipVersion" is the IP version to use in the IP layer.

func (*DnsSettings) Descriptor 

func (*DnsSettings) Descriptor() ([]byte, []int)

func (*DnsSettings) Marshal 

func (m *DnsSettings) Marshal() (dAtA []byte, err error)

func (*DnsSettings) MarshalTo 

func (m *DnsSettings) MarshalTo(dAtA []byte) (int, error)

func (*DnsSettings) MarshalToSizedBuffer 

func (m *DnsSettings) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DnsSettings) ProtoMessage 

func (*DnsSettings) ProtoMessage()

func (*DnsSettings) Reset 

func (m *DnsSettings) Reset()

func (*DnsSettings) Size 

func (m *DnsSettings) Size() (n int)

func (*DnsSettings) String 

func (m *DnsSettings) String() string

func (*DnsSettings) Unmarshal 

func (m *DnsSettings) Unmarshal(dAtA []byte) error

func (*DnsSettings) Validate 

func (s *DnsSettings) Validate() error

func (*DnsSettings) XXX_DiscardUnknown 

func (m *DnsSettings) XXX_DiscardUnknown()

func (*DnsSettings) XXX_Marshal 

func (m *DnsSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DnsSettings) XXX_Merge 

func (m *DnsSettings) XXX_Merge(src proto.Message)

func (*DnsSettings) XXX_Size 

func (m *DnsSettings) XXX_Size() int

func (*DnsSettings) XXX_Unmarshal 

func (m *DnsSettings) XXX_Unmarshal(b []byte) error

type EntityRef added in v0.10.0 

type EntityRef struct {
	Id           int64   `protobuf:"varint,1,opt,name=id,proto3" json:"id"`
	LastModified float64 `protobuf:"fixed64,2,opt,name=lastModified,proto3" json:"lastModified"`
}

EntityRef represents a reference to an entity (check, tenant) by it's ID and last modification time.

func (*EntityRef) Descriptor added in v0.10.0 

func (*EntityRef) Descriptor() ([]byte, []int)

func (*EntityRef) Marshal added in v0.10.0 

func (m *EntityRef) Marshal() (dAtA []byte, err error)

func (*EntityRef) MarshalTo added in v0.10.0 

func (m *EntityRef) MarshalTo(dAtA []byte) (int, error)

func (*EntityRef) MarshalToSizedBuffer added in v0.10.0 

func (m *EntityRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EntityRef) ProtoMessage added in v0.10.0 

func (*EntityRef) ProtoMessage()

func (*EntityRef) Reset added in v0.10.0 

func (m *EntityRef) Reset()

func (*EntityRef) Size added in v0.10.0 

func (m *EntityRef) Size() (n int)

func (*EntityRef) String added in v0.10.0 

func (m *EntityRef) String() string

func (*EntityRef) Unmarshal added in v0.10.0 

func (m *EntityRef) Unmarshal(dAtA []byte) error

func (*EntityRef) XXX_DiscardUnknown added in v0.10.0 

func (m *EntityRef) XXX_DiscardUnknown()

func (*EntityRef) XXX_Marshal added in v0.10.0 

func (m *EntityRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EntityRef) XXX_Merge added in v0.10.0 

func (m *EntityRef) XXX_Merge(src proto.Message)

func (*EntityRef) XXX_Size added in v0.10.0 

func (m *EntityRef) XXX_Size() int

func (*EntityRef) XXX_Unmarshal added in v0.10.0 

func (m *EntityRef) XXX_Unmarshal(b []byte) error

type GrpcSettings added in v0.19.2 

type GrpcSettings struct {
	IpVersion IpVersion  `protobuf:"varint,1,opt,name=ipVersion,proto3,enum=synthetic_monitoring.IpVersion" json:"ipVersion"`
	Service   string     `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Tls       bool       `protobuf:"varint,3,opt,name=tls,proto3" json:"tls,omitempty"`
	TlsConfig *TLSConfig `protobuf:"bytes,4,opt,name=tlsConfig,proto3" json:"tlsConfig,omitempty"`
}

GrpcSettings provides the settings for a gRPC check.

func (*GrpcSettings) Descriptor added in v0.19.2 

func (*GrpcSettings) Descriptor() ([]byte, []int)

func (*GrpcSettings) Marshal added in v0.19.2 

func (m *GrpcSettings) Marshal() (dAtA []byte, err error)

func (*GrpcSettings) MarshalTo added in v0.19.2 

func (m *GrpcSettings) MarshalTo(dAtA []byte) (int, error)

func (*GrpcSettings) MarshalToSizedBuffer added in v0.19.2 

func (m *GrpcSettings) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GrpcSettings) ProtoMessage added in v0.19.2 

func (*GrpcSettings) ProtoMessage()

func (*GrpcSettings) Reset added in v0.19.2 

func (m *GrpcSettings) Reset()

func (*GrpcSettings) Size added in v0.19.2 

func (m *GrpcSettings) Size() (n int)

func (*GrpcSettings) String added in v0.19.2 

func (m *GrpcSettings) String() string

func (*GrpcSettings) Unmarshal added in v0.19.2 

func (m *GrpcSettings) Unmarshal(dAtA []byte) error

func (*GrpcSettings) Validate added in v0.19.2 

func (s *GrpcSettings) Validate() error

func (*GrpcSettings) XXX_DiscardUnknown added in v0.19.2 

func (m *GrpcSettings) XXX_DiscardUnknown()

func (*GrpcSettings) XXX_Marshal added in v0.19.2 

func (m *GrpcSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GrpcSettings) XXX_Merge added in v0.19.2 

func (m *GrpcSettings) XXX_Merge(src proto.Message)

func (*GrpcSettings) XXX_Size added in v0.19.2 

func (m *GrpcSettings) XXX_Size() int

func (*GrpcSettings) XXX_Unmarshal added in v0.19.2 

func (m *GrpcSettings) XXX_Unmarshal(b []byte) error

type HeaderMatch 

type HeaderMatch struct {
	Header       string `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Regexp       string `protobuf:"bytes,2,opt,name=regexp,proto3" json:"regexp,omitempty"`
	AllowMissing bool   `protobuf:"varint,3,opt,name=allowMissing,proto3" json:"allowMissing,omitempty"`
}

HeaderMatch represents a single header that must match in order for the check to be considered successful.

func (*HeaderMatch) Descriptor 

func (*HeaderMatch) Descriptor() ([]byte, []int)

func (*HeaderMatch) Marshal 

func (m *HeaderMatch) Marshal() (dAtA []byte, err error)

func (*HeaderMatch) MarshalTo 

func (m *HeaderMatch) MarshalTo(dAtA []byte) (int, error)

func (*HeaderMatch) MarshalToSizedBuffer 

func (m *HeaderMatch) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HeaderMatch) ProtoMessage 

func (*HeaderMatch) ProtoMessage()

func (*HeaderMatch) Reset 

func (m *HeaderMatch) Reset()

func (*HeaderMatch) Size 

func (m *HeaderMatch) Size() (n int)

func (*HeaderMatch) String 

func (m *HeaderMatch) String() string

func (*HeaderMatch) Unmarshal 

func (m *HeaderMatch) Unmarshal(dAtA []byte) error

func (*HeaderMatch) XXX_DiscardUnknown 

func (m *HeaderMatch) XXX_DiscardUnknown()

func (*HeaderMatch) XXX_Marshal 

func (m *HeaderMatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeaderMatch) XXX_Merge 

func (m *HeaderMatch) XXX_Merge(src proto.Message)

func (*HeaderMatch) XXX_Size 

func (m *HeaderMatch) XXX_Size() int

func (*HeaderMatch) XXX_Unmarshal 

func (m *HeaderMatch) XXX_Unmarshal(b []byte) error

type HttpHeader added in v0.15.0 

type HttpHeader struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value"`
}

HttpHeader represents a single HTTP header key-value pair.

func (*HttpHeader) Descriptor added in v0.15.0 

func (*HttpHeader) Descriptor() ([]byte, []int)

func (*HttpHeader) Marshal added in v0.15.0 

func (m *HttpHeader) Marshal() (dAtA []byte, err error)

func (*HttpHeader) MarshalTo added in v0.15.0 

func (m *HttpHeader) MarshalTo(dAtA []byte) (int, error)

func (*HttpHeader) MarshalToSizedBuffer added in v0.15.0 

func (m *HttpHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HttpHeader) ProtoMessage added in v0.15.0 

func (*HttpHeader) ProtoMessage()

func (*HttpHeader) Reset added in v0.15.0 

func (m *HttpHeader) Reset()

func (*HttpHeader) Size added in v0.15.0 

func (m *HttpHeader) Size() (n int)

func (*HttpHeader) String added in v0.15.0 

func (m *HttpHeader) String() string

func (*HttpHeader) Unmarshal added in v0.15.0 

func (m *HttpHeader) Unmarshal(dAtA []byte) error

func (HttpHeader) Validate added in v0.15.0 

func (h HttpHeader) Validate() error

func (*HttpHeader) XXX_DiscardUnknown added in v0.15.0 

func (m *HttpHeader) XXX_DiscardUnknown()

func (*HttpHeader) XXX_Marshal added in v0.15.0 

func (m *HttpHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HttpHeader) XXX_Merge added in v0.15.0 

func (m *HttpHeader) XXX_Merge(src proto.Message)

func (*HttpHeader) XXX_Size added in v0.15.0 

func (m *HttpHeader) XXX_Size() int

func (*HttpHeader) XXX_Unmarshal added in v0.15.0 

func (m *HttpHeader) XXX_Unmarshal(b []byte) error

type HttpMethod 

type HttpMethod int32

HttpMethod represents the HTTP method used when making HTTP requests. 

const (
	HttpMethod_GET     HttpMethod = 0
	HttpMethod_CONNECT HttpMethod = 1
	HttpMethod_DELETE  HttpMethod = 2
	HttpMethod_HEAD    HttpMethod = 3
	HttpMethod_OPTIONS HttpMethod = 4
	HttpMethod_POST    HttpMethod = 5
	HttpMethod_PUT     HttpMethod = 6
	HttpMethod_TRACE   HttpMethod = 7
)

func (HttpMethod) EnumDescriptor 

func (HttpMethod) EnumDescriptor() ([]byte, []int)

func (HttpMethod) MarshalJSON 

func (v HttpMethod) MarshalJSON() ([]byte, error)

func (HttpMethod) String 

func (x HttpMethod) String() string

func (*HttpMethod) UnmarshalJSON 

func (out *HttpMethod) UnmarshalJSON(b []byte) error

func (HttpMethod) Validate added in v0.15.0 

func (v HttpMethod) Validate() error

type HttpRequestBody added in v0.15.0 

type HttpRequestBody struct {
	ContentType     string `protobuf:"bytes,1,opt,name=contentType,proto3" json:"contentType"`
	ContentEncoding string `protobuf:"bytes,2,opt,name=contentEncoding,proto3" json:"contentEncoding,omitempty"`
	Payload         []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload"`
}

HttpRequestBody represents the body of an HTTP request.

func (*HttpRequestBody) Descriptor added in v0.15.0 

func (*HttpRequestBody) Descriptor() ([]byte, []int)

func (*HttpRequestBody) Marshal added in v0.15.0 

func (m *HttpRequestBody) Marshal() (dAtA []byte, err error)

func (*HttpRequestBody) MarshalTo added in v0.15.0 

func (m *HttpRequestBody) MarshalTo(dAtA []byte) (int, error)

func (*HttpRequestBody) MarshalToSizedBuffer added in v0.15.0 

func (m *HttpRequestBody) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HttpRequestBody) ProtoMessage added in v0.15.0 

func (*HttpRequestBody) ProtoMessage()

func (*HttpRequestBody) Reset added in v0.15.0 

func (m *HttpRequestBody) Reset()

func (*HttpRequestBody) Size added in v0.15.0 

func (m *HttpRequestBody) Size() (n int)

func (*HttpRequestBody) String added in v0.15.0 

func (m *HttpRequestBody) String() string

func (*HttpRequestBody) Unmarshal added in v0.15.0 

func (m *HttpRequestBody) Unmarshal(dAtA []byte) error

func (*HttpRequestBody) Validate added in v0.15.0 

func (b *HttpRequestBody) Validate() error

func (*HttpRequestBody) XXX_DiscardUnknown added in v0.15.0 

func (m *HttpRequestBody) XXX_DiscardUnknown()

func (*HttpRequestBody) XXX_Marshal added in v0.15.0 

func (m *HttpRequestBody) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HttpRequestBody) XXX_Merge added in v0.15.0 

func (m *HttpRequestBody) XXX_Merge(src proto.Message)

func (*HttpRequestBody) XXX_Size added in v0.15.0 

func (m *HttpRequestBody) XXX_Size() int

func (*HttpRequestBody) XXX_Unmarshal added in v0.15.0 

func (m *HttpRequestBody) XXX_Unmarshal(b []byte) error

type HttpSettings 

type HttpSettings struct {
	IpVersion                    IpVersion            `protobuf:"varint,1,opt,name=ipVersion,proto3,enum=synthetic_monitoring.IpVersion" json:"ipVersion"`
	Method                       HttpMethod           `protobuf:"varint,2,opt,name=method,proto3,enum=synthetic_monitoring.HttpMethod" json:"method"`
	Headers                      []string             `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"`
	Body                         string               `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	NoFollowRedirects            bool                 `protobuf:"varint,5,opt,name=noFollowRedirects,proto3" json:"noFollowRedirects"`
	TlsConfig                    *TLSConfig           `protobuf:"bytes,100,opt,name=tlsConfig,proto3" json:"tlsConfig,omitempty"`
	BasicAuth                    *BasicAuth           `protobuf:"bytes,101,opt,name=basicAuth,proto3" json:"basicAuth,omitempty"`
	BearerToken                  string               `protobuf:"bytes,102,opt,name=bearerToken,proto3" json:"bearerToken,omitempty"`
	ProxyURL                     string               `protobuf:"bytes,103,opt,name=proxyURL,proto3" json:"proxyURL,omitempty"`
	Oauth2Config                 *OAuth2Config        `protobuf:"bytes,104,opt,name=oauth2Config,proto3" json:"oauth2Config,omitempty"`
	ProxyConnectHeaders          []string             `protobuf:"bytes,105,rep,name=proxyConnectHeaders,proto3" json:"proxyConnectHeaders,omitempty"`
	FailIfSSL                    bool                 `protobuf:"varint,200,opt,name=failIfSSL,proto3" json:"failIfSSL"`
	FailIfNotSSL                 bool                 `protobuf:"varint,201,opt,name=failIfNotSSL,proto3" json:"failIfNotSSL"`
	ValidStatusCodes             []int32              `protobuf:"varint,202,rep,packed,name=validStatusCodes,proto3" json:"validStatusCodes,omitempty"`
	ValidHTTPVersions            []string             `protobuf:"bytes,203,rep,name=validHTTPVersions,proto3" json:"validHTTPVersions,omitempty"`
	FailIfBodyMatchesRegexp      []string             `protobuf:"bytes,204,rep,name=failIfBodyMatchesRegexp,proto3" json:"failIfBodyMatchesRegexp,omitempty"`
	FailIfBodyNotMatchesRegexp   []string             `protobuf:"bytes,205,rep,name=failIfBodyNotMatchesRegexp,proto3" json:"failIfBodyNotMatchesRegexp,omitempty"`
	FailIfHeaderMatchesRegexp    []HeaderMatch        `protobuf:"bytes,206,rep,name=failIfHeaderMatchesRegexp,proto3" json:"failIfHeaderMatchesRegexp,omitempty"`
	FailIfHeaderNotMatchesRegexp []HeaderMatch        `protobuf:"bytes,207,rep,name=failIfHeaderNotMatchesRegexp,proto3" json:"failIfHeaderNotMatchesRegexp,omitempty"`
	Compression                  CompressionAlgorithm `protobuf:"varint,208,opt,name=compression,proto3,enum=synthetic_monitoring.CompressionAlgorithm" json:"compression,omitempty"`
	CacheBustingQueryParamName   string               `protobuf:"bytes,900,opt,name=cacheBustingQueryParamName,proto3" json:"cacheBustingQueryParamName,omitempty"`
}

HttpSettings provides the settings for a HTTP check.

func (*HttpSettings) Descriptor 

func (*HttpSettings) Descriptor() ([]byte, []int)

func (*HttpSettings) Marshal 

func (m *HttpSettings) Marshal() (dAtA []byte, err error)

func (*HttpSettings) MarshalTo 

func (m *HttpSettings) MarshalTo(dAtA []byte) (int, error)

func (*HttpSettings) MarshalToSizedBuffer 

func (m *HttpSettings) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HttpSettings) ProtoMessage 

func (*HttpSettings) ProtoMessage()

func (*HttpSettings) Reset 

func (m *HttpSettings) Reset()

func (*HttpSettings) Size 

func (m *HttpSettings) Size() (n int)

func (*HttpSettings) String 

func (m *HttpSettings) String() string

func (*HttpSettings) Unmarshal 

func (m *HttpSettings) Unmarshal(dAtA []byte) error

func (*HttpSettings) Validate 

func (s *HttpSettings) Validate() error

func (*HttpSettings) XXX_DiscardUnknown 

func (m *HttpSettings) XXX_DiscardUnknown()

func (*HttpSettings) XXX_Marshal 

func (m *HttpSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HttpSettings) XXX_Merge 

func (m *HttpSettings) XXX_Merge(src proto.Message)

func (*HttpSettings) XXX_Size 

func (m *HttpSettings) XXX_Size() int

func (*HttpSettings) XXX_Unmarshal 

func (m *HttpSettings) XXX_Unmarshal(b []byte) error

type IpVersion 

type IpVersion int32

IpVersion represents the version of the IP protocol to be used in checks. 

const (
	IpVersion_Any IpVersion = 0
	IpVersion_V4  IpVersion = 1
	IpVersion_V6  IpVersion = 2
)

func (IpVersion) EnumDescriptor 

func (IpVersion) EnumDescriptor() ([]byte, []int)

func (IpVersion) MarshalJSON 

func (v IpVersion) MarshalJSON() ([]byte, error)

func (IpVersion) String 

func (x IpVersion) String() string

func (IpVersion) ToIpProtocol added in v0.0.24 

func (v IpVersion) ToIpProtocol() (string, bool)

ToIpProtocol converts the IpVersion setting into a pair of IP protocol and fallback option.

func (*IpVersion) UnmarshalJSON 

func (out *IpVersion) UnmarshalJSON(b []byte) error

type Label 

type Label struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value"`
}

Label represents a single label in synthetic monitoring. These are applied to the resulting metrics and logs.

func (*Label) Descriptor 

func (*Label) Descriptor() ([]byte, []int)

func (*Label) Marshal 

func (m *Label) Marshal() (dAtA []byte, err error)

func (*Label) MarshalTo 

func (m *Label) MarshalTo(dAtA []byte) (int, error)

func (*Label) MarshalToSizedBuffer 

func (m *Label) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) Reset 

func (m *Label) Reset()

func (*Label) Size 

func (m *Label) Size() (n int)

func (*Label) String 

func (m *Label) String() string

func (*Label) Unmarshal 

func (m *Label) Unmarshal(dAtA []byte) error

func (Label) Validate added in v0.0.13 

func (l Label) Validate() error

func (*Label) XXX_DiscardUnknown 

func (m *Label) XXX_DiscardUnknown()

func (*Label) XXX_Marshal 

func (m *Label) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Label) XXX_Merge 

func (m *Label) XXX_Merge(src proto.Message)

func (*Label) XXX_Size 

func (m *Label) XXX_Size() int

func (*Label) XXX_Unmarshal 

func (m *Label) XXX_Unmarshal(b []byte) error

type MultiHttpEntry added in v0.15.0 

type MultiHttpEntry struct {
	Request    *MultiHttpEntryRequest     `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Assertions []*MultiHttpEntryAssertion `protobuf:"bytes,2,rep,name=assertions,proto3" json:"checks,omitempty"`
	Variables  []*MultiHttpEntryVariable  `protobuf:"bytes,3,rep,name=variables,proto3" json:"variables,omitempty"`
}

MultiHttpEntry represents a single entry in a MultiHttp check.

func (*MultiHttpEntry) Descriptor added in v0.15.0 

func (*MultiHttpEntry) Descriptor() ([]byte, []int)

func (*MultiHttpEntry) Marshal added in v0.15.0 

func (m *MultiHttpEntry) Marshal() (dAtA []byte, err error)

func (*MultiHttpEntry) MarshalTo added in v0.15.0 

func (m *MultiHttpEntry) MarshalTo(dAtA []byte) (int, error)

func (*MultiHttpEntry) MarshalToSizedBuffer added in v0.15.0 

func (m *MultiHttpEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MultiHttpEntry) ProtoMessage added in v0.15.0 

func (*MultiHttpEntry) ProtoMessage()

func (*MultiHttpEntry) Reset added in v0.15.0 

func (m *MultiHttpEntry) Reset()

func (*MultiHttpEntry) Size added in v0.15.0 

func (m *MultiHttpEntry) Size() (n int)

func (*MultiHttpEntry) String added in v0.15.0 

func (m *MultiHttpEntry) String() string

func (*MultiHttpEntry) Unmarshal added in v0.15.0 

func (m *MultiHttpEntry) Unmarshal(dAtA []byte) error

func (*MultiHttpEntry) Validate added in v0.15.0 

func (e *MultiHttpEntry) Validate() error

func (*MultiHttpEntry) XXX_DiscardUnknown added in v0.15.0 

func (m *MultiHttpEntry) XXX_DiscardUnknown()

func (*MultiHttpEntry) XXX_Marshal added in v0.15.0 

func (m *MultiHttpEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultiHttpEntry) XXX_Merge added in v0.15.0 

func (m *MultiHttpEntry) XXX_Merge(src proto.Message)

func (*MultiHttpEntry) XXX_Size added in v0.15.0 

func (m *MultiHttpEntry) XXX_Size() int

func (*MultiHttpEntry) XXX_Unmarshal added in v0.15.0 

func (m *MultiHttpEntry) XXX_Unmarshal(b []byte) error

type MultiHttpEntryAssertion added in v0.15.0 

type MultiHttpEntryAssertion struct {
	Type       MultiHttpEntryAssertionType             `protobuf:"varint,1,opt,name=type,proto3,enum=synthetic_monitoring.MultiHttpEntryAssertionType" json:"type"`
	Subject    MultiHttpEntryAssertionSubjectVariant   `` /* 132-byte string literal not displayed */
	Condition  MultiHttpEntryAssertionConditionVariant `` /* 138-byte string literal not displayed */
	Expression string                                  `protobuf:"bytes,4,opt,name=expression,proto3" json:"expression,omitempty"`
	Value      string                                  `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
}

MultiHttpEntryAssertion represents a single assertion to be made on the response.

The `value` field specifies the _value_ that the subject and the condition should meet, e.g. if the subject is body and the condition is contains, value specifies the substring that should be found in the body.

For the JSON_PATH_VALUE type, `expression` specifies the JSON path to match against `value`.

For the JSON_PATH_ASSERTION type, `expression` specifies the JSON path to assert.

For the TEXT type, if the subject is `RESPONSE_HEADERS`, `expression` specifies which specific header should be used as the subject of the operation. Headers are case-insensitive (RFC 7230, section 3.2, https://datatracker.ietf.org/doc/html/rfc7230#section-3.2).

func (*MultiHttpEntryAssertion) Descriptor added in v0.15.0 

func (*MultiHttpEntryAssertion) Descriptor() ([]byte, []int)

func (*MultiHttpEntryAssertion) Marshal added in v0.15.0 

func (m *MultiHttpEntryAssertion) Marshal() (dAtA []byte, err error)

func (*MultiHttpEntryAssertion) MarshalTo added in v0.15.0 

func (m *MultiHttpEntryAssertion) MarshalTo(dAtA []byte) (int, error)

func (*MultiHttpEntryAssertion) MarshalToSizedBuffer added in v0.15.0 

func (m *MultiHttpEntryAssertion) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MultiHttpEntryAssertion) ProtoMessage added in v0.15.0 

func (*MultiHttpEntryAssertion) ProtoMessage()

func (*MultiHttpEntryAssertion) Reset added in v0.15.0 

func (m *MultiHttpEntryAssertion) Reset()

func (*MultiHttpEntryAssertion) Size added in v0.15.0 

func (m *MultiHttpEntryAssertion) Size() (n int)

func (*MultiHttpEntryAssertion) String added in v0.15.0 

func (m *MultiHttpEntryAssertion) String() string

func (*MultiHttpEntryAssertion) Unmarshal added in v0.15.0 

func (m *MultiHttpEntryAssertion) Unmarshal(dAtA []byte) error

func (*MultiHttpEntryAssertion) Validate added in v0.15.0 

func (a *MultiHttpEntryAssertion) Validate() error

Validate verifies that the MultiHttpEntryAssertion is valid.

Because of the structure represents multiple orthogonal variants, this function has to branch based on the type.

func (*MultiHttpEntryAssertion) XXX_DiscardUnknown added in v0.15.0 

func (m *MultiHttpEntryAssertion) XXX_DiscardUnknown()

func (*MultiHttpEntryAssertion) XXX_Marshal added in v0.15.0 

func (m *MultiHttpEntryAssertion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultiHttpEntryAssertion) XXX_Merge added in v0.15.0 

func (m *MultiHttpEntryAssertion) XXX_Merge(src proto.Message)

func (*MultiHttpEntryAssertion) XXX_Size added in v0.15.0 

func (m *MultiHttpEntryAssertion) XXX_Size() int

func (*MultiHttpEntryAssertion) XXX_Unmarshal added in v0.15.0 

func (m *MultiHttpEntryAssertion) XXX_Unmarshal(b []byte) error

type MultiHttpEntryAssertionConditionVariant added in v0.15.0 

type MultiHttpEntryAssertionConditionVariant int32

MultiHttpEntryAssertionConditionVariant represents the condition between the assertion's expression and value. 

const (
	MultiHttpEntryAssertionConditionVariant_DEFAULT_CONDITION MultiHttpEntryAssertionConditionVariant = 0
	MultiHttpEntryAssertionConditionVariant_NOT_CONTAINS      MultiHttpEntryAssertionConditionVariant = 1
	MultiHttpEntryAssertionConditionVariant_EQUALS            MultiHttpEntryAssertionConditionVariant = 2
	MultiHttpEntryAssertionConditionVariant_STARTS_WITH       MultiHttpEntryAssertionConditionVariant = 3
	MultiHttpEntryAssertionConditionVariant_ENDS_WITH         MultiHttpEntryAssertionConditionVariant = 4
	MultiHttpEntryAssertionConditionVariant_TYPE_OF           MultiHttpEntryAssertionConditionVariant = 5
	MultiHttpEntryAssertionConditionVariant_CONTAINS          MultiHttpEntryAssertionConditionVariant = 6
)

func MultiHttpEntryAssertionConditionVariantString added in v0.18.2 

func MultiHttpEntryAssertionConditionVariantString(s string) (MultiHttpEntryAssertionConditionVariant, error)

MultiHttpEntryAssertionConditionVariantString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func MultiHttpEntryAssertionConditionVariantValues added in v0.18.2 

func MultiHttpEntryAssertionConditionVariantValues() []MultiHttpEntryAssertionConditionVariant

MultiHttpEntryAssertionConditionVariantValues returns all values of the enum

func (MultiHttpEntryAssertionConditionVariant) EnumDescriptor added in v0.15.0 

func (MultiHttpEntryAssertionConditionVariant) EnumDescriptor() ([]byte, []int)

func (MultiHttpEntryAssertionConditionVariant) IsAMultiHttpEntryAssertionConditionVariant added in v0.18.2 

func (i MultiHttpEntryAssertionConditionVariant) IsAMultiHttpEntryAssertionConditionVariant() bool

IsAMultiHttpEntryAssertionConditionVariant returns "true" if the value is listed in the enum definition. "false" otherwise

func (MultiHttpEntryAssertionConditionVariant) String added in v0.15.0 

func (i MultiHttpEntryAssertionConditionVariant) String() string

type MultiHttpEntryAssertionSubjectVariant added in v0.15.0 

type MultiHttpEntryAssertionSubjectVariant int32

MultiHttpEntryAssertionSubjectVariant represents the subject of the assertion. 

const (
	MultiHttpEntryAssertionSubjectVariant_DEFAULT_SUBJECT  MultiHttpEntryAssertionSubjectVariant = 0
	MultiHttpEntryAssertionSubjectVariant_RESPONSE_HEADERS MultiHttpEntryAssertionSubjectVariant = 1
	MultiHttpEntryAssertionSubjectVariant_HTTP_STATUS_CODE MultiHttpEntryAssertionSubjectVariant = 2
	MultiHttpEntryAssertionSubjectVariant_RESPONSE_BODY    MultiHttpEntryAssertionSubjectVariant = 3
)

func MultiHttpEntryAssertionSubjectVariantString added in v0.18.2 

func MultiHttpEntryAssertionSubjectVariantString(s string) (MultiHttpEntryAssertionSubjectVariant, error)

MultiHttpEntryAssertionSubjectVariantString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func MultiHttpEntryAssertionSubjectVariantValues added in v0.18.2 

func MultiHttpEntryAssertionSubjectVariantValues() []MultiHttpEntryAssertionSubjectVariant

MultiHttpEntryAssertionSubjectVariantValues returns all values of the enum

func (MultiHttpEntryAssertionSubjectVariant) EnumDescriptor added in v0.15.0 

func (MultiHttpEntryAssertionSubjectVariant) EnumDescriptor() ([]byte, []int)

func (MultiHttpEntryAssertionSubjectVariant) IsAMultiHttpEntryAssertionSubjectVariant added in v0.18.2 

func (i MultiHttpEntryAssertionSubjectVariant) IsAMultiHttpEntryAssertionSubjectVariant() bool

IsAMultiHttpEntryAssertionSubjectVariant returns "true" if the value is listed in the enum definition. "false" otherwise

func (MultiHttpEntryAssertionSubjectVariant) String added in v0.15.0 

func (i MultiHttpEntryAssertionSubjectVariant) String() string

type MultiHttpEntryAssertionType added in v0.15.0 

type MultiHttpEntryAssertionType int32

MultiHttpEntryAssertionType represents the type of assertion to be made. 

const (
	MultiHttpEntryAssertionType_TEXT                MultiHttpEntryAssertionType = 0
	MultiHttpEntryAssertionType_JSON_PATH_VALUE     MultiHttpEntryAssertionType = 1
	MultiHttpEntryAssertionType_JSON_PATH_ASSERTION MultiHttpEntryAssertionType = 2
	MultiHttpEntryAssertionType_REGEX_ASSERTION     MultiHttpEntryAssertionType = 3
)

func MultiHttpEntryAssertionTypeString added in v0.18.2 

func MultiHttpEntryAssertionTypeString(s string) (MultiHttpEntryAssertionType, error)

MultiHttpEntryAssertionTypeString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func MultiHttpEntryAssertionTypeValues added in v0.18.2 

func MultiHttpEntryAssertionTypeValues() []MultiHttpEntryAssertionType

MultiHttpEntryAssertionTypeValues returns all values of the enum

func (MultiHttpEntryAssertionType) EnumDescriptor added in v0.15.0 

func (MultiHttpEntryAssertionType) EnumDescriptor() ([]byte, []int)

func (MultiHttpEntryAssertionType) IsAMultiHttpEntryAssertionType added in v0.18.2 

func (i MultiHttpEntryAssertionType) IsAMultiHttpEntryAssertionType() bool

IsAMultiHttpEntryAssertionType returns "true" if the value is listed in the enum definition. "false" otherwise

func (MultiHttpEntryAssertionType) String added in v0.15.0 

func (i MultiHttpEntryAssertionType) String() string

type MultiHttpEntryRequest added in v0.15.0 

type MultiHttpEntryRequest struct {
	Method      HttpMethod       `protobuf:"varint,1,opt,name=method,proto3,enum=synthetic_monitoring.HttpMethod" json:"method"`
	Url         string           `protobuf:"bytes,2,opt,name=url,proto3" json:"url"`
	Headers     []*HttpHeader    `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"`
	QueryFields []*QueryField    `protobuf:"bytes,4,rep,name=queryFields,proto3" json:"queryFields,omitempty"`
	Body        *HttpRequestBody `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
}

MultiHttpEntryRequest contains the settings for a single request in a MultiHttp check.

func (*MultiHttpEntryRequest) Descriptor added in v0.15.0 

func (*MultiHttpEntryRequest) Descriptor() ([]byte, []int)

func (*MultiHttpEntryRequest) Marshal added in v0.15.0 

func (m *MultiHttpEntryRequest) Marshal() (dAtA []byte, err error)

func (*MultiHttpEntryRequest) MarshalTo added in v0.15.0 

func (m *MultiHttpEntryRequest) MarshalTo(dAtA []byte) (int, error)

func (*MultiHttpEntryRequest) MarshalToSizedBuffer added in v0.15.0 

func (m *MultiHttpEntryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MultiHttpEntryRequest) ProtoMessage added in v0.15.0 

func (*MultiHttpEntryRequest) ProtoMessage()

func (*MultiHttpEntryRequest) Reset added in v0.15.0 

func (m *MultiHttpEntryRequest) Reset()

func (*MultiHttpEntryRequest) Size added in v0.15.0 

func (m *MultiHttpEntryRequest) Size() (n int)

func (*MultiHttpEntryRequest) String added in v0.15.0 

func (m *MultiHttpEntryRequest) String() string

func (*MultiHttpEntryRequest) Unmarshal added in v0.15.0 

func (m *MultiHttpEntryRequest) Unmarshal(dAtA []byte) error

func (*MultiHttpEntryRequest) Validate added in v0.15.0 

func (r *MultiHttpEntryRequest) Validate() error

func (*MultiHttpEntryRequest) XXX_DiscardUnknown added in v0.15.0 

func (m *MultiHttpEntryRequest) XXX_DiscardUnknown()

func (*MultiHttpEntryRequest) XXX_Marshal added in v0.15.0 

func (m *MultiHttpEntryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultiHttpEntryRequest) XXX_Merge added in v0.15.0 

func (m *MultiHttpEntryRequest) XXX_Merge(src proto.Message)

func (*MultiHttpEntryRequest) XXX_Size added in v0.15.0 

func (m *MultiHttpEntryRequest) XXX_Size() int

func (*MultiHttpEntryRequest) XXX_Unmarshal added in v0.15.0 

func (m *MultiHttpEntryRequest) XXX_Unmarshal(b []byte) error

type MultiHttpEntryVariable added in v0.15.0 

type MultiHttpEntryVariable struct {
	Type       MultiHttpEntryVariableType `protobuf:"varint,1,opt,name=type,proto3,enum=synthetic_monitoring.MultiHttpEntryVariableType" json:"type"`
	Name       string                     `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Expression string                     `protobuf:"bytes,3,opt,name=expression,proto3" json:"expression,omitempty"`
	Attribute  string                     `protobuf:"bytes,4,opt,name=attribute,proto3" json:"attribute,omitempty"`
}

MultiHttpEntryVariable represents a single variable to be used in the request.

func (*MultiHttpEntryVariable) Descriptor added in v0.15.0 

func (*MultiHttpEntryVariable) Descriptor() ([]byte, []int)

func (*MultiHttpEntryVariable) Marshal added in v0.15.0 

func (m *MultiHttpEntryVariable) Marshal() (dAtA []byte, err error)

func (*MultiHttpEntryVariable) MarshalTo added in v0.15.0 

func (m *MultiHttpEntryVariable) MarshalTo(dAtA []byte) (int, error)

func (*MultiHttpEntryVariable) MarshalToSizedBuffer added in v0.15.0 

func (m *MultiHttpEntryVariable) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MultiHttpEntryVariable) ProtoMessage added in v0.15.0 

func (*MultiHttpEntryVariable) ProtoMessage()

func (*MultiHttpEntryVariable) Reset added in v0.15.0 

func (m *MultiHttpEntryVariable) Reset()

func (*MultiHttpEntryVariable) Size added in v0.15.0 

func (m *MultiHttpEntryVariable) Size() (n int)

func (*MultiHttpEntryVariable) String added in v0.15.0 

func (m *MultiHttpEntryVariable) String() string

func (*MultiHttpEntryVariable) Unmarshal added in v0.15.0 

func (m *MultiHttpEntryVariable) Unmarshal(dAtA []byte) error

func (*MultiHttpEntryVariable) Validate added in v0.15.0 

func (v *MultiHttpEntryVariable) Validate() error

func (*MultiHttpEntryVariable) XXX_DiscardUnknown added in v0.15.0 

func (m *MultiHttpEntryVariable) XXX_DiscardUnknown()

func (*MultiHttpEntryVariable) XXX_Marshal added in v0.15.0 

func (m *MultiHttpEntryVariable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultiHttpEntryVariable) XXX_Merge added in v0.15.0 

func (m *MultiHttpEntryVariable) XXX_Merge(src proto.Message)

func (*MultiHttpEntryVariable) XXX_Size added in v0.15.0 

func (m *MultiHttpEntryVariable) XXX_Size() int

func (*MultiHttpEntryVariable) XXX_Unmarshal added in v0.15.0 

func (m *MultiHttpEntryVariable) XXX_Unmarshal(b []byte) error

type MultiHttpEntryVariableType added in v0.15.0 

type MultiHttpEntryVariableType int32

MultiHttpEntryVariableType represents the type of expression used to populate the variable. 

const (
	MultiHttpEntryVariableType_JSON_PATH    MultiHttpEntryVariableType = 0
	MultiHttpEntryVariableType_REGEX        MultiHttpEntryVariableType = 1
	MultiHttpEntryVariableType_CSS_SELECTOR MultiHttpEntryVariableType = 2
)

func MultiHttpEntryVariableTypeString added in v0.18.2 

func MultiHttpEntryVariableTypeString(s string) (MultiHttpEntryVariableType, error)

MultiHttpEntryVariableTypeString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func MultiHttpEntryVariableTypeValues added in v0.18.2 

func MultiHttpEntryVariableTypeValues() []MultiHttpEntryVariableType

MultiHttpEntryVariableTypeValues returns all values of the enum

func (MultiHttpEntryVariableType) EnumDescriptor added in v0.15.0 

func (MultiHttpEntryVariableType) EnumDescriptor() ([]byte, []int)

func (MultiHttpEntryVariableType) IsAMultiHttpEntryVariableType added in v0.18.2 

func (i MultiHttpEntryVariableType) IsAMultiHttpEntryVariableType() bool

IsAMultiHttpEntryVariableType returns "true" if the value is listed in the enum definition. "false" otherwise

func (MultiHttpEntryVariableType) String added in v0.15.0 

func (i MultiHttpEntryVariableType) String() string

type MultiHttpSettings added in v0.15.0 

type MultiHttpSettings struct {
	Entries      []*MultiHttpEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries"`
	LogResponses bool              `protobuf:"varint,2,opt,name=logResponses,proto3" json:"logResponseBodies,omitempty"`
}

MultiHttpSettings represents the settings for the MultiHttp check type.

func (*MultiHttpSettings) Descriptor added in v0.15.0 

func (*MultiHttpSettings) Descriptor() ([]byte, []int)

func (*MultiHttpSettings) Marshal added in v0.15.0 

func (m *MultiHttpSettings) Marshal() (dAtA []byte, err error)

func (*MultiHttpSettings) MarshalTo added in v0.15.0 

func (m *MultiHttpSettings) MarshalTo(dAtA []byte) (int, error)

func (*MultiHttpSettings) MarshalToSizedBuffer added in v0.15.0 

func (m *MultiHttpSettings) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MultiHttpSettings) ProtoMessage added in v0.15.0 

func (*MultiHttpSettings) ProtoMessage()

func (*MultiHttpSettings) Reset added in v0.15.0 

func (m *MultiHttpSettings) Reset()

func (*MultiHttpSettings) Size added in v0.15.0 

func (m *MultiHttpSettings) Size() (n int)

func (*MultiHttpSettings) String added in v0.15.0 

func (m *MultiHttpSettings) String() string

func (*MultiHttpSettings) Unmarshal added in v0.15.0 

func (m *MultiHttpSettings) Unmarshal(dAtA []byte) error

func (*MultiHttpSettings) Validate added in v0.15.0 

func (s *MultiHttpSettings) Validate() error

func (*MultiHttpSettings) XXX_DiscardUnknown added in v0.15.0 

func (m *MultiHttpSettings) XXX_DiscardUnknown()

func (*MultiHttpSettings) XXX_Marshal added in v0.15.0 

func (m *MultiHttpSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultiHttpSettings) XXX_Merge added in v0.15.0 

func (m *MultiHttpSettings) XXX_Merge(src proto.Message)

func (*MultiHttpSettings) XXX_Size added in v0.15.0 

func (m *MultiHttpSettings) XXX_Size() int

func (*MultiHttpSettings) XXX_Unmarshal added in v0.15.0 

func (m *MultiHttpSettings) XXX_Unmarshal(b []byte) error

type OAuth2Config added in v0.12.0 

type OAuth2Config struct {
	ClientId       string     `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId"`
	ClientSecret   string     `protobuf:"bytes,2,opt,name=clientSecret,proto3" json:"clientSecret"`
	TokenURL       string     `protobuf:"bytes,3,opt,name=tokenURL,proto3" json:"tokenURL"`
	Scopes         []string   `protobuf:"bytes,4,rep,name=scopes,proto3" json:"scopes,omitempty"`
	EndpointParams []Label    `protobuf:"bytes,5,rep,name=endpointParams,proto3" json:"endpointParams,omitempty"`
	TlsConfig      *TLSConfig `protobuf:"bytes,6,opt,name=tlsConfig,proto3" json:"tlsConfig,omitempty"`
	ProxyURL       string     `protobuf:"bytes,7,opt,name=proxyURL,proto3" json:"proxyURL,omitempty"`
}

Configuration for two-legged OAuth2 (client_credentials grant type).

func (*OAuth2Config) Descriptor added in v0.12.0 

func (*OAuth2Config) Descriptor() ([]byte, []int)

func (*OAuth2Config) Marshal added in v0.12.0 

func (m *OAuth2Config) Marshal() (dAtA []byte, err error)

func (*OAuth2Config) MarshalTo added in v0.12.0 

func (m *OAuth2Config) MarshalTo(dAtA []byte) (int, error)

func (*OAuth2Config) MarshalToSizedBuffer added in v0.12.0 

func (m *OAuth2Config) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OAuth2Config) ProtoMessage added in v0.12.0 

func (*OAuth2Config) ProtoMessage()

func (*OAuth2Config) Reset added in v0.12.0 

func (m *OAuth2Config) Reset()

func (*OAuth2Config) Size added in v0.12.0 

func (m *OAuth2Config) Size() (n int)

func (*OAuth2Config) String added in v0.12.0 

func (m *OAuth2Config) String() string

func (*OAuth2Config) Unmarshal added in v0.12.0 

func (m *OAuth2Config) Unmarshal(dAtA []byte) error

func (*OAuth2Config) XXX_DiscardUnknown added in v0.12.0 

func (m *OAuth2Config) XXX_DiscardUnknown()

func (*OAuth2Config) XXX_Marshal added in v0.12.0 

func (m *OAuth2Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OAuth2Config) XXX_Merge added in v0.12.0 

func (m *OAuth2Config) XXX_Merge(src proto.Message)

func (*OAuth2Config) XXX_Size added in v0.12.0 

func (m *OAuth2Config) XXX_Size() int

func (*OAuth2Config) XXX_Unmarshal added in v0.12.0 

func (m *OAuth2Config) XXX_Unmarshal(b []byte) error

type PingRequest added in v0.9.0 

type PingRequest struct {
	Sequence int64 `protobuf:"varint,1,opt,name=Sequence,proto3" json:"sequence"`
}

PingRequest is the message sent as argument of the Ping method.

func (*PingRequest) Descriptor added in v0.9.0 

func (*PingRequest) Descriptor() ([]byte, []int)

func (*PingRequest) Marshal added in v0.9.0 

func (m *PingRequest) Marshal() (dAtA []byte, err error)

func (*PingRequest) MarshalTo added in v0.9.0 

func (m *PingRequest) MarshalTo(dAtA []byte) (int, error)

func (*PingRequest) MarshalToSizedBuffer added in v0.9.0 

func (m *PingRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PingRequest) ProtoMessage added in v0.9.0 

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset added in v0.9.0 

func (m *PingRequest) Reset()

func (*PingRequest) Size added in v0.9.0 

func (m *PingRequest) Size() (n int)

func (*PingRequest) String added in v0.9.0 

func (m *PingRequest) String() string

func (*PingRequest) Unmarshal added in v0.9.0 

func (m *PingRequest) Unmarshal(dAtA []byte) error

func (*PingRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal added in v0.9.0 

func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingRequest) XXX_Merge added in v0.9.0 

func (m *PingRequest) XXX_Merge(src proto.Message)

func (*PingRequest) XXX_Size added in v0.9.0 

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal added in v0.9.0 

func (m *PingRequest) XXX_Unmarshal(b []byte) error

type PingSettings 

type PingSettings struct {
	IpVersion       IpVersion `protobuf:"varint,1,opt,name=ipVersion,proto3,enum=synthetic_monitoring.IpVersion" json:"ipVersion"`
	SourceIpAddress string    `protobuf:"bytes,2,opt,name=sourceIpAddress,proto3" json:"sourceIpAddress,omitempty"`
	PayloadSize     int64     `protobuf:"varint,3,opt,name=payloadSize,proto3" json:"payloadSize,omitempty"`
	DontFragment    bool      `protobuf:"varint,4,opt,name=dontFragment,proto3" json:"dontFragment"`
	PacketCount     int64     `protobuf:"varint,900,opt,name=packetCount,proto3" json:"packetCount"`
}

PingSettings provides the settings for a ping check.

func (*PingSettings) Descriptor 

func (*PingSettings) Descriptor() ([]byte, []int)

func (*PingSettings) Marshal 

func (m *PingSettings) Marshal() (dAtA []byte, err error)

func (*PingSettings) MarshalTo 

func (m *PingSettings) MarshalTo(dAtA []byte) (int, error)

func (*PingSettings) MarshalToSizedBuffer 

func (m *PingSettings) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PingSettings) ProtoMessage 

func (*PingSettings) ProtoMessage()

func (*PingSettings) Reset 

func (m *PingSettings) Reset()

func (*PingSettings) Size 

func (m *PingSettings) Size() (n int)

func (*PingSettings) String 

func (m *PingSettings) String() string

func (*PingSettings) Unmarshal 

func (m *PingSettings) Unmarshal(dAtA []byte) error

func (*PingSettings) Validate 

func (s *PingSettings) Validate() error

func (*PingSettings) XXX_DiscardUnknown 

func (m *PingSettings) XXX_DiscardUnknown()

func (*PingSettings) XXX_Marshal 

func (m *PingSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingSettings) XXX_Merge 

func (m *PingSettings) XXX_Merge(src proto.Message)

func (*PingSettings) XXX_Size 

func (m *PingSettings) XXX_Size() int

func (*PingSettings) XXX_Unmarshal 

func (m *PingSettings) XXX_Unmarshal(b []byte) error

type PongResponse added in v0.9.0 

type PongResponse struct {
	Sequence int64 `protobuf:"varint,1,opt,name=Sequence,proto3" json:"sequence"`
}

PongResponse is the message received as response from the Ping method.

func (*PongResponse) Descriptor added in v0.9.0 

func (*PongResponse) Descriptor() ([]byte, []int)

func (*PongResponse) Marshal added in v0.9.0 

func (m *PongResponse) Marshal() (dAtA []byte, err error)

func (*PongResponse) MarshalTo added in v0.9.0 

func (m *PongResponse) MarshalTo(dAtA []byte) (int, error)

func (*PongResponse) MarshalToSizedBuffer added in v0.9.0 

func (m *PongResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PongResponse) ProtoMessage added in v0.9.0 

func (*PongResponse) ProtoMessage()

func (*PongResponse) Reset added in v0.9.0 

func (m *PongResponse) Reset()

func (*PongResponse) Size added in v0.9.0 

func (m *PongResponse) Size() (n int)

func (*PongResponse) String added in v0.9.0 

func (m *PongResponse) String() string

func (*PongResponse) Unmarshal added in v0.9.0 

func (m *PongResponse) Unmarshal(dAtA []byte) error

func (*PongResponse) XXX_DiscardUnknown added in v0.9.0 

func (m *PongResponse) XXX_DiscardUnknown()

func (*PongResponse) XXX_Marshal added in v0.9.0 

func (m *PongResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PongResponse) XXX_Merge added in v0.9.0 

func (m *PongResponse) XXX_Merge(src proto.Message)

func (*PongResponse) XXX_Size added in v0.9.0 

func (m *PongResponse) XXX_Size() int

func (*PongResponse) XXX_Unmarshal added in v0.9.0 

func (m *PongResponse) XXX_Unmarshal(b []byte) error

type Probe 

type Probe struct {
	Id           int64   `protobuf:"varint,1,opt,name=id,proto3" json:"id"`
	TenantId     int64   `protobuf:"varint,2,opt,name=tenantId,proto3" json:"tenantId"`
	Name         string  `protobuf:"bytes,3,opt,name=name,proto3" json:"name"`
	Latitude     float32 `protobuf:"fixed32,4,opt,name=latitude,proto3" json:"latitude"`
	Longitude    float32 `protobuf:"fixed32,5,opt,name=longitude,proto3" json:"longitude"`
	Labels       []Label `protobuf:"bytes,6,rep,name=labels,proto3" json:"labels"`
	Region       string  `protobuf:"bytes,7,opt,name=region,proto3" json:"region"`
	Public       bool    `protobuf:"varint,8,opt,name=public,proto3" json:"public"`
	Online       bool    `protobuf:"varint,9,opt,name=online,proto3" json:"online"`
	OnlineChange float64 `protobuf:"fixed64,10,opt,name=onlineChange,proto3" json:"onlineChange"`
	Version      string  `protobuf:"bytes,11,opt,name=version,proto3" json:"version"`
	Commit       string  `protobuf:"bytes,12,opt,name=commit,proto3" json:"commit"`
	Buildstamp   string  `protobuf:"bytes,13,opt,name=buildstamp,proto3" json:"buildstamp"`
	Deprecated   bool    `protobuf:"varint,14,opt,name=deprecated,proto3" json:"deprecated"`
	Created      float64 `protobuf:"fixed64,100,opt,name=created,proto3" json:"created"`
	Modified     float64 `protobuf:"fixed64,101,opt,name=modified,proto3" json:"modified"`
}

Probe represents a probe.

func (*Probe) Descriptor 

func (*Probe) Descriptor() ([]byte, []int)

func (*Probe) Marshal 

func (m *Probe) Marshal() (dAtA []byte, err error)

func (*Probe) MarshalTo 

func (m *Probe) MarshalTo(dAtA []byte) (int, error)

func (*Probe) MarshalToSizedBuffer 

func (m *Probe) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Probe) ProtoMessage 

func (*Probe) ProtoMessage()

func (*Probe) Reset 

func (m *Probe) Reset()

func (*Probe) Size 

func (m *Probe) Size() (n int)

func (*Probe) String 

func (m *Probe) String() string

func (*Probe) Unmarshal 

func (m *Probe) Unmarshal(dAtA []byte) error

func (*Probe) Validate 

func (p *Probe) Validate() error

func (*Probe) XXX_DiscardUnknown 

func (m *Probe) XXX_DiscardUnknown()

func (*Probe) XXX_Marshal 

func (m *Probe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Probe) XXX_Merge 

func (m *Probe) XXX_Merge(src proto.Message)

func (*Probe) XXX_Size 

func (m *Probe) XXX_Size() int

func (*Probe) XXX_Unmarshal 

func (m *Probe) XXX_Unmarshal(b []byte) error

type ProbeInfo added in v0.0.7 

type ProbeInfo struct {
	Version    string `protobuf:"bytes,1,opt,name=Version,proto3" json:"version"`
	Commit     string `protobuf:"bytes,2,opt,name=Commit,proto3" json:"commit"`
	Buildstamp string `protobuf:"bytes,3,opt,name=Buildstamp,proto3" json:"buildstamp"`
}

func (*ProbeInfo) Descriptor added in v0.0.7 

func (*ProbeInfo) Descriptor() ([]byte, []int)

func (*ProbeInfo) Marshal added in v0.0.7 

func (m *ProbeInfo) Marshal() (dAtA []byte, err error)

func (*ProbeInfo) MarshalTo added in v0.0.7 

func (m *ProbeInfo) MarshalTo(dAtA []byte) (int, error)

func (*ProbeInfo) MarshalToSizedBuffer added in v0.0.7 

func (m *ProbeInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProbeInfo) ProtoMessage added in v0.0.7 

func (*ProbeInfo) ProtoMessage()

func (*ProbeInfo) Reset added in v0.0.7 

func (m *ProbeInfo) Reset()

func (*ProbeInfo) Size added in v0.0.7 

func (m *ProbeInfo) Size() (n int)

func (*ProbeInfo) String added in v0.0.7 

func (m *ProbeInfo) String() string

func (*ProbeInfo) Unmarshal added in v0.0.7 

func (m *ProbeInfo) Unmarshal(dAtA []byte) error

func (*ProbeInfo) XXX_DiscardUnknown added in v0.0.7 

func (m *ProbeInfo) XXX_DiscardUnknown()

func (*ProbeInfo) XXX_Marshal added in v0.0.7 

func (m *ProbeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProbeInfo) XXX_Merge added in v0.0.7 

func (m *ProbeInfo) XXX_Merge(src proto.Message)

func (*ProbeInfo) XXX_Size added in v0.0.7 

func (m *ProbeInfo) XXX_Size() int

func (*ProbeInfo) XXX_Unmarshal added in v0.0.7 

func (m *ProbeInfo) XXX_Unmarshal(b []byte) error

type ProbeState added in v0.10.0 

type ProbeState struct {
	Checks  []EntityRef `protobuf:"bytes,1,rep,name=checks,proto3" json:"checks"`
	Tenants []EntityRef `protobuf:"bytes,2,rep,name=tenants,proto3" json:"tenants"`
}

ProbeState message is sent by probes as the argument to GetChanges. It contains a list of the checks and tenants already known to the probe.

func (*ProbeState) Descriptor added in v0.10.0 

func (*ProbeState) Descriptor() ([]byte, []int)

func (*ProbeState) Marshal added in v0.10.0 

func (m *ProbeState) Marshal() (dAtA []byte, err error)

func (*ProbeState) MarshalTo added in v0.10.0 

func (m *ProbeState) MarshalTo(dAtA []byte) (int, error)

func (*ProbeState) MarshalToSizedBuffer added in v0.10.0 

func (m *ProbeState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProbeState) ProtoMessage added in v0.10.0 

func (*ProbeState) ProtoMessage()

func (*ProbeState) Reset added in v0.10.0 

func (m *ProbeState) Reset()

func (*ProbeState) Size added in v0.10.0 

func (m *ProbeState) Size() (n int)

func (*ProbeState) String added in v0.10.0 

func (m *ProbeState) String() string

func (*ProbeState) Unmarshal added in v0.10.0 

func (m *ProbeState) Unmarshal(dAtA []byte) error

func (*ProbeState) XXX_DiscardUnknown added in v0.10.0 

func (m *ProbeState) XXX_DiscardUnknown()

func (*ProbeState) XXX_Marshal added in v0.10.0 

func (m *ProbeState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProbeState) XXX_Merge added in v0.10.0 

func (m *ProbeState) XXX_Merge(src proto.Message)

func (*ProbeState) XXX_Size added in v0.10.0 

func (m *ProbeState) XXX_Size() int

func (*ProbeState) XXX_Unmarshal added in v0.10.0 

func (m *ProbeState) XXX_Unmarshal(b []byte) error

type PushTelemetryResponse added in v0.21.0 

type PushTelemetryResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status"`
}

PushTelemetryResponse represents a response for a push telemetry rpc call.

func (*PushTelemetryResponse) Descriptor added in v0.21.0 

func (*PushTelemetryResponse) Descriptor() ([]byte, []int)

func (*PushTelemetryResponse) Marshal added in v0.21.0 

func (m *PushTelemetryResponse) Marshal() (dAtA []byte, err error)

func (*PushTelemetryResponse) MarshalTo added in v0.21.0 

func (m *PushTelemetryResponse) MarshalTo(dAtA []byte) (int, error)

func (*PushTelemetryResponse) MarshalToSizedBuffer added in v0.21.0 

func (m *PushTelemetryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushTelemetryResponse) ProtoMessage added in v0.21.0 

func (*PushTelemetryResponse) ProtoMessage()

func (*PushTelemetryResponse) Reset added in v0.21.0 

func (m *PushTelemetryResponse) Reset()

func (*PushTelemetryResponse) Size added in v0.21.0 

func (m *PushTelemetryResponse) Size() (n int)

func (*PushTelemetryResponse) String added in v0.21.0 

func (m *PushTelemetryResponse) String() string

func (*PushTelemetryResponse) Unmarshal added in v0.21.0 

func (m *PushTelemetryResponse) Unmarshal(dAtA []byte) error

func (*PushTelemetryResponse) XXX_DiscardUnknown added in v0.21.0 

func (m *PushTelemetryResponse) XXX_DiscardUnknown()

func (*PushTelemetryResponse) XXX_Marshal added in v0.21.0 

func (m *PushTelemetryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushTelemetryResponse) XXX_Merge added in v0.21.0 

func (m *PushTelemetryResponse) XXX_Merge(src proto.Message)

func (*PushTelemetryResponse) XXX_Size added in v0.21.0 

func (m *PushTelemetryResponse) XXX_Size() int

func (*PushTelemetryResponse) XXX_Unmarshal added in v0.21.0 

func (m *PushTelemetryResponse) XXX_Unmarshal(b []byte) error

type QueryField added in v0.15.0 

type QueryField struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value"`
}

QueryField represents a single query field key-value pair.

func (*QueryField) Descriptor added in v0.15.0 

func (*QueryField) Descriptor() ([]byte, []int)

func (*QueryField) Marshal added in v0.15.0 

func (m *QueryField) Marshal() (dAtA []byte, err error)

func (*QueryField) MarshalTo added in v0.15.0 

func (m *QueryField) MarshalTo(dAtA []byte) (int, error)

func (*QueryField) MarshalToSizedBuffer added in v0.15.0 

func (m *QueryField) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryField) ProtoMessage added in v0.15.0 

func (*QueryField) ProtoMessage()

func (*QueryField) Reset added in v0.15.0 

func (m *QueryField) Reset()

func (*QueryField) Size added in v0.15.0 

func (m *QueryField) Size() (n int)

func (*QueryField) String added in v0.15.0 

func (m *QueryField) String() string

func (*QueryField) Unmarshal added in v0.15.0 

func (m *QueryField) Unmarshal(dAtA []byte) error

func (QueryField) Validate added in v0.15.0 

func (f QueryField) Validate() error

func (*QueryField) XXX_DiscardUnknown added in v0.15.0 

func (m *QueryField) XXX_DiscardUnknown()

func (*QueryField) XXX_Marshal added in v0.15.0 

func (m *QueryField) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryField) XXX_Merge added in v0.15.0 

func (m *QueryField) XXX_Merge(src proto.Message)

func (*QueryField) XXX_Size added in v0.15.0 

func (m *QueryField) XXX_Size() int

func (*QueryField) XXX_Unmarshal added in v0.15.0 

func (m *QueryField) XXX_Unmarshal(b []byte) error

type RegionTelemetry added in v0.21.0 

type RegionTelemetry struct {
	Instance  string             `protobuf:"bytes,1,opt,name=instance,proto3" json:"instance"`
	RegionId  int32              `protobuf:"varint,2,opt,name=regionId,proto3" json:"regionId"`
	Telemetry []*TenantTelemetry `protobuf:"bytes,3,rep,name=telemetry,proto3" json:"telemetry"`
}

RegionTelemetry represents the telemetry data for a specific region. Groups the telemetry data for all the tenants that have checks being executed in the agent and belong to the same region.

func (*RegionTelemetry) Descriptor added in v0.21.0 

func (*RegionTelemetry) Descriptor() ([]byte, []int)

func (*RegionTelemetry) Marshal added in v0.21.0 

func (m *RegionTelemetry) Marshal() (dAtA []byte, err error)

func (*RegionTelemetry) MarshalTo added in v0.21.0 

func (m *RegionTelemetry) MarshalTo(dAtA []byte) (int, error)

func (*RegionTelemetry) MarshalToSizedBuffer added in v0.21.0 

func (m *RegionTelemetry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegionTelemetry) ProtoMessage added in v0.21.0 

func (*RegionTelemetry) ProtoMessage()

func (*RegionTelemetry) Reset added in v0.21.0 

func (m *RegionTelemetry) Reset()

func (*RegionTelemetry) Size added in v0.21.0 

func (m *RegionTelemetry) Size() (n int)

func (*RegionTelemetry) String added in v0.21.0 

func (m *RegionTelemetry) String() string

func (*RegionTelemetry) Unmarshal added in v0.21.0 

func (m *RegionTelemetry) Unmarshal(dAtA []byte) error

func (*RegionTelemetry) XXX_DiscardUnknown added in v0.21.0 

func (m *RegionTelemetry) XXX_DiscardUnknown()

func (*RegionTelemetry) XXX_Marshal added in v0.21.0 

func (m *RegionTelemetry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegionTelemetry) XXX_Merge added in v0.21.0 

func (m *RegionTelemetry) XXX_Merge(src proto.Message)

func (*RegionTelemetry) XXX_Size added in v0.21.0 

func (m *RegionTelemetry) XXX_Size() int

func (*RegionTelemetry) XXX_Unmarshal added in v0.21.0 

func (m *RegionTelemetry) XXX_Unmarshal(b []byte) error

type RegisterProbeResult 

type RegisterProbeResult struct {
	Probe  Probe  `protobuf:"bytes,1,opt,name=probe,proto3" json:"probe"`
	Status Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status"`
}

RegisterProbeResult is the message returned by the RegisterProbe method of the Checks service. It provides both the status of the operation and the probe's details after successful registration.

func (*RegisterProbeResult) Descriptor 

func (*RegisterProbeResult) Descriptor() ([]byte, []int)

func (*RegisterProbeResult) Marshal 

func (m *RegisterProbeResult) Marshal() (dAtA []byte, err error)

func (*RegisterProbeResult) MarshalTo 

func (m *RegisterProbeResult) MarshalTo(dAtA []byte) (int, error)

func (*RegisterProbeResult) MarshalToSizedBuffer 

func (m *RegisterProbeResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterProbeResult) ProtoMessage 

func (*RegisterProbeResult) ProtoMessage()

func (*RegisterProbeResult) Reset 

func (m *RegisterProbeResult) Reset()

func (*RegisterProbeResult) Size 

func (m *RegisterProbeResult) Size() (n int)

func (*RegisterProbeResult) String 

func (m *RegisterProbeResult) String() string

func (*RegisterProbeResult) Unmarshal 

func (m *RegisterProbeResult) Unmarshal(dAtA []byte) error

func (*RegisterProbeResult) XXX_DiscardUnknown 

func (m *RegisterProbeResult) XXX_DiscardUnknown()

func (*RegisterProbeResult) XXX_Marshal 

func (m *RegisterProbeResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterProbeResult) XXX_Merge 

func (m *RegisterProbeResult) XXX_Merge(src proto.Message)

func (*RegisterProbeResult) XXX_Size 

func (m *RegisterProbeResult) XXX_Size() int

func (*RegisterProbeResult) XXX_Unmarshal 

func (m *RegisterProbeResult) XXX_Unmarshal(b []byte) error

type RemoteInfo 

type RemoteInfo struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name"`
	Url      string `protobuf:"bytes,2,opt,name=url,proto3" json:"url"`
	Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username"`
	Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password"`
}

RemoteInfo represents an instance of the Prometheus remote write service to send metrics or events to.

func (*RemoteInfo) Descriptor 

func (*RemoteInfo) Descriptor() ([]byte, []int)

func (*RemoteInfo) Marshal 

func (m *RemoteInfo) Marshal() (dAtA []byte, err error)

func (*RemoteInfo) MarshalTo 

func (m *RemoteInfo) MarshalTo(dAtA []byte) (int, error)

func (*RemoteInfo) MarshalToSizedBuffer 

func (m *RemoteInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoteInfo) ProtoMessage 

func (*RemoteInfo) ProtoMessage()

func (*RemoteInfo) Reset 

func (m *RemoteInfo) Reset()

func (*RemoteInfo) Size 

func (m *RemoteInfo) Size() (n int)

func (*RemoteInfo) String 

func (m *RemoteInfo) String() string

func (*RemoteInfo) Unmarshal 

func (m *RemoteInfo) Unmarshal(dAtA []byte) error

func (*RemoteInfo) XXX_DiscardUnknown 

func (m *RemoteInfo) XXX_DiscardUnknown()

func (*RemoteInfo) XXX_Marshal 

func (m *RemoteInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoteInfo) XXX_Merge 

func (m *RemoteInfo) XXX_Merge(src proto.Message)

func (*RemoteInfo) XXX_Size 

func (m *RemoteInfo) XXX_Size() int

func (*RemoteInfo) XXX_Unmarshal 

func (m *RemoteInfo) XXX_Unmarshal(b []byte) error

type ScriptedSettings added in v0.21.0 

type ScriptedSettings struct {
	Script []byte `protobuf:"bytes,1,opt,name=script,proto3" json:"script"`
}

func (*ScriptedSettings) Descriptor added in v0.21.0 

func (*ScriptedSettings) Descriptor() ([]byte, []int)

func (*ScriptedSettings) Marshal added in v0.21.0 

func (m *ScriptedSettings) Marshal() (dAtA []byte, err error)

func (*ScriptedSettings) MarshalTo added in v0.21.0 

func (m *ScriptedSettings) MarshalTo(dAtA []byte) (int, error)

func (*ScriptedSettings) MarshalToSizedBuffer added in v0.21.0 

func (m *ScriptedSettings) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScriptedSettings) ProtoMessage added in v0.21.0 

func (*ScriptedSettings) ProtoMessage()

func (*ScriptedSettings) Reset added in v0.21.0 

func (m *ScriptedSettings) Reset()

func (*ScriptedSettings) Size added in v0.21.0 

func (m *ScriptedSettings) Size() (n int)

func (*ScriptedSettings) String added in v0.21.0 

func (m *ScriptedSettings) String() string

func (*ScriptedSettings) Unmarshal added in v0.21.0 

func (m *ScriptedSettings) Unmarshal(dAtA []byte) error

func (*ScriptedSettings) Validate added in v0.21.0 

func (s *ScriptedSettings) Validate() error

func (*ScriptedSettings) XXX_DiscardUnknown added in v0.21.0 

func (m *ScriptedSettings) XXX_DiscardUnknown()

func (*ScriptedSettings) XXX_Marshal added in v0.21.0 

func (m *ScriptedSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScriptedSettings) XXX_Merge added in v0.21.0 

func (m *ScriptedSettings) XXX_Merge(src proto.Message)

func (*ScriptedSettings) XXX_Size added in v0.21.0 

func (m *ScriptedSettings) XXX_Size() int

func (*ScriptedSettings) XXX_Unmarshal added in v0.21.0 

func (m *ScriptedSettings) XXX_Unmarshal(b []byte) error

type Status 

type Status struct {
	Code    StatusCode `protobuf:"varint,1,opt,name=code,proto3,enum=synthetic_monitoring.StatusCode" json:"code,omitempty"`
	Message string     `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

Status represents the result of registering a probe with the API, including both a code as well as textual message that can be presented to the user.

func (*Status) Descriptor 

func (*Status) Descriptor() ([]byte, []int)

func (*Status) Marshal 

func (m *Status) Marshal() (dAtA []byte, err error)

func (*Status) MarshalTo 

func (m *Status) MarshalTo(dAtA []byte) (int, error)

func (*Status) MarshalToSizedBuffer 

func (m *Status) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) Size 

func (m *Status) Size() (n int)

func (*Status) String 

func (m *Status) String() string

func (*Status) Unmarshal 

func (m *Status) Unmarshal(dAtA []byte) error

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Status) XXX_Merge 

func (m *Status) XXX_Merge(src proto.Message)

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

func (m *Status) XXX_Unmarshal(b []byte) error

type StatusCode 

type StatusCode int32

StatusCode represents the result of registering a probe with the API. 

const (
	StatusCode_OK               StatusCode = 0
	StatusCode_NOT_FOUND        StatusCode = 1
	StatusCode_INVALID_ARGUMENT StatusCode = 2
	StatusCode_ALREADY_EXISTS   StatusCode = 3
	StatusCode_INTERNAL_ERROR   StatusCode = 4
	StatusCode_NOT_AUTHORIZED   StatusCode = 5
)

func (StatusCode) EnumDescriptor 

func (StatusCode) EnumDescriptor() ([]byte, []int)

func (StatusCode) String 

func (x StatusCode) String() string

type TCPQueryResponse 

type TCPQueryResponse struct {
	Send     []byte `protobuf:"bytes,1,opt,name=send,proto3" json:"send"`
	Expect   []byte `protobuf:"bytes,2,opt,name=expect,proto3" json:"expect"`
	StartTLS bool   `protobuf:"varint,3,opt,name=startTLS,proto3" json:"startTLS,omitempty"`
}

TCPQueryResponse represents a single step in a sequence of send/expect pairs to be used when connecting to a generic TCP service.

func (*TCPQueryResponse) Descriptor 

func (*TCPQueryResponse) Descriptor() ([]byte, []int)

func (*TCPQueryResponse) Marshal 

func (m *TCPQueryResponse) Marshal() (dAtA []byte, err error)

func (*TCPQueryResponse) MarshalTo 

func (m *TCPQueryResponse) MarshalTo(dAtA []byte) (int, error)

func (*TCPQueryResponse) MarshalToSizedBuffer 

func (m *TCPQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TCPQueryResponse) ProtoMessage 

func (*TCPQueryResponse) ProtoMessage()

func (*TCPQueryResponse) Reset 

func (m *TCPQueryResponse) Reset()

func (*TCPQueryResponse) Size 

func (m *TCPQueryResponse) Size() (n int)

func (*TCPQueryResponse) String 

func (m *TCPQueryResponse) String() string

func (*TCPQueryResponse) Unmarshal 

func (m *TCPQueryResponse) Unmarshal(dAtA []byte) error

func (*TCPQueryResponse) XXX_DiscardUnknown 

func (m *TCPQueryResponse) XXX_DiscardUnknown()

func (*TCPQueryResponse) XXX_Marshal 

func (m *TCPQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TCPQueryResponse) XXX_Merge 

func (m *TCPQueryResponse) XXX_Merge(src proto.Message)

func (*TCPQueryResponse) XXX_Size 

func (m *TCPQueryResponse) XXX_Size() int

func (*TCPQueryResponse) XXX_Unmarshal 

func (m *TCPQueryResponse) XXX_Unmarshal(b []byte) error

type TLSConfig 

type TLSConfig struct {
	InsecureSkipVerify bool   `protobuf:"varint,1,opt,name=insecureSkipVerify,proto3" json:"insecureSkipVerify,omitempty"`
	CACert             []byte `protobuf:"bytes,2,opt,name=CACert,proto3" json:"caCert,omitempty"`
	ClientCert         []byte `protobuf:"bytes,3,opt,name=clientCert,proto3" json:"clientCert,omitempty"`
	ClientKey          []byte `protobuf:"bytes,4,opt,name=clientKey,proto3" json:"clientKey,omitempty"`
	ServerName         string `protobuf:"bytes,5,opt,name=serverName,proto3" json:"serverName,omitempty"`
}

TLSConfig represents the TLS data to be used when establishing a secure connection in the protocols that support it.

func (*TLSConfig) Descriptor 

func (*TLSConfig) Descriptor() ([]byte, []int)

func (*TLSConfig) Marshal 

func (m *TLSConfig) Marshal() (dAtA []byte, err error)

func (*TLSConfig) MarshalTo 

func (m *TLSConfig) MarshalTo(dAtA []byte) (int, error)

func (*TLSConfig) MarshalToSizedBuffer 

func (m *TLSConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TLSConfig) ProtoMessage 

func (*TLSConfig) ProtoMessage()

func (*TLSConfig) Reset 

func (m *TLSConfig) Reset()

func (*TLSConfig) Size 

func (m *TLSConfig) Size() (n int)

func (*TLSConfig) String 

func (m *TLSConfig) String() string

func (*TLSConfig) Unmarshal 

func (m *TLSConfig) Unmarshal(dAtA []byte) error

func (*TLSConfig) XXX_DiscardUnknown 

func (m *TLSConfig) XXX_DiscardUnknown()

func (*TLSConfig) XXX_Marshal 

func (m *TLSConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TLSConfig) XXX_Merge 

func (m *TLSConfig) XXX_Merge(src proto.Message)

func (*TLSConfig) XXX_Size 

func (m *TLSConfig) XXX_Size() int

func (*TLSConfig) XXX_Unmarshal 

func (m *TLSConfig) XXX_Unmarshal(b []byte) error

type TcpSettings 

type TcpSettings struct {
	IpVersion       IpVersion          `protobuf:"varint,1,opt,name=ipVersion,proto3,enum=synthetic_monitoring.IpVersion" json:"ipVersion"`
	SourceIpAddress string             `protobuf:"bytes,2,opt,name=sourceIpAddress,proto3" json:"sourceIpAddress,omitempty"`
	Tls             bool               `protobuf:"varint,3,opt,name=tls,proto3" json:"tls,omitempty"`
	TlsConfig       *TLSConfig         `protobuf:"bytes,4,opt,name=tlsConfig,proto3" json:"tlsConfig,omitempty"`
	QueryResponse   []TCPQueryResponse `protobuf:"bytes,5,rep,name=queryResponse,proto3" json:"queryResponse,omitempty"`
}

TcpSettings provides the settings for a TCP check.

"ipVersion" is the IP version to use in the IP layer.

func (*TcpSettings) Descriptor 

func (*TcpSettings) Descriptor() ([]byte, []int)

func (*TcpSettings) Marshal 

func (m *TcpSettings) Marshal() (dAtA []byte, err error)

func (*TcpSettings) MarshalTo 

func (m *TcpSettings) MarshalTo(dAtA []byte) (int, error)

func (*TcpSettings) MarshalToSizedBuffer 

func (m *TcpSettings) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TcpSettings) ProtoMessage 

func (*TcpSettings) ProtoMessage()

func (*TcpSettings) Reset 

func (m *TcpSettings) Reset()

func (*TcpSettings) Size 

func (m *TcpSettings) Size() (n int)

func (*TcpSettings) String 

func (m *TcpSettings) String() string

func (*TcpSettings) Unmarshal 

func (m *TcpSettings) Unmarshal(dAtA []byte) error

func (*TcpSettings) Validate 

func (s *TcpSettings) Validate() error

func (*TcpSettings) XXX_DiscardUnknown 

func (m *TcpSettings) XXX_DiscardUnknown()

func (*TcpSettings) XXX_Marshal 

func (m *TcpSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TcpSettings) XXX_Merge 

func (m *TcpSettings) XXX_Merge(src proto.Message)

func (*TcpSettings) XXX_Size 

func (m *TcpSettings) XXX_Size() int

func (*TcpSettings) XXX_Unmarshal 

func (m *TcpSettings) XXX_Unmarshal(b []byte) error

type TelemetryClient added in v0.21.0 

type TelemetryClient interface {
	// PushTelemetry pushes telemetry data for all the tenants that are running
	// checks in the agent which belong to the same region.
	PushTelemetry(ctx context.Context, in *RegionTelemetry, opts ...grpc.CallOption) (*PushTelemetryResponse, error)
}

TelemetryClient is the client API for Telemetry service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTelemetryClient added in v0.21.0 

func NewTelemetryClient(cc *grpc.ClientConn) TelemetryClient

type TelemetryServer added in v0.21.0 

type TelemetryServer interface {
	// PushTelemetry pushes telemetry data for all the tenants that are running
	// checks in the agent which belong to the same region.
	PushTelemetry(context.Context, *RegionTelemetry) (*PushTelemetryResponse, error)
}

TelemetryServer is the server API for Telemetry service.

type Tenant 

type Tenant struct {
	Id            int64         `protobuf:"varint,1,opt,name=id,proto3" json:"id"`
	OrgId         int64         `protobuf:"varint,2,opt,name=orgId,proto3" json:"orgId"`
	MetricsRemote *RemoteInfo   `protobuf:"bytes,3,opt,name=metricsRemote,proto3" json:"metricsRemote"`
	EventsRemote  *RemoteInfo   `protobuf:"bytes,4,opt,name=eventsRemote,proto3" json:"eventsRemote"`
	StackId       int64         `protobuf:"varint,5,opt,name=stackId,proto3" json:"stackId"`
	Status        TenantStatus  `protobuf:"varint,6,opt,name=status,proto3,enum=synthetic_monitoring.TenantStatus" json:"status"`
	Reason        string        `protobuf:"bytes,7,opt,name=reason,proto3" json:"reason"`
	Limits        *TenantLimits `protobuf:"bytes,8,opt,name=limits,proto3" json:"limits"`
	Created       float64       `protobuf:"fixed64,100,opt,name=created,proto3" json:"created"`
	Modified      float64       `protobuf:"fixed64,101,opt,name=modified,proto3" json:"modified"`
}

Tenant represents a user of synthetic-monitoring.

func (*Tenant) Descriptor 

func (*Tenant) Descriptor() ([]byte, []int)

func (*Tenant) Marshal 

func (m *Tenant) Marshal() (dAtA []byte, err error)

func (*Tenant) MarshalTo 

func (m *Tenant) MarshalTo(dAtA []byte) (int, error)

func (*Tenant) MarshalToSizedBuffer 

func (m *Tenant) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Tenant) ProtoMessage 

func (*Tenant) ProtoMessage()

func (*Tenant) Reset 

func (m *Tenant) Reset()

func (*Tenant) Size 

func (m *Tenant) Size() (n int)

func (*Tenant) String 

func (m *Tenant) String() string

func (*Tenant) Unmarshal 

func (m *Tenant) Unmarshal(dAtA []byte) error

func (*Tenant) XXX_DiscardUnknown 

func (m *Tenant) XXX_DiscardUnknown()

func (*Tenant) XXX_Marshal 

func (m *Tenant) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Tenant) XXX_Merge 

func (m *Tenant) XXX_Merge(src proto.Message)

func (*Tenant) XXX_Size 

func (m *Tenant) XXX_Size() int

func (*Tenant) XXX_Unmarshal 

func (m *Tenant) XXX_Unmarshal(b []byte) error

type TenantInfo 

type TenantInfo struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

TenantInfo identifies the tenant for which information is being requeted via the GetTenant method of the Tenants service.

func (*TenantInfo) Descriptor 

func (*TenantInfo) Descriptor() ([]byte, []int)

func (*TenantInfo) Marshal 

func (m *TenantInfo) Marshal() (dAtA []byte, err error)

func (*TenantInfo) MarshalTo 

func (m *TenantInfo) MarshalTo(dAtA []byte) (int, error)

func (*TenantInfo) MarshalToSizedBuffer 

func (m *TenantInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TenantInfo) ProtoMessage 

func (*TenantInfo) ProtoMessage()

func (*TenantInfo) Reset 

func (m *TenantInfo) Reset()

func (*TenantInfo) Size 

func (m *TenantInfo) Size() (n int)

func (*TenantInfo) String 

func (m *TenantInfo) String() string

func (*TenantInfo) Unmarshal 

func (m *TenantInfo) Unmarshal(dAtA []byte) error

func (*TenantInfo) XXX_DiscardUnknown 

func (m *TenantInfo) XXX_DiscardUnknown()

func (*TenantInfo) XXX_Marshal 

func (m *TenantInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TenantInfo) XXX_Merge 

func (m *TenantInfo) XXX_Merge(src proto.Message)

func (*TenantInfo) XXX_Size 

func (m *TenantInfo) XXX_Size() int

func (*TenantInfo) XXX_Unmarshal 

func (m *TenantInfo) XXX_Unmarshal(b []byte) error

type TenantLimits added in v0.20.1 

type TenantLimits struct {
	MaxChecks         int64 `protobuf:"varint,1,opt,name=maxChecks,proto3" json:"maxChecks"`
	MaxScriptedChecks int64 `protobuf:"varint,2,opt,name=maxScriptedChecks,proto3" json:"maxScriptedChecks"`
	MaxMetricLabels   int64 `protobuf:"varint,3,opt,name=maxMetricLabels,proto3" json:"maxMetricLabels"`
	MaxLogLabels      int64 `protobuf:"varint,4,opt,name=maxLogLabels,proto3" json:"maxLogLabels"`
}

TenantLimits specifies the limits for a tenant.

func (*TenantLimits) Descriptor added in v0.20.1 

func (*TenantLimits) Descriptor() ([]byte, []int)

func (*TenantLimits) Marshal added in v0.20.1 

func (m *TenantLimits) Marshal() (dAtA []byte, err error)

func (*TenantLimits) MarshalTo added in v0.20.1 

func (m *TenantLimits) MarshalTo(dAtA []byte) (int, error)

func (*TenantLimits) MarshalToSizedBuffer added in v0.20.1 

func (m *TenantLimits) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TenantLimits) ProtoMessage added in v0.20.1 

func (*TenantLimits) ProtoMessage()

func (*TenantLimits) Reset added in v0.20.1 

func (m *TenantLimits) Reset()

func (*TenantLimits) Size added in v0.20.1 

func (m *TenantLimits) Size() (n int)

func (*TenantLimits) String added in v0.20.1 

func (m *TenantLimits) String() string

func (*TenantLimits) Unmarshal added in v0.20.1 

func (m *TenantLimits) Unmarshal(dAtA []byte) error

func (*TenantLimits) XXX_DiscardUnknown added in v0.20.1 

func (m *TenantLimits) XXX_DiscardUnknown()

func (*TenantLimits) XXX_Marshal added in v0.20.1 

func (m *TenantLimits) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TenantLimits) XXX_Merge added in v0.20.1 

func (m *TenantLimits) XXX_Merge(src proto.Message)

func (*TenantLimits) XXX_Size added in v0.20.1 

func (m *TenantLimits) XXX_Size() int

func (*TenantLimits) XXX_Unmarshal added in v0.20.1 

func (m *TenantLimits) XXX_Unmarshal(b []byte) error

type TenantStatus added in v0.0.12 

type TenantStatus int32

TenantStatus represents the status associated to particular tenant. 

const (
	TenantStatus_ACTIVE   TenantStatus = 0
	TenantStatus_DISABLED TenantStatus = 1
)

func (TenantStatus) EnumDescriptor added in v0.0.12 

func (TenantStatus) EnumDescriptor() ([]byte, []int)

func (TenantStatus) String added in v0.0.12 

func (x TenantStatus) String() string

type TenantTelemetry added in v0.21.0 

type TenantTelemetry struct {
	TenantId  int64                  `protobuf:"varint,1,opt,name=tenantId,proto3" json:"tenantId"`
	Telemetry []*CheckClassTelemetry `protobuf:"bytes,2,rep,name=telemetry,proto3" json:"telemetry"`
}

TenantTelemetry represents the telemetry data for a specific tenant.

func (*TenantTelemetry) Descriptor added in v0.21.0 

func (*TenantTelemetry) Descriptor() ([]byte, []int)

func (*TenantTelemetry) Marshal added in v0.21.0 

func (m *TenantTelemetry) Marshal() (dAtA []byte, err error)

func (*TenantTelemetry) MarshalTo added in v0.21.0 

func (m *TenantTelemetry) MarshalTo(dAtA []byte) (int, error)

func (*TenantTelemetry) MarshalToSizedBuffer added in v0.21.0 

func (m *TenantTelemetry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TenantTelemetry) ProtoMessage added in v0.21.0 

func (*TenantTelemetry) ProtoMessage()

func (*TenantTelemetry) Reset added in v0.21.0 

func (m *TenantTelemetry) Reset()

func (*TenantTelemetry) Size added in v0.21.0 

func (m *TenantTelemetry) Size() (n int)

func (*TenantTelemetry) String added in v0.21.0 

func (m *TenantTelemetry) String() string

func (*TenantTelemetry) Unmarshal added in v0.21.0 

func (m *TenantTelemetry) Unmarshal(dAtA []byte) error

func (*TenantTelemetry) XXX_DiscardUnknown added in v0.21.0 

func (m *TenantTelemetry) XXX_DiscardUnknown()

func (*TenantTelemetry) XXX_Marshal added in v0.21.0 

func (m *TenantTelemetry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TenantTelemetry) XXX_Merge added in v0.21.0 

func (m *TenantTelemetry) XXX_Merge(src proto.Message)

func (*TenantTelemetry) XXX_Size added in v0.21.0 

func (m *TenantTelemetry) XXX_Size() int

func (*TenantTelemetry) XXX_Unmarshal added in v0.21.0 

func (m *TenantTelemetry) XXX_Unmarshal(b []byte) error

type TenantsClient 

type TenantsClient interface {
	// GetTenant returns the details of the specified tenant
	GetTenant(ctx context.Context, in *TenantInfo, opts ...grpc.CallOption) (*Tenant, error)
}

TenantsClient is the client API for Tenants service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTenantsClient 

func NewTenantsClient(cc *grpc.ClientConn) TenantsClient

type TenantsServer 

type TenantsServer interface {
	// GetTenant returns the details of the specified tenant
	GetTenant(context.Context, *TenantInfo) (*Tenant, error)
}

TenantsServer is the server API for Tenants service.

type TracerouteSettings added in v0.1.0 

type TracerouteSettings struct {
	MaxHops        int64 `protobuf:"varint,1,opt,name=maxHops,proto3" json:"maxHops"`
	MaxUnknownHops int64 `protobuf:"varint,2,opt,name=maxUnknownHops,proto3" json:"maxUnknownHops"`
	PtrLookup      bool  `protobuf:"varint,3,opt,name=ptrLookup,proto3" json:"ptrLookup"`
	HopTimeout     int64 `protobuf:"varint,4,opt,name=hopTimeout,proto3" json:"hopTimeout"`
}

func (*TracerouteSettings) Descriptor added in v0.1.0 

func (*TracerouteSettings) Descriptor() ([]byte, []int)

func (*TracerouteSettings) Marshal added in v0.1.0 

func (m *TracerouteSettings) Marshal() (dAtA []byte, err error)

func (*TracerouteSettings) MarshalTo added in v0.1.0 

func (m *TracerouteSettings) MarshalTo(dAtA []byte) (int, error)

func (*TracerouteSettings) MarshalToSizedBuffer added in v0.1.0 

func (m *TracerouteSettings) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TracerouteSettings) ProtoMessage added in v0.1.0 

func (*TracerouteSettings) ProtoMessage()

func (*TracerouteSettings) Reset added in v0.1.0 

func (m *TracerouteSettings) Reset()

func (*TracerouteSettings) Size added in v0.1.0 

func (m *TracerouteSettings) Size() (n int)

func (*TracerouteSettings) String added in v0.1.0 

func (m *TracerouteSettings) String() string

func (*TracerouteSettings) Unmarshal added in v0.1.0 

func (m *TracerouteSettings) Unmarshal(dAtA []byte) error

func (*TracerouteSettings) Validate added in v0.1.0 

func (s *TracerouteSettings) Validate() error

func (*TracerouteSettings) XXX_DiscardUnknown added in v0.1.0 

func (m *TracerouteSettings) XXX_DiscardUnknown()

func (*TracerouteSettings) XXX_Marshal added in v0.1.0 

func (m *TracerouteSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TracerouteSettings) XXX_Merge added in v0.1.0 

func (m *TracerouteSettings) XXX_Merge(src proto.Message)

func (*TracerouteSettings) XXX_Size added in v0.1.0 

func (m *TracerouteSettings) XXX_Size() int

func (*TracerouteSettings) XXX_Unmarshal added in v0.1.0 

func (m *TracerouteSettings) XXX_Unmarshal(b []byte) error

type UnimplementedAdHocChecksServer added in v0.8.0 

type UnimplementedAdHocChecksServer struct {
}

UnimplementedAdHocChecksServer can be embedded to have forward compatible implementations.

func (*UnimplementedAdHocChecksServer) GetAdHocChecks added in v0.8.0 

func (*UnimplementedAdHocChecksServer) GetAdHocChecks(req *Void, srv AdHocChecks_GetAdHocChecksServer) error

func (*UnimplementedAdHocChecksServer) RegisterProbe added in v0.8.0 

func (*UnimplementedAdHocChecksServer) RegisterProbe(ctx context.Context, req *ProbeInfo) (*RegisterProbeResult, error)

type UnimplementedChecksServer 

type UnimplementedChecksServer struct {
}

UnimplementedChecksServer can be embedded to have forward compatible implementations.

func (*UnimplementedChecksServer) GetChanges 

func (*UnimplementedChecksServer) GetChanges(req *ProbeState, srv Checks_GetChangesServer) error

func (*UnimplementedChecksServer) Ping added in v0.9.0 

func (*UnimplementedChecksServer) Ping(ctx context.Context, req *PingRequest) (*PongResponse, error)

func (*UnimplementedChecksServer) RegisterProbe 

func (*UnimplementedChecksServer) RegisterProbe(ctx context.Context, req *ProbeInfo) (*RegisterProbeResult, error)

type UnimplementedTelemetryServer added in v0.21.0 

type UnimplementedTelemetryServer struct {
}

UnimplementedTelemetryServer can be embedded to have forward compatible implementations.

func (*UnimplementedTelemetryServer) PushTelemetry added in v0.21.0 

func (*UnimplementedTelemetryServer) PushTelemetry(ctx context.Context, req *RegionTelemetry) (*PushTelemetryResponse, error)

type UnimplementedTenantsServer 

type UnimplementedTenantsServer struct {
}

UnimplementedTenantsServer can be embedded to have forward compatible implementations.

func (*UnimplementedTenantsServer) GetTenant 

func (*UnimplementedTenantsServer) GetTenant(ctx context.Context, req *TenantInfo) (*Tenant, error)

type Void 

type Void struct {
}

Void is an empty message used by RPC methods that don't take arguments.

func (*Void) Descriptor 

func (*Void) Descriptor() ([]byte, []int)

func (*Void) Marshal 

func (m *Void) Marshal() (dAtA []byte, err error)

func (*Void) MarshalTo 

func (m *Void) MarshalTo(dAtA []byte) (int, error)

func (*Void) MarshalToSizedBuffer 

func (m *Void) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Void) ProtoMessage 

func (*Void) ProtoMessage()

func (*Void) Reset 

func (m *Void) Reset()

func (*Void) Size 

func (m *Void) Size() (n int)

func (*Void) String 

func (m *Void) String() string

func (*Void) Unmarshal 

func (m *Void) Unmarshal(dAtA []byte) error

func (*Void) XXX_DiscardUnknown 

func (m *Void) XXX_DiscardUnknown()

func (*Void) XXX_Marshal 

func (m *Void) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Void) XXX_Merge 

func (m *Void) XXX_Merge(src proto.Message)

func (*Void) XXX_Size 

func (m *Void) XXX_Size() int

func (*Void) XXX_Unmarshal 

func (m *Void) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.