monitor

package
v0.0.0-...-b371d68 Latest Latest
Warning

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

 Go to latest Published: Jan 30, 2024 License: BSD-3-Clause Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LOCALHOST = "127.0.0.1"
	DEFSYS    = "netjawn"
)
View Source 
const (
	PHMT_HEARTBEATREQ = 2
)
View Source 
const (
	TIMEOUT = 5 * time.Second
)

Variables

View Source 
var (
	ErrInvalidLengthCompat        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCompat          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCompat = fmt.Errorf("proto: unexpected end of group")
)

Functions

func Run 

func Run(pdb *kibitz.DB)

Types

type ACP1HeartBeat 

type ACP1HeartBeat struct {
	StatusCode           int32    `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	StatusMessage        string   `protobuf:"bytes,2,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	Ipv4                 uint32   `protobuf:"fixed32,3,opt,name=ipv4,proto3" json:"ipv4,omitempty"`
	Port                 int32    `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	Timestamp            uint64   `protobuf:"fixed64,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Subsystem            string   `protobuf:"bytes,6,opt,name=subsystem,proto3" json:"subsystem,omitempty"`
	Environment          string   `protobuf:"bytes,7,opt,name=environment,proto3" json:"environment,omitempty"`
	SortMetric           int32    `protobuf:"varint,8,opt,name=sort_metric,json=sortMetric,proto3" json:"sort_metric,omitempty"`
	Hostname             string   `protobuf:"bytes,9,opt,name=hostname,proto3" json:"hostname,omitempty"`
	ServerId             string   `protobuf:"bytes,10,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	ProcessId            int32    `protobuf:"varint,11,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	CapacityMetric       int32    `protobuf:"varint,12,opt,name=capacity_metric,json=capacityMetric,proto3" json:"capacity_metric,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ACP1HeartBeat) Descriptor 

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

func (*ACP1HeartBeat) GetCapacityMetric 

func (m *ACP1HeartBeat) GetCapacityMetric() int32

func (*ACP1HeartBeat) GetEnvironment 

func (m *ACP1HeartBeat) GetEnvironment() string

func (*ACP1HeartBeat) GetHostname 

func (m *ACP1HeartBeat) GetHostname() string

func (*ACP1HeartBeat) GetIpv4 

func (m *ACP1HeartBeat) GetIpv4() uint32

func (*ACP1HeartBeat) GetPort 

func (m *ACP1HeartBeat) GetPort() int32

func (*ACP1HeartBeat) GetProcessId 

func (m *ACP1HeartBeat) GetProcessId() int32

func (*ACP1HeartBeat) GetServerId 

func (m *ACP1HeartBeat) GetServerId() string

func (*ACP1HeartBeat) GetSortMetric 

func (m *ACP1HeartBeat) GetSortMetric() int32

func (*ACP1HeartBeat) GetStatusCode 

func (m *ACP1HeartBeat) GetStatusCode() int32

func (*ACP1HeartBeat) GetStatusMessage 

func (m *ACP1HeartBeat) GetStatusMessage() string

func (*ACP1HeartBeat) GetSubsystem 

func (m *ACP1HeartBeat) GetSubsystem() string

func (*ACP1HeartBeat) GetTimestamp 

func (m *ACP1HeartBeat) GetTimestamp() uint64

func (*ACP1HeartBeat) Marshal 

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

func (*ACP1HeartBeat) MarshalTo 

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

func (*ACP1HeartBeat) MarshalToSizedBuffer 

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

func (*ACP1HeartBeat) ProtoMessage 

func (*ACP1HeartBeat) ProtoMessage()

func (*ACP1HeartBeat) Reset 

func (m *ACP1HeartBeat) Reset()

func (*ACP1HeartBeat) Size 

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

func (*ACP1HeartBeat) String 

func (m *ACP1HeartBeat) String() string

func (*ACP1HeartBeat) Unmarshal 

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

func (*ACP1HeartBeat) XXX_DiscardUnknown 

func (m *ACP1HeartBeat) XXX_DiscardUnknown()

func (*ACP1HeartBeat) XXX_Marshal 

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

func (*ACP1HeartBeat) XXX_Merge 

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

func (*ACP1HeartBeat) XXX_Size 

func (m *ACP1HeartBeat) XXX_Size() int

func (*ACP1HeartBeat) XXX_Unmarshal 

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

type ACP1HeartBeatReply 

type ACP1HeartBeatReply struct {
	StatusCode           int32            `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	StatusMessage        string           `protobuf:"bytes,2,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	Hbinfo               []*ACP1HeartBeat `protobuf:"bytes,3,rep,name=hbinfo,proto3" json:"hbinfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ACP1HeartBeatReply) Descriptor 

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

func (*ACP1HeartBeatReply) GetHbinfo 

func (m *ACP1HeartBeatReply) GetHbinfo() []*ACP1HeartBeat

func (*ACP1HeartBeatReply) GetStatusCode 

func (m *ACP1HeartBeatReply) GetStatusCode() int32

func (*ACP1HeartBeatReply) GetStatusMessage 

func (m *ACP1HeartBeatReply) GetStatusMessage() string

func (*ACP1HeartBeatReply) Marshal 

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

func (*ACP1HeartBeatReply) MarshalTo 

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

func (*ACP1HeartBeatReply) MarshalToSizedBuffer 

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

func (*ACP1HeartBeatReply) ProtoMessage 

func (*ACP1HeartBeatReply) ProtoMessage()

func (*ACP1HeartBeatReply) Reset 

func (m *ACP1HeartBeatReply) Reset()

func (*ACP1HeartBeatReply) Size 

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

func (*ACP1HeartBeatReply) String 

func (m *ACP1HeartBeatReply) String() string

func (*ACP1HeartBeatReply) Unmarshal 

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

func (*ACP1HeartBeatReply) XXX_DiscardUnknown 

func (m *ACP1HeartBeatReply) XXX_DiscardUnknown()

func (*ACP1HeartBeatReply) XXX_Marshal 

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

func (*ACP1HeartBeatReply) XXX_Merge 

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

func (*ACP1HeartBeatReply) XXX_Size 

func (m *ACP1HeartBeatReply) XXX_Size() int

func (*ACP1HeartBeatReply) XXX_Unmarshal 

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

type ACP1HeartBeatRequest 

type ACP1HeartBeatRequest struct {
	Myself               *ACP1HeartBeat `protobuf:"bytes,1,opt,name=myself,proto3" json:"myself,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ACP1HeartBeatRequest) Descriptor 

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

func (*ACP1HeartBeatRequest) GetMyself 

func (m *ACP1HeartBeatRequest) GetMyself() *ACP1HeartBeat

func (*ACP1HeartBeatRequest) Marshal 

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

func (*ACP1HeartBeatRequest) MarshalTo 

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

func (*ACP1HeartBeatRequest) MarshalToSizedBuffer 

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

func (*ACP1HeartBeatRequest) ProtoMessage 

func (*ACP1HeartBeatRequest) ProtoMessage()

func (*ACP1HeartBeatRequest) Reset 

func (m *ACP1HeartBeatRequest) Reset()

func (*ACP1HeartBeatRequest) Size 

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

func (*ACP1HeartBeatRequest) String 

func (m *ACP1HeartBeatRequest) String() string

func (*ACP1HeartBeatRequest) Unmarshal 

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

func (*ACP1HeartBeatRequest) XXX_DiscardUnknown 

func (m *ACP1HeartBeatRequest) XXX_DiscardUnknown()

func (*ACP1HeartBeatRequest) XXX_Marshal 

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

func (*ACP1HeartBeatRequest) XXX_Merge 

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

func (*ACP1HeartBeatRequest) XXX_Size 

func (m *ACP1HeartBeatRequest) XXX_Size() int

func (*ACP1HeartBeatRequest) XXX_Unmarshal 

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