myprobe

package

v0.10.5 Latest Latest Go to latest Published: Oct 23, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/hostinger/cloudprober

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Probe
- func (p *Probe) Init(name string, opts *options.Options) error
- func (p *Probe) Start(ctx context.Context, dataChan chan *metrics.EventMetrics)
type ProbeConf
type ProbeConf_Op

Constants ¶

This section is empty.

Variables ¶

View Source

var E_RedisProbe = &proto.ExtensionDesc{
	ExtendedType:  (*proto1.ProbeDef)(nil),
	ExtensionType: (*ProbeConf)(nil),
	Field:         200,
	Name:          "myprober.redis_probe",
	Tag:           "bytes,200,opt,name=redis_probe",
	Filename:      "github.com/google/cloudprober/examples/extensions/myprober/myprobe/myprobe.proto",
}

View Source

var ProbeConf_Op_name = map[int32]string{
	0: "GET",
	1: "SET",
	2: "DELETE",
}

View Source

var ProbeConf_Op_value = map[string]int32{
	"GET":    0,
	"SET":    1,
	"DELETE": 2,
}

Functions ¶

This section is empty.

Types ¶

type Probe ¶

type Probe struct {
	// contains filtered or unexported fields
}

Probe holds aggregate information about all probe runs, per-target.

func (*Probe) Init ¶

func (p *Probe) Init(name string, opts *options.Options) error

Init initializes the probe with the given params.

func (*Probe) Start ¶

func (p *Probe) Start(ctx context.Context, dataChan chan *metrics.EventMetrics)

Start starts and runs the probe indefinitely.

type ProbeConf ¶

type ProbeConf struct {
	Op *ProbeConf_Op `protobuf:"varint,1,req,name=op,enum=myprober.ProbeConf_Op" json:"op,omitempty"`
	// Key and value for the redis operation
	Key                  *string  `protobuf:"bytes,2,req,name=key" json:"key,omitempty"`
	Value                *string  `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProbeConf) Descriptor ¶

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

func (*ProbeConf) GetKey ¶

func (m *ProbeConf) GetKey() string

func (*ProbeConf) GetOp ¶

func (m *ProbeConf) GetOp() ProbeConf_Op

func (*ProbeConf) GetValue ¶

func (m *ProbeConf) GetValue() string

func (*ProbeConf) ProtoMessage ¶

func (*ProbeConf) ProtoMessage()

func (*ProbeConf) Reset ¶

func (m *ProbeConf) Reset()

func (*ProbeConf) String ¶

func (m *ProbeConf) String() string

func (*ProbeConf) XXX_DiscardUnknown ¶

func (m *ProbeConf) XXX_DiscardUnknown()

func (*ProbeConf) XXX_Marshal ¶

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

func (*ProbeConf) XXX_Merge ¶

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

func (*ProbeConf) XXX_Size ¶

func (m *ProbeConf) XXX_Size() int

func (*ProbeConf) XXX_Unmarshal ¶

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

type ProbeConf_Op ¶

type ProbeConf_Op int32

Redis operation

const (
	ProbeConf_GET    ProbeConf_Op = 0
	ProbeConf_SET    ProbeConf_Op = 1
	ProbeConf_DELETE ProbeConf_Op = 2
)

func (ProbeConf_Op) Enum ¶

func (x ProbeConf_Op) Enum() *ProbeConf_Op

func (ProbeConf_Op) EnumDescriptor ¶

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

func (ProbeConf_Op) String ¶

func (x ProbeConf_Op) String() string

func (*ProbeConf_Op) UnmarshalJSON ¶

func (x *ProbeConf_Op) UnmarshalJSON(data []byte) error

Source Files ¶

View all Source files

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