api

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Jun 18, 2022 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_api_api_proto protoreflect.FileDescriptor

Functions

func RegisterMonitorDataServiceServer 

func RegisterMonitorDataServiceServer(s *grpc.Server, srv MonitorDataServiceServer)

Types

type Agents 

type Agents struct {
	AgentIDs []string
}

type CustomMetrics 

type CustomMetrics struct {
	CustomMetrics []string
}

type IsActive added in v1.1.1 

type IsActive struct {
	IsUp bool `protobuf:"varint,1,opt,name=isUp,proto3" json:"isUp,omitempty"`
	// contains filtered or unexported fields
}

func (*IsActive) Descriptor deprecated added in v1.1.1 

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

Deprecated: Use IsActive.ProtoReflect.Descriptor instead.

func (*IsActive) GetIsUp added in v1.1.1 

func (x *IsActive) GetIsUp() bool

func (*IsActive) ProtoMessage added in v1.1.1 

func (*IsActive) ProtoMessage()

func (*IsActive) ProtoReflect added in v1.1.1 

func (x *IsActive) ProtoReflect() protoreflect.Message

func (*IsActive) Reset added in v1.1.1 

func (x *IsActive) Reset()

func (*IsActive) String added in v1.1.1 

func (x *IsActive) String() string

type Message 

type Message struct {
	Body string `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetBody 

func (x *Message) GetBody() string

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type MonitorData 

type MonitorData struct {
	MonitorData string `protobuf:"bytes,1,opt,name=monitorData,proto3" json:"monitorData,omitempty"`
	// contains filtered or unexported fields
}

func (*MonitorData) Descriptor deprecated 

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

Deprecated: Use MonitorData.ProtoReflect.Descriptor instead.

func (*MonitorData) GetMonitorData 

func (x *MonitorData) GetMonitorData() string

func (*MonitorData) ProtoMessage 

func (*MonitorData) ProtoMessage()

func (*MonitorData) ProtoReflect 

func (x *MonitorData) ProtoReflect() protoreflect.Message

func (*MonitorData) Reset 

func (x *MonitorData) Reset()

func (*MonitorData) String 

func (x *MonitorData) String() string

type MonitorDataRequest 

type MonitorDataRequest struct {
	ServerName string `protobuf:"bytes,1,opt,name=serverName,proto3" json:"serverName,omitempty"`
	LogType    string `protobuf:"bytes,2,opt,name=logType,proto3" json:"logType,omitempty"`
	From       int64  `protobuf:"varint,3,opt,name=from,proto3" json:"from,omitempty"`
	To         int64  `protobuf:"varint,4,opt,name=to,proto3" json:"to,omitempty"`
	Time       int64  `protobuf:"varint,5,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*MonitorDataRequest) Descriptor deprecated 

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

Deprecated: Use MonitorDataRequest.ProtoReflect.Descriptor instead.

func (*MonitorDataRequest) GetFrom 

func (x *MonitorDataRequest) GetFrom() int64

func (*MonitorDataRequest) GetLogType 

func (x *MonitorDataRequest) GetLogType() string

func (*MonitorDataRequest) GetServerName 

func (x *MonitorDataRequest) GetServerName() string

func (*MonitorDataRequest) GetTime 

func (x *MonitorDataRequest) GetTime() int64

func (*MonitorDataRequest) GetTo 

func (x *MonitorDataRequest) GetTo() int64

func (*MonitorDataRequest) ProtoMessage 

func (*MonitorDataRequest) ProtoMessage()

func (*MonitorDataRequest) ProtoReflect 

func (x *MonitorDataRequest) ProtoReflect() protoreflect.Message

func (*MonitorDataRequest) Reset 

func (x *MonitorDataRequest) Reset()

func (*MonitorDataRequest) String 

func (x *MonitorDataRequest) String() string

type MonitorDataServiceClient 

type MonitorDataServiceClient interface {
	HandlePing(ctx context.Context, in *ServerInfo, opts ...grpc.CallOption) (*Message, error)
	IsUp(ctx context.Context, in *ServerInfo, opts ...grpc.CallOption) (*IsActive, error)
	InitAgent(ctx context.Context, in *ServerInfo, opts ...grpc.CallOption) (*Message, error)
	HandleMonitorData(ctx context.Context, in *MonitorData, opts ...grpc.CallOption) (*Message, error)
	HandleCustomMonitorData(ctx context.Context, in *MonitorData, opts ...grpc.CallOption) (*Message, error)
	HandleMonitorDataRequest(ctx context.Context, in *MonitorDataRequest, opts ...grpc.CallOption) (*MonitorData, error)
	HandleCustomMetricNameRequest(ctx context.Context, in *ServerInfo, opts ...grpc.CallOption) (*Message, error)
	HandleAgentIdsRequest(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Message, error)
}

MonitorDataServiceClient is the client API for MonitorDataService service.

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

func NewMonitorDataServiceClient 

func NewMonitorDataServiceClient(cc grpc.ClientConnInterface) MonitorDataServiceClient

type MonitorDataServiceServer 

type MonitorDataServiceServer interface {
	HandlePing(context.Context, *ServerInfo) (*Message, error)
	IsUp(context.Context, *ServerInfo) (*IsActive, error)
	InitAgent(context.Context, *ServerInfo) (*Message, error)
	HandleMonitorData(context.Context, *MonitorData) (*Message, error)
	HandleCustomMonitorData(context.Context, *MonitorData) (*Message, error)
	HandleMonitorDataRequest(context.Context, *MonitorDataRequest) (*MonitorData, error)
	HandleCustomMetricNameRequest(context.Context, *ServerInfo) (*Message, error)
	HandleAgentIdsRequest(context.Context, *Void) (*Message, error)
}

MonitorDataServiceServer is the server API for MonitorDataService service.

type Server 

type Server struct {
}

func (*Server) HandleAgentIdsRequest 

func (s *Server) HandleAgentIdsRequest(context.Context, *Void) (*Message, error)

func (*Server) HandleCustomMetricNameRequest 

func (s *Server) HandleCustomMetricNameRequest(ctx context.Context, in *ServerInfo) (*Message, error)

func (*Server) HandleCustomMonitorData 

func (s *Server) HandleCustomMonitorData(ctx context.Context, in *MonitorData) (*Message, error)

func (*Server) HandleMonitorData 

func (s *Server) HandleMonitorData(ctx context.Context, in *MonitorData) (*Message, error)

func (*Server) HandleMonitorDataRequest 

func (s *Server) HandleMonitorDataRequest(ctx context.Context, in *MonitorDataRequest) (*MonitorData, error)

func (*Server) HandlePing added in v1.1.1 

func (s *Server) HandlePing(ctx context.Context, in *ServerInfo) (*Message, error)

func (*Server) InitAgent 

func (s *Server) InitAgent(ctx context.Context, in *ServerInfo) (*Message, error)

func (*Server) IsUp added in v1.1.1 

func (s *Server) IsUp(ctx context.Context, in *ServerInfo) (*IsActive, error)

type ServerInfo 

type ServerInfo struct {
	ServerName string `protobuf:"bytes,1,opt,name=serverName,proto3" json:"serverName,omitempty"`
	Timezone   string `protobuf:"bytes,2,opt,name=timezone,proto3" json:"timezone,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerInfo) Descriptor deprecated 

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

Deprecated: Use ServerInfo.ProtoReflect.Descriptor instead.

func (*ServerInfo) GetServerName 

func (x *ServerInfo) GetServerName() string

func (*ServerInfo) GetTimezone 

func (x *ServerInfo) GetTimezone() string

func (*ServerInfo) ProtoMessage 

func (*ServerInfo) ProtoMessage()

func (*ServerInfo) ProtoReflect 

func (x *ServerInfo) ProtoReflect() protoreflect.Message

func (*ServerInfo) Reset 

func (x *ServerInfo) Reset()

func (*ServerInfo) String 

func (x *ServerInfo) String() string

type UnimplementedMonitorDataServiceServer 

type UnimplementedMonitorDataServiceServer struct {
}

UnimplementedMonitorDataServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMonitorDataServiceServer) HandleAgentIdsRequest 

func (*UnimplementedMonitorDataServiceServer) HandleAgentIdsRequest(context.Context, *Void) (*Message, error)

func (*UnimplementedMonitorDataServiceServer) HandleCustomMetricNameRequest 

func (*UnimplementedMonitorDataServiceServer) HandleCustomMetricNameRequest(context.Context, *ServerInfo) (*Message, error)

func (*UnimplementedMonitorDataServiceServer) HandleCustomMonitorData 

func (*UnimplementedMonitorDataServiceServer) HandleCustomMonitorData(context.Context, *MonitorData) (*Message, error)

func (*UnimplementedMonitorDataServiceServer) HandleMonitorData 

func (*UnimplementedMonitorDataServiceServer) HandleMonitorData(context.Context, *MonitorData) (*Message, error)

func (*UnimplementedMonitorDataServiceServer) HandleMonitorDataRequest 

func (*UnimplementedMonitorDataServiceServer) HandleMonitorDataRequest(context.Context, *MonitorDataRequest) (*MonitorData, error)

func (*UnimplementedMonitorDataServiceServer) HandlePing added in v1.1.1 

func (*UnimplementedMonitorDataServiceServer) HandlePing(context.Context, *ServerInfo) (*Message, error)

func (*UnimplementedMonitorDataServiceServer) InitAgent 

func (*UnimplementedMonitorDataServiceServer) InitAgent(context.Context, *ServerInfo) (*Message, error)

func (*UnimplementedMonitorDataServiceServer) IsUp added in v1.1.1 

func (*UnimplementedMonitorDataServiceServer) IsUp(context.Context, *ServerInfo) (*IsActive, error)

type Void 

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

func (*Void) Descriptor deprecated 

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

Deprecated: Use Void.ProtoReflect.Descriptor instead.

func (*Void) ProtoMessage 

func (*Void) ProtoMessage()

func (*Void) ProtoReflect 

func (x *Void) ProtoReflect() protoreflect.Message

func (*Void) Reset 

func (x *Void) Reset()

func (*Void) String 

func (x *Void) String() string

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.