synthetic_monitoring

package
v0.0.21 Latest Latest
Warning

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

 Go to latest Published: May 10, 2021 License: Apache-2.0 Imports: 17 Imported by: 9

Documentation

Overview

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

Index

Constants

View Source 
const (
	MaxCheckLabels      = 5   // Loki allows a maximum of 15 labels, we reserve 7 for internal use
	MaxProbeLabels      = 3   // and split the other 8 in 3 for the probes and 5 for the checks.
	MaxLabelValueLength = 128 // Keep this number low so that the UI remains usable.
)

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

	ErrInvalidDnsName             = errors.New("invalid DNS name")
	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")
	ErrInvalidHttpHeaders      = errors.New("invalid HTTP headers")

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

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

func RegisterTenantsServer 

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

Types

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*BasicAuth) Descriptor 

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

func (*BasicAuth) Marshal 

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

func (*BasicAuth) MarshalTo 

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

func (*BasicAuth) MarshalToSizedBuffer 

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

func (*BasicAuth) ProtoMessage 

func (*BasicAuth) ProtoMessage()

func (*BasicAuth) Reset 

func (m *BasicAuth) Reset()

func (*BasicAuth) Size 

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

func (*BasicAuth) String 

func (m *BasicAuth) String() string

func (*BasicAuth) Unmarshal 

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

func (*BasicAuth) XXX_DiscardUnknown 

func (m *BasicAuth) XXX_DiscardUnknown()

func (*BasicAuth) XXX_Marshal 

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

func (*BasicAuth) XXX_Merge 

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

func (*BasicAuth) XXX_Size 

func (m *BasicAuth) XXX_Size() int

func (*BasicAuth) XXX_Unmarshal 

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

type Changes added in v0.0.14 

type Changes struct {
	Checks               []CheckChange `protobuf:"bytes,1,rep,name=checks,proto3" json:"checks"`
	Tenants              []Tenant      `protobuf:"bytes,2,rep,name=tenants,proto3" json:"tenants"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

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

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

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

func (*Changes) Descriptor added in v0.0.14 

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

func (*Changes) Marshal added in v0.0.14 

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

func (*Changes) MarshalTo added in v0.0.14 

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

func (*Changes) MarshalToSizedBuffer added in v0.0.14 

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

func (*Changes) ProtoMessage added in v0.0.14 

func (*Changes) ProtoMessage()

func (*Changes) Reset added in v0.0.14 

func (m *Changes) Reset()

func (*Changes) Size added in v0.0.14 

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

func (*Changes) String added in v0.0.14 

func (m *Changes) String() string

func (*Changes) Unmarshal added in v0.0.14 

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

func (*Changes) XXX_DiscardUnknown added in v0.0.14 

func (m *Changes) XXX_DiscardUnknown()

func (*Changes) XXX_Marshal added in v0.0.14 

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

func (*Changes) XXX_Merge added in v0.0.14 

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

func (*Changes) XXX_Size added in v0.0.14 

func (m *Changes) XXX_Size() int

func (*Changes) XXX_Unmarshal added in v0.0.14 

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

type Check 

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

Check represents a check.

The "settings" field defines the type of check.

func (*Check) ConfigVersion 

func (c *Check) ConfigVersion() string

func (*Check) Descriptor 

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

func (*Check) Marshal 

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

func (*Check) MarshalTo 

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

func (*Check) MarshalToSizedBuffer 

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

func (*Check) ProtoMessage 

func (*Check) ProtoMessage()

func (*Check) Reset 

func (m *Check) Reset()

func (*Check) Size 

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

func (*Check) String 

func (m *Check) String() string

func (Check) Type added in v0.0.18 

func (c Check) Type() CheckType

func (*Check) Unmarshal 

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

func (*Check) Validate 

func (c *Check) Validate() error

func (*Check) XXX_DiscardUnknown 

func (m *Check) XXX_DiscardUnknown()

func (*Check) XXX_Marshal 

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

func (*Check) XXX_Merge 

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

func (*Check) XXX_Size 

func (m *Check) XXX_Size() int

func (*Check) XXX_Unmarshal 

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

type CheckChange 

type CheckChange struct {
	Operation            CheckOperation `protobuf:"varint,1,opt,name=operation,proto3,enum=synthetic_monitoring.CheckOperation" json:"operation,omitempty"`
	Check                Check          `protobuf:"bytes,2,opt,name=check,proto3" json:"check"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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 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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

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) XXX_DiscardUnknown 

func (m *CheckSettings) XXX_DiscardUnknown()

func (*CheckSettings) XXX_Marshal 

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

func (*CheckSettings) XXX_Merge 

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

func (*CheckSettings) XXX_Size 

func (m *CheckSettings) XXX_Size() int

func (*CheckSettings) XXX_Unmarshal 

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

type CheckType added in v0.0.18 

type CheckType int32

CheckType represents the type of the associated check 

const (
	CheckTypeDns  CheckType = 0
	CheckTypeHttp CheckType = 1
	CheckTypePing CheckType = 2
	CheckTypeTcp  CheckType = 3
)

func CheckTypeFromString added in v0.0.18 

func CheckTypeFromString(in string) (CheckType, bool)

func (CheckType) String added in v0.0.18 

func (t 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 *Void, opts ...grpc.CallOption) (Checks_GetChangesClient, 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(*Void, Checks_GetChangesServer) error
}

ChecksServer is the server API for Checks service.

type Checks_GetChangesClient 

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

type Checks_GetChangesServer 

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

type CompressionAlgorithm added in v0.0.20 

type CompressionAlgorithm int32

CompressionAlgorithm represents the compression algorithm to use. 

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

func (CompressionAlgorithm) EnumDescriptor added in v0.0.20 

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

func (CompressionAlgorithm) MarshalJSON added in v0.0.20 

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

func (CompressionAlgorithm) String added in v0.0.20 

func (x CompressionAlgorithm) String() string

func (*CompressionAlgorithm) UnmarshalJSON added in v0.0.20 

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

type DNSRRValidator 

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

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:"validateAditionalRRS,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 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

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"`
	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"`
	XXX_NoUnkeyedLiteral         struct{}             `json:"-"`
	XXX_unrecognized             []byte               `json:"-"`
	XXX_sizecache                int32                `json:"-"`
}

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) UnmarshalJSON 

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

type Label 

type Label struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*Label) Descriptor 

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

func (*Label) Marshal 

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

func (*Label) MarshalTo 

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

func (*Label) MarshalToSizedBuffer 

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

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) Reset 

func (m *Label) Reset()

func (*Label) Size 

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

func (*Label) String 

func (m *Label) String() string

func (*Label) Unmarshal 

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

func (Label) Validate added in v0.0.13 

func (l Label) Validate() error

func (*Label) XXX_DiscardUnknown 

func (m *Label) XXX_DiscardUnknown()

func (*Label) XXX_Marshal 

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

func (*Label) XXX_Merge 

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

func (*Label) XXX_Size 

func (m *Label) XXX_Size() int

func (*Label) XXX_Unmarshal 

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

type 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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

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 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"`
	Created              float64  `protobuf:"fixed64,100,opt,name=created,proto3" json:"created"`
	Modified             float64  `protobuf:"fixed64,101,opt,name=modified,proto3" json:"modified"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Probe represents a probe.

func (*Probe) Descriptor 

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

func (*Probe) Marshal 

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

func (*Probe) MarshalTo 

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

func (*Probe) MarshalToSizedBuffer 

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

func (*Probe) ProtoMessage 

func (*Probe) ProtoMessage()

func (*Probe) Reset 

func (m *Probe) Reset()

func (*Probe) Size 

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

func (*Probe) String 

func (m *Probe) String() string

func (*Probe) Unmarshal 

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

func (*Probe) Validate 

func (p *Probe) Validate() error

func (*Probe) XXX_DiscardUnknown 

func (m *Probe) XXX_DiscardUnknown()

func (*Probe) XXX_Marshal 

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

func (*Probe) XXX_Merge 

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

func (*Probe) XXX_Size 

func (m *Probe) XXX_Size() int

func (*Probe) XXX_Unmarshal 

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

type ProbeInfo added in v0.0.7 

type ProbeInfo struct {
	Version              string   `protobuf:"bytes,1,opt,name=Version,proto3" json:"version"`
	Commit               string   `protobuf:"bytes,2,opt,name=Commit,proto3" json:"commit"`
	Buildstamp           string   `protobuf:"bytes,3,opt,name=Buildstamp,proto3" json:"buildstamp"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProbeInfo) Descriptor added in v0.0.7 

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

func (*ProbeInfo) Marshal added in v0.0.7 

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

func (*ProbeInfo) MarshalTo added in v0.0.7 

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

func (*ProbeInfo) MarshalToSizedBuffer added in v0.0.7 

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

func (*ProbeInfo) ProtoMessage added in v0.0.7 

func (*ProbeInfo) ProtoMessage()

func (*ProbeInfo) Reset added in v0.0.7 

func (m *ProbeInfo) Reset()

func (*ProbeInfo) Size added in v0.0.7 

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

func (*ProbeInfo) String added in v0.0.7 

func (m *ProbeInfo) String() string

func (*ProbeInfo) Unmarshal added in v0.0.7 

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

func (*ProbeInfo) XXX_DiscardUnknown added in v0.0.7 

func (m *ProbeInfo) XXX_DiscardUnknown()

func (*ProbeInfo) XXX_Marshal added in v0.0.7 

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

func (*ProbeInfo) XXX_Merge added in v0.0.7 

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

func (*ProbeInfo) XXX_Size added in v0.0.7 

func (m *ProbeInfo) XXX_Size() int

func (*ProbeInfo) XXX_Unmarshal added in v0.0.7 

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

type 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 added in v0.0.12 

type TenantStatus int32

TenantStatus represents the status associated to particular tenant. 

const (
	TenantStatus_ACTIVE   TenantStatus = 0
	TenantStatus_DISABLED TenantStatus = 1
)

func (TenantStatus) EnumDescriptor added in v0.0.12 

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

func (TenantStatus) String added in v0.0.12 

func (x TenantStatus) String() string

type 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 UnimplementedChecksServer 

type UnimplementedChecksServer struct {
}

UnimplementedChecksServer can be embedded to have forward compatible implementations.

func (*UnimplementedChecksServer) GetChanges 

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

func (*UnimplementedChecksServer) RegisterProbe 

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

type UnimplementedTenantsServer 

type UnimplementedTenantsServer struct {
}

UnimplementedTenantsServer can be embedded to have forward compatible implementations.

func (*UnimplementedTenantsServer) GetTenant 

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

type Void 

type Void struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*Void) Descriptor 

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

func (*Void) Marshal 

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

func (*Void) MarshalTo 

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

func (*Void) MarshalToSizedBuffer 

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

func (*Void) ProtoMessage 

func (*Void) ProtoMessage()

func (*Void) Reset 

func (m *Void) Reset()

func (*Void) Size 

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

func (*Void) String 

func (m *Void) String() string

func (*Void) Unmarshal 

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

func (*Void) XXX_DiscardUnknown 

func (m *Void) XXX_DiscardUnknown()

func (*Void) XXX_Marshal 

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

func (*Void) XXX_Merge 

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

func (*Void) XXX_Size 

func (m *Void) XXX_Size() int

func (*Void) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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