Documentation ¶
Index ¶
- Constants
- Variables
- type CPUTempCollection
- type Config
- func (*Config) Descriptor() ([]byte, []int)
- func (m *Config) GetAggUrl() string
- func (m *Config) GetIpUrl() string
- func (m *Config) GetPollingInterval() string
- func (m *Config) GetRfThermalThresholds() map[string]*Thresholds
- func (m *Config) GetServers() map[string]*Server
- func (m *Config) Marshal() (dAtA []byte, err error)
- func (m *Config) MarshalTo(dAtA []byte) (int, error)
- func (m *Config) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Config) ProtoMessage()
- func (m *Config) Reset()
- func (m *Config) Size() (n int)
- func (m *Config) String() string
- func (m *Config) Unmarshal(dAtA []byte) error
- func (m *Config) XXX_DiscardUnknown()
- func (m *Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Config) XXX_Merge(src proto.Message)
- func (*Config) XXX_MessageName() string
- func (m *Config) XXX_Size() int
- func (m *Config) XXX_Unmarshal(b []byte) error
- type PayLoad
- type RFD
- func (*RFD) ConfigURL() string
- func (rfd *RFD) Entry()
- func (rfd *RFD) Init(api types.ModuleAPIClient)
- func (*RFD) Name() string
- func (*RFD) NewConfig() proto.Message
- func (rfd *RFD) SetDiscoveryChan(c chan<- types.Event)
- func (rfd *RFD) Stop()
- func (rfd *RFD) UpdateConfig(cfg proto.Message) (e error)
- type Server
- func (*Server) Descriptor() ([]byte, []int)
- func (m *Server) GetIp() string
- func (m *Server) GetName() string
- func (m *Server) GetPort() string
- func (m *Server) GetReqTimeout() int32
- func (m *Server) Marshal() (dAtA []byte, err error)
- func (m *Server) MarshalTo(dAtA []byte) (int, error)
- func (m *Server) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Server) ProtoMessage()
- func (m *Server) Reset()
- func (m *Server) Size() (n int)
- func (m *Server) String() string
- func (m *Server) Unmarshal(dAtA []byte) error
- func (m *Server) XXX_DiscardUnknown()
- func (m *Server) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Server) XXX_Merge(src proto.Message)
- func (*Server) XXX_MessageName() string
- func (m *Server) XXX_Size() int
- func (m *Server) XXX_Unmarshal(b []byte) error
- type Thresholds
- func (*Thresholds) Descriptor() ([]byte, []int)
- func (m *Thresholds) GetLowerCritical() int32
- func (m *Thresholds) GetLowerHigh() int32
- func (m *Thresholds) GetLowerNormal() int32
- func (m *Thresholds) GetUpperCritical() int32
- func (m *Thresholds) GetUpperHigh() int32
- func (m *Thresholds) GetUpperNormal() int32
- func (m *Thresholds) Marshal() (dAtA []byte, err error)
- func (m *Thresholds) MarshalTo(dAtA []byte) (int, error)
- func (m *Thresholds) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Thresholds) ProtoMessage()
- func (m *Thresholds) Reset()
- func (m *Thresholds) Size() (n int)
- func (m *Thresholds) String() string
- func (m *Thresholds) Unmarshal(dAtA []byte) error
- func (m *Thresholds) XXX_DiscardUnknown()
- func (m *Thresholds) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Thresholds) XXX_Merge(src proto.Message)
- func (*Thresholds) XXX_MessageName() string
- func (m *Thresholds) XXX_Size() int
- func (m *Thresholds) XXX_Unmarshal(b []byte) error
Constants ¶
View Source
const ( // ThermalStateURL points to Thermal extension ThermalStateURL = "type.googleapis.com/RFThermal.Temp/State" // ModuleStateURL refers to module state ModuleStateURL = "/Services/rfthermaldiscovery/State" )
Variables ¶
Functions ¶
This section is empty.
Types ¶
type CPUTempCollection ¶
type CPUTempCollection struct {
CPUTempList []nodeCPUTemp `json:"cputemplist"`
}
CPUTempCollection is array of CPU Temperature responses
type Config ¶
type Config struct { Servers map[string]*Server `` /* 155-byte string literal not displayed */ IpUrl string `protobuf:"bytes,2,opt,name=ip_url,json=ipUrl,proto3" json:"ip_url,omitempty"` AggUrl string `protobuf:"bytes,3,opt,name=agg_url,json=aggUrl,proto3" json:"agg_url,omitempty"` PollingInterval string `protobuf:"bytes,4,opt,name=polling_interval,json=pollingInterval,proto3" json:"polling_interval,omitempty"` RfThermalThresholds map[string]*Thresholds `` /* 208-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Config) Descriptor ¶
func (*Config) GetPollingInterval ¶
func (*Config) GetRfThermalThresholds ¶
func (m *Config) GetRfThermalThresholds() map[string]*Thresholds
func (*Config) GetServers ¶
func (*Config) MarshalToSizedBuffer ¶
func (*Config) ProtoMessage ¶
func (*Config) ProtoMessage()
func (*Config) XXX_DiscardUnknown ¶
func (m *Config) XXX_DiscardUnknown()
func (*Config) XXX_Marshal ¶
func (*Config) XXX_MessageName ¶
func (*Config) XXX_Unmarshal ¶
type PayLoad ¶
type PayLoad struct { NodesAddressList []string `json:"nodesaddresslist"` Timeout int32 `json:"timeout"` }
PayLoad struct for collection of nodes
type RFD ¶
type RFD struct {
// contains filtered or unexported fields
}
RFD provides rfdiscovery module capabilities
func (*RFD) Init ¶
func (rfd *RFD) Init(api types.ModuleAPIClient)
Init is used to intialize an executable module prior to entrypoint
func (*RFD) SetDiscoveryChan ¶
SetDiscoveryChan sets the current discovery channel this is generally done by the API
type Server ¶
type Server struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Ip string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"` Port string `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"` ReqTimeout int32 `protobuf:"varint,4,opt,name=req_timeout,json=reqTimeout,proto3" json:"req_timeout,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Server) Descriptor ¶
func (*Server) GetReqTimeout ¶
func (*Server) MarshalToSizedBuffer ¶
func (*Server) ProtoMessage ¶
func (*Server) ProtoMessage()
func (*Server) XXX_DiscardUnknown ¶
func (m *Server) XXX_DiscardUnknown()
func (*Server) XXX_Marshal ¶
func (*Server) XXX_MessageName ¶
func (*Server) XXX_Unmarshal ¶
type Thresholds ¶
type Thresholds struct { LowerNormal int32 `protobuf:"varint,1,opt,name=lower_normal,json=lowerNormal,proto3" json:"lower_normal,omitempty"` UpperNormal int32 `protobuf:"varint,2,opt,name=upper_normal,json=upperNormal,proto3" json:"upper_normal,omitempty"` LowerHigh int32 `protobuf:"varint,3,opt,name=lower_high,json=lowerHigh,proto3" json:"lower_high,omitempty"` UpperHigh int32 `protobuf:"varint,4,opt,name=upper_high,json=upperHigh,proto3" json:"upper_high,omitempty"` LowerCritical int32 `protobuf:"varint,5,opt,name=lower_critical,json=lowerCritical,proto3" json:"lower_critical,omitempty"` UpperCritical int32 `protobuf:"varint,6,opt,name=upper_critical,json=upperCritical,proto3" json:"upper_critical,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Thresholds) Descriptor ¶
func (*Thresholds) Descriptor() ([]byte, []int)
func (*Thresholds) GetLowerCritical ¶
func (m *Thresholds) GetLowerCritical() int32
func (*Thresholds) GetLowerHigh ¶
func (m *Thresholds) GetLowerHigh() int32
func (*Thresholds) GetLowerNormal ¶
func (m *Thresholds) GetLowerNormal() int32
func (*Thresholds) GetUpperCritical ¶
func (m *Thresholds) GetUpperCritical() int32
func (*Thresholds) GetUpperHigh ¶
func (m *Thresholds) GetUpperHigh() int32
func (*Thresholds) GetUpperNormal ¶
func (m *Thresholds) GetUpperNormal() int32
func (*Thresholds) Marshal ¶
func (m *Thresholds) Marshal() (dAtA []byte, err error)
func (*Thresholds) MarshalToSizedBuffer ¶
func (m *Thresholds) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Thresholds) ProtoMessage ¶
func (*Thresholds) ProtoMessage()
func (*Thresholds) Reset ¶
func (m *Thresholds) Reset()
func (*Thresholds) Size ¶
func (m *Thresholds) Size() (n int)
func (*Thresholds) String ¶
func (m *Thresholds) String() string
func (*Thresholds) Unmarshal ¶
func (m *Thresholds) Unmarshal(dAtA []byte) error
func (*Thresholds) XXX_DiscardUnknown ¶
func (m *Thresholds) XXX_DiscardUnknown()
func (*Thresholds) XXX_Marshal ¶
func (m *Thresholds) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Thresholds) XXX_Merge ¶
func (m *Thresholds) XXX_Merge(src proto.Message)
func (*Thresholds) XXX_MessageName ¶
func (*Thresholds) XXX_MessageName() string
func (*Thresholds) XXX_Size ¶
func (m *Thresholds) XXX_Size() int
func (*Thresholds) XXX_Unmarshal ¶
func (m *Thresholds) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.