proddle

package
v0.1.5 Latest Latest
Warning

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

 Go to latest Published: May 16, 2019 License: BSD-2-Clause Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Protocol_name = map[int32]string{
	0: "DNS",
	1: "HTTP",
	2: "HTTPS",
	3: "PING",
	4: "TRACEROUTE",
}
View Source 
var Protocol_value = map[string]int32{
	"DNS":        0,
	"HTTP":       1,
	"HTTPS":      2,
	"PING":       3,
	"TRACEROUTE": 4,
}

Functions

func RegisterProbeCacheServer 

func RegisterProbeCacheServer(s *grpc.Server, srv ProbeCacheServer)

func RegisterSchedulerServer 

func RegisterSchedulerServer(s *grpc.Server, srv SchedulerServer)

Types

type BucketHash 

type BucketHash struct {
	BucketKey            uint64   `protobuf:"varint,1,opt,name=bucket_key,json=bucketKey,proto3" json:"bucket_key,omitempty"`
	Hash                 uint64   `protobuf:"varint,2,opt,name=hash,proto3" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BucketHash) Descriptor 

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

func (*BucketHash) GetBucketKey 

func (m *BucketHash) GetBucketKey() uint64

func (*BucketHash) GetHash 

func (m *BucketHash) GetHash() uint64

func (*BucketHash) ProtoMessage 

func (*BucketHash) ProtoMessage()

func (*BucketHash) Reset 

func (m *BucketHash) Reset()

func (*BucketHash) String 

func (m *BucketHash) String() string

func (*BucketHash) XXX_DiscardUnknown added in v0.1.2 

func (m *BucketHash) XXX_DiscardUnknown()

func (*BucketHash) XXX_Marshal added in v0.1.2 

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

func (*BucketHash) XXX_Merge added in v0.1.2 

func (dst *BucketHash) XXX_Merge(src proto.Message)

func (*BucketHash) XXX_Size added in v0.1.2 

func (m *BucketHash) XXX_Size() int

func (*BucketHash) XXX_Unmarshal added in v0.1.2 

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

type BucketProbes 

type BucketProbes struct {
	BucketKey            uint64   `protobuf:"varint,1,opt,name=bucket_key,json=bucketKey,proto3" json:"bucket_key,omitempty"`
	Probe                []*Probe `protobuf:"bytes,2,rep,name=probe,proto3" json:"probe,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BucketProbes) Descriptor 

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

func (*BucketProbes) GetBucketKey 

func (m *BucketProbes) GetBucketKey() uint64

func (*BucketProbes) GetProbe 

func (m *BucketProbes) GetProbe() []*Probe

func (*BucketProbes) ProtoMessage 

func (*BucketProbes) ProtoMessage()

func (*BucketProbes) Reset 

func (m *BucketProbes) Reset()

func (*BucketProbes) String 

func (m *BucketProbes) String() string

func (*BucketProbes) XXX_DiscardUnknown added in v0.1.2 

func (m *BucketProbes) XXX_DiscardUnknown()

func (*BucketProbes) XXX_Marshal added in v0.1.2 

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

func (*BucketProbes) XXX_Merge added in v0.1.2 

func (dst *BucketProbes) XXX_Merge(src proto.Message)

func (*BucketProbes) XXX_Size added in v0.1.2 

func (m *BucketProbes) XXX_Size() int

func (*BucketProbes) XXX_Unmarshal added in v0.1.2 

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

type CancelProbeReply 

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

func (*CancelProbeReply) Descriptor 

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

func (*CancelProbeReply) ProtoMessage 

func (*CancelProbeReply) ProtoMessage()

func (*CancelProbeReply) Reset 

func (m *CancelProbeReply) Reset()

func (*CancelProbeReply) String 

func (m *CancelProbeReply) String() string

func (*CancelProbeReply) XXX_DiscardUnknown added in v0.1.2 

func (m *CancelProbeReply) XXX_DiscardUnknown()

func (*CancelProbeReply) XXX_Marshal added in v0.1.2 

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

func (*CancelProbeReply) XXX_Merge added in v0.1.2 

func (dst *CancelProbeReply) XXX_Merge(src proto.Message)

func (*CancelProbeReply) XXX_Size added in v0.1.2 

func (m *CancelProbeReply) XXX_Size() int

func (*CancelProbeReply) XXX_Unmarshal added in v0.1.2 

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

type CancelProbeRequest 

type CancelProbeRequest struct {
	Domain   string     `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"`
	Protocol []Protocol `protobuf:"varint,2,rep,packed,name=protocol,proto3,enum=proddle.Protocol" json:"protocol,omitempty"`
	// HTTP specific
	UrlSuffix            string   `protobuf:"bytes,3,opt,name=url_suffix,json=urlSuffix,proto3" json:"url_suffix,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CancelProbeRequest) Descriptor 

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

func (*CancelProbeRequest) GetDomain 

func (m *CancelProbeRequest) GetDomain() string

func (*CancelProbeRequest) GetProtocol 

func (m *CancelProbeRequest) GetProtocol() []Protocol

func (*CancelProbeRequest) GetUrlSuffix 

func (m *CancelProbeRequest) GetUrlSuffix() string

func (*CancelProbeRequest) ProtoMessage 

func (*CancelProbeRequest) ProtoMessage()

func (*CancelProbeRequest) Reset 

func (m *CancelProbeRequest) Reset()

func (*CancelProbeRequest) String 

func (m *CancelProbeRequest) String() string

func (*CancelProbeRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *CancelProbeRequest) XXX_DiscardUnknown()

func (*CancelProbeRequest) XXX_Marshal added in v0.1.2 

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

func (*CancelProbeRequest) XXX_Merge added in v0.1.2 

func (dst *CancelProbeRequest) XXX_Merge(src proto.Message)

func (*CancelProbeRequest) XXX_Size added in v0.1.2 

func (m *CancelProbeRequest) XXX_Size() int

func (*CancelProbeRequest) XXX_Unmarshal added in v0.1.2 

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

type GetBucketKeysReply 

type GetBucketKeysReply struct {
	BucketKey            []uint64 `protobuf:"varint,1,rep,packed,name=bucket_key,json=bucketKey,proto3" json:"bucket_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetBucketKeysReply) Descriptor 

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

func (*GetBucketKeysReply) GetBucketKey 

func (m *GetBucketKeysReply) GetBucketKey() []uint64

func (*GetBucketKeysReply) ProtoMessage 

func (*GetBucketKeysReply) ProtoMessage()

func (*GetBucketKeysReply) Reset 

func (m *GetBucketKeysReply) Reset()

func (*GetBucketKeysReply) String 

func (m *GetBucketKeysReply) String() string

func (*GetBucketKeysReply) XXX_DiscardUnknown added in v0.1.2 

func (m *GetBucketKeysReply) XXX_DiscardUnknown()

func (*GetBucketKeysReply) XXX_Marshal added in v0.1.2 

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

func (*GetBucketKeysReply) XXX_Merge added in v0.1.2 

func (dst *GetBucketKeysReply) XXX_Merge(src proto.Message)

func (*GetBucketKeysReply) XXX_Size added in v0.1.2 

func (m *GetBucketKeysReply) XXX_Size() int

func (*GetBucketKeysReply) XXX_Unmarshal added in v0.1.2 

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

type GetBucketKeysRequest 

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

func (*GetBucketKeysRequest) Descriptor 

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

func (*GetBucketKeysRequest) ProtoMessage 

func (*GetBucketKeysRequest) ProtoMessage()

func (*GetBucketKeysRequest) Reset 

func (m *GetBucketKeysRequest) Reset()

func (*GetBucketKeysRequest) String 

func (m *GetBucketKeysRequest) String() string

func (*GetBucketKeysRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *GetBucketKeysRequest) XXX_DiscardUnknown()

func (*GetBucketKeysRequest) XXX_Marshal added in v0.1.2 

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

func (*GetBucketKeysRequest) XXX_Merge added in v0.1.2 

func (dst *GetBucketKeysRequest) XXX_Merge(src proto.Message)

func (*GetBucketKeysRequest) XXX_Size added in v0.1.2 

func (m *GetBucketKeysRequest) XXX_Size() int

func (*GetBucketKeysRequest) XXX_Unmarshal added in v0.1.2 

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

type GetProbesReply 

type GetProbesReply struct {
	BucketProbes         []*BucketProbes `protobuf:"bytes,1,rep,name=bucket_probes,json=bucketProbes,proto3" json:"bucket_probes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetProbesReply) Descriptor 

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

func (*GetProbesReply) GetBucketProbes 

func (m *GetProbesReply) GetBucketProbes() []*BucketProbes

func (*GetProbesReply) ProtoMessage 

func (*GetProbesReply) ProtoMessage()

func (*GetProbesReply) Reset 

func (m *GetProbesReply) Reset()

func (*GetProbesReply) String 

func (m *GetProbesReply) String() string

func (*GetProbesReply) XXX_DiscardUnknown added in v0.1.2 

func (m *GetProbesReply) XXX_DiscardUnknown()

func (*GetProbesReply) XXX_Marshal added in v0.1.2 

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

func (*GetProbesReply) XXX_Merge added in v0.1.2 

func (dst *GetProbesReply) XXX_Merge(src proto.Message)

func (*GetProbesReply) XXX_Size added in v0.1.2 

func (m *GetProbesReply) XXX_Size() int

func (*GetProbesReply) XXX_Unmarshal added in v0.1.2 

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

type GetProbesRequest 

type GetProbesRequest struct {
	BucketHash           []*BucketHash `protobuf:"bytes,1,rep,name=bucket_hash,json=bucketHash,proto3" json:"bucket_hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*GetProbesRequest) Descriptor 

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

func (*GetProbesRequest) GetBucketHash 

func (m *GetProbesRequest) GetBucketHash() []*BucketHash

func (*GetProbesRequest) ProtoMessage 

func (*GetProbesRequest) ProtoMessage()

func (*GetProbesRequest) Reset 

func (m *GetProbesRequest) Reset()

func (*GetProbesRequest) String 

func (m *GetProbesRequest) String() string

func (*GetProbesRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *GetProbesRequest) XXX_DiscardUnknown()

func (*GetProbesRequest) XXX_Marshal added in v0.1.2 

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

func (*GetProbesRequest) XXX_Merge added in v0.1.2 

func (dst *GetProbesRequest) XXX_Merge(src proto.Message)

func (*GetProbesRequest) XXX_Size added in v0.1.2 

func (m *GetProbesRequest) XXX_Size() int

func (*GetProbesRequest) XXX_Unmarshal added in v0.1.2 

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

type Probe 

type Probe struct {
	ProbeId                  uint64   `protobuf:"varint,1,opt,name=probe_id,json=probeId,proto3" json:"probe_id,omitempty"`
	ProbeIntervalSeconds     uint32   `protobuf:"varint,2,opt,name=probe_interval_seconds,json=probeIntervalSeconds,proto3" json:"probe_interval_seconds,omitempty"`
	TimeoutSeconds           uint32   `protobuf:"varint,3,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	AttemptsToDeclareFailure uint32   `` /* 138-byte string literal not displayed */
	Protocol                 Protocol `protobuf:"varint,5,opt,name=protocol,proto3,enum=proddle.Protocol" json:"protocol,omitempty"`
	Domain                   string   `protobuf:"bytes,6,opt,name=domain,proto3" json:"domain,omitempty"`
	// HTTP/HTTPS specific
	Port                 uint32   `protobuf:"varint,7,opt,name=port,proto3" json:"port,omitempty"`
	UrlSuffix            string   `protobuf:"bytes,8,opt,name=url_suffix,json=urlSuffix,proto3" json:"url_suffix,omitempty"`
	FollowRedirect       bool     `protobuf:"varint,9,opt,name=follow_redirect,json=followRedirect,proto3" json:"follow_redirect,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Probe) Descriptor 

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

func (*Probe) GetAttemptsToDeclareFailure 

func (m *Probe) GetAttemptsToDeclareFailure() uint32

func (*Probe) GetDomain 

func (m *Probe) GetDomain() string

func (*Probe) GetFollowRedirect 

func (m *Probe) GetFollowRedirect() bool

func (*Probe) GetPort 

func (m *Probe) GetPort() uint32

func (*Probe) GetProbeId 

func (m *Probe) GetProbeId() uint64

func (*Probe) GetProbeIntervalSeconds 

func (m *Probe) GetProbeIntervalSeconds() uint32

func (*Probe) GetProtocol 

func (m *Probe) GetProtocol() Protocol

func (*Probe) GetTimeoutSeconds 

func (m *Probe) GetTimeoutSeconds() uint32

func (*Probe) GetUrlSuffix 

func (m *Probe) GetUrlSuffix() string

func (*Probe) ProtoMessage 

func (*Probe) ProtoMessage()

func (*Probe) Reset 

func (m *Probe) Reset()

func (*Probe) String 

func (m *Probe) String() string

func (*Probe) XXX_DiscardUnknown added in v0.1.2 

func (m *Probe) XXX_DiscardUnknown()

func (*Probe) XXX_Marshal added in v0.1.2 

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

func (*Probe) XXX_Merge added in v0.1.2 

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

func (*Probe) XXX_Size added in v0.1.2 

func (m *Probe) XXX_Size() int

func (*Probe) XXX_Unmarshal added in v0.1.2 

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

type ProbeCacheClient 

type ProbeCacheClient interface {
	GetProbes(ctx context.Context, in *GetProbesRequest, opts ...grpc.CallOption) (*GetProbesReply, error)
	GetBucketKeys(ctx context.Context, in *GetBucketKeysRequest, opts ...grpc.CallOption) (*GetBucketKeysReply, error)
	SendProbeResults(ctx context.Context, in *SendProbeResultsRequest, opts ...grpc.CallOption) (*SendProbeResultsReply, error)
}

ProbeCacheClient is the client API for ProbeCache service.

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

func NewProbeCacheClient 

func NewProbeCacheClient(cc *grpc.ClientConn) ProbeCacheClient

type ProbeCacheServer 

type ProbeCacheServer interface {
	GetProbes(context.Context, *GetProbesRequest) (*GetProbesReply, error)
	GetBucketKeys(context.Context, *GetBucketKeysRequest) (*GetBucketKeysReply, error)
	SendProbeResults(context.Context, *SendProbeResultsRequest) (*SendProbeResultsReply, error)
}

ProbeCacheServer is the server API for ProbeCache service.

type ProbeResult 

type ProbeResult struct {
	ProbeId                        uint64   `protobuf:"varint,1,opt,name=probe_id,json=probeId,proto3" json:"probe_id,omitempty"`
	ProberHostname                 string   `protobuf:"bytes,2,opt,name=prober_hostname,json=proberHostname,proto3" json:"prober_hostname,omitempty"`
	Protocol                       Protocol `protobuf:"varint,3,opt,name=protocol,proto3,enum=proddle.Protocol" json:"protocol,omitempty"`
	TimestampSec                   uint64   `protobuf:"varint,4,opt,name=timestamp_sec,json=timestampSec,proto3" json:"timestamp_sec,omitempty"`
	Success                        bool     `protobuf:"varint,5,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage                   string   `protobuf:"bytes,6,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	ApplicationLayerLatencyNanosec uint64   `` /* 156-byte string literal not displayed */
	// DNS specific
	DnsAnswer [][]byte `protobuf:"bytes,8,rep,name=dns_answer,json=dnsAnswer,proto3" json:"dns_answer,omitempty"`
	// HTTP/HTTPS specific
	HttpStatusCode           uint32   `protobuf:"varint,9,opt,name=http_status_code,json=httpStatusCode,proto3" json:"http_status_code,omitempty"`
	HttpStatusMessage        string   `protobuf:"bytes,10,opt,name=http_status_message,json=httpStatusMessage,proto3" json:"http_status_message,omitempty"`
	ApplicationBytesReceived uint32   `` /* 137-byte string literal not displayed */
	XXX_NoUnkeyedLiteral     struct{} `json:"-"`
	XXX_unrecognized         []byte   `json:"-"`
	XXX_sizecache            int32    `json:"-"`
}

func (*ProbeResult) Descriptor 

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

func (*ProbeResult) GetApplicationBytesReceived 

func (m *ProbeResult) GetApplicationBytesReceived() uint32

func (*ProbeResult) GetApplicationLayerLatencyNanosec 

func (m *ProbeResult) GetApplicationLayerLatencyNanosec() uint64

func (*ProbeResult) GetDnsAnswer 

func (m *ProbeResult) GetDnsAnswer() [][]byte

func (*ProbeResult) GetErrorMessage 

func (m *ProbeResult) GetErrorMessage() string

func (*ProbeResult) GetHttpStatusCode 

func (m *ProbeResult) GetHttpStatusCode() uint32

func (*ProbeResult) GetHttpStatusMessage 

func (m *ProbeResult) GetHttpStatusMessage() string

func (*ProbeResult) GetProbeId 

func (m *ProbeResult) GetProbeId() uint64

func (*ProbeResult) GetProberHostname 

func (m *ProbeResult) GetProberHostname() string

func (*ProbeResult) GetProtocol 

func (m *ProbeResult) GetProtocol() Protocol

func (*ProbeResult) GetSuccess 

func (m *ProbeResult) GetSuccess() bool

func (*ProbeResult) GetTimestampSec 

func (m *ProbeResult) GetTimestampSec() uint64

func (*ProbeResult) ProtoMessage 

func (*ProbeResult) ProtoMessage()

func (*ProbeResult) Reset 

func (m *ProbeResult) Reset()

func (*ProbeResult) String 

func (m *ProbeResult) String() string

func (*ProbeResult) XXX_DiscardUnknown added in v0.1.2 

func (m *ProbeResult) XXX_DiscardUnknown()

func (*ProbeResult) XXX_Marshal added in v0.1.2 

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

func (*ProbeResult) XXX_Merge added in v0.1.2 

func (dst *ProbeResult) XXX_Merge(src proto.Message)

func (*ProbeResult) XXX_Size added in v0.1.2 

func (m *ProbeResult) XXX_Size() int

func (*ProbeResult) XXX_Unmarshal added in v0.1.2 

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

type Protocol 

type Protocol int32

* probe messages 

const (
	Protocol_DNS        Protocol = 0
	Protocol_HTTP       Protocol = 1
	Protocol_HTTPS      Protocol = 2
	Protocol_PING       Protocol = 3
	Protocol_TRACEROUTE Protocol = 4
)

func (Protocol) EnumDescriptor 

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

func (Protocol) String 

func (x Protocol) String() string

type ScheduleProbeReply 

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

func (*ScheduleProbeReply) Descriptor 

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

func (*ScheduleProbeReply) ProtoMessage 

func (*ScheduleProbeReply) ProtoMessage()

func (*ScheduleProbeReply) Reset 

func (m *ScheduleProbeReply) Reset()

func (*ScheduleProbeReply) String 

func (m *ScheduleProbeReply) String() string

func (*ScheduleProbeReply) XXX_DiscardUnknown added in v0.1.2 

func (m *ScheduleProbeReply) XXX_DiscardUnknown()

func (*ScheduleProbeReply) XXX_Marshal added in v0.1.2 

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

func (*ScheduleProbeReply) XXX_Merge added in v0.1.2 

func (dst *ScheduleProbeReply) XXX_Merge(src proto.Message)

func (*ScheduleProbeReply) XXX_Size added in v0.1.2 

func (m *ScheduleProbeReply) XXX_Size() int

func (*ScheduleProbeReply) XXX_Unmarshal added in v0.1.2 

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

type ScheduleProbeRequest 

type ScheduleProbeRequest struct {
	Probe                []*Probe `protobuf:"bytes,2,rep,name=probe,proto3" json:"probe,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScheduleProbeRequest) Descriptor 

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

func (*ScheduleProbeRequest) GetProbe 

func (m *ScheduleProbeRequest) GetProbe() []*Probe

func (*ScheduleProbeRequest) ProtoMessage 

func (*ScheduleProbeRequest) ProtoMessage()

func (*ScheduleProbeRequest) Reset 

func (m *ScheduleProbeRequest) Reset()

func (*ScheduleProbeRequest) String 

func (m *ScheduleProbeRequest) String() string

func (*ScheduleProbeRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *ScheduleProbeRequest) XXX_DiscardUnknown()

func (*ScheduleProbeRequest) XXX_Marshal added in v0.1.2 

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

func (*ScheduleProbeRequest) XXX_Merge added in v0.1.2 

func (dst *ScheduleProbeRequest) XXX_Merge(src proto.Message)

func (*ScheduleProbeRequest) XXX_Size added in v0.1.2 

func (m *ScheduleProbeRequest) XXX_Size() int

func (*ScheduleProbeRequest) XXX_Unmarshal added in v0.1.2 

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

type SchedulerClient 

type SchedulerClient interface {
	CancelProbe(ctx context.Context, in *CancelProbeRequest, opts ...grpc.CallOption) (*CancelProbeReply, error)
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchReply, error)
	ScheduleProbe(ctx context.Context, in *ScheduleProbeRequest, opts ...grpc.CallOption) (*ScheduleProbeReply, error)
}

SchedulerClient is the client API for Scheduler service.

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

func NewSchedulerClient 

func NewSchedulerClient(cc *grpc.ClientConn) SchedulerClient

type SchedulerServer 

type SchedulerServer interface {
	CancelProbe(context.Context, *CancelProbeRequest) (*CancelProbeReply, error)
	Search(context.Context, *SearchRequest) (*SearchReply, error)
	ScheduleProbe(context.Context, *ScheduleProbeRequest) (*ScheduleProbeReply, error)
}

SchedulerServer is the server API for Scheduler service.

type SearchReply 

type SearchReply struct {
	Probe                []*Probe `protobuf:"bytes,1,rep,name=probe,proto3" json:"probe,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SearchReply) Descriptor 

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

func (*SearchReply) GetProbe 

func (m *SearchReply) GetProbe() []*Probe

func (*SearchReply) ProtoMessage 

func (*SearchReply) ProtoMessage()

func (*SearchReply) Reset 

func (m *SearchReply) Reset()

func (*SearchReply) String 

func (m *SearchReply) String() string

func (*SearchReply) XXX_DiscardUnknown added in v0.1.2 

func (m *SearchReply) XXX_DiscardUnknown()

func (*SearchReply) XXX_Marshal added in v0.1.2 

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

func (*SearchReply) XXX_Merge added in v0.1.2 

func (dst *SearchReply) XXX_Merge(src proto.Message)

func (*SearchReply) XXX_Size added in v0.1.2 

func (m *SearchReply) XXX_Size() int

func (*SearchReply) XXX_Unmarshal added in v0.1.2 

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

type SearchRequest 

type SearchRequest struct {
	Protocol             []Protocol `protobuf:"varint,1,rep,packed,name=protocol,proto3,enum=proddle.Protocol" json:"protocol,omitempty"`
	Domain               string     `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*SearchRequest) Descriptor 

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

func (*SearchRequest) GetDomain 

func (m *SearchRequest) GetDomain() string

func (*SearchRequest) GetProtocol 

func (m *SearchRequest) GetProtocol() []Protocol

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset 

func (m *SearchRequest) Reset()

func (*SearchRequest) String 

func (m *SearchRequest) String() string

func (*SearchRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *SearchRequest) XXX_DiscardUnknown()

func (*SearchRequest) XXX_Marshal added in v0.1.2 

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

func (*SearchRequest) XXX_Merge added in v0.1.2 

func (dst *SearchRequest) XXX_Merge(src proto.Message)

func (*SearchRequest) XXX_Size added in v0.1.2 

func (m *SearchRequest) XXX_Size() int

func (*SearchRequest) XXX_Unmarshal added in v0.1.2 

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

type SendProbeResultsReply 

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

func (*SendProbeResultsReply) Descriptor 

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

func (*SendProbeResultsReply) ProtoMessage 

func (*SendProbeResultsReply) ProtoMessage()

func (*SendProbeResultsReply) Reset 

func (m *SendProbeResultsReply) Reset()

func (*SendProbeResultsReply) String 

func (m *SendProbeResultsReply) String() string

func (*SendProbeResultsReply) XXX_DiscardUnknown added in v0.1.2 

func (m *SendProbeResultsReply) XXX_DiscardUnknown()

func (*SendProbeResultsReply) XXX_Marshal added in v0.1.2 

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

func (*SendProbeResultsReply) XXX_Merge added in v0.1.2 

func (dst *SendProbeResultsReply) XXX_Merge(src proto.Message)

func (*SendProbeResultsReply) XXX_Size added in v0.1.2 

func (m *SendProbeResultsReply) XXX_Size() int

func (*SendProbeResultsReply) XXX_Unmarshal added in v0.1.2 

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

type SendProbeResultsRequest 

type SendProbeResultsRequest struct {
	ProbeResult          []*ProbeResult `protobuf:"bytes,1,rep,name=probe_result,json=probeResult,proto3" json:"probe_result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*SendProbeResultsRequest) Descriptor 

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

func (*SendProbeResultsRequest) GetProbeResult 

func (m *SendProbeResultsRequest) GetProbeResult() []*ProbeResult

func (*SendProbeResultsRequest) ProtoMessage 

func (*SendProbeResultsRequest) ProtoMessage()

func (*SendProbeResultsRequest) Reset 

func (m *SendProbeResultsRequest) Reset()

func (*SendProbeResultsRequest) String 

func (m *SendProbeResultsRequest) String() string

func (*SendProbeResultsRequest) XXX_DiscardUnknown added in v0.1.2 

func (m *SendProbeResultsRequest) XXX_DiscardUnknown()

func (*SendProbeResultsRequest) XXX_Marshal added in v0.1.2 

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

func (*SendProbeResultsRequest) XXX_Merge added in v0.1.2 

func (dst *SendProbeResultsRequest) XXX_Merge(src proto.Message)

func (*SendProbeResultsRequest) XXX_Size added in v0.1.2 

func (m *SendProbeResultsRequest) XXX_Size() int

func (*SendProbeResultsRequest) XXX_Unmarshal added in v0.1.2 

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