synthetic_monitoring

package
v0.0.0-...-05b72f9 Latest Latest
Warning

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

Go to latest
Published: Nov 29, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

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.
)
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")

	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")
	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 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 CheckClassStrings

func CheckClassStrings() []string

CheckClassStrings returns a slice of all String values of the enum

func CheckTypeStrings

func CheckTypeStrings() []string

CheckTypeStrings returns a slice of all String values of the enum

func GlobalIDToLocalID

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

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

func IsGlobalIDValid

func IsGlobalIDValid(id int64) bool

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

func IsLocalIDValid

func IsLocalIDValid(id int64) bool

func IsRegionIDValid

func IsRegionIDValid(id int) bool

IsRegionIDValid checks that a region ID is within bounds.

func LocalIDToGlobalID

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

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

func MultiHttpEntryAssertionConditionVariantStrings

func MultiHttpEntryAssertionConditionVariantStrings() []string

MultiHttpEntryAssertionConditionVariantStrings returns a slice of all String values of the enum

func MultiHttpEntryAssertionSubjectVariantStrings

func MultiHttpEntryAssertionSubjectVariantStrings() []string

MultiHttpEntryAssertionSubjectVariantStrings returns a slice of all String values of the enum

func MultiHttpEntryAssertionTypeStrings

func MultiHttpEntryAssertionTypeStrings() []string

MultiHttpEntryAssertionTypeStrings returns a slice of all String values of the enum

func MultiHttpEntryVariableTypeStrings

func MultiHttpEntryVariableTypeStrings() []string

MultiHttpEntryVariableTypeStrings returns a slice of all String values of the enum

func RegisterAdHocChecksServer

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

func RegisterChecksServer

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

func RegisterTenantsServer

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

Types

type AdHocCheck

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

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

func (*AdHocCheck) Marshal

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

func (*AdHocCheck) MarshalTo

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

func (*AdHocCheck) MarshalToSizedBuffer

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

func (*AdHocCheck) ProtoMessage

func (*AdHocCheck) ProtoMessage()

func (*AdHocCheck) Reset

func (m *AdHocCheck) Reset()

func (*AdHocCheck) Size

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

func (*AdHocCheck) String

func (m *AdHocCheck) String() string

func (AdHocCheck) Type

func (c AdHocCheck) Type() CheckType

func (*AdHocCheck) Unmarshal

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

func (AdHocCheck) Validate

func (c AdHocCheck) Validate() error

func (*AdHocCheck) XXX_DiscardUnknown

func (m *AdHocCheck) XXX_DiscardUnknown()

func (*AdHocCheck) XXX_Marshal

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

func (*AdHocCheck) XXX_Merge

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

func (*AdHocCheck) XXX_Size

func (m *AdHocCheck) XXX_Size() int

func (*AdHocCheck) XXX_Unmarshal

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

type AdHocChecksClient

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

func NewAdHocChecksClient(cc *grpc.ClientConn) AdHocChecksClient

type AdHocChecksServer

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

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

type AdHocChecks_GetAdHocChecksServer

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

type AdHocRequest

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

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

func (*AdHocRequest) Marshal

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

func (*AdHocRequest) MarshalTo

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

func (*AdHocRequest) MarshalToSizedBuffer

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

func (*AdHocRequest) ProtoMessage

func (*AdHocRequest) ProtoMessage()

func (*AdHocRequest) Reset

func (m *AdHocRequest) Reset()

func (*AdHocRequest) Size

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

func (*AdHocRequest) String

func (m *AdHocRequest) String() string

func (*AdHocRequest) Unmarshal

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

func (*AdHocRequest) XXX_DiscardUnknown

func (m *AdHocRequest) XXX_DiscardUnknown()

func (*AdHocRequest) XXX_Marshal

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

func (*AdHocRequest) XXX_Merge

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

func (*AdHocRequest) XXX_Size

func (m *AdHocRequest) XXX_Size() int

func (*AdHocRequest) XXX_Unmarshal

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

type BadGlobalIDError

type BadGlobalIDError int64

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

func (BadGlobalIDError) Error

func (n BadGlobalIDError) Error() string

Error implements the error interface.

func (BadGlobalIDError) ID

func (n BadGlobalIDError) ID() int64

ID returns the ID that caused the error.

type BadLocalIDError

type BadLocalIDError int64

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

func (BadLocalIDError) Error

func (n BadLocalIDError) Error() string

Error implements the error interface.

func (BadLocalIDError) ID

func (n BadLocalIDError) ID() int64

ID returns the ID that caused the error.

type BadRegionIDError

type BadRegionIDError int

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

func (BadRegionIDError) Error

func (n BadRegionIDError) Error() string

Error implements the error interface.

func (BadRegionIDError) ID

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

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

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

func (*Changes) Marshal

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

func (*Changes) MarshalTo

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

func (*Changes) MarshalToSizedBuffer

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

func (*Changes) ProtoMessage

func (*Changes) ProtoMessage()

func (*Changes) Reset

func (m *Changes) Reset()

func (*Changes) Size

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

func (*Changes) String

func (m *Changes) String() string

func (*Changes) Unmarshal

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

func (*Changes) XXX_DiscardUnknown

func (m *Changes) XXX_DiscardUnknown()

func (*Changes) XXX_Marshal

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

func (*Changes) XXX_Merge

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

func (*Changes) XXX_Size

func (m *Changes) XXX_Size() int

func (*Changes) XXX_Unmarshal

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

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

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

type CheckClass int32
const (
	CheckClassProtocol CheckClass = 0
	CheckClassScripted CheckClass = 1
)

func CheckClassString

func CheckClassString(s string) (CheckClass, error)

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

func CheckClassValues

func CheckClassValues() []CheckClass

CheckClassValues returns all values of the enum

func (CheckClass) IsACheckClass

func (i CheckClass) IsACheckClass() bool

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

func (CheckClass) String

func (i CheckClass) String() string

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"`
	K6         *K6Settings         `protobuf:"bytes,6,opt,name=k6,proto3" json:"k6,omitempty"`
	Multihttp  *MultiHttpSettings  `protobuf:"bytes,7,opt,name=multihttp,proto3" json:"multihttp,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

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

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
	CheckTypeK6         CheckType = 5
	CheckTypeMultiHttp  CheckType = 6
)

func CheckTypeFromString

func CheckTypeFromString(in string) (CheckType, bool)

func CheckTypeString

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

func CheckTypeValues() []CheckType

CheckTypeValues returns all values of the enum

func (CheckType) Class

func (c CheckType) Class() CheckClass

func (CheckType) IsACheckType

func (i CheckType) IsACheckType() bool

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

func (CheckType) String

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

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

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

func (CompressionAlgorithm) MarshalJSON

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

func (CompressionAlgorithm) String

func (x CompressionAlgorithm) String() string

func (*CompressionAlgorithm) UnmarshalJSON

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

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

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

func (*EntityRef) Marshal

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

func (*EntityRef) MarshalTo

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

func (*EntityRef) MarshalToSizedBuffer

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

func (*EntityRef) ProtoMessage

func (*EntityRef) ProtoMessage()

func (*EntityRef) Reset

func (m *EntityRef) Reset()

func (*EntityRef) Size

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

func (*EntityRef) String

func (m *EntityRef) String() string

func (*EntityRef) Unmarshal

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

func (*EntityRef) XXX_DiscardUnknown

func (m *EntityRef) XXX_DiscardUnknown()

func (*EntityRef) XXX_Marshal

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

func (*EntityRef) XXX_Merge

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

func (*EntityRef) XXX_Size

func (m *EntityRef) XXX_Size() int

func (*EntityRef) XXX_Unmarshal

func (m *EntityRef) 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

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

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

func (*HttpHeader) Marshal

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

func (*HttpHeader) MarshalTo

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

func (*HttpHeader) MarshalToSizedBuffer

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

func (*HttpHeader) ProtoMessage

func (*HttpHeader) ProtoMessage()

func (*HttpHeader) Reset

func (m *HttpHeader) Reset()

func (*HttpHeader) Size

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

func (*HttpHeader) String

func (m *HttpHeader) String() string

func (*HttpHeader) Unmarshal

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

func (HttpHeader) Validate

func (h HttpHeader) Validate() error

func (*HttpHeader) XXX_DiscardUnknown

func (m *HttpHeader) XXX_DiscardUnknown()

func (*HttpHeader) XXX_Marshal

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

func (*HttpHeader) XXX_Merge

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

func (*HttpHeader) XXX_Size

func (m *HttpHeader) XXX_Size() int

func (*HttpHeader) XXX_Unmarshal

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

func (v HttpMethod) Validate() error

type HttpRequestBody

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

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

func (*HttpRequestBody) Marshal

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

func (*HttpRequestBody) MarshalTo

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

func (*HttpRequestBody) MarshalToSizedBuffer

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

func (*HttpRequestBody) ProtoMessage

func (*HttpRequestBody) ProtoMessage()

func (*HttpRequestBody) Reset

func (m *HttpRequestBody) Reset()

func (*HttpRequestBody) Size

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

func (*HttpRequestBody) String

func (m *HttpRequestBody) String() string

func (*HttpRequestBody) Unmarshal

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

func (*HttpRequestBody) Validate

func (b *HttpRequestBody) Validate() error

func (*HttpRequestBody) XXX_DiscardUnknown

func (m *HttpRequestBody) XXX_DiscardUnknown()

func (*HttpRequestBody) XXX_Marshal

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

func (*HttpRequestBody) XXX_Merge

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

func (*HttpRequestBody) XXX_Size

func (m *HttpRequestBody) XXX_Size() int

func (*HttpRequestBody) XXX_Unmarshal

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

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 K6Settings

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

func (*K6Settings) Descriptor

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

func (*K6Settings) Marshal

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

func (*K6Settings) MarshalTo

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

func (*K6Settings) MarshalToSizedBuffer

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

func (*K6Settings) ProtoMessage

func (*K6Settings) ProtoMessage()

func (*K6Settings) Reset

func (m *K6Settings) Reset()

func (*K6Settings) Size

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

func (*K6Settings) String

func (m *K6Settings) String() string

func (*K6Settings) Unmarshal

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

func (*K6Settings) Validate

func (s *K6Settings) Validate() error

func (*K6Settings) XXX_DiscardUnknown

func (m *K6Settings) XXX_DiscardUnknown()

func (*K6Settings) XXX_Marshal

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

func (*K6Settings) XXX_Merge

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

func (*K6Settings) XXX_Size

func (m *K6Settings) XXX_Size() int

func (*K6Settings) XXX_Unmarshal

func (m *K6Settings) XXX_Unmarshal(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

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

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

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

func (*MultiHttpEntry) Marshal

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

func (*MultiHttpEntry) MarshalTo

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

func (*MultiHttpEntry) MarshalToSizedBuffer

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

func (*MultiHttpEntry) ProtoMessage

func (*MultiHttpEntry) ProtoMessage()

func (*MultiHttpEntry) Reset

func (m *MultiHttpEntry) Reset()

func (*MultiHttpEntry) Size

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

func (*MultiHttpEntry) String

func (m *MultiHttpEntry) String() string

func (*MultiHttpEntry) Unmarshal

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

func (*MultiHttpEntry) Validate

func (e *MultiHttpEntry) Validate() error

func (*MultiHttpEntry) XXX_DiscardUnknown

func (m *MultiHttpEntry) XXX_DiscardUnknown()

func (*MultiHttpEntry) XXX_Marshal

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

func (*MultiHttpEntry) XXX_Merge

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

func (*MultiHttpEntry) XXX_Size

func (m *MultiHttpEntry) XXX_Size() int

func (*MultiHttpEntry) XXX_Unmarshal

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

type MultiHttpEntryAssertion

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

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

func (*MultiHttpEntryAssertion) Marshal

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

func (*MultiHttpEntryAssertion) MarshalTo

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

func (*MultiHttpEntryAssertion) MarshalToSizedBuffer

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

func (*MultiHttpEntryAssertion) ProtoMessage

func (*MultiHttpEntryAssertion) ProtoMessage()

func (*MultiHttpEntryAssertion) Reset

func (m *MultiHttpEntryAssertion) Reset()

func (*MultiHttpEntryAssertion) Size

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

func (*MultiHttpEntryAssertion) String

func (m *MultiHttpEntryAssertion) String() string

func (*MultiHttpEntryAssertion) Unmarshal

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

func (*MultiHttpEntryAssertion) Validate

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

func (m *MultiHttpEntryAssertion) XXX_DiscardUnknown()

func (*MultiHttpEntryAssertion) XXX_Marshal

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

func (*MultiHttpEntryAssertion) XXX_Merge

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

func (*MultiHttpEntryAssertion) XXX_Size

func (m *MultiHttpEntryAssertion) XXX_Size() int

func (*MultiHttpEntryAssertion) XXX_Unmarshal

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

type MultiHttpEntryAssertionConditionVariant

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

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

func MultiHttpEntryAssertionConditionVariantValues() []MultiHttpEntryAssertionConditionVariant

MultiHttpEntryAssertionConditionVariantValues returns all values of the enum

func (MultiHttpEntryAssertionConditionVariant) EnumDescriptor

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

func (MultiHttpEntryAssertionConditionVariant) IsAMultiHttpEntryAssertionConditionVariant

func (i MultiHttpEntryAssertionConditionVariant) IsAMultiHttpEntryAssertionConditionVariant() bool

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

func (MultiHttpEntryAssertionConditionVariant) String

type MultiHttpEntryAssertionSubjectVariant

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

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

func MultiHttpEntryAssertionSubjectVariantValues() []MultiHttpEntryAssertionSubjectVariant

MultiHttpEntryAssertionSubjectVariantValues returns all values of the enum

func (MultiHttpEntryAssertionSubjectVariant) EnumDescriptor

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

func (MultiHttpEntryAssertionSubjectVariant) IsAMultiHttpEntryAssertionSubjectVariant

func (i MultiHttpEntryAssertionSubjectVariant) IsAMultiHttpEntryAssertionSubjectVariant() bool

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

func (MultiHttpEntryAssertionSubjectVariant) String

type MultiHttpEntryAssertionType

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

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

func MultiHttpEntryAssertionTypeValues() []MultiHttpEntryAssertionType

MultiHttpEntryAssertionTypeValues returns all values of the enum

func (MultiHttpEntryAssertionType) EnumDescriptor

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

func (MultiHttpEntryAssertionType) IsAMultiHttpEntryAssertionType

func (i MultiHttpEntryAssertionType) IsAMultiHttpEntryAssertionType() bool

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

func (MultiHttpEntryAssertionType) String

type MultiHttpEntryRequest

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

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

func (*MultiHttpEntryRequest) Marshal

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

func (*MultiHttpEntryRequest) MarshalTo

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

func (*MultiHttpEntryRequest) MarshalToSizedBuffer

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

func (*MultiHttpEntryRequest) ProtoMessage

func (*MultiHttpEntryRequest) ProtoMessage()

func (*MultiHttpEntryRequest) Reset

func (m *MultiHttpEntryRequest) Reset()

func (*MultiHttpEntryRequest) Size

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

func (*MultiHttpEntryRequest) String

func (m *MultiHttpEntryRequest) String() string

func (*MultiHttpEntryRequest) Unmarshal

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

func (*MultiHttpEntryRequest) Validate

func (r *MultiHttpEntryRequest) Validate() error

func (*MultiHttpEntryRequest) XXX_DiscardUnknown

func (m *MultiHttpEntryRequest) XXX_DiscardUnknown()

func (*MultiHttpEntryRequest) XXX_Marshal

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

func (*MultiHttpEntryRequest) XXX_Merge

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

func (*MultiHttpEntryRequest) XXX_Size

func (m *MultiHttpEntryRequest) XXX_Size() int

func (*MultiHttpEntryRequest) XXX_Unmarshal

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

type MultiHttpEntryVariable

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

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

func (*MultiHttpEntryVariable) Marshal

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

func (*MultiHttpEntryVariable) MarshalTo

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

func (*MultiHttpEntryVariable) MarshalToSizedBuffer

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

func (*MultiHttpEntryVariable) ProtoMessage

func (*MultiHttpEntryVariable) ProtoMessage()

func (*MultiHttpEntryVariable) Reset

func (m *MultiHttpEntryVariable) Reset()

func (*MultiHttpEntryVariable) Size

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

func (*MultiHttpEntryVariable) String

func (m *MultiHttpEntryVariable) String() string

func (*MultiHttpEntryVariable) Unmarshal

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

func (*MultiHttpEntryVariable) Validate

func (v *MultiHttpEntryVariable) Validate() error

func (*MultiHttpEntryVariable) XXX_DiscardUnknown

func (m *MultiHttpEntryVariable) XXX_DiscardUnknown()

func (*MultiHttpEntryVariable) XXX_Marshal

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

func (*MultiHttpEntryVariable) XXX_Merge

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

func (*MultiHttpEntryVariable) XXX_Size

func (m *MultiHttpEntryVariable) XXX_Size() int

func (*MultiHttpEntryVariable) XXX_Unmarshal

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

type MultiHttpEntryVariableType

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

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

func MultiHttpEntryVariableTypeValues() []MultiHttpEntryVariableType

MultiHttpEntryVariableTypeValues returns all values of the enum

func (MultiHttpEntryVariableType) EnumDescriptor

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

func (MultiHttpEntryVariableType) IsAMultiHttpEntryVariableType

func (i MultiHttpEntryVariableType) IsAMultiHttpEntryVariableType() bool

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

func (MultiHttpEntryVariableType) String

type MultiHttpSettings

type MultiHttpSettings struct {
	Entries []*MultiHttpEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries"`
}

MultiHttpSettings represents the settings for the MultiHttp check type.

func (*MultiHttpSettings) Descriptor

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

func (*MultiHttpSettings) Marshal

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

func (*MultiHttpSettings) MarshalTo

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

func (*MultiHttpSettings) MarshalToSizedBuffer

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

func (*MultiHttpSettings) ProtoMessage

func (*MultiHttpSettings) ProtoMessage()

func (*MultiHttpSettings) Reset

func (m *MultiHttpSettings) Reset()

func (*MultiHttpSettings) Size

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

func (*MultiHttpSettings) String

func (m *MultiHttpSettings) String() string

func (*MultiHttpSettings) Unmarshal

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

func (*MultiHttpSettings) Validate

func (s *MultiHttpSettings) Validate() error

func (*MultiHttpSettings) XXX_DiscardUnknown

func (m *MultiHttpSettings) XXX_DiscardUnknown()

func (*MultiHttpSettings) XXX_Marshal

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

func (*MultiHttpSettings) XXX_Merge

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

func (*MultiHttpSettings) XXX_Size

func (m *MultiHttpSettings) XXX_Size() int

func (*MultiHttpSettings) XXX_Unmarshal

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

type OAuth2Config

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

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

func (*OAuth2Config) Marshal

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

func (*OAuth2Config) MarshalTo

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

func (*OAuth2Config) MarshalToSizedBuffer

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

func (*OAuth2Config) ProtoMessage

func (*OAuth2Config) ProtoMessage()

func (*OAuth2Config) Reset

func (m *OAuth2Config) Reset()

func (*OAuth2Config) Size

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

func (*OAuth2Config) String

func (m *OAuth2Config) String() string

func (*OAuth2Config) Unmarshal

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

func (*OAuth2Config) XXX_DiscardUnknown

func (m *OAuth2Config) XXX_DiscardUnknown()

func (*OAuth2Config) XXX_Marshal

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

func (*OAuth2Config) XXX_Merge

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

func (*OAuth2Config) XXX_Size

func (m *OAuth2Config) XXX_Size() int

func (*OAuth2Config) XXX_Unmarshal

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

type PingRequest

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

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

func (*PingRequest) Marshal

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

func (*PingRequest) MarshalTo

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

func (*PingRequest) MarshalToSizedBuffer

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

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset

func (m *PingRequest) Reset()

func (*PingRequest) Size

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

func (*PingRequest) String

func (m *PingRequest) String() string

func (*PingRequest) Unmarshal

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

func (*PingRequest) XXX_DiscardUnknown

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal

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

func (*PingRequest) XXX_Merge

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

func (*PingRequest) XXX_Size

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal

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

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

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

func (*PongResponse) Marshal

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

func (*PongResponse) MarshalTo

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

func (*PongResponse) MarshalToSizedBuffer

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

func (*PongResponse) ProtoMessage

func (*PongResponse) ProtoMessage()

func (*PongResponse) Reset

func (m *PongResponse) Reset()

func (*PongResponse) Size

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

func (*PongResponse) String

func (m *PongResponse) String() string

func (*PongResponse) Unmarshal

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

func (*PongResponse) XXX_DiscardUnknown

func (m *PongResponse) XXX_DiscardUnknown()

func (*PongResponse) XXX_Marshal

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

func (*PongResponse) XXX_Merge

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

func (*PongResponse) XXX_Size

func (m *PongResponse) XXX_Size() int

func (*PongResponse) XXX_Unmarshal

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

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

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

func (*ProbeInfo) Marshal

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

func (*ProbeInfo) MarshalTo

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

func (*ProbeInfo) MarshalToSizedBuffer

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

func (*ProbeInfo) ProtoMessage

func (*ProbeInfo) ProtoMessage()

func (*ProbeInfo) Reset

func (m *ProbeInfo) Reset()

func (*ProbeInfo) Size

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

func (*ProbeInfo) String

func (m *ProbeInfo) String() string

func (*ProbeInfo) Unmarshal

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

func (*ProbeInfo) XXX_DiscardUnknown

func (m *ProbeInfo) XXX_DiscardUnknown()

func (*ProbeInfo) XXX_Marshal

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

func (*ProbeInfo) XXX_Merge

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

func (*ProbeInfo) XXX_Size

func (m *ProbeInfo) XXX_Size() int

func (*ProbeInfo) XXX_Unmarshal

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

type ProbeState

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

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

func (*ProbeState) Marshal

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

func (*ProbeState) MarshalTo

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

func (*ProbeState) MarshalToSizedBuffer

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

func (*ProbeState) ProtoMessage

func (*ProbeState) ProtoMessage()

func (*ProbeState) Reset

func (m *ProbeState) Reset()

func (*ProbeState) Size

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

func (*ProbeState) String

func (m *ProbeState) String() string

func (*ProbeState) Unmarshal

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

func (*ProbeState) XXX_DiscardUnknown

func (m *ProbeState) XXX_DiscardUnknown()

func (*ProbeState) XXX_Marshal

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

func (*ProbeState) XXX_Merge

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

func (*ProbeState) XXX_Size

func (m *ProbeState) XXX_Size() int

func (*ProbeState) XXX_Unmarshal

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

type QueryField

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

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

func (*QueryField) Marshal

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

func (*QueryField) MarshalTo

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

func (*QueryField) MarshalToSizedBuffer

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

func (*QueryField) ProtoMessage

func (*QueryField) ProtoMessage()

func (*QueryField) Reset

func (m *QueryField) Reset()

func (*QueryField) Size

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

func (*QueryField) String

func (m *QueryField) String() string

func (*QueryField) Unmarshal

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

func (QueryField) Validate

func (f QueryField) Validate() error

func (*QueryField) XXX_DiscardUnknown

func (m *QueryField) XXX_DiscardUnknown()

func (*QueryField) XXX_Marshal

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

func (*QueryField) XXX_Merge

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

func (*QueryField) XXX_Size

func (m *QueryField) XXX_Size() int

func (*QueryField) XXX_Unmarshal

func (m *QueryField) 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 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 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"`
	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 TenantStatus

type TenantStatus int32

TenantStatus represents the status associated to particular tenant.

const (
	TenantStatus_ACTIVE   TenantStatus = 0
	TenantStatus_DISABLED TenantStatus = 1
)

func (TenantStatus) EnumDescriptor

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

func (TenantStatus) String

func (x TenantStatus) String() string

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

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

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

func (*TracerouteSettings) Marshal

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

func (*TracerouteSettings) MarshalTo

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

func (*TracerouteSettings) MarshalToSizedBuffer

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

func (*TracerouteSettings) ProtoMessage

func (*TracerouteSettings) ProtoMessage()

func (*TracerouteSettings) Reset

func (m *TracerouteSettings) Reset()

func (*TracerouteSettings) Size

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

func (*TracerouteSettings) String

func (m *TracerouteSettings) String() string

func (*TracerouteSettings) Unmarshal

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

func (*TracerouteSettings) Validate

func (s *TracerouteSettings) Validate() error

func (*TracerouteSettings) XXX_DiscardUnknown

func (m *TracerouteSettings) XXX_DiscardUnknown()

func (*TracerouteSettings) XXX_Marshal

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

func (*TracerouteSettings) XXX_Merge

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

func (*TracerouteSettings) XXX_Size

func (m *TracerouteSettings) XXX_Size() int

func (*TracerouteSettings) XXX_Unmarshal

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

type UnimplementedAdHocChecksServer

type UnimplementedAdHocChecksServer struct {
}

UnimplementedAdHocChecksServer can be embedded to have forward compatible implementations.

func (*UnimplementedAdHocChecksServer) GetAdHocChecks

func (*UnimplementedAdHocChecksServer) RegisterProbe

type UnimplementedChecksServer

type UnimplementedChecksServer struct {
}

UnimplementedChecksServer can be embedded to have forward compatible implementations.

func (*UnimplementedChecksServer) GetChanges

func (*UnimplementedChecksServer) Ping

func (*UnimplementedChecksServer) RegisterProbe

type UnimplementedTenantsServer

type UnimplementedTenantsServer struct {
}

UnimplementedTenantsServer can be embedded to have forward compatible implementations.

func (*UnimplementedTenantsServer) GetTenant

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL