Documentation ¶
Index ¶
- Variables
- func RegisterAgentServerServer(s grpc.ServiceRegistrar, srv AgentServerServer)
- func RegisterApplicationMonitoringServer(s grpc.ServiceRegistrar, srv ApplicationMonitoringServer)
- func RegisterCacheServer(s grpc.ServiceRegistrar, srv CacheServer)
- func RegisterIncidentServerServer(s grpc.ServiceRegistrar, srv IncidentServerServer)
- func RegisterNotificationManagerServer(s grpc.ServiceRegistrar, srv NotificationManagerServer)
- func RegisterSchedulersExecutorServer(s grpc.ServiceRegistrar, srv SchedulersExecutorServer)
- func RegisterStorageServer(s grpc.ServiceRegistrar, srv StorageServer)
- type AddRequest
- func (*AddRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddRequest) GetCassandra() *DbConfig
- func (m *AddRequest) GetConfig() isAddRequest_Config
- func (x *AddRequest) GetGrpc() *GrpcConfig
- func (x *AddRequest) GetHttp() *HttpConfig
- func (x *AddRequest) GetHttpValue() *HttpJsonValueConfig
- func (x *AddRequest) GetInterval() int32
- func (x *AddRequest) GetMongo() *DbConfig
- func (x *AddRequest) GetMysql() *DbConfig
- func (x *AddRequest) GetName() string
- func (x *AddRequest) GetPostgres() *DbConfig
- func (x *AddRequest) GetSitemap() *SiteMapConfig
- func (x *AddRequest) GetSslExpiration() *SslExpirationConfig
- func (x *AddRequest) GetTcp() *TcpConfig
- func (x *AddRequest) GetTimeout() int32
- func (*AddRequest) ProtoMessage()
- func (x *AddRequest) ProtoReflect() protoreflect.Message
- func (x *AddRequest) Reset()
- func (x *AddRequest) String() string
- type AddRequest_Cassandra
- type AddRequest_Grpc
- type AddRequest_Http
- type AddRequest_HttpValue
- type AddRequest_Mongo
- type AddRequest_Mysql
- type AddRequest_Postgres
- type AddRequest_Sitemap
- type AddRequest_SslExpiration
- type AddRequest_Tcp
- type AddResponse
- type AgentIdRequest
- type AgentItem
- func (*AgentItem) Descriptor() ([]byte, []int)deprecated
- func (x *AgentItem) GetAgentName() string
- func (x *AgentItem) GetHostInfo() *HostInfo
- func (x *AgentItem) GetId() string
- func (x *AgentItem) GetInterval() int64
- func (x *AgentItem) GetStatus() AgentStatus
- func (*AgentItem) ProtoMessage()
- func (x *AgentItem) ProtoReflect() protoreflect.Message
- func (x *AgentItem) Reset()
- func (x *AgentItem) String() string
- type AgentServerClient
- type AgentServerServer
- type AgentServer_SendMetricsClient
- type AgentServer_SendMetricsServer
- type AgentStatus
- func (AgentStatus) Descriptor() protoreflect.EnumDescriptor
- func (x AgentStatus) Enum() *AgentStatus
- func (AgentStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x AgentStatus) Number() protoreflect.EnumNumber
- func (x AgentStatus) String() string
- func (AgentStatus) Type() protoreflect.EnumType
- type Application
- func (*Application) Descriptor() ([]byte, []int)deprecated
- func (x *Application) GetHostName() string
- func (x *Application) GetId() string
- func (x *Application) GetName() string
- func (x *Application) GetStatus() ApplicationStatus
- func (*Application) ProtoMessage()
- func (x *Application) ProtoReflect() protoreflect.Message
- func (x *Application) Reset()
- func (x *Application) String() string
- type ApplicationByIdReuqest
- func (*ApplicationByIdReuqest) Descriptor() ([]byte, []int)deprecated
- func (x *ApplicationByIdReuqest) GetApplicationId() string
- func (*ApplicationByIdReuqest) ProtoMessage()
- func (x *ApplicationByIdReuqest) ProtoReflect() protoreflect.Message
- func (x *ApplicationByIdReuqest) Reset()
- func (x *ApplicationByIdReuqest) String() string
- type ApplicationInfo
- func (*ApplicationInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ApplicationInfo) GetAgentId() string
- func (x *ApplicationInfo) GetHostName() string
- func (x *ApplicationInfo) GetName() string
- func (*ApplicationInfo) ProtoMessage()
- func (x *ApplicationInfo) ProtoReflect() protoreflect.Message
- func (x *ApplicationInfo) Reset()
- func (x *ApplicationInfo) String() string
- type ApplicationMonitoringClient
- type ApplicationMonitoringServer
- type ApplicationStatus
- func (ApplicationStatus) Descriptor() protoreflect.EnumDescriptor
- func (x ApplicationStatus) Enum() *ApplicationStatus
- func (ApplicationStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x ApplicationStatus) Number() protoreflect.EnumNumber
- func (x ApplicationStatus) String() string
- func (ApplicationStatus) Type() protoreflect.EnumType
- type CacheClient
- type CacheServer
- type ComponentOwnerType
- func (ComponentOwnerType) Descriptor() protoreflect.EnumDescriptor
- func (x ComponentOwnerType) Enum() *ComponentOwnerType
- func (ComponentOwnerType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ComponentOwnerType) Number() protoreflect.EnumNumber
- func (x ComponentOwnerType) String() string
- func (ComponentOwnerType) Type() protoreflect.EnumType
- type CpuInfo
- type CpuInfo_CPU
- type CreateNotificationMethodRequest
- func (*CreateNotificationMethodRequest) Descriptor() ([]byte, []int)deprecated
- func (m *CreateNotificationMethodRequest) GetMethod() isCreateNotificationMethodRequest_Method
- func (x *CreateNotificationMethodRequest) GetName() string
- func (x *CreateNotificationMethodRequest) GetSlack() *SlackMethod
- func (x *CreateNotificationMethodRequest) GetType() NotificationMethodType
- func (x *CreateNotificationMethodRequest) GetWebhook() *WebHookMethod
- func (*CreateNotificationMethodRequest) ProtoMessage()
- func (x *CreateNotificationMethodRequest) ProtoReflect() protoreflect.Message
- func (x *CreateNotificationMethodRequest) Reset()
- func (x *CreateNotificationMethodRequest) String() string
- type CreateNotificationMethodRequest_Slack
- type CreateNotificationMethodRequest_Webhook
- type CreateRuleRequest
- func (*CreateRuleRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateRuleRequest) GetAutoClose() bool
- func (x *CreateRuleRequest) GetName() string
- func (x *CreateRuleRequest) GetNotification() bool
- func (x *CreateRuleRequest) GetOwnerId() string
- func (x *CreateRuleRequest) GetOwnerType() ComponentOwnerType
- func (x *CreateRuleRequest) GetRule() string
- func (*CreateRuleRequest) ProtoMessage()
- func (x *CreateRuleRequest) ProtoReflect() protoreflect.Message
- func (x *CreateRuleRequest) Reset()
- func (x *CreateRuleRequest) String() string
- type DbConfig
- func (*DbConfig) Descriptor() ([]byte, []int)deprecated
- func (x *DbConfig) GetCluster() string
- func (x *DbConfig) GetDbName() string
- func (x *DbConfig) GetHost() string
- func (x *DbConfig) GetPassword() string
- func (x *DbConfig) GetPort() int32
- func (x *DbConfig) GetUser() string
- func (*DbConfig) ProtoMessage()
- func (x *DbConfig) ProtoReflect() protoreflect.Message
- func (x *DbConfig) Reset()
- func (x *DbConfig) String() string
- type DeleteScheduleWithIdRequest
- func (*DeleteScheduleWithIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteScheduleWithIdRequest) GetId() string
- func (*DeleteScheduleWithIdRequest) ProtoMessage()
- func (x *DeleteScheduleWithIdRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteScheduleWithIdRequest) Reset()
- func (x *DeleteScheduleWithIdRequest) String() string
- type DiskInfo
- type DiskInfo_Disk
- func (*DiskInfo_Disk) Descriptor() ([]byte, []int)deprecated
- func (x *DiskInfo_Disk) GetFree() uint64
- func (x *DiskInfo_Disk) GetTotal() uint64
- func (x *DiskInfo_Disk) GetUsed() uint64
- func (x *DiskInfo_Disk) GetUsedPercent() float64
- func (*DiskInfo_Disk) ProtoMessage()
- func (x *DiskInfo_Disk) ProtoReflect() protoreflect.Message
- func (x *DiskInfo_Disk) Reset()
- func (x *DiskInfo_Disk) String() string
- type GetAgentByIdRequest
- func (*GetAgentByIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetAgentByIdRequest) GetAgentId() string
- func (*GetAgentByIdRequest) ProtoMessage()
- func (x *GetAgentByIdRequest) ProtoReflect() protoreflect.Message
- func (x *GetAgentByIdRequest) Reset()
- func (x *GetAgentByIdRequest) String() string
- type GetAgentInformationRequest
- func (*GetAgentInformationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetAgentInformationRequest) GetAgentId() string
- func (x *GetAgentInformationRequest) GetPagination() *Pagination
- func (x *GetAgentInformationRequest) GetTimeRange() *TimeFilter
- func (x *GetAgentInformationRequest) GetType() TypeAgentStat
- func (*GetAgentInformationRequest) ProtoMessage()
- func (x *GetAgentInformationRequest) ProtoReflect() protoreflect.Message
- func (x *GetAgentInformationRequest) Reset()
- func (x *GetAgentInformationRequest) String() string
- type GetAgentInformationResponse
- func (*GetAgentInformationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetAgentInformationResponse) GetCount() int32
- func (x *GetAgentInformationResponse) GetStats() []*GetAgentInformationResponse_Statistic
- func (*GetAgentInformationResponse) ProtoMessage()
- func (x *GetAgentInformationResponse) ProtoReflect() protoreflect.Message
- func (x *GetAgentInformationResponse) Reset()
- func (x *GetAgentInformationResponse) String() string
- type GetAgentInformationResponse_Statistic
- func (*GetAgentInformationResponse_Statistic) Descriptor() ([]byte, []int)deprecated
- func (x *GetAgentInformationResponse_Statistic) GetCpuInfo() *CpuInfo
- func (x *GetAgentInformationResponse_Statistic) GetDiskInfo() *DiskInfo
- func (x *GetAgentInformationResponse_Statistic) GetMemoryInfo() *MemoryInfo
- func (x *GetAgentInformationResponse_Statistic) GetNetInfo() *NetInfo
- func (x *GetAgentInformationResponse_Statistic) GetTime() *timestamppb.Timestamp
- func (*GetAgentInformationResponse_Statistic) ProtoMessage()
- func (x *GetAgentInformationResponse_Statistic) ProtoReflect() protoreflect.Message
- func (x *GetAgentInformationResponse_Statistic) Reset()
- func (x *GetAgentInformationResponse_Statistic) String() string
- type GetAgentListResponse
- func (*GetAgentListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetAgentListResponse) GetAgents() []*AgentItem
- func (*GetAgentListResponse) ProtoMessage()
- func (x *GetAgentListResponse) ProtoReflect() protoreflect.Message
- func (x *GetAgentListResponse) Reset()
- func (x *GetAgentListResponse) String() string
- type GetApplicationListResponse
- func (*GetApplicationListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetApplicationListResponse) GetApplications() []*Application
- func (*GetApplicationListResponse) ProtoMessage()
- func (x *GetApplicationListResponse) ProtoReflect() protoreflect.Message
- func (x *GetApplicationListResponse) Reset()
- func (x *GetApplicationListResponse) String() string
- type GetByAgentNameRequest
- func (*GetByAgentNameRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetByAgentNameRequest) GetAgentName() string
- func (*GetByAgentNameRequest) ProtoMessage()
- func (x *GetByAgentNameRequest) ProtoReflect() protoreflect.Message
- func (x *GetByAgentNameRequest) Reset()
- func (x *GetByAgentNameRequest) String() string
- type GetIncidentsListRequest
- func (*GetIncidentsListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetIncidentsListRequest) GetPagination() *Pagination
- func (x *GetIncidentsListRequest) GetRuleId() *wrapperspb.StringValue
- func (x *GetIncidentsListRequest) GetSort() *SortingIncidentList
- func (x *GetIncidentsListRequest) GetStatus() IncidentStatus
- func (x *GetIncidentsListRequest) GetTimeRange() *TimeFilter
- func (*GetIncidentsListRequest) ProtoMessage()
- func (x *GetIncidentsListRequest) ProtoReflect() protoreflect.Message
- func (x *GetIncidentsListRequest) Reset()
- func (x *GetIncidentsListRequest) String() string
- type GetIncidentsListResponse
- func (*GetIncidentsListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetIncidentsListResponse) GetCount() int64
- func (x *GetIncidentsListResponse) GetIncidents() []*Incident
- func (*GetIncidentsListResponse) ProtoMessage()
- func (x *GetIncidentsListResponse) ProtoReflect() protoreflect.Message
- func (x *GetIncidentsListResponse) Reset()
- func (x *GetIncidentsListResponse) String() string
- type GetListRequest
- func (*GetListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetListRequest) GetOwnerId() string
- func (x *GetListRequest) GetOwnerType() ComponentOwnerType
- func (*GetListRequest) ProtoMessage()
- func (x *GetListRequest) ProtoReflect() protoreflect.Message
- func (x *GetListRequest) Reset()
- func (x *GetListRequest) String() string
- type GetListResponse
- func (*GetListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetListResponse) GetMethods() []*NotificationMethod
- func (*GetListResponse) ProtoMessage()
- func (x *GetListResponse) ProtoReflect() protoreflect.Message
- func (x *GetListResponse) Reset()
- func (x *GetListResponse) String() string
- type GetRulesByOwnerIdRequest
- func (*GetRulesByOwnerIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetRulesByOwnerIdRequest) GetOwnerId() string
- func (x *GetRulesByOwnerIdRequest) GetOwnerType() ComponentOwnerType
- func (*GetRulesByOwnerIdRequest) ProtoMessage()
- func (x *GetRulesByOwnerIdRequest) ProtoReflect() protoreflect.Message
- func (x *GetRulesByOwnerIdRequest) Reset()
- func (x *GetRulesByOwnerIdRequest) String() string
- type GetScheduleWithIdRequest
- func (*GetScheduleWithIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetScheduleWithIdRequest) GetId() string
- func (*GetScheduleWithIdRequest) ProtoMessage()
- func (x *GetScheduleWithIdRequest) ProtoReflect() protoreflect.Message
- func (x *GetScheduleWithIdRequest) Reset()
- func (x *GetScheduleWithIdRequest) String() string
- type GetScheduleWithIdResponse
- func (*GetScheduleWithIdResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetScheduleWithIdResponse) GetScheduledNext() *timestamppb.Timestamp
- func (*GetScheduleWithIdResponse) ProtoMessage()
- func (x *GetScheduleWithIdResponse) ProtoReflect() protoreflect.Message
- func (x *GetScheduleWithIdResponse) Reset()
- func (x *GetScheduleWithIdResponse) String() string
- type GetSchedulerByIdRequest
- func (*GetSchedulerByIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchedulerByIdRequest) GetId() string
- func (*GetSchedulerByIdRequest) ProtoMessage()
- func (x *GetSchedulerByIdRequest) ProtoReflect() protoreflect.Message
- func (x *GetSchedulerByIdRequest) Reset()
- func (x *GetSchedulerByIdRequest) String() string
- type GetSchedulerInformationRequest
- func (*GetSchedulerInformationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchedulerInformationRequest) GetPagination() *Pagination
- func (x *GetSchedulerInformationRequest) GetSchedulerId() string
- func (x *GetSchedulerInformationRequest) GetSort() *SortingSchedulerList
- func (x *GetSchedulerInformationRequest) GetStatus() SchedulerCode
- func (x *GetSchedulerInformationRequest) GetTimeRange() *TimeFilter
- func (*GetSchedulerInformationRequest) ProtoMessage()
- func (x *GetSchedulerInformationRequest) ProtoReflect() protoreflect.Message
- func (x *GetSchedulerInformationRequest) Reset()
- func (x *GetSchedulerInformationRequest) String() string
- type GetSchedulerInformationResponse
- func (*GetSchedulerInformationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchedulerInformationResponse) GetCount() int32
- func (x *GetSchedulerInformationResponse) GetSnapshots() []*SchedulerSnapshot
- func (*GetSchedulerInformationResponse) ProtoMessage()
- func (x *GetSchedulerInformationResponse) ProtoReflect() protoreflect.Message
- func (x *GetSchedulerInformationResponse) Reset()
- func (x *GetSchedulerInformationResponse) String() string
- type GetSchedulerListResponse
- func (*GetSchedulerListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchedulerListResponse) GetLists() []*Scheduler
- func (*GetSchedulerListResponse) ProtoMessage()
- func (x *GetSchedulerListResponse) ProtoReflect() protoreflect.Message
- func (x *GetSchedulerListResponse) Reset()
- func (x *GetSchedulerListResponse) String() string
- type GetSchedulerUptimeRequest
- func (*GetSchedulerUptimeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchedulerUptimeRequest) GetSchedulerId() string
- func (x *GetSchedulerUptimeRequest) GetTimeRange() *TimeFilter
- func (*GetSchedulerUptimeRequest) ProtoMessage()
- func (x *GetSchedulerUptimeRequest) ProtoReflect() protoreflect.Message
- func (x *GetSchedulerUptimeRequest) Reset()
- func (x *GetSchedulerUptimeRequest) String() string
- type GetSchedulerUptimeResponse
- func (*GetSchedulerUptimeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchedulerUptimeResponse) GetLatency() float64
- func (x *GetSchedulerUptimeResponse) GetUptime() float64
- func (*GetSchedulerUptimeResponse) ProtoMessage()
- func (x *GetSchedulerUptimeResponse) ProtoReflect() protoreflect.Message
- func (x *GetSchedulerUptimeResponse) Reset()
- func (x *GetSchedulerUptimeResponse) String() string
- type GetTransactionByIdRequest
- func (*GetTransactionByIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTransactionByIdRequest) GetTransactionId() string
- func (*GetTransactionByIdRequest) ProtoMessage()
- func (x *GetTransactionByIdRequest) ProtoReflect() protoreflect.Message
- func (x *GetTransactionByIdRequest) Reset()
- func (x *GetTransactionByIdRequest) String() string
- type GetTransactionByIdResponse
- func (*GetTransactionByIdResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTransactionByIdResponse) GetChildren() []*TransactionInfo
- func (x *GetTransactionByIdResponse) GetTransaction() *TransactionInfo
- func (*GetTransactionByIdResponse) ProtoMessage()
- func (x *GetTransactionByIdResponse) ProtoReflect() protoreflect.Message
- func (x *GetTransactionByIdResponse) Reset()
- func (x *GetTransactionByIdResponse) String() string
- type GetTransactionByNameRequest
- func (*GetTransactionByNameRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTransactionByNameRequest) GetApplicationId() string
- func (x *GetTransactionByNameRequest) GetPagination() *Pagination
- func (x *GetTransactionByNameRequest) GetTimeRange() *TimeFilter
- func (x *GetTransactionByNameRequest) GetTransactionName() string
- func (*GetTransactionByNameRequest) ProtoMessage()
- func (x *GetTransactionByNameRequest) ProtoReflect() protoreflect.Message
- func (x *GetTransactionByNameRequest) Reset()
- func (x *GetTransactionByNameRequest) String() string
- type GetTransactionByNameResponse
- func (*GetTransactionByNameResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTransactionByNameResponse) GetCount() int64
- func (x *GetTransactionByNameResponse) GetTransactions() []*TransactionInfo
- func (*GetTransactionByNameResponse) ProtoMessage()
- func (x *GetTransactionByNameResponse) ProtoReflect() protoreflect.Message
- func (x *GetTransactionByNameResponse) Reset()
- func (x *GetTransactionByNameResponse) String() string
- type GetTransactionGroupRequest
- func (*GetTransactionGroupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTransactionGroupRequest) GetApplicationId() string
- func (x *GetTransactionGroupRequest) GetGroupType() GroupTransaction
- func (x *GetTransactionGroupRequest) GetStatus() TransactionStatus
- func (x *GetTransactionGroupRequest) GetTimeRange() *TimeFilter
- func (x *GetTransactionGroupRequest) GetType() TransactionType
- func (*GetTransactionGroupRequest) ProtoMessage()
- func (x *GetTransactionGroupRequest) ProtoReflect() protoreflect.Message
- func (x *GetTransactionGroupRequest) Reset()
- func (x *GetTransactionGroupRequest) String() string
- type GetTransactionGroupResponse
- func (*GetTransactionGroupResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTransactionGroupResponse) GetTransactions() map[string]*TransactionGroup
- func (*GetTransactionGroupResponse) ProtoMessage()
- func (x *GetTransactionGroupResponse) ProtoReflect() protoreflect.Message
- func (x *GetTransactionGroupResponse) Reset()
- func (x *GetTransactionGroupResponse) String() string
- type GetTransactionsRequest
- func (*GetTransactionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTransactionsRequest) GetApplicationId() string
- func (x *GetTransactionsRequest) GetHost() *wrapperspb.StringValue
- func (x *GetTransactionsRequest) GetMethod() *wrapperspb.StringValue
- func (x *GetTransactionsRequest) GetName() *wrapperspb.StringValue
- func (x *GetTransactionsRequest) GetPagination() *Pagination
- func (x *GetTransactionsRequest) GetPath() *wrapperspb.StringValue
- func (x *GetTransactionsRequest) GetSort() *SortingTransactionList
- func (x *GetTransactionsRequest) GetStatus() TransactionStatus
- func (x *GetTransactionsRequest) GetTimeRange() *TimeFilter
- func (x *GetTransactionsRequest) GetType() TransactionType
- func (*GetTransactionsRequest) ProtoMessage()
- func (x *GetTransactionsRequest) ProtoReflect() protoreflect.Message
- func (x *GetTransactionsRequest) Reset()
- func (x *GetTransactionsRequest) String() string
- type GetTransactionsResponse
- func (*GetTransactionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTransactionsResponse) GetCount() int64
- func (x *GetTransactionsResponse) GetTransactions() []*TransactionInfo
- func (*GetTransactionsResponse) ProtoMessage()
- func (x *GetTransactionsResponse) ProtoReflect() protoreflect.Message
- func (x *GetTransactionsResponse) Reset()
- func (x *GetTransactionsResponse) String() string
- type GroupTransaction
- func (GroupTransaction) Descriptor() protoreflect.EnumDescriptor
- func (x GroupTransaction) Enum() *GroupTransaction
- func (GroupTransaction) EnumDescriptor() ([]byte, []int)deprecated
- func (x GroupTransaction) Number() protoreflect.EnumNumber
- func (x GroupTransaction) String() string
- func (GroupTransaction) Type() protoreflect.EnumType
- type GrpcConfig
- func (*GrpcConfig) Descriptor() ([]byte, []int)deprecated
- func (x *GrpcConfig) GetHost() string
- func (x *GrpcConfig) GetPort() int32
- func (x *GrpcConfig) GetService() string
- func (*GrpcConfig) ProtoMessage()
- func (x *GrpcConfig) ProtoReflect() protoreflect.Message
- func (x *GrpcConfig) Reset()
- func (x *GrpcConfig) String() string
- type HostInfo
- func (*HostInfo) Descriptor() ([]byte, []int)deprecated
- func (x *HostInfo) GetHostName() string
- func (x *HostInfo) GetOs() string
- func (x *HostInfo) GetPlatformInfo() *PlatformInfo
- func (*HostInfo) ProtoMessage()
- func (x *HostInfo) ProtoReflect() protoreflect.Message
- func (x *HostInfo) Reset()
- func (x *HostInfo) String() string
- type HttpConfig
- func (*HttpConfig) Descriptor() ([]byte, []int)deprecated
- func (x *HttpConfig) GetHeaders() map[string]string
- func (x *HttpConfig) GetMethod() string
- func (x *HttpConfig) GetStatusCode() int32
- func (x *HttpConfig) GetUrl() string
- func (*HttpConfig) ProtoMessage()
- func (x *HttpConfig) ProtoReflect() protoreflect.Message
- func (x *HttpConfig) Reset()
- func (x *HttpConfig) String() string
- type HttpJsonValueConfig
- func (*HttpJsonValueConfig) Descriptor() ([]byte, []int)deprecated
- func (x *HttpJsonValueConfig) GetHeaders() map[string]string
- func (x *HttpJsonValueConfig) GetMethod() string
- func (x *HttpJsonValueConfig) GetSelectors() []*HttpJsonValueConfig_Selectors
- func (x *HttpJsonValueConfig) GetUrl() string
- func (*HttpJsonValueConfig) ProtoMessage()
- func (x *HttpJsonValueConfig) ProtoReflect() protoreflect.Message
- func (x *HttpJsonValueConfig) Reset()
- func (x *HttpJsonValueConfig) String() string
- type HttpJsonValueConfig_JsonValueParseType
- func (HttpJsonValueConfig_JsonValueParseType) Descriptor() protoreflect.EnumDescriptor
- func (x HttpJsonValueConfig_JsonValueParseType) Enum() *HttpJsonValueConfig_JsonValueParseType
- func (HttpJsonValueConfig_JsonValueParseType) EnumDescriptor() ([]byte, []int)deprecated
- func (x HttpJsonValueConfig_JsonValueParseType) Number() protoreflect.EnumNumber
- func (x HttpJsonValueConfig_JsonValueParseType) String() string
- func (HttpJsonValueConfig_JsonValueParseType) Type() protoreflect.EnumType
- type HttpJsonValueConfig_Selectors
- func (*HttpJsonValueConfig_Selectors) Descriptor() ([]byte, []int)deprecated
- func (x *HttpJsonValueConfig_Selectors) GetPath() string
- func (x *HttpJsonValueConfig_Selectors) GetType() HttpJsonValueConfig_JsonValueParseType
- func (*HttpJsonValueConfig_Selectors) ProtoMessage()
- func (x *HttpJsonValueConfig_Selectors) ProtoReflect() protoreflect.Message
- func (x *HttpJsonValueConfig_Selectors) Reset()
- func (x *HttpJsonValueConfig_Selectors) String() string
- type Incident
- func (*Incident) Descriptor() ([]byte, []int)deprecated
- func (x *Incident) GetHistories() []*Incident_HistoryItem
- func (x *Incident) GetId() string
- func (x *Incident) GetRuleId() string
- func (x *Incident) GetStatus() IncidentStatus
- func (*Incident) ProtoMessage()
- func (x *Incident) ProtoReflect() protoreflect.Message
- func (x *Incident) Reset()
- func (x *Incident) String() string
- type IncidentIdRequest
- func (*IncidentIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *IncidentIdRequest) GetIncidentId() string
- func (*IncidentIdRequest) ProtoMessage()
- func (x *IncidentIdRequest) ProtoReflect() protoreflect.Message
- func (x *IncidentIdRequest) Reset()
- func (x *IncidentIdRequest) String() string
- type IncidentServerClient
- type IncidentServerServer
- type IncidentStatus
- func (IncidentStatus) Descriptor() protoreflect.EnumDescriptor
- func (x IncidentStatus) Enum() *IncidentStatus
- func (IncidentStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x IncidentStatus) Number() protoreflect.EnumNumber
- func (x IncidentStatus) String() string
- func (IncidentStatus) Type() protoreflect.EnumType
- type Incident_HistoryItem
- func (*Incident_HistoryItem) Descriptor() ([]byte, []int)deprecated
- func (x *Incident_HistoryItem) GetStatus() IncidentStatus
- func (x *Incident_HistoryItem) GetTimestamp() *timestamppb.Timestamp
- func (*Incident_HistoryItem) ProtoMessage()
- func (x *Incident_HistoryItem) ProtoReflect() protoreflect.Message
- func (x *Incident_HistoryItem) Reset()
- func (x *Incident_HistoryItem) String() string
- type InitializeApplicationResponse
- func (*InitializeApplicationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InitializeApplicationResponse) GetApplicationId() string
- func (x *InitializeApplicationResponse) GetTracingHeader() string
- func (*InitializeApplicationResponse) ProtoMessage()
- func (x *InitializeApplicationResponse) ProtoReflect() protoreflect.Message
- func (x *InitializeApplicationResponse) Reset()
- func (x *InitializeApplicationResponse) String() string
- type InsertScheduleWithIdRequest
- func (*InsertScheduleWithIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InsertScheduleWithIdRequest) GetId() string
- func (x *InsertScheduleWithIdRequest) GetScheduledNext() *timestamppb.Timestamp
- func (*InsertScheduleWithIdRequest) ProtoMessage()
- func (x *InsertScheduleWithIdRequest) ProtoReflect() protoreflect.Message
- func (x *InsertScheduleWithIdRequest) Reset()
- func (x *InsertScheduleWithIdRequest) String() string
- type MemoryInfo
- func (*MemoryInfo) Descriptor() ([]byte, []int)deprecated
- func (x *MemoryInfo) GetMem() *MemoryInfo_Memory
- func (x *MemoryInfo) GetSwap() *MemoryInfo_Memory
- func (*MemoryInfo) ProtoMessage()
- func (x *MemoryInfo) ProtoReflect() protoreflect.Message
- func (x *MemoryInfo) Reset()
- func (x *MemoryInfo) String() string
- type MemoryInfo_Memory
- func (*MemoryInfo_Memory) Descriptor() ([]byte, []int)deprecated
- func (x *MemoryInfo_Memory) GetFree() uint64
- func (x *MemoryInfo_Memory) GetShared() uint64
- func (x *MemoryInfo_Memory) GetTotal() uint64
- func (x *MemoryInfo_Memory) GetUsed() uint64
- func (x *MemoryInfo_Memory) GetUsedPercent() float64
- func (*MemoryInfo_Memory) ProtoMessage()
- func (x *MemoryInfo_Memory) ProtoReflect() protoreflect.Message
- func (x *MemoryInfo_Memory) Reset()
- func (x *MemoryInfo_Memory) String() string
- type Metric
- func (*Metric) Descriptor() ([]byte, []int)deprecated
- func (x *Metric) GetAgentId() string
- func (x *Metric) GetAgentName() string
- func (x *Metric) GetCpuInfo() *CpuInfo
- func (x *Metric) GetDiskInfo() *DiskInfo
- func (x *Metric) GetMemoryInfo() *MemoryInfo
- func (x *Metric) GetNetInfo() *NetInfo
- func (x *Metric) GetTime() *timestamppb.Timestamp
- func (*Metric) ProtoMessage()
- func (x *Metric) ProtoReflect() protoreflect.Message
- func (x *Metric) Reset()
- func (x *Metric) String() string
- type NetInfo
- type NetInfo_Interface
- func (*NetInfo_Interface) Descriptor() ([]byte, []int)deprecated
- func (x *NetInfo_Interface) GetBytesRecv() uint64
- func (x *NetInfo_Interface) GetBytesSent() uint64
- func (x *NetInfo_Interface) GetDropIn() uint64
- func (x *NetInfo_Interface) GetDropOut() uint64
- func (x *NetInfo_Interface) GetErrIn() uint64
- func (x *NetInfo_Interface) GetErrOut() uint64
- func (x *NetInfo_Interface) GetPacketsRecv() uint64
- func (x *NetInfo_Interface) GetPacketsSent() uint64
- func (*NetInfo_Interface) ProtoMessage()
- func (x *NetInfo_Interface) ProtoReflect() protoreflect.Message
- func (x *NetInfo_Interface) Reset()
- func (x *NetInfo_Interface) String() string
- type NotificationManagerClient
- type NotificationManagerServer
- type NotificationMethod
- func (*NotificationMethod) Descriptor() ([]byte, []int)deprecated
- func (x *NotificationMethod) GetId() string
- func (m *NotificationMethod) GetMethod() isNotificationMethod_Method
- func (x *NotificationMethod) GetName() string
- func (x *NotificationMethod) GetSlack() *SlackMethod
- func (x *NotificationMethod) GetStatus() NotificationMethodStatus
- func (x *NotificationMethod) GetType() NotificationMethodType
- func (x *NotificationMethod) GetWebhook() *WebHookMethod
- func (*NotificationMethod) ProtoMessage()
- func (x *NotificationMethod) ProtoReflect() protoreflect.Message
- func (x *NotificationMethod) Reset()
- func (x *NotificationMethod) String() string
- type NotificationMethodIdRequest
- func (*NotificationMethodIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NotificationMethodIdRequest) GetId() string
- func (*NotificationMethodIdRequest) ProtoMessage()
- func (x *NotificationMethodIdRequest) ProtoReflect() protoreflect.Message
- func (x *NotificationMethodIdRequest) Reset()
- func (x *NotificationMethodIdRequest) String() string
- type NotificationMethodRequest
- func (*NotificationMethodRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NotificationMethodRequest) GetNotificationMethodId() string
- func (x *NotificationMethodRequest) GetOwnerId() string
- func (x *NotificationMethodRequest) GetOwnerType() ComponentOwnerType
- func (*NotificationMethodRequest) ProtoMessage()
- func (x *NotificationMethodRequest) ProtoReflect() protoreflect.Message
- func (x *NotificationMethodRequest) Reset()
- func (x *NotificationMethodRequest) String() string
- type NotificationMethodStatus
- func (NotificationMethodStatus) Descriptor() protoreflect.EnumDescriptor
- func (x NotificationMethodStatus) Enum() *NotificationMethodStatus
- func (NotificationMethodStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x NotificationMethodStatus) Number() protoreflect.EnumNumber
- func (x NotificationMethodStatus) String() string
- func (NotificationMethodStatus) Type() protoreflect.EnumType
- type NotificationMethodType
- func (NotificationMethodType) Descriptor() protoreflect.EnumDescriptor
- func (x NotificationMethodType) Enum() *NotificationMethodType
- func (NotificationMethodType) EnumDescriptor() ([]byte, []int)deprecated
- func (x NotificationMethodType) Number() protoreflect.EnumNumber
- func (x NotificationMethodType) String() string
- func (NotificationMethodType) Type() protoreflect.EnumType
- type NotificationMethod_Slack
- type NotificationMethod_Webhook
- type NotifyRequest
- func (*NotifyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyRequest) GetIncidentId() string
- func (x *NotifyRequest) GetOwnerId() string
- func (x *NotifyRequest) GetOwnerType() ComponentOwnerType
- func (x *NotifyRequest) GetRuleName() string
- func (*NotifyRequest) ProtoMessage()
- func (x *NotifyRequest) ProtoReflect() protoreflect.Message
- func (x *NotifyRequest) Reset()
- func (x *NotifyRequest) String() string
- type Pagination
- type PlatformInfo
- func (*PlatformInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PlatformInfo) GetFamily() string
- func (x *PlatformInfo) GetName() string
- func (x *PlatformInfo) GetVersion() string
- func (*PlatformInfo) ProtoMessage()
- func (x *PlatformInfo) ProtoReflect() protoreflect.Message
- func (x *PlatformInfo) Reset()
- func (x *PlatformInfo) String() string
- type RegisterRequest
- func (*RegisterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterRequest) GetAgentName() string
- func (x *RegisterRequest) GetHostInfo() *HostInfo
- func (x *RegisterRequest) GetInterval() int64
- func (x *RegisterRequest) GetTime() *timestamppb.Timestamp
- func (*RegisterRequest) ProtoMessage()
- func (x *RegisterRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterRequest) Reset()
- func (x *RegisterRequest) String() string
- type RegisterResponse
- func (*RegisterResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterResponse) GetEnvName() string
- func (x *RegisterResponse) GetId() string
- func (*RegisterResponse) ProtoMessage()
- func (x *RegisterResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterResponse) Reset()
- func (x *RegisterResponse) String() string
- type RemoveRequest
- type RemoveResponse
- type Rule
- func (*Rule) Descriptor() ([]byte, []int)deprecated
- func (x *Rule) GetAutoClose() bool
- func (x *Rule) GetId() string
- func (x *Rule) GetName() string
- func (x *Rule) GetNotification() bool
- func (x *Rule) GetOwnerId() string
- func (x *Rule) GetOwnerType() ComponentOwnerType
- func (x *Rule) GetRule() string
- func (x *Rule) GetStatus() RuleStatus
- func (*Rule) ProtoMessage()
- func (x *Rule) ProtoReflect() protoreflect.Message
- func (x *Rule) Reset()
- func (x *Rule) String() string
- type RuleIdRequest
- type RuleStatus
- type Rules
- type RunRequest
- type RunResponse
- type Scheduler
- func (*Scheduler) Descriptor() ([]byte, []int)deprecated
- func (x *Scheduler) GetCassandra() *DbConfig
- func (m *Scheduler) GetConfig() isScheduler_Config
- func (x *Scheduler) GetGrpc() *GrpcConfig
- func (x *Scheduler) GetHttp() *HttpConfig
- func (x *Scheduler) GetHttpValue() *HttpJsonValueConfig
- func (x *Scheduler) GetId() string
- func (x *Scheduler) GetInterval() int32
- func (x *Scheduler) GetMongo() *DbConfig
- func (x *Scheduler) GetMysql() *DbConfig
- func (x *Scheduler) GetName() string
- func (x *Scheduler) GetPostgres() *DbConfig
- func (x *Scheduler) GetSitemap() *SiteMapConfig
- func (x *Scheduler) GetSslExpiration() *SslExpirationConfig
- func (x *Scheduler) GetStatus() SchedulerStatus
- func (x *Scheduler) GetTcp() *TcpConfig
- func (x *Scheduler) GetTimeout() int32
- func (x *Scheduler) GetType() SchedulerType
- func (*Scheduler) ProtoMessage()
- func (x *Scheduler) ProtoReflect() protoreflect.Message
- func (x *Scheduler) Reset()
- func (x *Scheduler) String() string
- type SchedulerCode
- func (SchedulerCode) Descriptor() protoreflect.EnumDescriptor
- func (x SchedulerCode) Enum() *SchedulerCode
- func (SchedulerCode) EnumDescriptor() ([]byte, []int)deprecated
- func (x SchedulerCode) Number() protoreflect.EnumNumber
- func (x SchedulerCode) String() string
- func (SchedulerCode) Type() protoreflect.EnumType
- type SchedulerResponse
- func (*SchedulerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SchedulerResponse) GetSchedulerId() string
- func (x *SchedulerResponse) GetSnapshot() *SchedulerSnapshot
- func (*SchedulerResponse) ProtoMessage()
- func (x *SchedulerResponse) ProtoReflect() protoreflect.Message
- func (x *SchedulerResponse) Reset()
- func (x *SchedulerResponse) String() string
- type SchedulerSnapshot
- func (*SchedulerSnapshot) Descriptor() ([]byte, []int)deprecated
- func (x *SchedulerSnapshot) GetCode() SchedulerCode
- func (x *SchedulerSnapshot) GetError() *SchedulerSnapshot_Error
- func (x *SchedulerSnapshot) GetMeta() *SchedulerSnapshot_MetaData
- func (x *SchedulerSnapshot) GetType() SchedulerType
- func (*SchedulerSnapshot) ProtoMessage()
- func (x *SchedulerSnapshot) ProtoReflect() protoreflect.Message
- func (x *SchedulerSnapshot) Reset()
- func (x *SchedulerSnapshot) String() string
- type SchedulerSnapshotWithId
- func (*SchedulerSnapshotWithId) Descriptor() ([]byte, []int)deprecated
- func (x *SchedulerSnapshotWithId) GetId() string
- func (x *SchedulerSnapshotWithId) GetSnapshot() *SchedulerSnapshot
- func (*SchedulerSnapshotWithId) ProtoMessage()
- func (x *SchedulerSnapshotWithId) ProtoReflect() protoreflect.Message
- func (x *SchedulerSnapshotWithId) Reset()
- func (x *SchedulerSnapshotWithId) String() string
- type SchedulerSnapshot_Error
- func (*SchedulerSnapshot_Error) Descriptor() ([]byte, []int)deprecated
- func (x *SchedulerSnapshot_Error) GetMessage() string
- func (*SchedulerSnapshot_Error) ProtoMessage()
- func (x *SchedulerSnapshot_Error) ProtoReflect() protoreflect.Message
- func (x *SchedulerSnapshot_Error) Reset()
- func (x *SchedulerSnapshot_Error) String() string
- type SchedulerSnapshot_MetaData
- func (*SchedulerSnapshot_MetaData) Descriptor() ([]byte, []int)deprecated
- func (x *SchedulerSnapshot_MetaData) GetEndTime() *timestamppb.Timestamp
- func (x *SchedulerSnapshot_MetaData) GetStartTime() *timestamppb.Timestamp
- func (x *SchedulerSnapshot_MetaData) GetValue() *structpb.Value
- func (*SchedulerSnapshot_MetaData) ProtoMessage()
- func (x *SchedulerSnapshot_MetaData) ProtoReflect() protoreflect.Message
- func (x *SchedulerSnapshot_MetaData) Reset()
- func (x *SchedulerSnapshot_MetaData) String() string
- type SchedulerStatus
- func (SchedulerStatus) Descriptor() protoreflect.EnumDescriptor
- func (x SchedulerStatus) Enum() *SchedulerStatus
- func (SchedulerStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x SchedulerStatus) Number() protoreflect.EnumNumber
- func (x SchedulerStatus) String() string
- func (SchedulerStatus) Type() protoreflect.EnumType
- type SchedulerType
- func (SchedulerType) Descriptor() protoreflect.EnumDescriptor
- func (x SchedulerType) Enum() *SchedulerType
- func (SchedulerType) EnumDescriptor() ([]byte, []int)deprecated
- func (x SchedulerType) Number() protoreflect.EnumNumber
- func (x SchedulerType) String() string
- func (SchedulerType) Type() protoreflect.EnumType
- type Scheduler_Cassandra
- type Scheduler_Grpc
- type Scheduler_Http
- type Scheduler_HttpValue
- type Scheduler_Mongo
- type Scheduler_Mysql
- type Scheduler_Postgres
- type Scheduler_Sitemap
- type Scheduler_SslExpiration
- type Scheduler_Tcp
- type SchedulersExecutorClient
- type SchedulersExecutorServer
- type SendMetricsRequest
- func (*SendMetricsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SendMetricsRequest) GetDisconnect() *SendMetricsRequest_Disconnect
- func (x *SendMetricsRequest) GetMetric() *Metric
- func (m *SendMetricsRequest) GetMsg() isSendMetricsRequest_Msg
- func (*SendMetricsRequest) ProtoMessage()
- func (x *SendMetricsRequest) ProtoReflect() protoreflect.Message
- func (x *SendMetricsRequest) Reset()
- func (x *SendMetricsRequest) String() string
- type SendMetricsRequest_Disconnect
- func (*SendMetricsRequest_Disconnect) Descriptor() ([]byte, []int)deprecated
- func (x *SendMetricsRequest_Disconnect) GetAgentId() string
- func (x *SendMetricsRequest_Disconnect) GetTime() *timestamppb.Timestamp
- func (*SendMetricsRequest_Disconnect) ProtoMessage()
- func (x *SendMetricsRequest_Disconnect) ProtoReflect() protoreflect.Message
- func (x *SendMetricsRequest_Disconnect) Reset()
- func (x *SendMetricsRequest_Disconnect) String() string
- type SendMetricsRequest_Disconnect_
- type SendMetricsRequest_Metric
- type SiteMapConfig
- func (*SiteMapConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SiteMapConfig) GetConcurrency() int32
- func (x *SiteMapConfig) GetUrl() string
- func (*SiteMapConfig) ProtoMessage()
- func (x *SiteMapConfig) ProtoReflect() protoreflect.Message
- func (x *SiteMapConfig) Reset()
- func (x *SiteMapConfig) String() string
- type SlackMethod
- type SortDirection
- func (SortDirection) Descriptor() protoreflect.EnumDescriptor
- func (x SortDirection) Enum() *SortDirection
- func (SortDirection) EnumDescriptor() ([]byte, []int)deprecated
- func (x SortDirection) Number() protoreflect.EnumNumber
- func (x SortDirection) String() string
- func (SortDirection) Type() protoreflect.EnumType
- type SortIncidentList
- func (SortIncidentList) Descriptor() protoreflect.EnumDescriptor
- func (x SortIncidentList) Enum() *SortIncidentList
- func (SortIncidentList) EnumDescriptor() ([]byte, []int)deprecated
- func (x SortIncidentList) Number() protoreflect.EnumNumber
- func (x SortIncidentList) String() string
- func (SortIncidentList) Type() protoreflect.EnumType
- type SortSchedulerList
- func (SortSchedulerList) Descriptor() protoreflect.EnumDescriptor
- func (x SortSchedulerList) Enum() *SortSchedulerList
- func (SortSchedulerList) EnumDescriptor() ([]byte, []int)deprecated
- func (x SortSchedulerList) Number() protoreflect.EnumNumber
- func (x SortSchedulerList) String() string
- func (SortSchedulerList) Type() protoreflect.EnumType
- type SortTransactionList
- func (SortTransactionList) Descriptor() protoreflect.EnumDescriptor
- func (x SortTransactionList) Enum() *SortTransactionList
- func (SortTransactionList) EnumDescriptor() ([]byte, []int)deprecated
- func (x SortTransactionList) Number() protoreflect.EnumNumber
- func (x SortTransactionList) String() string
- func (SortTransactionList) Type() protoreflect.EnumType
- type SortingIncidentList
- func (*SortingIncidentList) Descriptor() ([]byte, []int)deprecated
- func (x *SortingIncidentList) GetDirection() SortDirection
- func (x *SortingIncidentList) GetSortBy() SortIncidentList
- func (*SortingIncidentList) ProtoMessage()
- func (x *SortingIncidentList) ProtoReflect() protoreflect.Message
- func (x *SortingIncidentList) Reset()
- func (x *SortingIncidentList) String() string
- type SortingSchedulerList
- func (*SortingSchedulerList) Descriptor() ([]byte, []int)deprecated
- func (x *SortingSchedulerList) GetDirection() SortDirection
- func (x *SortingSchedulerList) GetSortBy() SortSchedulerList
- func (*SortingSchedulerList) ProtoMessage()
- func (x *SortingSchedulerList) ProtoReflect() protoreflect.Message
- func (x *SortingSchedulerList) Reset()
- func (x *SortingSchedulerList) String() string
- type SortingTransactionList
- func (*SortingTransactionList) Descriptor() ([]byte, []int)deprecated
- func (x *SortingTransactionList) GetDirection() SortDirection
- func (x *SortingTransactionList) GetSortBy() SortTransactionList
- func (*SortingTransactionList) ProtoMessage()
- func (x *SortingTransactionList) ProtoReflect() protoreflect.Message
- func (x *SortingTransactionList) Reset()
- func (x *SortingTransactionList) String() string
- type SslExpirationConfig
- func (*SslExpirationConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SslExpirationConfig) GetHost() string
- func (x *SslExpirationConfig) GetPort() int32
- func (*SslExpirationConfig) ProtoMessage()
- func (x *SslExpirationConfig) ProtoReflect() protoreflect.Message
- func (x *SslExpirationConfig) Reset()
- func (x *SslExpirationConfig) String() string
- type StopRequest
- type StopResponse
- type StorageClient
- type StorageRecord
- func (*StorageRecord) Descriptor() ([]byte, []int)deprecated
- func (x *StorageRecord) GetAgentMetric() *Metric
- func (m *StorageRecord) GetRecord() isStorageRecord_Record
- func (x *StorageRecord) GetSnapshot() *SchedulerSnapshotWithId
- func (x *StorageRecord) GetTransaction() *TransactionInfo
- func (*StorageRecord) ProtoMessage()
- func (x *StorageRecord) ProtoReflect() protoreflect.Message
- func (x *StorageRecord) Reset()
- func (x *StorageRecord) String() string
- type StorageRecord_AgentMetric
- type StorageRecord_Snapshot
- type StorageRecord_Transaction
- type StorageServer
- type TcpConfig
- type TimeFilter
- func (*TimeFilter) Descriptor() ([]byte, []int)deprecated
- func (x *TimeFilter) GetFrom() *timestamppb.Timestamp
- func (x *TimeFilter) GetTo() *timestamppb.Timestamp
- func (*TimeFilter) ProtoMessage()
- func (x *TimeFilter) ProtoReflect() protoreflect.Message
- func (x *TimeFilter) Reset()
- func (x *TimeFilter) String() string
- type TransactionGroup
- func (*TransactionGroup) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionGroup) GetAverageTime() float64
- func (x *TransactionGroup) GetCount() int64
- func (x *TransactionGroup) GetMaxTime() float64
- func (x *TransactionGroup) GetMinTime() float64
- func (x *TransactionGroup) GetSuccessRatio() float64
- func (x *TransactionGroup) GetThroughput() float64
- func (*TransactionGroup) ProtoMessage()
- func (x *TransactionGroup) ProtoReflect() protoreflect.Message
- func (x *TransactionGroup) Reset()
- func (x *TransactionGroup) String() string
- type TransactionInfo
- func (*TransactionInfo) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionInfo) GetApplicationId() string
- func (x *TransactionInfo) GetEndTime() *timestamppb.Timestamp
- func (x *TransactionInfo) GetError() *TransactionInfo_Error
- func (x *TransactionInfo) GetId() string
- func (x *TransactionInfo) GetMeta() *TransactionInfo_Meta
- func (x *TransactionInfo) GetName() string
- func (x *TransactionInfo) GetParentId() string
- func (x *TransactionInfo) GetStartTime() *timestamppb.Timestamp
- func (x *TransactionInfo) GetStatus() TransactionStatus
- func (x *TransactionInfo) GetType() TransactionType
- func (*TransactionInfo) ProtoMessage()
- func (x *TransactionInfo) ProtoReflect() protoreflect.Message
- func (x *TransactionInfo) Reset()
- func (x *TransactionInfo) String() string
- type TransactionInfo_Error
- func (*TransactionInfo_Error) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionInfo_Error) GetMessage() string
- func (*TransactionInfo_Error) ProtoMessage()
- func (x *TransactionInfo_Error) ProtoReflect() protoreflect.Message
- func (x *TransactionInfo_Error) Reset()
- func (x *TransactionInfo_Error) String() string
- type TransactionInfo_Meta
- func (*TransactionInfo_Meta) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionInfo_Meta) GetHost() string
- func (x *TransactionInfo_Meta) GetMethod() string
- func (x *TransactionInfo_Meta) GetPath() string
- func (*TransactionInfo_Meta) ProtoMessage()
- func (x *TransactionInfo_Meta) ProtoReflect() protoreflect.Message
- func (x *TransactionInfo_Meta) Reset()
- func (x *TransactionInfo_Meta) String() string
- type TransactionStatus
- func (TransactionStatus) Descriptor() protoreflect.EnumDescriptor
- func (x TransactionStatus) Enum() *TransactionStatus
- func (TransactionStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x TransactionStatus) Number() protoreflect.EnumNumber
- func (x TransactionStatus) String() string
- func (TransactionStatus) Type() protoreflect.EnumType
- type TransactionType
- func (TransactionType) Descriptor() protoreflect.EnumDescriptor
- func (x TransactionType) Enum() *TransactionType
- func (TransactionType) EnumDescriptor() ([]byte, []int)deprecated
- func (x TransactionType) Number() protoreflect.EnumNumber
- func (x TransactionType) String() string
- func (TransactionType) Type() protoreflect.EnumType
- type TypeAgentStat
- func (TypeAgentStat) Descriptor() protoreflect.EnumDescriptor
- func (x TypeAgentStat) Enum() *TypeAgentStat
- func (TypeAgentStat) EnumDescriptor() ([]byte, []int)deprecated
- func (x TypeAgentStat) Number() protoreflect.EnumNumber
- func (x TypeAgentStat) String() string
- func (TypeAgentStat) Type() protoreflect.EnumType
- type UnRegisterRequest
- func (*UnRegisterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnRegisterRequest) GetId() string
- func (x *UnRegisterRequest) GetTime() *timestamppb.Timestamp
- func (*UnRegisterRequest) ProtoMessage()
- func (x *UnRegisterRequest) ProtoReflect() protoreflect.Message
- func (x *UnRegisterRequest) Reset()
- func (x *UnRegisterRequest) String() string
- type UnRegisterResponse
- type UnimplementedAgentServerServer
- func (UnimplementedAgentServerServer) GetAgentById(context.Context, *GetAgentByIdRequest) (*AgentItem, error)
- func (UnimplementedAgentServerServer) GetAgentList(context.Context, *emptypb.Empty) (*GetAgentListResponse, error)
- func (UnimplementedAgentServerServer) GetByAgentName(context.Context, *GetByAgentNameRequest) (*GetAgentListResponse, error)
- func (UnimplementedAgentServerServer) Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
- func (UnimplementedAgentServerServer) SendMetrics(AgentServer_SendMetricsServer) error
- func (UnimplementedAgentServerServer) UnRegister(context.Context, *UnRegisterRequest) (*UnRegisterResponse, error)
- type UnimplementedApplicationMonitoringServer
- func (UnimplementedApplicationMonitoringServer) ArchiveApplicationById(context.Context, *ApplicationByIdReuqest) (*Application, error)
- func (UnimplementedApplicationMonitoringServer) DisableApplicationById(context.Context, *ApplicationByIdReuqest) (*Application, error)
- func (UnimplementedApplicationMonitoringServer) EnableApplicationById(context.Context, *ApplicationByIdReuqest) (*Application, error)
- func (UnimplementedApplicationMonitoringServer) GetApplicationById(context.Context, *ApplicationByIdReuqest) (*Application, error)
- func (UnimplementedApplicationMonitoringServer) GetApplicationList(context.Context, *emptypb.Empty) (*GetApplicationListResponse, error)
- func (UnimplementedApplicationMonitoringServer) GetApplicationListByAgentId(context.Context, *AgentIdRequest) (*GetApplicationListResponse, error)
- func (UnimplementedApplicationMonitoringServer) InitializeApplication(context.Context, *ApplicationInfo) (*InitializeApplicationResponse, error)
- func (UnimplementedApplicationMonitoringServer) SaveTransaction(context.Context, *TransactionInfo) (*emptypb.Empty, error)
- type UnimplementedCacheServer
- func (UnimplementedCacheServer) DeleteScheduleById(context.Context, *DeleteScheduleWithIdRequest) (*emptypb.Empty, error)
- func (UnimplementedCacheServer) GetScheduleById(context.Context, *GetScheduleWithIdRequest) (*GetScheduleWithIdResponse, error)
- func (UnimplementedCacheServer) InsertScheduleWithId(context.Context, *InsertScheduleWithIdRequest) (*emptypb.Empty, error)
- type UnimplementedIncidentServerServer
- func (UnimplementedIncidentServerServer) ActivateRule(context.Context, *RuleIdRequest) (*Rule, error)
- func (UnimplementedIncidentServerServer) CloseIncident(context.Context, *IncidentIdRequest) (*Incident, error)
- func (UnimplementedIncidentServerServer) CreateRule(context.Context, *CreateRuleRequest) (*Rule, error)
- func (UnimplementedIncidentServerServer) DeactivateRule(context.Context, *RuleIdRequest) (*Rule, error)
- func (UnimplementedIncidentServerServer) GetRuleById(context.Context, *RuleIdRequest) (*Rule, error)
- func (UnimplementedIncidentServerServer) GetRulesByOwnerId(context.Context, *GetRulesByOwnerIdRequest) (*Rules, error)
- func (UnimplementedIncidentServerServer) ProcessRecordFromStorage(context.Context, *StorageRecord) (*emptypb.Empty, error)
- func (UnimplementedIncidentServerServer) RemoveRule(context.Context, *RuleIdRequest) (*Rule, error)
- func (UnimplementedIncidentServerServer) StudyIncident(context.Context, *IncidentIdRequest) (*Incident, error)
- func (UnimplementedIncidentServerServer) ValidateRule(context.Context, *ValidateRuleRequest) (*ValidateRuleResponse, error)
- type UnimplementedNotificationManagerServer
- func (UnimplementedNotificationManagerServer) Activate(context.Context, *NotificationMethodIdRequest) (*NotificationMethod, error)
- func (UnimplementedNotificationManagerServer) Add(context.Context, *NotificationMethodRequest) (*NotificationMethod, error)
- func (UnimplementedNotificationManagerServer) CreateNotificationMethod(context.Context, *CreateNotificationMethodRequest) (*NotificationMethod, error)
- func (UnimplementedNotificationManagerServer) Deactivate(context.Context, *NotificationMethodIdRequest) (*NotificationMethod, error)
- func (UnimplementedNotificationManagerServer) DeleteById(context.Context, *NotificationMethodIdRequest) (*NotificationMethod, error)
- func (UnimplementedNotificationManagerServer) GetById(context.Context, *NotificationMethodIdRequest) (*NotificationMethod, error)
- func (UnimplementedNotificationManagerServer) GetList(context.Context, *GetListRequest) (*GetListResponse, error)
- func (UnimplementedNotificationManagerServer) GetNotificationMethods(context.Context, *emptypb.Empty) (*GetListResponse, error)
- func (UnimplementedNotificationManagerServer) Notify(context.Context, *NotifyRequest) (*emptypb.Empty, error)
- func (UnimplementedNotificationManagerServer) Remove(context.Context, *NotificationMethodRequest) (*NotificationMethod, error)
- type UnimplementedSchedulersExecutorServer
- func (UnimplementedSchedulersExecutorServer) Add(context.Context, *AddRequest) (*AddResponse, error)
- func (UnimplementedSchedulersExecutorServer) GetSchedulerById(context.Context, *GetSchedulerByIdRequest) (*Scheduler, error)
- func (UnimplementedSchedulersExecutorServer) GetSchedulerList(context.Context, *emptypb.Empty) (*GetSchedulerListResponse, error)
- func (UnimplementedSchedulersExecutorServer) Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
- func (UnimplementedSchedulersExecutorServer) Run(context.Context, *RunRequest) (*RunResponse, error)
- func (UnimplementedSchedulersExecutorServer) Stop(context.Context, *StopRequest) (*StopResponse, error)
- type UnimplementedStorageServer
- func (UnimplementedStorageServer) GetAgentInformation(context.Context, *GetAgentInformationRequest) (*GetAgentInformationResponse, error)
- func (UnimplementedStorageServer) GetIncidentById(context.Context, *IncidentIdRequest) (*Incident, error)
- func (UnimplementedStorageServer) GetIncidentByRuleId(context.Context, *RuleIdRequest) (*Incident, error)
- func (UnimplementedStorageServer) GetIncidentsList(context.Context, *GetIncidentsListRequest) (*GetIncidentsListResponse, error)
- func (UnimplementedStorageServer) GetSchedulerInformation(context.Context, *GetSchedulerInformationRequest) (*GetSchedulerInformationResponse, error)
- func (UnimplementedStorageServer) GetSchedulerUptime(context.Context, *GetSchedulerUptimeRequest) (*GetSchedulerUptimeResponse, error)
- func (UnimplementedStorageServer) GetTransactionById(context.Context, *GetTransactionByIdRequest) (*GetTransactionByIdResponse, error)
- func (UnimplementedStorageServer) GetTransactions(context.Context, *GetTransactionsRequest) (*GetTransactionsResponse, error)
- func (UnimplementedStorageServer) GetTransactionsGroup(context.Context, *GetTransactionGroupRequest) (*GetTransactionGroupResponse, error)
- func (UnimplementedStorageServer) SaveIncident(context.Context, *Incident) (*emptypb.Empty, error)
- func (UnimplementedStorageServer) SaveResponseFromAgent(context.Context, *Metric) (*emptypb.Empty, error)
- func (UnimplementedStorageServer) SaveResponseFromScheduler(context.Context, *SchedulerResponse) (*emptypb.Empty, error)
- func (UnimplementedStorageServer) SaveTransaction(context.Context, *TransactionInfo) (*emptypb.Empty, error)
- func (UnimplementedStorageServer) UpdateIncidentStatus(context.Context, *UpdateIncidentStatusRequest) (*Incident, error)
- type UnsafeAgentServerServer
- type UnsafeApplicationMonitoringServer
- type UnsafeCacheServer
- type UnsafeIncidentServerServer
- type UnsafeNotificationManagerServer
- type UnsafeSchedulersExecutorServer
- type UnsafeStorageServer
- type UpdateIncidentStatusRequest
- func (*UpdateIncidentStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateIncidentStatusRequest) GetIncidentId() string
- func (x *UpdateIncidentStatusRequest) GetStatus() IncidentStatus
- func (*UpdateIncidentStatusRequest) ProtoMessage()
- func (x *UpdateIncidentStatusRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateIncidentStatusRequest) Reset()
- func (x *UpdateIncidentStatusRequest) String() string
- type ValidateRuleRequest
- func (*ValidateRuleRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ValidateRuleRequest) GetOwnerType() ComponentOwnerType
- func (x *ValidateRuleRequest) GetRule() string
- func (*ValidateRuleRequest) ProtoMessage()
- func (x *ValidateRuleRequest) ProtoReflect() protoreflect.Message
- func (x *ValidateRuleRequest) Reset()
- func (x *ValidateRuleRequest) String() string
- type ValidateRuleResponse
- func (*ValidateRuleResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ValidateRuleResponse) GetError() *ValidateRuleResponse_Error
- func (x *ValidateRuleResponse) GetIsValid() bool
- func (*ValidateRuleResponse) ProtoMessage()
- func (x *ValidateRuleResponse) ProtoReflect() protoreflect.Message
- func (x *ValidateRuleResponse) Reset()
- func (x *ValidateRuleResponse) String() string
- type ValidateRuleResponse_Error
- func (*ValidateRuleResponse_Error) Descriptor() ([]byte, []int)deprecated
- func (x *ValidateRuleResponse_Error) GetMessage() string
- func (*ValidateRuleResponse_Error) ProtoMessage()
- func (x *ValidateRuleResponse_Error) ProtoReflect() protoreflect.Message
- func (x *ValidateRuleResponse_Error) Reset()
- func (x *ValidateRuleResponse_Error) String() string
- type WebHookMethod
Constants ¶
This section is empty.
Variables ¶
var ( ComponentOwnerType_name = map[int32]string{ 0: "COMPONENT_OWNER_TYPE_UNSPECIFIED", 1: "COMPONENT_OWNER_TYPE_SCHEDULER", 2: "COMPONENT_OWNER_TYPE_AGENT", 3: "COMPONENT_OWNER_TYPE_APPLICATION", } ComponentOwnerType_value = map[string]int32{ "COMPONENT_OWNER_TYPE_UNSPECIFIED": 0, "COMPONENT_OWNER_TYPE_SCHEDULER": 1, "COMPONENT_OWNER_TYPE_AGENT": 2, "COMPONENT_OWNER_TYPE_APPLICATION": 3, } )
Enum value maps for ComponentOwnerType.
var ( AgentStatus_name = map[int32]string{ 0: "AGENT_STATUS_UNSPECIFIED", 1: "REGISTRED", 2: "RUNNED", 3: "DISCONNECTED", 4: "UNREGISTRED", } AgentStatus_value = map[string]int32{ "AGENT_STATUS_UNSPECIFIED": 0, "REGISTRED": 1, "RUNNED": 2, "DISCONNECTED": 3, "UNREGISTRED": 4, } )
Enum value maps for AgentStatus.
var ( ApplicationStatus_name = map[int32]string{ 0: "APPLICATION_STATUS_UNSPECIFIED", 1: "APPLICATION_STATUS_ENABLED", 2: "APPLICATION_STATUS_DISABLED", 3: "APPLICATION_STATUS_ARCHIVED", } ApplicationStatus_value = map[string]int32{ "APPLICATION_STATUS_UNSPECIFIED": 0, "APPLICATION_STATUS_ENABLED": 1, "APPLICATION_STATUS_DISABLED": 2, "APPLICATION_STATUS_ARCHIVED": 3, } )
Enum value maps for ApplicationStatus.
var ( TransactionStatus_name = map[int32]string{ 0: "TRANSACTION_CODE_UNSPECIFIED", 1: "TRANSACTION_SUCCESSFUL", 2: "TRANSACTION_FAILED", } TransactionStatus_value = map[string]int32{ "TRANSACTION_CODE_UNSPECIFIED": 0, "TRANSACTION_SUCCESSFUL": 1, "TRANSACTION_FAILED": 2, } )
Enum value maps for TransactionStatus.
var ( TransactionType_name = map[int32]string{ 0: "TRANSACTION_TYPE_UNSPECIFIED", 1: "TRANSACTION_TYPE_XHR", 2: "TRANSACTION_TYPE_FETCH", 3: "TRANSACTION_TYPE_WEBSOCKET", 4: "TRANSACTION_TYPE_HTTP", 5: "TRANSACTION_TYPE_GRPC", 6: "TRANSACTION_TYPE_DB", 7: "TRANSACTION_TYPE_INTERNAL", 8: "TRANSACTION_TYPE_ROUTER", } TransactionType_value = map[string]int32{ "TRANSACTION_TYPE_UNSPECIFIED": 0, "TRANSACTION_TYPE_XHR": 1, "TRANSACTION_TYPE_FETCH": 2, "TRANSACTION_TYPE_WEBSOCKET": 3, "TRANSACTION_TYPE_HTTP": 4, "TRANSACTION_TYPE_GRPC": 5, "TRANSACTION_TYPE_DB": 6, "TRANSACTION_TYPE_INTERNAL": 7, "TRANSACTION_TYPE_ROUTER": 8, } )
Enum value maps for TransactionType.
var ( IncidentStatus_name = map[int32]string{ 0: "INCIDENT_STATUS_UNSPECIFIED", 1: "INCIDENT_STATUS_OPENED", 2: "INCIDENT_STATUS_STUDIED", 3: "INCIDENT_STATUS_CAN_BE_CLOSED", 4: "INCIDENT_STATUS_CLOSED", } IncidentStatus_value = map[string]int32{ "INCIDENT_STATUS_UNSPECIFIED": 0, "INCIDENT_STATUS_OPENED": 1, "INCIDENT_STATUS_STUDIED": 2, "INCIDENT_STATUS_CAN_BE_CLOSED": 3, "INCIDENT_STATUS_CLOSED": 4, } )
Enum value maps for IncidentStatus.
var ( RuleStatus_name = map[int32]string{ 0: "RULE_STATUS_UNSPECIFIED", 1: "RULE_STATUS_ACTIVE", 2: "RULE_STATUS_INACTIVE", 3: "RULE_STATUS_REMOVED", } RuleStatus_value = map[string]int32{ "RULE_STATUS_UNSPECIFIED": 0, "RULE_STATUS_ACTIVE": 1, "RULE_STATUS_INACTIVE": 2, "RULE_STATUS_REMOVED": 3, } )
Enum value maps for RuleStatus.
var ( SchedulerCode_name = map[int32]string{ 0: "SCHEDULER_CODE_UNSPECIFIED", 1: "OK", 2: "ERROR", } SchedulerCode_value = map[string]int32{ "SCHEDULER_CODE_UNSPECIFIED": 0, "OK": 1, "ERROR": 2, } )
Enum value maps for SchedulerCode.
var ( SchedulerStatus_name = map[int32]string{ 0: "SCHEDULER_STATUS_UNSPECIFIED", 1: "RUNNED", 2: "STOPPED", 3: "REMOVED", } SchedulerStatus_value = map[string]int32{ "SCHEDULER_STATUS_UNSPECIFIED": 0, "RUNNED": 1, "STOPPED": 2, "REMOVED": 3, } )
Enum value maps for SchedulerStatus.
var ( SchedulerType_name = map[int32]string{ 0: "SCHEDULER_TYPE_UNSPECIFIED", 1: "TCP", 2: "GRPC", 3: "HTTP", 4: "SITE_MAP", 5: "HTTP_JSON_VALUE", 6: "SSL_EXPIRATION", 7: "MONGO", 8: "POSTGRES", 9: "CASSANDRA", 10: "MYSQL", } SchedulerType_value = map[string]int32{ "SCHEDULER_TYPE_UNSPECIFIED": 0, "TCP": 1, "GRPC": 2, "HTTP": 3, "SITE_MAP": 4, "HTTP_JSON_VALUE": 5, "SSL_EXPIRATION": 6, "MONGO": 7, "POSTGRES": 8, "CASSANDRA": 9, "MYSQL": 10, } )
Enum value maps for SchedulerType.
var ( HttpJsonValueConfig_JsonValueParseType_name = map[int32]string{ 0: "JSON_PARSE_VALUE_UNSPECIFIED", 1: "STRING", 2: "BOOL", 3: "NUMBER", 4: "TIME", 5: "ANY", 6: "RAW", } HttpJsonValueConfig_JsonValueParseType_value = map[string]int32{ "JSON_PARSE_VALUE_UNSPECIFIED": 0, "STRING": 1, "BOOL": 2, "NUMBER": 3, "TIME": 4, "ANY": 5, "RAW": 6, } )
Enum value maps for HttpJsonValueConfig_JsonValueParseType.
var ( NotificationMethodType_name = map[int32]string{ 0: "NOTIFICATION_METHOD_UNSPECIFIED", 1: "NOTIFICATION_METHOD_WEBHOOK", 2: "NOTIFICATION_METHOD_SLACK", } NotificationMethodType_value = map[string]int32{ "NOTIFICATION_METHOD_UNSPECIFIED": 0, "NOTIFICATION_METHOD_WEBHOOK": 1, "NOTIFICATION_METHOD_SLACK": 2, } )
Enum value maps for NotificationMethodType.
var ( NotificationMethodStatus_name = map[int32]string{ 0: "NOTIFICATION_STATUS_UNSPECIFIED", 1: "NOTIFICATION_STATUS_ACTIVE", 2: "NOTIFICATION_STATUS_INACTIVE", 3: "NOTIFICATION_STATUS_REMOVED", } NotificationMethodStatus_value = map[string]int32{ "NOTIFICATION_STATUS_UNSPECIFIED": 0, "NOTIFICATION_STATUS_ACTIVE": 1, "NOTIFICATION_STATUS_INACTIVE": 2, "NOTIFICATION_STATUS_REMOVED": 3, } )
Enum value maps for NotificationMethodStatus.
var ( SortIncidentList_name = map[int32]string{ 0: "SORT_INCIDENT_LIST_UNSPECIFIED", 1: "INCIDENT_LIST_BY_START_TIME", 2: "INCIDENT_LIST_BY_END_TIME", } SortIncidentList_value = map[string]int32{ "SORT_INCIDENT_LIST_UNSPECIFIED": 0, "INCIDENT_LIST_BY_START_TIME": 1, "INCIDENT_LIST_BY_END_TIME": 2, } )
Enum value maps for SortIncidentList.
var ( SortTransactionList_name = map[int32]string{ 0: "SORT_TRANSACTION_LIST_UNSPECIFIED", 1: "DURATION", 2: "BY_TRANSACTION_START_TIME", 3: "BY_TRANSACTION_END_TIME", } SortTransactionList_value = map[string]int32{ "SORT_TRANSACTION_LIST_UNSPECIFIED": 0, "DURATION": 1, "BY_TRANSACTION_START_TIME": 2, "BY_TRANSACTION_END_TIME": 3, } )
Enum value maps for SortTransactionList.
var ( SortDirection_name = map[int32]string{ 0: "SORT_DIRECTION_UNSPECIFIED", 1: "ASC", 2: "DESC", } SortDirection_value = map[string]int32{ "SORT_DIRECTION_UNSPECIFIED": 0, "ASC": 1, "DESC": 2, } )
Enum value maps for SortDirection.
var ( SortSchedulerList_name = map[int32]string{ 0: "SORT_SCHEDULER_LIST_UNSPECIFIED", 1: "BY_START_TIME", 2: "BY_END_TIME", 3: "BY_LATENCY", } SortSchedulerList_value = map[string]int32{ "SORT_SCHEDULER_LIST_UNSPECIFIED": 0, "BY_START_TIME": 1, "BY_END_TIME": 2, "BY_LATENCY": 3, } )
Enum value maps for SortSchedulerList.
var ( GroupTransaction_name = map[int32]string{ 0: "GROUP_TRANSACTION_UNSPECIFIED", 1: "BY_TYPE", 2: "BY_NAME", 3: "BY_METHOD", 4: "BY_HOST", 5: "BY_PATH", } GroupTransaction_value = map[string]int32{ "GROUP_TRANSACTION_UNSPECIFIED": 0, "BY_TYPE": 1, "BY_NAME": 2, "BY_METHOD": 3, "BY_HOST": 4, "BY_PATH": 5, } )
Enum value maps for GroupTransaction.
var ( TypeAgentStat_name = map[int32]string{ 0: "AGENT_STATS_TYPE_UNSPECIFIED", 1: "ALL", 2: "CPU", 3: "DISK", 4: "MEMORY", 5: "NET", } TypeAgentStat_value = map[string]int32{ "AGENT_STATS_TYPE_UNSPECIFIED": 0, "ALL": 1, "CPU": 2, "DISK": 3, "MEMORY": 4, "NET": 5, } )
Enum value maps for TypeAgentStat.
var AgentServer_ServiceDesc = grpc.ServiceDesc{ ServiceName: "squzy.v1.agent.AgentServer", HandlerType: (*AgentServerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Register", Handler: _AgentServer_Register_Handler, }, { MethodName: "GetByAgentName", Handler: _AgentServer_GetByAgentName_Handler, }, { MethodName: "GetAgentById", Handler: _AgentServer_GetAgentById_Handler, }, { MethodName: "UnRegister", Handler: _AgentServer_UnRegister_Handler, }, { MethodName: "GetAgentList", Handler: _AgentServer_GetAgentList_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "SendMetrics", Handler: _AgentServer_SendMetrics_Handler, ClientStreams: true, }, }, Metadata: "proto/v1/squzy_agent_server.proto", }
AgentServer_ServiceDesc is the grpc.ServiceDesc for AgentServer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ApplicationMonitoring_ServiceDesc = grpc.ServiceDesc{ ServiceName: "squzy.v1.monitoring.ApplicationMonitoring", HandlerType: (*ApplicationMonitoringServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "InitializeApplication", Handler: _ApplicationMonitoring_InitializeApplication_Handler, }, { MethodName: "SaveTransaction", Handler: _ApplicationMonitoring_SaveTransaction_Handler, }, { MethodName: "GetApplicationById", Handler: _ApplicationMonitoring_GetApplicationById_Handler, }, { MethodName: "GetApplicationList", Handler: _ApplicationMonitoring_GetApplicationList_Handler, }, { MethodName: "ArchiveApplicationById", Handler: _ApplicationMonitoring_ArchiveApplicationById_Handler, }, { MethodName: "EnableApplicationById", Handler: _ApplicationMonitoring_EnableApplicationById_Handler, }, { MethodName: "DisableApplicationById", Handler: _ApplicationMonitoring_DisableApplicationById_Handler, }, { MethodName: "GetApplicationListByAgentId", Handler: _ApplicationMonitoring_GetApplicationListByAgentId_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/v1/squzy_application_monitoring.proto", }
ApplicationMonitoring_ServiceDesc is the grpc.ServiceDesc for ApplicationMonitoring service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Cache_ServiceDesc = grpc.ServiceDesc{ ServiceName: "squzy.v1.cache.Cache", HandlerType: (*CacheServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "InsertScheduleWithId", Handler: _Cache_InsertScheduleWithId_Handler, }, { MethodName: "GetScheduleById", Handler: _Cache_GetScheduleById_Handler, }, { MethodName: "DeleteScheduleById", Handler: _Cache_DeleteScheduleById_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/v1/squzy_cache.proto", }
Cache_ServiceDesc is the grpc.ServiceDesc for Cache service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_proto_v1_squzy_agent_server_proto protoreflect.FileDescriptor
var File_proto_v1_squzy_application_monitoring_proto protoreflect.FileDescriptor
var File_proto_v1_squzy_cache_proto protoreflect.FileDescriptor
var File_proto_v1_squzy_incident_server_proto protoreflect.FileDescriptor
var File_proto_v1_squzy_monitoring_proto protoreflect.FileDescriptor
var File_proto_v1_squzy_notification_server_proto protoreflect.FileDescriptor
var File_proto_v1_squzy_storage_proto protoreflect.FileDescriptor
var IncidentServer_ServiceDesc = grpc.ServiceDesc{ ServiceName: "squzy.v1.incident.IncidentServer", HandlerType: (*IncidentServerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateRule", Handler: _IncidentServer_CreateRule_Handler, }, { MethodName: "GetRuleById", Handler: _IncidentServer_GetRuleById_Handler, }, { MethodName: "GetRulesByOwnerId", Handler: _IncidentServer_GetRulesByOwnerId_Handler, }, { MethodName: "RemoveRule", Handler: _IncidentServer_RemoveRule_Handler, }, { MethodName: "ValidateRule", Handler: _IncidentServer_ValidateRule_Handler, }, { MethodName: "ProcessRecordFromStorage", Handler: _IncidentServer_ProcessRecordFromStorage_Handler, }, { MethodName: "CloseIncident", Handler: _IncidentServer_CloseIncident_Handler, }, { MethodName: "ActivateRule", Handler: _IncidentServer_ActivateRule_Handler, }, { MethodName: "DeactivateRule", Handler: _IncidentServer_DeactivateRule_Handler, }, { MethodName: "StudyIncident", Handler: _IncidentServer_StudyIncident_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/v1/squzy_incident_server.proto", }
IncidentServer_ServiceDesc is the grpc.ServiceDesc for IncidentServer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var NotificationManager_ServiceDesc = grpc.ServiceDesc{ ServiceName: "squzy.v1.notification.NotificationManager", HandlerType: (*NotificationManagerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateNotificationMethod", Handler: _NotificationManager_CreateNotificationMethod_Handler, }, { MethodName: "GetById", Handler: _NotificationManager_GetById_Handler, }, { MethodName: "GetNotificationMethods", Handler: _NotificationManager_GetNotificationMethods_Handler, }, { MethodName: "DeleteById", Handler: _NotificationManager_DeleteById_Handler, }, { MethodName: "Activate", Handler: _NotificationManager_Activate_Handler, }, { MethodName: "Deactivate", Handler: _NotificationManager_Deactivate_Handler, }, { MethodName: "Add", Handler: _NotificationManager_Add_Handler, }, { MethodName: "Remove", Handler: _NotificationManager_Remove_Handler, }, { MethodName: "GetList", Handler: _NotificationManager_GetList_Handler, }, { MethodName: "Notify", Handler: _NotificationManager_Notify_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/v1/squzy_notification_server.proto", }
NotificationManager_ServiceDesc is the grpc.ServiceDesc for NotificationManager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SchedulersExecutor_ServiceDesc = grpc.ServiceDesc{ ServiceName: "squzy.v1.monitoring.SchedulersExecutor", HandlerType: (*SchedulersExecutorServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetSchedulerList", Handler: _SchedulersExecutor_GetSchedulerList_Handler, }, { MethodName: "GetSchedulerById", Handler: _SchedulersExecutor_GetSchedulerById_Handler, }, { MethodName: "Add", Handler: _SchedulersExecutor_Add_Handler, }, { MethodName: "Remove", Handler: _SchedulersExecutor_Remove_Handler, }, { MethodName: "Run", Handler: _SchedulersExecutor_Run_Handler, }, { MethodName: "Stop", Handler: _SchedulersExecutor_Stop_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/v1/squzy_monitoring.proto", }
SchedulersExecutor_ServiceDesc is the grpc.ServiceDesc for SchedulersExecutor service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Storage_ServiceDesc = grpc.ServiceDesc{ ServiceName: "squzy.v1.storage.Storage", HandlerType: (*StorageServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SaveResponseFromScheduler", Handler: _Storage_SaveResponseFromScheduler_Handler, }, { MethodName: "SaveResponseFromAgent", Handler: _Storage_SaveResponseFromAgent_Handler, }, { MethodName: "SaveTransaction", Handler: _Storage_SaveTransaction_Handler, }, { MethodName: "GetSchedulerInformation", Handler: _Storage_GetSchedulerInformation_Handler, }, { MethodName: "GetSchedulerUptime", Handler: _Storage_GetSchedulerUptime_Handler, }, { MethodName: "GetAgentInformation", Handler: _Storage_GetAgentInformation_Handler, }, { MethodName: "GetTransactionsGroup", Handler: _Storage_GetTransactionsGroup_Handler, }, { MethodName: "GetTransactions", Handler: _Storage_GetTransactions_Handler, }, { MethodName: "GetTransactionById", Handler: _Storage_GetTransactionById_Handler, }, { MethodName: "SaveIncident", Handler: _Storage_SaveIncident_Handler, }, { MethodName: "UpdateIncidentStatus", Handler: _Storage_UpdateIncidentStatus_Handler, }, { MethodName: "GetIncidentById", Handler: _Storage_GetIncidentById_Handler, }, { MethodName: "GetIncidentByRuleId", Handler: _Storage_GetIncidentByRuleId_Handler, }, { MethodName: "GetIncidentsList", Handler: _Storage_GetIncidentsList_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/v1/squzy_storage.proto", }
Storage_ServiceDesc is the grpc.ServiceDesc for Storage service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterAgentServerServer ¶ added in v1.13.0
func RegisterAgentServerServer(s grpc.ServiceRegistrar, srv AgentServerServer)
func RegisterApplicationMonitoringServer ¶ added in v1.13.0
func RegisterApplicationMonitoringServer(s grpc.ServiceRegistrar, srv ApplicationMonitoringServer)
func RegisterCacheServer ¶ added in v1.15.0
func RegisterCacheServer(s grpc.ServiceRegistrar, srv CacheServer)
func RegisterIncidentServerServer ¶ added in v1.13.0
func RegisterIncidentServerServer(s grpc.ServiceRegistrar, srv IncidentServerServer)
func RegisterNotificationManagerServer ¶ added in v1.13.0
func RegisterNotificationManagerServer(s grpc.ServiceRegistrar, srv NotificationManagerServer)
func RegisterSchedulersExecutorServer ¶ added in v1.13.0
func RegisterSchedulersExecutorServer(s grpc.ServiceRegistrar, srv SchedulersExecutorServer)
func RegisterStorageServer ¶ added in v1.13.0
func RegisterStorageServer(s grpc.ServiceRegistrar, srv StorageServer)
Types ¶
type AddRequest ¶
type AddRequest struct { // How often we need execute check Interval int32 `protobuf:"varint,1,opt,name=interval,proto3" json:"interval,omitempty"` // Timeout for check request Timeout int32 `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` // Types that are assignable to Config: // // *AddRequest_Tcp // *AddRequest_Sitemap // *AddRequest_Grpc // *AddRequest_Http // *AddRequest_HttpValue // *AddRequest_SslExpiration // *AddRequest_Mongo // *AddRequest_Postgres // *AddRequest_Cassandra // *AddRequest_Mysql Config isAddRequest_Config `protobuf_oneof:"config"` // contains filtered or unexported fields }
func (*AddRequest) Descriptor
deprecated
func (*AddRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddRequest.ProtoReflect.Descriptor instead.
func (*AddRequest) GetCassandra ¶ added in v1.16.0
func (x *AddRequest) GetCassandra() *DbConfig
func (*AddRequest) GetConfig ¶
func (m *AddRequest) GetConfig() isAddRequest_Config
func (*AddRequest) GetGrpc ¶
func (x *AddRequest) GetGrpc() *GrpcConfig
func (*AddRequest) GetHttp ¶
func (x *AddRequest) GetHttp() *HttpConfig
func (*AddRequest) GetHttpValue ¶
func (x *AddRequest) GetHttpValue() *HttpJsonValueConfig
func (*AddRequest) GetInterval ¶
func (x *AddRequest) GetInterval() int32
func (*AddRequest) GetMongo ¶ added in v1.16.0
func (x *AddRequest) GetMongo() *DbConfig
func (*AddRequest) GetMysql ¶ added in v1.16.0
func (x *AddRequest) GetMysql() *DbConfig
func (*AddRequest) GetName ¶
func (x *AddRequest) GetName() string
func (*AddRequest) GetPostgres ¶ added in v1.16.0
func (x *AddRequest) GetPostgres() *DbConfig
func (*AddRequest) GetSitemap ¶
func (x *AddRequest) GetSitemap() *SiteMapConfig
func (*AddRequest) GetSslExpiration ¶
func (x *AddRequest) GetSslExpiration() *SslExpirationConfig
func (*AddRequest) GetTcp ¶
func (x *AddRequest) GetTcp() *TcpConfig
func (*AddRequest) GetTimeout ¶
func (x *AddRequest) GetTimeout() int32
func (*AddRequest) ProtoMessage ¶
func (*AddRequest) ProtoMessage()
func (*AddRequest) ProtoReflect ¶
func (x *AddRequest) ProtoReflect() protoreflect.Message
func (*AddRequest) Reset ¶
func (x *AddRequest) Reset()
func (*AddRequest) String ¶
func (x *AddRequest) String() string
type AddRequest_Cassandra ¶ added in v1.16.0
type AddRequest_Cassandra struct {
Cassandra *DbConfig `protobuf:"bytes,12,opt,name=cassandra,proto3,oneof"`
}
type AddRequest_Grpc ¶
type AddRequest_Grpc struct {
Grpc *GrpcConfig `protobuf:"bytes,6,opt,name=grpc,proto3,oneof"`
}
type AddRequest_Http ¶
type AddRequest_Http struct {
Http *HttpConfig `protobuf:"bytes,7,opt,name=http,proto3,oneof"`
}
type AddRequest_HttpValue ¶
type AddRequest_HttpValue struct {
HttpValue *HttpJsonValueConfig `protobuf:"bytes,8,opt,name=http_value,json=httpValue,proto3,oneof"`
}
type AddRequest_Mongo ¶ added in v1.16.0
type AddRequest_Mongo struct {
Mongo *DbConfig `protobuf:"bytes,10,opt,name=mongo,proto3,oneof"`
}
type AddRequest_Mysql ¶ added in v1.16.0
type AddRequest_Mysql struct {
Mysql *DbConfig `protobuf:"bytes,13,opt,name=mysql,proto3,oneof"`
}
type AddRequest_Postgres ¶ added in v1.16.0
type AddRequest_Postgres struct {
Postgres *DbConfig `protobuf:"bytes,11,opt,name=postgres,proto3,oneof"`
}
type AddRequest_Sitemap ¶
type AddRequest_Sitemap struct {
Sitemap *SiteMapConfig `protobuf:"bytes,5,opt,name=sitemap,proto3,oneof"`
}
type AddRequest_SslExpiration ¶
type AddRequest_SslExpiration struct {
SslExpiration *SslExpirationConfig `protobuf:"bytes,9,opt,name=ssl_expiration,json=sslExpiration,proto3,oneof"`
}
type AddRequest_Tcp ¶
type AddRequest_Tcp struct {
Tcp *TcpConfig `protobuf:"bytes,4,opt,name=tcp,proto3,oneof"`
}
type AddResponse ¶
type AddResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*AddResponse) Descriptor
deprecated
func (*AddResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddResponse.ProtoReflect.Descriptor instead.
func (*AddResponse) GetId ¶
func (x *AddResponse) GetId() string
func (*AddResponse) ProtoMessage ¶
func (*AddResponse) ProtoMessage()
func (*AddResponse) ProtoReflect ¶
func (x *AddResponse) ProtoReflect() protoreflect.Message
func (*AddResponse) Reset ¶
func (x *AddResponse) Reset()
func (*AddResponse) String ¶
func (x *AddResponse) String() string
type AgentIdRequest ¶
type AgentIdRequest struct { AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"` // contains filtered or unexported fields }
func (*AgentIdRequest) Descriptor
deprecated
func (*AgentIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use AgentIdRequest.ProtoReflect.Descriptor instead.
func (*AgentIdRequest) GetAgentId ¶
func (x *AgentIdRequest) GetAgentId() string
func (*AgentIdRequest) ProtoMessage ¶
func (*AgentIdRequest) ProtoMessage()
func (*AgentIdRequest) ProtoReflect ¶
func (x *AgentIdRequest) ProtoReflect() protoreflect.Message
func (*AgentIdRequest) Reset ¶
func (x *AgentIdRequest) Reset()
func (*AgentIdRequest) String ¶
func (x *AgentIdRequest) String() string
type AgentItem ¶
type AgentItem struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` AgentName string `protobuf:"bytes,2,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"` Status AgentStatus `protobuf:"varint,3,opt,name=status,proto3,enum=squzy.v1.agent.AgentStatus" json:"status,omitempty"` HostInfo *HostInfo `protobuf:"bytes,4,opt,name=host_info,json=hostInfo,proto3" json:"host_info,omitempty"` Interval int64 `protobuf:"varint,5,opt,name=interval,proto3" json:"interval,omitempty"` // contains filtered or unexported fields }
func (*AgentItem) Descriptor
deprecated
func (*AgentItem) GetAgentName ¶
func (*AgentItem) GetHostInfo ¶
func (*AgentItem) GetInterval ¶
func (*AgentItem) GetStatus ¶
func (x *AgentItem) GetStatus() AgentStatus
func (*AgentItem) ProtoMessage ¶
func (*AgentItem) ProtoMessage()
func (*AgentItem) ProtoReflect ¶
func (x *AgentItem) ProtoReflect() protoreflect.Message
type AgentServerClient ¶ added in v1.13.0
type AgentServerClient interface { Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error) GetByAgentName(ctx context.Context, in *GetByAgentNameRequest, opts ...grpc.CallOption) (*GetAgentListResponse, error) GetAgentById(ctx context.Context, in *GetAgentByIdRequest, opts ...grpc.CallOption) (*AgentItem, error) UnRegister(ctx context.Context, in *UnRegisterRequest, opts ...grpc.CallOption) (*UnRegisterResponse, error) GetAgentList(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetAgentListResponse, error) SendMetrics(ctx context.Context, opts ...grpc.CallOption) (AgentServer_SendMetricsClient, error) }
AgentServerClient is the client API for AgentServer service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAgentServerClient ¶ added in v1.13.0
func NewAgentServerClient(cc grpc.ClientConnInterface) AgentServerClient
type AgentServerServer ¶ added in v1.13.0
type AgentServerServer interface { Register(context.Context, *RegisterRequest) (*RegisterResponse, error) GetByAgentName(context.Context, *GetByAgentNameRequest) (*GetAgentListResponse, error) GetAgentById(context.Context, *GetAgentByIdRequest) (*AgentItem, error) UnRegister(context.Context, *UnRegisterRequest) (*UnRegisterResponse, error) GetAgentList(context.Context, *emptypb.Empty) (*GetAgentListResponse, error) SendMetrics(AgentServer_SendMetricsServer) error // contains filtered or unexported methods }
AgentServerServer is the server API for AgentServer service. All implementations must embed UnimplementedAgentServerServer for forward compatibility
type AgentServer_SendMetricsClient ¶ added in v1.13.0
type AgentServer_SendMetricsClient interface { Send(*SendMetricsRequest) error CloseAndRecv() (*emptypb.Empty, error) grpc.ClientStream }
type AgentServer_SendMetricsServer ¶ added in v1.13.0
type AgentServer_SendMetricsServer interface { SendAndClose(*emptypb.Empty) error Recv() (*SendMetricsRequest, error) grpc.ServerStream }
type AgentStatus ¶
type AgentStatus int32
const ( // Initial status AgentStatus_AGENT_STATUS_UNSPECIFIED AgentStatus = 0 // Agent is runned but not send stat yet AgentStatus_REGISTRED AgentStatus = 1 // Actually send stat AgentStatus_RUNNED AgentStatus = 2 // Stopped to send stat AgentStatus_DISCONNECTED AgentStatus = 3 // Unregistred AgentStatus_UNREGISTRED AgentStatus = 4 )
func (AgentStatus) Descriptor ¶
func (AgentStatus) Descriptor() protoreflect.EnumDescriptor
func (AgentStatus) Enum ¶
func (x AgentStatus) Enum() *AgentStatus
func (AgentStatus) EnumDescriptor
deprecated
func (AgentStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use AgentStatus.Descriptor instead.
func (AgentStatus) Number ¶
func (x AgentStatus) Number() protoreflect.EnumNumber
func (AgentStatus) String ¶
func (x AgentStatus) String() string
func (AgentStatus) Type ¶
func (AgentStatus) Type() protoreflect.EnumType
type Application ¶
type Application struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Uniq name provided from developer Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // host name HostName string `protobuf:"bytes,3,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"` // Is application can recieved transactions Status ApplicationStatus `protobuf:"varint,4,opt,name=status,proto3,enum=squzy.v1.monitoring.ApplicationStatus" json:"status,omitempty"` // contains filtered or unexported fields }
func (*Application) Descriptor
deprecated
func (*Application) Descriptor() ([]byte, []int)
Deprecated: Use Application.ProtoReflect.Descriptor instead.
func (*Application) GetHostName ¶
func (x *Application) GetHostName() string
func (*Application) GetId ¶
func (x *Application) GetId() string
func (*Application) GetName ¶
func (x *Application) GetName() string
func (*Application) GetStatus ¶
func (x *Application) GetStatus() ApplicationStatus
func (*Application) ProtoMessage ¶
func (*Application) ProtoMessage()
func (*Application) ProtoReflect ¶
func (x *Application) ProtoReflect() protoreflect.Message
func (*Application) Reset ¶
func (x *Application) Reset()
func (*Application) String ¶
func (x *Application) String() string
type ApplicationByIdReuqest ¶
type ApplicationByIdReuqest struct { ApplicationId string `protobuf:"bytes,1,opt,name=application_id,json=applicationId,proto3" json:"application_id,omitempty"` // contains filtered or unexported fields }
func (*ApplicationByIdReuqest) Descriptor
deprecated
func (*ApplicationByIdReuqest) Descriptor() ([]byte, []int)
Deprecated: Use ApplicationByIdReuqest.ProtoReflect.Descriptor instead.
func (*ApplicationByIdReuqest) GetApplicationId ¶
func (x *ApplicationByIdReuqest) GetApplicationId() string
func (*ApplicationByIdReuqest) ProtoMessage ¶
func (*ApplicationByIdReuqest) ProtoMessage()
func (*ApplicationByIdReuqest) ProtoReflect ¶
func (x *ApplicationByIdReuqest) ProtoReflect() protoreflect.Message
func (*ApplicationByIdReuqest) Reset ¶
func (x *ApplicationByIdReuqest) Reset()
func (*ApplicationByIdReuqest) String ¶
func (x *ApplicationByIdReuqest) String() string
type ApplicationInfo ¶
type ApplicationInfo struct { // Uniq name provided from developer Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // host name HostName string `protobuf:"bytes,2,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"` // agent id on host AgentId string `protobuf:"bytes,3,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"` // contains filtered or unexported fields }
func (*ApplicationInfo) Descriptor
deprecated
func (*ApplicationInfo) Descriptor() ([]byte, []int)
Deprecated: Use ApplicationInfo.ProtoReflect.Descriptor instead.
func (*ApplicationInfo) GetAgentId ¶
func (x *ApplicationInfo) GetAgentId() string
func (*ApplicationInfo) GetHostName ¶
func (x *ApplicationInfo) GetHostName() string
func (*ApplicationInfo) GetName ¶
func (x *ApplicationInfo) GetName() string
func (*ApplicationInfo) ProtoMessage ¶
func (*ApplicationInfo) ProtoMessage()
func (*ApplicationInfo) ProtoReflect ¶
func (x *ApplicationInfo) ProtoReflect() protoreflect.Message
func (*ApplicationInfo) Reset ¶
func (x *ApplicationInfo) Reset()
func (*ApplicationInfo) String ¶
func (x *ApplicationInfo) String() string
type ApplicationMonitoringClient ¶ added in v1.13.0
type ApplicationMonitoringClient interface { // protolint:disable:next MAX_LINE_LENGTH InitializeApplication(ctx context.Context, in *ApplicationInfo, opts ...grpc.CallOption) (*InitializeApplicationResponse, error) SaveTransaction(ctx context.Context, in *TransactionInfo, opts ...grpc.CallOption) (*emptypb.Empty, error) GetApplicationById(ctx context.Context, in *ApplicationByIdReuqest, opts ...grpc.CallOption) (*Application, error) // protolint:disable:next MAX_LINE_LENGTH GetApplicationList(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetApplicationListResponse, error) // protolint:disable:next MAX_LINE_LENGTH ArchiveApplicationById(ctx context.Context, in *ApplicationByIdReuqest, opts ...grpc.CallOption) (*Application, error) EnableApplicationById(ctx context.Context, in *ApplicationByIdReuqest, opts ...grpc.CallOption) (*Application, error) DisableApplicationById(ctx context.Context, in *ApplicationByIdReuqest, opts ...grpc.CallOption) (*Application, error) // protolint:disable:next MAX_LINE_LENGTH GetApplicationListByAgentId(ctx context.Context, in *AgentIdRequest, opts ...grpc.CallOption) (*GetApplicationListResponse, error) }
ApplicationMonitoringClient is the client API for ApplicationMonitoring service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewApplicationMonitoringClient ¶ added in v1.13.0
func NewApplicationMonitoringClient(cc grpc.ClientConnInterface) ApplicationMonitoringClient
type ApplicationMonitoringServer ¶ added in v1.13.0
type ApplicationMonitoringServer interface { // protolint:disable:next MAX_LINE_LENGTH InitializeApplication(context.Context, *ApplicationInfo) (*InitializeApplicationResponse, error) SaveTransaction(context.Context, *TransactionInfo) (*emptypb.Empty, error) GetApplicationById(context.Context, *ApplicationByIdReuqest) (*Application, error) // protolint:disable:next MAX_LINE_LENGTH GetApplicationList(context.Context, *emptypb.Empty) (*GetApplicationListResponse, error) // protolint:disable:next MAX_LINE_LENGTH ArchiveApplicationById(context.Context, *ApplicationByIdReuqest) (*Application, error) EnableApplicationById(context.Context, *ApplicationByIdReuqest) (*Application, error) DisableApplicationById(context.Context, *ApplicationByIdReuqest) (*Application, error) // protolint:disable:next MAX_LINE_LENGTH GetApplicationListByAgentId(context.Context, *AgentIdRequest) (*GetApplicationListResponse, error) // contains filtered or unexported methods }
ApplicationMonitoringServer is the server API for ApplicationMonitoring service. All implementations must embed UnimplementedApplicationMonitoringServer for forward compatibility
type ApplicationStatus ¶
type ApplicationStatus int32
const ( ApplicationStatus_APPLICATION_STATUS_UNSPECIFIED ApplicationStatus = 0 ApplicationStatus_APPLICATION_STATUS_ENABLED ApplicationStatus = 1 ApplicationStatus_APPLICATION_STATUS_DISABLED ApplicationStatus = 2 ApplicationStatus_APPLICATION_STATUS_ARCHIVED ApplicationStatus = 3 )
func (ApplicationStatus) Descriptor ¶
func (ApplicationStatus) Descriptor() protoreflect.EnumDescriptor
func (ApplicationStatus) Enum ¶
func (x ApplicationStatus) Enum() *ApplicationStatus
func (ApplicationStatus) EnumDescriptor
deprecated
func (ApplicationStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use ApplicationStatus.Descriptor instead.
func (ApplicationStatus) Number ¶
func (x ApplicationStatus) Number() protoreflect.EnumNumber
func (ApplicationStatus) String ¶
func (x ApplicationStatus) String() string
func (ApplicationStatus) Type ¶
func (ApplicationStatus) Type() protoreflect.EnumType
type CacheClient ¶ added in v1.15.0
type CacheClient interface { // protolint:disable:next MAX_LINE_LENGTH InsertScheduleWithId(ctx context.Context, in *InsertScheduleWithIdRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // protolint:disable:next MAX_LINE_LENGTH GetScheduleById(ctx context.Context, in *GetScheduleWithIdRequest, opts ...grpc.CallOption) (*GetScheduleWithIdResponse, error) // protolint:disable:next MAX_LINE_LENGTH DeleteScheduleById(ctx context.Context, in *DeleteScheduleWithIdRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) }
CacheClient is the client API for Cache service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewCacheClient ¶ added in v1.15.0
func NewCacheClient(cc grpc.ClientConnInterface) CacheClient
type CacheServer ¶ added in v1.15.0
type CacheServer interface { // protolint:disable:next MAX_LINE_LENGTH InsertScheduleWithId(context.Context, *InsertScheduleWithIdRequest) (*emptypb.Empty, error) // protolint:disable:next MAX_LINE_LENGTH GetScheduleById(context.Context, *GetScheduleWithIdRequest) (*GetScheduleWithIdResponse, error) // protolint:disable:next MAX_LINE_LENGTH DeleteScheduleById(context.Context, *DeleteScheduleWithIdRequest) (*emptypb.Empty, error) // contains filtered or unexported methods }
CacheServer is the server API for Cache service. All implementations must embed UnimplementedCacheServer for forward compatibility
type ComponentOwnerType ¶
type ComponentOwnerType int32
const ( ComponentOwnerType_COMPONENT_OWNER_TYPE_UNSPECIFIED ComponentOwnerType = 0 ComponentOwnerType_COMPONENT_OWNER_TYPE_SCHEDULER ComponentOwnerType = 1 ComponentOwnerType_COMPONENT_OWNER_TYPE_AGENT ComponentOwnerType = 2 ComponentOwnerType_COMPONENT_OWNER_TYPE_APPLICATION ComponentOwnerType = 3 )
func (ComponentOwnerType) Descriptor ¶
func (ComponentOwnerType) Descriptor() protoreflect.EnumDescriptor
func (ComponentOwnerType) Enum ¶
func (x ComponentOwnerType) Enum() *ComponentOwnerType
func (ComponentOwnerType) EnumDescriptor
deprecated
func (ComponentOwnerType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ComponentOwnerType.Descriptor instead.
func (ComponentOwnerType) Number ¶
func (x ComponentOwnerType) Number() protoreflect.EnumNumber
func (ComponentOwnerType) String ¶
func (x ComponentOwnerType) String() string
func (ComponentOwnerType) Type ¶
func (ComponentOwnerType) Type() protoreflect.EnumType
type CpuInfo ¶
type CpuInfo struct { // protolint:disable:next REPEATED_FIELD_NAMES_PLURALIZED Cpus []*CpuInfo_CPU `protobuf:"bytes,1,rep,name=cpus,proto3" json:"cpus,omitempty"` // contains filtered or unexported fields }
func (*CpuInfo) Descriptor
deprecated
func (*CpuInfo) GetCpus ¶
func (x *CpuInfo) GetCpus() []*CpuInfo_CPU
func (*CpuInfo) ProtoMessage ¶
func (*CpuInfo) ProtoMessage()
func (*CpuInfo) ProtoReflect ¶
func (x *CpuInfo) ProtoReflect() protoreflect.Message
type CpuInfo_CPU ¶
type CpuInfo_CPU struct { Load float64 `protobuf:"fixed64,1,opt,name=load,proto3" json:"load,omitempty"` // contains filtered or unexported fields }
func (*CpuInfo_CPU) Descriptor
deprecated
func (*CpuInfo_CPU) Descriptor() ([]byte, []int)
Deprecated: Use CpuInfo_CPU.ProtoReflect.Descriptor instead.
func (*CpuInfo_CPU) GetLoad ¶
func (x *CpuInfo_CPU) GetLoad() float64
func (*CpuInfo_CPU) ProtoMessage ¶
func (*CpuInfo_CPU) ProtoMessage()
func (*CpuInfo_CPU) ProtoReflect ¶
func (x *CpuInfo_CPU) ProtoReflect() protoreflect.Message
func (*CpuInfo_CPU) Reset ¶
func (x *CpuInfo_CPU) Reset()
func (*CpuInfo_CPU) String ¶
func (x *CpuInfo_CPU) String() string
type CreateNotificationMethodRequest ¶
type CreateNotificationMethodRequest struct { Type NotificationMethodType `protobuf:"varint,1,opt,name=type,proto3,enum=squzy.v1.notification.NotificationMethodType" json:"type,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Types that are assignable to Method: // // *CreateNotificationMethodRequest_Slack // *CreateNotificationMethodRequest_Webhook Method isCreateNotificationMethodRequest_Method `protobuf_oneof:"method"` // contains filtered or unexported fields }
func (*CreateNotificationMethodRequest) Descriptor
deprecated
func (*CreateNotificationMethodRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateNotificationMethodRequest.ProtoReflect.Descriptor instead.
func (*CreateNotificationMethodRequest) GetMethod ¶
func (m *CreateNotificationMethodRequest) GetMethod() isCreateNotificationMethodRequest_Method
func (*CreateNotificationMethodRequest) GetName ¶
func (x *CreateNotificationMethodRequest) GetName() string
func (*CreateNotificationMethodRequest) GetSlack ¶
func (x *CreateNotificationMethodRequest) GetSlack() *SlackMethod
func (*CreateNotificationMethodRequest) GetType ¶
func (x *CreateNotificationMethodRequest) GetType() NotificationMethodType
func (*CreateNotificationMethodRequest) GetWebhook ¶
func (x *CreateNotificationMethodRequest) GetWebhook() *WebHookMethod
func (*CreateNotificationMethodRequest) ProtoMessage ¶
func (*CreateNotificationMethodRequest) ProtoMessage()
func (*CreateNotificationMethodRequest) ProtoReflect ¶
func (x *CreateNotificationMethodRequest) ProtoReflect() protoreflect.Message
func (*CreateNotificationMethodRequest) Reset ¶
func (x *CreateNotificationMethodRequest) Reset()
func (*CreateNotificationMethodRequest) String ¶
func (x *CreateNotificationMethodRequest) String() string
type CreateNotificationMethodRequest_Slack ¶
type CreateNotificationMethodRequest_Slack struct {
Slack *SlackMethod `protobuf:"bytes,3,opt,name=slack,proto3,oneof"`
}
type CreateNotificationMethodRequest_Webhook ¶
type CreateNotificationMethodRequest_Webhook struct {
Webhook *WebHookMethod `protobuf:"bytes,4,opt,name=webhook,proto3,oneof"`
}
type CreateRuleRequest ¶
type CreateRuleRequest struct { Rule string `protobuf:"bytes,1,opt,name=rule,proto3" json:"rule,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` AutoClose bool `protobuf:"varint,3,opt,name=auto_close,json=autoClose,proto3" json:"auto_close,omitempty"` OwnerType ComponentOwnerType `` /* 129-byte string literal not displayed */ OwnerId string `protobuf:"bytes,5,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"` Notification bool `protobuf:"varint,6,opt,name=notification,proto3" json:"notification,omitempty"` // contains filtered or unexported fields }
func (*CreateRuleRequest) Descriptor
deprecated
func (*CreateRuleRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateRuleRequest.ProtoReflect.Descriptor instead.
func (*CreateRuleRequest) GetAutoClose ¶
func (x *CreateRuleRequest) GetAutoClose() bool
func (*CreateRuleRequest) GetName ¶
func (x *CreateRuleRequest) GetName() string
func (*CreateRuleRequest) GetNotification ¶
func (x *CreateRuleRequest) GetNotification() bool
func (*CreateRuleRequest) GetOwnerId ¶
func (x *CreateRuleRequest) GetOwnerId() string
func (*CreateRuleRequest) GetOwnerType ¶
func (x *CreateRuleRequest) GetOwnerType() ComponentOwnerType
func (*CreateRuleRequest) GetRule ¶
func (x *CreateRuleRequest) GetRule() string
func (*CreateRuleRequest) ProtoMessage ¶
func (*CreateRuleRequest) ProtoMessage()
func (*CreateRuleRequest) ProtoReflect ¶
func (x *CreateRuleRequest) ProtoReflect() protoreflect.Message
func (*CreateRuleRequest) Reset ¶
func (x *CreateRuleRequest) Reset()
func (*CreateRuleRequest) String ¶
func (x *CreateRuleRequest) String() string
type DbConfig ¶ added in v1.16.0
type DbConfig struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` User string `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"` Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"` DbName string `protobuf:"bytes,5,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"` Cluster string `protobuf:"bytes,6,opt,name=cluster,proto3" json:"cluster,omitempty"` // contains filtered or unexported fields }
func (*DbConfig) Descriptor
deprecated
added in
v1.16.0
func (*DbConfig) GetCluster ¶ added in v1.16.0
func (*DbConfig) GetPassword ¶ added in v1.16.0
func (*DbConfig) ProtoMessage ¶ added in v1.16.0
func (*DbConfig) ProtoMessage()
func (*DbConfig) ProtoReflect ¶ added in v1.16.0
func (x *DbConfig) ProtoReflect() protoreflect.Message
type DeleteScheduleWithIdRequest ¶ added in v1.15.0
type DeleteScheduleWithIdRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*DeleteScheduleWithIdRequest) Descriptor
deprecated
added in
v1.15.0
func (*DeleteScheduleWithIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteScheduleWithIdRequest.ProtoReflect.Descriptor instead.
func (*DeleteScheduleWithIdRequest) GetId ¶ added in v1.15.0
func (x *DeleteScheduleWithIdRequest) GetId() string
func (*DeleteScheduleWithIdRequest) ProtoMessage ¶ added in v1.15.0
func (*DeleteScheduleWithIdRequest) ProtoMessage()
func (*DeleteScheduleWithIdRequest) ProtoReflect ¶ added in v1.15.0
func (x *DeleteScheduleWithIdRequest) ProtoReflect() protoreflect.Message
func (*DeleteScheduleWithIdRequest) Reset ¶ added in v1.15.0
func (x *DeleteScheduleWithIdRequest) Reset()
func (*DeleteScheduleWithIdRequest) String ¶ added in v1.15.0
func (x *DeleteScheduleWithIdRequest) String() string
type DiskInfo ¶
type DiskInfo struct { Disks map[string]*DiskInfo_Disk `` /* 151-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DiskInfo) Descriptor
deprecated
func (*DiskInfo) GetDisks ¶
func (x *DiskInfo) GetDisks() map[string]*DiskInfo_Disk
func (*DiskInfo) ProtoMessage ¶
func (*DiskInfo) ProtoMessage()
func (*DiskInfo) ProtoReflect ¶
func (x *DiskInfo) ProtoReflect() protoreflect.Message
type DiskInfo_Disk ¶
type DiskInfo_Disk struct { Total uint64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` Free uint64 `protobuf:"varint,2,opt,name=free,proto3" json:"free,omitempty"` Used uint64 `protobuf:"varint,3,opt,name=used,proto3" json:"used,omitempty"` UsedPercent float64 `protobuf:"fixed64,4,opt,name=used_percent,json=usedPercent,proto3" json:"used_percent,omitempty"` // contains filtered or unexported fields }
func (*DiskInfo_Disk) Descriptor
deprecated
func (*DiskInfo_Disk) Descriptor() ([]byte, []int)
Deprecated: Use DiskInfo_Disk.ProtoReflect.Descriptor instead.
func (*DiskInfo_Disk) GetFree ¶
func (x *DiskInfo_Disk) GetFree() uint64
func (*DiskInfo_Disk) GetTotal ¶
func (x *DiskInfo_Disk) GetTotal() uint64
func (*DiskInfo_Disk) GetUsed ¶
func (x *DiskInfo_Disk) GetUsed() uint64
func (*DiskInfo_Disk) GetUsedPercent ¶
func (x *DiskInfo_Disk) GetUsedPercent() float64
func (*DiskInfo_Disk) ProtoMessage ¶
func (*DiskInfo_Disk) ProtoMessage()
func (*DiskInfo_Disk) ProtoReflect ¶
func (x *DiskInfo_Disk) ProtoReflect() protoreflect.Message
func (*DiskInfo_Disk) Reset ¶
func (x *DiskInfo_Disk) Reset()
func (*DiskInfo_Disk) String ¶
func (x *DiskInfo_Disk) String() string
type GetAgentByIdRequest ¶
type GetAgentByIdRequest struct { AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"` // contains filtered or unexported fields }
func (*GetAgentByIdRequest) Descriptor
deprecated
func (*GetAgentByIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetAgentByIdRequest.ProtoReflect.Descriptor instead.
func (*GetAgentByIdRequest) GetAgentId ¶
func (x *GetAgentByIdRequest) GetAgentId() string
func (*GetAgentByIdRequest) ProtoMessage ¶
func (*GetAgentByIdRequest) ProtoMessage()
func (*GetAgentByIdRequest) ProtoReflect ¶
func (x *GetAgentByIdRequest) ProtoReflect() protoreflect.Message
func (*GetAgentByIdRequest) Reset ¶
func (x *GetAgentByIdRequest) Reset()
func (*GetAgentByIdRequest) String ¶
func (x *GetAgentByIdRequest) String() string
type GetAgentInformationRequest ¶
type GetAgentInformationRequest struct { AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"` Type TypeAgentStat `protobuf:"varint,2,opt,name=type,proto3,enum=squzy.v1.storage.TypeAgentStat" json:"type,omitempty"` Pagination *Pagination `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"` // nil no pagination TimeRange *TimeFilter `protobuf:"bytes,4,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"` // nil not set (filter by timestamp) // contains filtered or unexported fields }
func (*GetAgentInformationRequest) Descriptor
deprecated
func (*GetAgentInformationRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetAgentInformationRequest.ProtoReflect.Descriptor instead.
func (*GetAgentInformationRequest) GetAgentId ¶
func (x *GetAgentInformationRequest) GetAgentId() string
func (*GetAgentInformationRequest) GetPagination ¶
func (x *GetAgentInformationRequest) GetPagination() *Pagination
func (*GetAgentInformationRequest) GetTimeRange ¶
func (x *GetAgentInformationRequest) GetTimeRange() *TimeFilter
func (*GetAgentInformationRequest) GetType ¶
func (x *GetAgentInformationRequest) GetType() TypeAgentStat
func (*GetAgentInformationRequest) ProtoMessage ¶
func (*GetAgentInformationRequest) ProtoMessage()
func (*GetAgentInformationRequest) ProtoReflect ¶
func (x *GetAgentInformationRequest) ProtoReflect() protoreflect.Message
func (*GetAgentInformationRequest) Reset ¶
func (x *GetAgentInformationRequest) Reset()
func (*GetAgentInformationRequest) String ¶
func (x *GetAgentInformationRequest) String() string
type GetAgentInformationResponse ¶
type GetAgentInformationResponse struct { Stats []*GetAgentInformationResponse_Statistic `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"` Count int32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*GetAgentInformationResponse) Descriptor
deprecated
func (*GetAgentInformationResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetAgentInformationResponse.ProtoReflect.Descriptor instead.
func (*GetAgentInformationResponse) GetCount ¶
func (x *GetAgentInformationResponse) GetCount() int32
func (*GetAgentInformationResponse) GetStats ¶
func (x *GetAgentInformationResponse) GetStats() []*GetAgentInformationResponse_Statistic
func (*GetAgentInformationResponse) ProtoMessage ¶
func (*GetAgentInformationResponse) ProtoMessage()
func (*GetAgentInformationResponse) ProtoReflect ¶
func (x *GetAgentInformationResponse) ProtoReflect() protoreflect.Message
func (*GetAgentInformationResponse) Reset ¶
func (x *GetAgentInformationResponse) Reset()
func (*GetAgentInformationResponse) String ¶
func (x *GetAgentInformationResponse) String() string
type GetAgentInformationResponse_Statistic ¶
type GetAgentInformationResponse_Statistic struct { Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"` CpuInfo *CpuInfo `protobuf:"bytes,2,opt,name=cpu_info,json=cpuInfo,proto3" json:"cpu_info,omitempty"` MemoryInfo *MemoryInfo `protobuf:"bytes,3,opt,name=memory_info,json=memoryInfo,proto3" json:"memory_info,omitempty"` DiskInfo *DiskInfo `protobuf:"bytes,4,opt,name=disk_info,json=diskInfo,proto3" json:"disk_info,omitempty"` NetInfo *NetInfo `protobuf:"bytes,5,opt,name=net_info,json=netInfo,proto3" json:"net_info,omitempty"` // contains filtered or unexported fields }
func (*GetAgentInformationResponse_Statistic) Descriptor
deprecated
func (*GetAgentInformationResponse_Statistic) Descriptor() ([]byte, []int)
Deprecated: Use GetAgentInformationResponse_Statistic.ProtoReflect.Descriptor instead.
func (*GetAgentInformationResponse_Statistic) GetCpuInfo ¶
func (x *GetAgentInformationResponse_Statistic) GetCpuInfo() *CpuInfo
func (*GetAgentInformationResponse_Statistic) GetDiskInfo ¶
func (x *GetAgentInformationResponse_Statistic) GetDiskInfo() *DiskInfo
func (*GetAgentInformationResponse_Statistic) GetMemoryInfo ¶
func (x *GetAgentInformationResponse_Statistic) GetMemoryInfo() *MemoryInfo
func (*GetAgentInformationResponse_Statistic) GetNetInfo ¶
func (x *GetAgentInformationResponse_Statistic) GetNetInfo() *NetInfo
func (*GetAgentInformationResponse_Statistic) GetTime ¶
func (x *GetAgentInformationResponse_Statistic) GetTime() *timestamppb.Timestamp
func (*GetAgentInformationResponse_Statistic) ProtoMessage ¶
func (*GetAgentInformationResponse_Statistic) ProtoMessage()
func (*GetAgentInformationResponse_Statistic) ProtoReflect ¶
func (x *GetAgentInformationResponse_Statistic) ProtoReflect() protoreflect.Message
func (*GetAgentInformationResponse_Statistic) Reset ¶
func (x *GetAgentInformationResponse_Statistic) Reset()
func (*GetAgentInformationResponse_Statistic) String ¶
func (x *GetAgentInformationResponse_Statistic) String() string
type GetAgentListResponse ¶
type GetAgentListResponse struct { Agents []*AgentItem `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"` // contains filtered or unexported fields }
func (*GetAgentListResponse) Descriptor
deprecated
func (*GetAgentListResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetAgentListResponse.ProtoReflect.Descriptor instead.
func (*GetAgentListResponse) GetAgents ¶
func (x *GetAgentListResponse) GetAgents() []*AgentItem
func (*GetAgentListResponse) ProtoMessage ¶
func (*GetAgentListResponse) ProtoMessage()
func (*GetAgentListResponse) ProtoReflect ¶
func (x *GetAgentListResponse) ProtoReflect() protoreflect.Message
func (*GetAgentListResponse) Reset ¶
func (x *GetAgentListResponse) Reset()
func (*GetAgentListResponse) String ¶
func (x *GetAgentListResponse) String() string
type GetApplicationListResponse ¶
type GetApplicationListResponse struct { Applications []*Application `protobuf:"bytes,1,rep,name=applications,proto3" json:"applications,omitempty"` // contains filtered or unexported fields }
func (*GetApplicationListResponse) Descriptor
deprecated
func (*GetApplicationListResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetApplicationListResponse.ProtoReflect.Descriptor instead.
func (*GetApplicationListResponse) GetApplications ¶
func (x *GetApplicationListResponse) GetApplications() []*Application
func (*GetApplicationListResponse) ProtoMessage ¶
func (*GetApplicationListResponse) ProtoMessage()
func (*GetApplicationListResponse) ProtoReflect ¶
func (x *GetApplicationListResponse) ProtoReflect() protoreflect.Message
func (*GetApplicationListResponse) Reset ¶
func (x *GetApplicationListResponse) Reset()
func (*GetApplicationListResponse) String ¶
func (x *GetApplicationListResponse) String() string
type GetByAgentNameRequest ¶
type GetByAgentNameRequest struct { AgentName string `protobuf:"bytes,1,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"` // contains filtered or unexported fields }
func (*GetByAgentNameRequest) Descriptor
deprecated
func (*GetByAgentNameRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetByAgentNameRequest.ProtoReflect.Descriptor instead.
func (*GetByAgentNameRequest) GetAgentName ¶
func (x *GetByAgentNameRequest) GetAgentName() string
func (*GetByAgentNameRequest) ProtoMessage ¶
func (*GetByAgentNameRequest) ProtoMessage()
func (*GetByAgentNameRequest) ProtoReflect ¶
func (x *GetByAgentNameRequest) ProtoReflect() protoreflect.Message
func (*GetByAgentNameRequest) Reset ¶
func (x *GetByAgentNameRequest) Reset()
func (*GetByAgentNameRequest) String ¶
func (x *GetByAgentNameRequest) String() string
type GetIncidentsListRequest ¶
type GetIncidentsListRequest struct { Status IncidentStatus `protobuf:"varint,1,opt,name=status,proto3,enum=squzy.v1.incident.IncidentStatus" json:"status,omitempty"` RuleId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"` Pagination *Pagination `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"` TimeRange *TimeFilter `protobuf:"bytes,4,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"` Sort *SortingIncidentList `protobuf:"bytes,5,opt,name=sort,proto3" json:"sort,omitempty"` // contains filtered or unexported fields }
func (*GetIncidentsListRequest) Descriptor
deprecated
func (*GetIncidentsListRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetIncidentsListRequest.ProtoReflect.Descriptor instead.
func (*GetIncidentsListRequest) GetPagination ¶
func (x *GetIncidentsListRequest) GetPagination() *Pagination
func (*GetIncidentsListRequest) GetRuleId ¶
func (x *GetIncidentsListRequest) GetRuleId() *wrapperspb.StringValue
func (*GetIncidentsListRequest) GetSort ¶
func (x *GetIncidentsListRequest) GetSort() *SortingIncidentList
func (*GetIncidentsListRequest) GetStatus ¶
func (x *GetIncidentsListRequest) GetStatus() IncidentStatus
func (*GetIncidentsListRequest) GetTimeRange ¶
func (x *GetIncidentsListRequest) GetTimeRange() *TimeFilter
func (*GetIncidentsListRequest) ProtoMessage ¶
func (*GetIncidentsListRequest) ProtoMessage()
func (*GetIncidentsListRequest) ProtoReflect ¶
func (x *GetIncidentsListRequest) ProtoReflect() protoreflect.Message
func (*GetIncidentsListRequest) Reset ¶
func (x *GetIncidentsListRequest) Reset()
func (*GetIncidentsListRequest) String ¶
func (x *GetIncidentsListRequest) String() string
type GetIncidentsListResponse ¶
type GetIncidentsListResponse struct { Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` Incidents []*Incident `protobuf:"bytes,2,rep,name=incidents,proto3" json:"incidents,omitempty"` // contains filtered or unexported fields }
func (*GetIncidentsListResponse) Descriptor
deprecated
func (*GetIncidentsListResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetIncidentsListResponse.ProtoReflect.Descriptor instead.
func (*GetIncidentsListResponse) GetCount ¶
func (x *GetIncidentsListResponse) GetCount() int64
func (*GetIncidentsListResponse) GetIncidents ¶
func (x *GetIncidentsListResponse) GetIncidents() []*Incident
func (*GetIncidentsListResponse) ProtoMessage ¶
func (*GetIncidentsListResponse) ProtoMessage()
func (*GetIncidentsListResponse) ProtoReflect ¶
func (x *GetIncidentsListResponse) ProtoReflect() protoreflect.Message
func (*GetIncidentsListResponse) Reset ¶
func (x *GetIncidentsListResponse) Reset()
func (*GetIncidentsListResponse) String ¶
func (x *GetIncidentsListResponse) String() string
type GetListRequest ¶
type GetListRequest struct { OwnerType ComponentOwnerType `` /* 129-byte string literal not displayed */ OwnerId string `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"` // contains filtered or unexported fields }
func (*GetListRequest) Descriptor
deprecated
func (*GetListRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetListRequest.ProtoReflect.Descriptor instead.
func (*GetListRequest) GetOwnerId ¶
func (x *GetListRequest) GetOwnerId() string
func (*GetListRequest) GetOwnerType ¶
func (x *GetListRequest) GetOwnerType() ComponentOwnerType
func (*GetListRequest) ProtoMessage ¶
func (*GetListRequest) ProtoMessage()
func (*GetListRequest) ProtoReflect ¶
func (x *GetListRequest) ProtoReflect() protoreflect.Message
func (*GetListRequest) Reset ¶
func (x *GetListRequest) Reset()
func (*GetListRequest) String ¶
func (x *GetListRequest) String() string
type GetListResponse ¶
type GetListResponse struct { Methods []*NotificationMethod `protobuf:"bytes,1,rep,name=methods,proto3" json:"methods,omitempty"` // contains filtered or unexported fields }
func (*GetListResponse) Descriptor
deprecated
func (*GetListResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetListResponse.ProtoReflect.Descriptor instead.
func (*GetListResponse) GetMethods ¶
func (x *GetListResponse) GetMethods() []*NotificationMethod
func (*GetListResponse) ProtoMessage ¶
func (*GetListResponse) ProtoMessage()
func (*GetListResponse) ProtoReflect ¶
func (x *GetListResponse) ProtoReflect() protoreflect.Message
func (*GetListResponse) Reset ¶
func (x *GetListResponse) Reset()
func (*GetListResponse) String ¶
func (x *GetListResponse) String() string
type GetRulesByOwnerIdRequest ¶
type GetRulesByOwnerIdRequest struct { OwnerType ComponentOwnerType `` /* 129-byte string literal not displayed */ OwnerId string `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"` // contains filtered or unexported fields }
func (*GetRulesByOwnerIdRequest) Descriptor
deprecated
func (*GetRulesByOwnerIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRulesByOwnerIdRequest.ProtoReflect.Descriptor instead.
func (*GetRulesByOwnerIdRequest) GetOwnerId ¶
func (x *GetRulesByOwnerIdRequest) GetOwnerId() string
func (*GetRulesByOwnerIdRequest) GetOwnerType ¶
func (x *GetRulesByOwnerIdRequest) GetOwnerType() ComponentOwnerType
func (*GetRulesByOwnerIdRequest) ProtoMessage ¶
func (*GetRulesByOwnerIdRequest) ProtoMessage()
func (*GetRulesByOwnerIdRequest) ProtoReflect ¶
func (x *GetRulesByOwnerIdRequest) ProtoReflect() protoreflect.Message
func (*GetRulesByOwnerIdRequest) Reset ¶
func (x *GetRulesByOwnerIdRequest) Reset()
func (*GetRulesByOwnerIdRequest) String ¶
func (x *GetRulesByOwnerIdRequest) String() string
type GetScheduleWithIdRequest ¶ added in v1.15.0
type GetScheduleWithIdRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetScheduleWithIdRequest) Descriptor
deprecated
added in
v1.15.0
func (*GetScheduleWithIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetScheduleWithIdRequest.ProtoReflect.Descriptor instead.
func (*GetScheduleWithIdRequest) GetId ¶ added in v1.15.0
func (x *GetScheduleWithIdRequest) GetId() string
func (*GetScheduleWithIdRequest) ProtoMessage ¶ added in v1.15.0
func (*GetScheduleWithIdRequest) ProtoMessage()
func (*GetScheduleWithIdRequest) ProtoReflect ¶ added in v1.15.0
func (x *GetScheduleWithIdRequest) ProtoReflect() protoreflect.Message
func (*GetScheduleWithIdRequest) Reset ¶ added in v1.15.0
func (x *GetScheduleWithIdRequest) Reset()
func (*GetScheduleWithIdRequest) String ¶ added in v1.15.0
func (x *GetScheduleWithIdRequest) String() string
type GetScheduleWithIdResponse ¶ added in v1.15.0
type GetScheduleWithIdResponse struct { ScheduledNext *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=scheduled_next,json=scheduledNext,proto3" json:"scheduled_next,omitempty"` // contains filtered or unexported fields }
func (*GetScheduleWithIdResponse) Descriptor
deprecated
added in
v1.15.0
func (*GetScheduleWithIdResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetScheduleWithIdResponse.ProtoReflect.Descriptor instead.
func (*GetScheduleWithIdResponse) GetScheduledNext ¶ added in v1.15.0
func (x *GetScheduleWithIdResponse) GetScheduledNext() *timestamppb.Timestamp
func (*GetScheduleWithIdResponse) ProtoMessage ¶ added in v1.15.0
func (*GetScheduleWithIdResponse) ProtoMessage()
func (*GetScheduleWithIdResponse) ProtoReflect ¶ added in v1.15.0
func (x *GetScheduleWithIdResponse) ProtoReflect() protoreflect.Message
func (*GetScheduleWithIdResponse) Reset ¶ added in v1.15.0
func (x *GetScheduleWithIdResponse) Reset()
func (*GetScheduleWithIdResponse) String ¶ added in v1.15.0
func (x *GetScheduleWithIdResponse) String() string
type GetSchedulerByIdRequest ¶
type GetSchedulerByIdRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetSchedulerByIdRequest) Descriptor
deprecated
func (*GetSchedulerByIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSchedulerByIdRequest.ProtoReflect.Descriptor instead.
func (*GetSchedulerByIdRequest) GetId ¶
func (x *GetSchedulerByIdRequest) GetId() string
func (*GetSchedulerByIdRequest) ProtoMessage ¶
func (*GetSchedulerByIdRequest) ProtoMessage()
func (*GetSchedulerByIdRequest) ProtoReflect ¶
func (x *GetSchedulerByIdRequest) ProtoReflect() protoreflect.Message
func (*GetSchedulerByIdRequest) Reset ¶
func (x *GetSchedulerByIdRequest) Reset()
func (*GetSchedulerByIdRequest) String ¶
func (x *GetSchedulerByIdRequest) String() string
type GetSchedulerInformationRequest ¶
type GetSchedulerInformationRequest struct { SchedulerId string `protobuf:"bytes,1,opt,name=scheduler_id,json=schedulerId,proto3" json:"scheduler_id,omitempty"` Pagination *Pagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` // if nil means all record TimeRange *TimeFilter `protobuf:"bytes,3,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"` // nil not set (filter by start time) Sort *SortingSchedulerList `protobuf:"bytes,4,opt,name=sort,proto3" json:"sort,omitempty"` // sort for table Status SchedulerCode `protobuf:"varint,5,opt,name=status,proto3,enum=squzy.v1.monitoring.SchedulerCode" json:"status,omitempty"` // filter for table // contains filtered or unexported fields }
func (*GetSchedulerInformationRequest) Descriptor
deprecated
func (*GetSchedulerInformationRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSchedulerInformationRequest.ProtoReflect.Descriptor instead.
func (*GetSchedulerInformationRequest) GetPagination ¶
func (x *GetSchedulerInformationRequest) GetPagination() *Pagination
func (*GetSchedulerInformationRequest) GetSchedulerId ¶
func (x *GetSchedulerInformationRequest) GetSchedulerId() string
func (*GetSchedulerInformationRequest) GetSort ¶
func (x *GetSchedulerInformationRequest) GetSort() *SortingSchedulerList
func (*GetSchedulerInformationRequest) GetStatus ¶
func (x *GetSchedulerInformationRequest) GetStatus() SchedulerCode
func (*GetSchedulerInformationRequest) GetTimeRange ¶
func (x *GetSchedulerInformationRequest) GetTimeRange() *TimeFilter
func (*GetSchedulerInformationRequest) ProtoMessage ¶
func (*GetSchedulerInformationRequest) ProtoMessage()
func (*GetSchedulerInformationRequest) ProtoReflect ¶
func (x *GetSchedulerInformationRequest) ProtoReflect() protoreflect.Message
func (*GetSchedulerInformationRequest) Reset ¶
func (x *GetSchedulerInformationRequest) Reset()
func (*GetSchedulerInformationRequest) String ¶
func (x *GetSchedulerInformationRequest) String() string
type GetSchedulerInformationResponse ¶
type GetSchedulerInformationResponse struct { Snapshots []*SchedulerSnapshot `protobuf:"bytes,1,rep,name=snapshots,proto3" json:"snapshots,omitempty"` Count int32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*GetSchedulerInformationResponse) Descriptor
deprecated
func (*GetSchedulerInformationResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSchedulerInformationResponse.ProtoReflect.Descriptor instead.
func (*GetSchedulerInformationResponse) GetCount ¶
func (x *GetSchedulerInformationResponse) GetCount() int32
func (*GetSchedulerInformationResponse) GetSnapshots ¶
func (x *GetSchedulerInformationResponse) GetSnapshots() []*SchedulerSnapshot
func (*GetSchedulerInformationResponse) ProtoMessage ¶
func (*GetSchedulerInformationResponse) ProtoMessage()
func (*GetSchedulerInformationResponse) ProtoReflect ¶
func (x *GetSchedulerInformationResponse) ProtoReflect() protoreflect.Message
func (*GetSchedulerInformationResponse) Reset ¶
func (x *GetSchedulerInformationResponse) Reset()
func (*GetSchedulerInformationResponse) String ¶
func (x *GetSchedulerInformationResponse) String() string
type GetSchedulerListResponse ¶
type GetSchedulerListResponse struct { Lists []*Scheduler `protobuf:"bytes,1,rep,name=lists,proto3" json:"lists,omitempty"` // contains filtered or unexported fields }
func (*GetSchedulerListResponse) Descriptor
deprecated
func (*GetSchedulerListResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSchedulerListResponse.ProtoReflect.Descriptor instead.
func (*GetSchedulerListResponse) GetLists ¶
func (x *GetSchedulerListResponse) GetLists() []*Scheduler
func (*GetSchedulerListResponse) ProtoMessage ¶
func (*GetSchedulerListResponse) ProtoMessage()
func (*GetSchedulerListResponse) ProtoReflect ¶
func (x *GetSchedulerListResponse) ProtoReflect() protoreflect.Message
func (*GetSchedulerListResponse) Reset ¶
func (x *GetSchedulerListResponse) Reset()
func (*GetSchedulerListResponse) String ¶
func (x *GetSchedulerListResponse) String() string
type GetSchedulerUptimeRequest ¶
type GetSchedulerUptimeRequest struct { SchedulerId string `protobuf:"bytes,1,opt,name=scheduler_id,json=schedulerId,proto3" json:"scheduler_id,omitempty"` TimeRange *TimeFilter `protobuf:"bytes,2,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"` // contains filtered or unexported fields }
func (*GetSchedulerUptimeRequest) Descriptor
deprecated
func (*GetSchedulerUptimeRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSchedulerUptimeRequest.ProtoReflect.Descriptor instead.
func (*GetSchedulerUptimeRequest) GetSchedulerId ¶
func (x *GetSchedulerUptimeRequest) GetSchedulerId() string
func (*GetSchedulerUptimeRequest) GetTimeRange ¶
func (x *GetSchedulerUptimeRequest) GetTimeRange() *TimeFilter
func (*GetSchedulerUptimeRequest) ProtoMessage ¶
func (*GetSchedulerUptimeRequest) ProtoMessage()
func (*GetSchedulerUptimeRequest) ProtoReflect ¶
func (x *GetSchedulerUptimeRequest) ProtoReflect() protoreflect.Message
func (*GetSchedulerUptimeRequest) Reset ¶
func (x *GetSchedulerUptimeRequest) Reset()
func (*GetSchedulerUptimeRequest) String ¶
func (x *GetSchedulerUptimeRequest) String() string
type GetSchedulerUptimeResponse ¶
type GetSchedulerUptimeResponse struct { Uptime float64 `protobuf:"fixed64,1,opt,name=uptime,proto3" json:"uptime,omitempty"` Latency float64 `protobuf:"fixed64,2,opt,name=latency,proto3" json:"latency,omitempty"` // contains filtered or unexported fields }
func (*GetSchedulerUptimeResponse) Descriptor
deprecated
func (*GetSchedulerUptimeResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSchedulerUptimeResponse.ProtoReflect.Descriptor instead.
func (*GetSchedulerUptimeResponse) GetLatency ¶
func (x *GetSchedulerUptimeResponse) GetLatency() float64
func (*GetSchedulerUptimeResponse) GetUptime ¶
func (x *GetSchedulerUptimeResponse) GetUptime() float64
func (*GetSchedulerUptimeResponse) ProtoMessage ¶
func (*GetSchedulerUptimeResponse) ProtoMessage()
func (*GetSchedulerUptimeResponse) ProtoReflect ¶
func (x *GetSchedulerUptimeResponse) ProtoReflect() protoreflect.Message
func (*GetSchedulerUptimeResponse) Reset ¶
func (x *GetSchedulerUptimeResponse) Reset()
func (*GetSchedulerUptimeResponse) String ¶
func (x *GetSchedulerUptimeResponse) String() string
type GetTransactionByIdRequest ¶
type GetTransactionByIdRequest struct { TransactionId string `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` // contains filtered or unexported fields }
func (*GetTransactionByIdRequest) Descriptor
deprecated
func (*GetTransactionByIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTransactionByIdRequest.ProtoReflect.Descriptor instead.
func (*GetTransactionByIdRequest) GetTransactionId ¶
func (x *GetTransactionByIdRequest) GetTransactionId() string
func (*GetTransactionByIdRequest) ProtoMessage ¶
func (*GetTransactionByIdRequest) ProtoMessage()
func (*GetTransactionByIdRequest) ProtoReflect ¶
func (x *GetTransactionByIdRequest) ProtoReflect() protoreflect.Message
func (*GetTransactionByIdRequest) Reset ¶
func (x *GetTransactionByIdRequest) Reset()
func (*GetTransactionByIdRequest) String ¶
func (x *GetTransactionByIdRequest) String() string
type GetTransactionByIdResponse ¶
type GetTransactionByIdResponse struct { Transaction *TransactionInfo `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"` Children []*TransactionInfo `protobuf:"bytes,2,rep,name=children,proto3" json:"children,omitempty"` // contains filtered or unexported fields }
func (*GetTransactionByIdResponse) Descriptor
deprecated
func (*GetTransactionByIdResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTransactionByIdResponse.ProtoReflect.Descriptor instead.
func (*GetTransactionByIdResponse) GetChildren ¶
func (x *GetTransactionByIdResponse) GetChildren() []*TransactionInfo
func (*GetTransactionByIdResponse) GetTransaction ¶
func (x *GetTransactionByIdResponse) GetTransaction() *TransactionInfo
func (*GetTransactionByIdResponse) ProtoMessage ¶
func (*GetTransactionByIdResponse) ProtoMessage()
func (*GetTransactionByIdResponse) ProtoReflect ¶
func (x *GetTransactionByIdResponse) ProtoReflect() protoreflect.Message
func (*GetTransactionByIdResponse) Reset ¶
func (x *GetTransactionByIdResponse) Reset()
func (*GetTransactionByIdResponse) String ¶
func (x *GetTransactionByIdResponse) String() string
type GetTransactionByNameRequest ¶
type GetTransactionByNameRequest struct { ApplicationId string `protobuf:"bytes,1,opt,name=application_id,json=applicationId,proto3" json:"application_id,omitempty"` TransactionName string `protobuf:"bytes,2,opt,name=transaction_name,json=transactionName,proto3" json:"transaction_name,omitempty"` Pagination *Pagination `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"` TimeRange *TimeFilter `protobuf:"bytes,4,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"` // contains filtered or unexported fields }
func (*GetTransactionByNameRequest) Descriptor
deprecated
func (*GetTransactionByNameRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTransactionByNameRequest.ProtoReflect.Descriptor instead.
func (*GetTransactionByNameRequest) GetApplicationId ¶
func (x *GetTransactionByNameRequest) GetApplicationId() string
func (*GetTransactionByNameRequest) GetPagination ¶
func (x *GetTransactionByNameRequest) GetPagination() *Pagination
func (*GetTransactionByNameRequest) GetTimeRange ¶
func (x *GetTransactionByNameRequest) GetTimeRange() *TimeFilter
func (*GetTransactionByNameRequest) GetTransactionName ¶
func (x *GetTransactionByNameRequest) GetTransactionName() string
func (*GetTransactionByNameRequest) ProtoMessage ¶
func (*GetTransactionByNameRequest) ProtoMessage()
func (*GetTransactionByNameRequest) ProtoReflect ¶
func (x *GetTransactionByNameRequest) ProtoReflect() protoreflect.Message
func (*GetTransactionByNameRequest) Reset ¶
func (x *GetTransactionByNameRequest) Reset()
func (*GetTransactionByNameRequest) String ¶
func (x *GetTransactionByNameRequest) String() string
type GetTransactionByNameResponse ¶
type GetTransactionByNameResponse struct { Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` Transactions []*TransactionInfo `protobuf:"bytes,2,rep,name=transactions,proto3" json:"transactions,omitempty"` // contains filtered or unexported fields }
func (*GetTransactionByNameResponse) Descriptor
deprecated
func (*GetTransactionByNameResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTransactionByNameResponse.ProtoReflect.Descriptor instead.
func (*GetTransactionByNameResponse) GetCount ¶
func (x *GetTransactionByNameResponse) GetCount() int64
func (*GetTransactionByNameResponse) GetTransactions ¶
func (x *GetTransactionByNameResponse) GetTransactions() []*TransactionInfo
func (*GetTransactionByNameResponse) ProtoMessage ¶
func (*GetTransactionByNameResponse) ProtoMessage()
func (*GetTransactionByNameResponse) ProtoReflect ¶
func (x *GetTransactionByNameResponse) ProtoReflect() protoreflect.Message
func (*GetTransactionByNameResponse) Reset ¶
func (x *GetTransactionByNameResponse) Reset()
func (*GetTransactionByNameResponse) String ¶
func (x *GetTransactionByNameResponse) String() string
type GetTransactionGroupRequest ¶
type GetTransactionGroupRequest struct { ApplicationId string `protobuf:"bytes,1,opt,name=application_id,json=applicationId,proto3" json:"application_id,omitempty"` TimeRange *TimeFilter `protobuf:"bytes,2,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"` // nil not set (filter by start time) GroupType GroupTransaction `` // how we will group transactions /* 128-byte string literal not displayed */ Type TransactionType `protobuf:"varint,4,opt,name=type,proto3,enum=squzy.v1.monitoring.TransactionType" json:"type,omitempty"` Status TransactionStatus `protobuf:"varint,5,opt,name=status,proto3,enum=squzy.v1.monitoring.TransactionStatus" json:"status,omitempty"` // contains filtered or unexported fields }
func (*GetTransactionGroupRequest) Descriptor
deprecated
func (*GetTransactionGroupRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTransactionGroupRequest.ProtoReflect.Descriptor instead.
func (*GetTransactionGroupRequest) GetApplicationId ¶
func (x *GetTransactionGroupRequest) GetApplicationId() string
func (*GetTransactionGroupRequest) GetGroupType ¶
func (x *GetTransactionGroupRequest) GetGroupType() GroupTransaction
func (*GetTransactionGroupRequest) GetStatus ¶
func (x *GetTransactionGroupRequest) GetStatus() TransactionStatus
func (*GetTransactionGroupRequest) GetTimeRange ¶
func (x *GetTransactionGroupRequest) GetTimeRange() *TimeFilter
func (*GetTransactionGroupRequest) GetType ¶
func (x *GetTransactionGroupRequest) GetType() TransactionType
func (*GetTransactionGroupRequest) ProtoMessage ¶
func (*GetTransactionGroupRequest) ProtoMessage()
func (*GetTransactionGroupRequest) ProtoReflect ¶
func (x *GetTransactionGroupRequest) ProtoReflect() protoreflect.Message
func (*GetTransactionGroupRequest) Reset ¶
func (x *GetTransactionGroupRequest) Reset()
func (*GetTransactionGroupRequest) String ¶
func (x *GetTransactionGroupRequest) String() string
type GetTransactionGroupResponse ¶
type GetTransactionGroupResponse struct { Transactions map[string]*TransactionGroup `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetTransactionGroupResponse) Descriptor
deprecated
func (*GetTransactionGroupResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTransactionGroupResponse.ProtoReflect.Descriptor instead.
func (*GetTransactionGroupResponse) GetTransactions ¶
func (x *GetTransactionGroupResponse) GetTransactions() map[string]*TransactionGroup
func (*GetTransactionGroupResponse) ProtoMessage ¶
func (*GetTransactionGroupResponse) ProtoMessage()
func (*GetTransactionGroupResponse) ProtoReflect ¶
func (x *GetTransactionGroupResponse) ProtoReflect() protoreflect.Message
func (*GetTransactionGroupResponse) Reset ¶
func (x *GetTransactionGroupResponse) Reset()
func (*GetTransactionGroupResponse) String ¶
func (x *GetTransactionGroupResponse) String() string
type GetTransactionsRequest ¶
type GetTransactionsRequest struct { ApplicationId string `protobuf:"bytes,1,opt,name=application_id,json=applicationId,proto3" json:"application_id,omitempty"` // if empty then ignore Pagination *Pagination `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` TimeRange *TimeFilter `protobuf:"bytes,3,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"` Type TransactionType `protobuf:"varint,4,opt,name=type,proto3,enum=squzy.v1.monitoring.TransactionType" json:"type,omitempty"` Status TransactionStatus `protobuf:"varint,5,opt,name=status,proto3,enum=squzy.v1.monitoring.TransactionStatus" json:"status,omitempty"` // filter is not exists Host *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=host,proto3" json:"host,omitempty"` Name *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"` Path *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=path,proto3" json:"path,omitempty"` Method *wrapperspb.StringValue `protobuf:"bytes,9,opt,name=method,proto3" json:"method,omitempty"` Sort *SortingTransactionList `protobuf:"bytes,10,opt,name=sort,proto3" json:"sort,omitempty"` // contains filtered or unexported fields }
func (*GetTransactionsRequest) Descriptor
deprecated
func (*GetTransactionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTransactionsRequest.ProtoReflect.Descriptor instead.
func (*GetTransactionsRequest) GetApplicationId ¶
func (x *GetTransactionsRequest) GetApplicationId() string
func (*GetTransactionsRequest) GetHost ¶
func (x *GetTransactionsRequest) GetHost() *wrapperspb.StringValue
func (*GetTransactionsRequest) GetMethod ¶
func (x *GetTransactionsRequest) GetMethod() *wrapperspb.StringValue
func (*GetTransactionsRequest) GetName ¶
func (x *GetTransactionsRequest) GetName() *wrapperspb.StringValue
func (*GetTransactionsRequest) GetPagination ¶
func (x *GetTransactionsRequest) GetPagination() *Pagination
func (*GetTransactionsRequest) GetPath ¶
func (x *GetTransactionsRequest) GetPath() *wrapperspb.StringValue
func (*GetTransactionsRequest) GetSort ¶
func (x *GetTransactionsRequest) GetSort() *SortingTransactionList
func (*GetTransactionsRequest) GetStatus ¶
func (x *GetTransactionsRequest) GetStatus() TransactionStatus
func (*GetTransactionsRequest) GetTimeRange ¶
func (x *GetTransactionsRequest) GetTimeRange() *TimeFilter
func (*GetTransactionsRequest) GetType ¶
func (x *GetTransactionsRequest) GetType() TransactionType
func (*GetTransactionsRequest) ProtoMessage ¶
func (*GetTransactionsRequest) ProtoMessage()
func (*GetTransactionsRequest) ProtoReflect ¶
func (x *GetTransactionsRequest) ProtoReflect() protoreflect.Message
func (*GetTransactionsRequest) Reset ¶
func (x *GetTransactionsRequest) Reset()
func (*GetTransactionsRequest) String ¶
func (x *GetTransactionsRequest) String() string
type GetTransactionsResponse ¶
type GetTransactionsResponse struct { Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` Transactions []*TransactionInfo `protobuf:"bytes,2,rep,name=transactions,proto3" json:"transactions,omitempty"` // contains filtered or unexported fields }
func (*GetTransactionsResponse) Descriptor
deprecated
func (*GetTransactionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTransactionsResponse.ProtoReflect.Descriptor instead.
func (*GetTransactionsResponse) GetCount ¶
func (x *GetTransactionsResponse) GetCount() int64
func (*GetTransactionsResponse) GetTransactions ¶
func (x *GetTransactionsResponse) GetTransactions() []*TransactionInfo
func (*GetTransactionsResponse) ProtoMessage ¶
func (*GetTransactionsResponse) ProtoMessage()
func (*GetTransactionsResponse) ProtoReflect ¶
func (x *GetTransactionsResponse) ProtoReflect() protoreflect.Message
func (*GetTransactionsResponse) Reset ¶
func (x *GetTransactionsResponse) Reset()
func (*GetTransactionsResponse) String ¶
func (x *GetTransactionsResponse) String() string
type GroupTransaction ¶
type GroupTransaction int32
const ( GroupTransaction_GROUP_TRANSACTION_UNSPECIFIED GroupTransaction = 0 GroupTransaction_BY_TYPE GroupTransaction = 1 GroupTransaction_BY_NAME GroupTransaction = 2 GroupTransaction_BY_METHOD GroupTransaction = 3 GroupTransaction_BY_HOST GroupTransaction = 4 GroupTransaction_BY_PATH GroupTransaction = 5 )
func (GroupTransaction) Descriptor ¶
func (GroupTransaction) Descriptor() protoreflect.EnumDescriptor
func (GroupTransaction) Enum ¶
func (x GroupTransaction) Enum() *GroupTransaction
func (GroupTransaction) EnumDescriptor
deprecated
func (GroupTransaction) EnumDescriptor() ([]byte, []int)
Deprecated: Use GroupTransaction.Descriptor instead.
func (GroupTransaction) Number ¶
func (x GroupTransaction) Number() protoreflect.EnumNumber
func (GroupTransaction) String ¶
func (x GroupTransaction) String() string
func (GroupTransaction) Type ¶
func (GroupTransaction) Type() protoreflect.EnumType
type GrpcConfig ¶
type GrpcConfig struct { Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*GrpcConfig) Descriptor
deprecated
func (*GrpcConfig) Descriptor() ([]byte, []int)
Deprecated: Use GrpcConfig.ProtoReflect.Descriptor instead.
func (*GrpcConfig) GetHost ¶
func (x *GrpcConfig) GetHost() string
func (*GrpcConfig) GetPort ¶
func (x *GrpcConfig) GetPort() int32
func (*GrpcConfig) GetService ¶
func (x *GrpcConfig) GetService() string
func (*GrpcConfig) ProtoMessage ¶
func (*GrpcConfig) ProtoMessage()
func (*GrpcConfig) ProtoReflect ¶
func (x *GrpcConfig) ProtoReflect() protoreflect.Message
func (*GrpcConfig) Reset ¶
func (x *GrpcConfig) Reset()
func (*GrpcConfig) String ¶
func (x *GrpcConfig) String() string
type HostInfo ¶
type HostInfo struct { HostName string `protobuf:"bytes,1,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"` Os string `protobuf:"bytes,2,opt,name=os,proto3" json:"os,omitempty"` PlatformInfo *PlatformInfo `protobuf:"bytes,3,opt,name=platform_info,json=platformInfo,proto3" json:"platform_info,omitempty"` // contains filtered or unexported fields }
func (*HostInfo) Descriptor
deprecated
func (*HostInfo) GetHostName ¶
func (*HostInfo) GetPlatformInfo ¶
func (x *HostInfo) GetPlatformInfo() *PlatformInfo
func (*HostInfo) ProtoMessage ¶
func (*HostInfo) ProtoMessage()
func (*HostInfo) ProtoReflect ¶
func (x *HostInfo) ProtoReflect() protoreflect.Message
type HttpConfig ¶
type HttpConfig struct { Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"` Headers map[string]string `` /* 155-byte string literal not displayed */ StatusCode int32 `protobuf:"varint,4,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"` // contains filtered or unexported fields }
func (*HttpConfig) Descriptor
deprecated
func (*HttpConfig) Descriptor() ([]byte, []int)
Deprecated: Use HttpConfig.ProtoReflect.Descriptor instead.
func (*HttpConfig) GetHeaders ¶
func (x *HttpConfig) GetHeaders() map[string]string
func (*HttpConfig) GetMethod ¶
func (x *HttpConfig) GetMethod() string
func (*HttpConfig) GetStatusCode ¶
func (x *HttpConfig) GetStatusCode() int32
func (*HttpConfig) GetUrl ¶
func (x *HttpConfig) GetUrl() string
func (*HttpConfig) ProtoMessage ¶
func (*HttpConfig) ProtoMessage()
func (*HttpConfig) ProtoReflect ¶
func (x *HttpConfig) ProtoReflect() protoreflect.Message
func (*HttpConfig) Reset ¶
func (x *HttpConfig) Reset()
func (*HttpConfig) String ¶
func (x *HttpConfig) String() string
type HttpJsonValueConfig ¶
type HttpJsonValueConfig struct { Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"` Headers map[string]string `` /* 155-byte string literal not displayed */ Selectors []*HttpJsonValueConfig_Selectors `protobuf:"bytes,4,rep,name=selectors,proto3" json:"selectors,omitempty"` // contains filtered or unexported fields }
func (*HttpJsonValueConfig) Descriptor
deprecated
func (*HttpJsonValueConfig) Descriptor() ([]byte, []int)
Deprecated: Use HttpJsonValueConfig.ProtoReflect.Descriptor instead.
func (*HttpJsonValueConfig) GetHeaders ¶
func (x *HttpJsonValueConfig) GetHeaders() map[string]string
func (*HttpJsonValueConfig) GetMethod ¶
func (x *HttpJsonValueConfig) GetMethod() string
func (*HttpJsonValueConfig) GetSelectors ¶
func (x *HttpJsonValueConfig) GetSelectors() []*HttpJsonValueConfig_Selectors
func (*HttpJsonValueConfig) GetUrl ¶
func (x *HttpJsonValueConfig) GetUrl() string
func (*HttpJsonValueConfig) ProtoMessage ¶
func (*HttpJsonValueConfig) ProtoMessage()
func (*HttpJsonValueConfig) ProtoReflect ¶
func (x *HttpJsonValueConfig) ProtoReflect() protoreflect.Message
func (*HttpJsonValueConfig) Reset ¶
func (x *HttpJsonValueConfig) Reset()
func (*HttpJsonValueConfig) String ¶
func (x *HttpJsonValueConfig) String() string
type HttpJsonValueConfig_JsonValueParseType ¶
type HttpJsonValueConfig_JsonValueParseType int32
const ( // Initial status HttpJsonValueConfig_JSON_PARSE_VALUE_UNSPECIFIED HttpJsonValueConfig_JsonValueParseType = 0 HttpJsonValueConfig_STRING HttpJsonValueConfig_JsonValueParseType = 1 HttpJsonValueConfig_BOOL HttpJsonValueConfig_JsonValueParseType = 2 HttpJsonValueConfig_NUMBER HttpJsonValueConfig_JsonValueParseType = 3 HttpJsonValueConfig_TIME HttpJsonValueConfig_JsonValueParseType = 4 HttpJsonValueConfig_ANY HttpJsonValueConfig_JsonValueParseType = 5 HttpJsonValueConfig_RAW HttpJsonValueConfig_JsonValueParseType = 6 )
func (HttpJsonValueConfig_JsonValueParseType) Descriptor ¶
func (HttpJsonValueConfig_JsonValueParseType) Descriptor() protoreflect.EnumDescriptor
func (HttpJsonValueConfig_JsonValueParseType) EnumDescriptor
deprecated
func (HttpJsonValueConfig_JsonValueParseType) EnumDescriptor() ([]byte, []int)
Deprecated: Use HttpJsonValueConfig_JsonValueParseType.Descriptor instead.
func (HttpJsonValueConfig_JsonValueParseType) Number ¶
func (x HttpJsonValueConfig_JsonValueParseType) Number() protoreflect.EnumNumber
func (HttpJsonValueConfig_JsonValueParseType) String ¶
func (x HttpJsonValueConfig_JsonValueParseType) String() string
func (HttpJsonValueConfig_JsonValueParseType) Type ¶
func (HttpJsonValueConfig_JsonValueParseType) Type() protoreflect.EnumType
type HttpJsonValueConfig_Selectors ¶
type HttpJsonValueConfig_Selectors struct { Type HttpJsonValueConfig_JsonValueParseType `` /* 126-byte string literal not displayed */ Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*HttpJsonValueConfig_Selectors) Descriptor
deprecated
func (*HttpJsonValueConfig_Selectors) Descriptor() ([]byte, []int)
Deprecated: Use HttpJsonValueConfig_Selectors.ProtoReflect.Descriptor instead.
func (*HttpJsonValueConfig_Selectors) GetPath ¶
func (x *HttpJsonValueConfig_Selectors) GetPath() string
func (*HttpJsonValueConfig_Selectors) GetType ¶
func (x *HttpJsonValueConfig_Selectors) GetType() HttpJsonValueConfig_JsonValueParseType
func (*HttpJsonValueConfig_Selectors) ProtoMessage ¶
func (*HttpJsonValueConfig_Selectors) ProtoMessage()
func (*HttpJsonValueConfig_Selectors) ProtoReflect ¶
func (x *HttpJsonValueConfig_Selectors) ProtoReflect() protoreflect.Message
func (*HttpJsonValueConfig_Selectors) Reset ¶
func (x *HttpJsonValueConfig_Selectors) Reset()
func (*HttpJsonValueConfig_Selectors) String ¶
func (x *HttpJsonValueConfig_Selectors) String() string
type Incident ¶
type Incident struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Status IncidentStatus `protobuf:"varint,2,opt,name=status,proto3,enum=squzy.v1.incident.IncidentStatus" json:"status,omitempty"` RuleId string `protobuf:"bytes,3,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"` Histories []*Incident_HistoryItem `protobuf:"bytes,4,rep,name=histories,proto3" json:"histories,omitempty"` // contains filtered or unexported fields }
func (*Incident) Descriptor
deprecated
func (*Incident) GetHistories ¶
func (x *Incident) GetHistories() []*Incident_HistoryItem
func (*Incident) GetStatus ¶
func (x *Incident) GetStatus() IncidentStatus
func (*Incident) ProtoMessage ¶
func (*Incident) ProtoMessage()
func (*Incident) ProtoReflect ¶
func (x *Incident) ProtoReflect() protoreflect.Message
type IncidentIdRequest ¶
type IncidentIdRequest struct { IncidentId string `protobuf:"bytes,1,opt,name=incident_id,json=incidentId,proto3" json:"incident_id,omitempty"` // contains filtered or unexported fields }
func (*IncidentIdRequest) Descriptor
deprecated
func (*IncidentIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use IncidentIdRequest.ProtoReflect.Descriptor instead.
func (*IncidentIdRequest) GetIncidentId ¶
func (x *IncidentIdRequest) GetIncidentId() string
func (*IncidentIdRequest) ProtoMessage ¶
func (*IncidentIdRequest) ProtoMessage()
func (*IncidentIdRequest) ProtoReflect ¶
func (x *IncidentIdRequest) ProtoReflect() protoreflect.Message
func (*IncidentIdRequest) Reset ¶
func (x *IncidentIdRequest) Reset()
func (*IncidentIdRequest) String ¶
func (x *IncidentIdRequest) String() string
type IncidentServerClient ¶ added in v1.13.0
type IncidentServerClient interface { CreateRule(ctx context.Context, in *CreateRuleRequest, opts ...grpc.CallOption) (*Rule, error) GetRuleById(ctx context.Context, in *RuleIdRequest, opts ...grpc.CallOption) (*Rule, error) GetRulesByOwnerId(ctx context.Context, in *GetRulesByOwnerIdRequest, opts ...grpc.CallOption) (*Rules, error) RemoveRule(ctx context.Context, in *RuleIdRequest, opts ...grpc.CallOption) (*Rule, error) ValidateRule(ctx context.Context, in *ValidateRuleRequest, opts ...grpc.CallOption) (*ValidateRuleResponse, error) ProcessRecordFromStorage(ctx context.Context, in *StorageRecord, opts ...grpc.CallOption) (*emptypb.Empty, error) CloseIncident(ctx context.Context, in *IncidentIdRequest, opts ...grpc.CallOption) (*Incident, error) ActivateRule(ctx context.Context, in *RuleIdRequest, opts ...grpc.CallOption) (*Rule, error) DeactivateRule(ctx context.Context, in *RuleIdRequest, opts ...grpc.CallOption) (*Rule, error) StudyIncident(ctx context.Context, in *IncidentIdRequest, opts ...grpc.CallOption) (*Incident, error) }
IncidentServerClient is the client API for IncidentServer service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewIncidentServerClient ¶ added in v1.13.0
func NewIncidentServerClient(cc grpc.ClientConnInterface) IncidentServerClient
type IncidentServerServer ¶ added in v1.13.0
type IncidentServerServer interface { CreateRule(context.Context, *CreateRuleRequest) (*Rule, error) GetRuleById(context.Context, *RuleIdRequest) (*Rule, error) GetRulesByOwnerId(context.Context, *GetRulesByOwnerIdRequest) (*Rules, error) RemoveRule(context.Context, *RuleIdRequest) (*Rule, error) ValidateRule(context.Context, *ValidateRuleRequest) (*ValidateRuleResponse, error) ProcessRecordFromStorage(context.Context, *StorageRecord) (*emptypb.Empty, error) CloseIncident(context.Context, *IncidentIdRequest) (*Incident, error) ActivateRule(context.Context, *RuleIdRequest) (*Rule, error) DeactivateRule(context.Context, *RuleIdRequest) (*Rule, error) StudyIncident(context.Context, *IncidentIdRequest) (*Incident, error) // contains filtered or unexported methods }
IncidentServerServer is the server API for IncidentServer service. All implementations must embed UnimplementedIncidentServerServer for forward compatibility
type IncidentStatus ¶
type IncidentStatus int32
const ( IncidentStatus_INCIDENT_STATUS_UNSPECIFIED IncidentStatus = 0 IncidentStatus_INCIDENT_STATUS_OPENED IncidentStatus = 1 IncidentStatus_INCIDENT_STATUS_STUDIED IncidentStatus = 2 IncidentStatus_INCIDENT_STATUS_CAN_BE_CLOSED IncidentStatus = 3 IncidentStatus_INCIDENT_STATUS_CLOSED IncidentStatus = 4 )
func (IncidentStatus) Descriptor ¶
func (IncidentStatus) Descriptor() protoreflect.EnumDescriptor
func (IncidentStatus) Enum ¶
func (x IncidentStatus) Enum() *IncidentStatus
func (IncidentStatus) EnumDescriptor
deprecated
func (IncidentStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use IncidentStatus.Descriptor instead.
func (IncidentStatus) Number ¶
func (x IncidentStatus) Number() protoreflect.EnumNumber
func (IncidentStatus) String ¶
func (x IncidentStatus) String() string
func (IncidentStatus) Type ¶
func (IncidentStatus) Type() protoreflect.EnumType
type Incident_HistoryItem ¶
type Incident_HistoryItem struct { Status IncidentStatus `protobuf:"varint,1,opt,name=status,proto3,enum=squzy.v1.incident.IncidentStatus" json:"status,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*Incident_HistoryItem) Descriptor
deprecated
func (*Incident_HistoryItem) Descriptor() ([]byte, []int)
Deprecated: Use Incident_HistoryItem.ProtoReflect.Descriptor instead.
func (*Incident_HistoryItem) GetStatus ¶
func (x *Incident_HistoryItem) GetStatus() IncidentStatus
func (*Incident_HistoryItem) GetTimestamp ¶
func (x *Incident_HistoryItem) GetTimestamp() *timestamppb.Timestamp
func (*Incident_HistoryItem) ProtoMessage ¶
func (*Incident_HistoryItem) ProtoMessage()
func (*Incident_HistoryItem) ProtoReflect ¶
func (x *Incident_HistoryItem) ProtoReflect() protoreflect.Message
func (*Incident_HistoryItem) Reset ¶
func (x *Incident_HistoryItem) Reset()
func (*Incident_HistoryItem) String ¶
func (x *Incident_HistoryItem) String() string
type InitializeApplicationResponse ¶
type InitializeApplicationResponse struct { ApplicationId string `protobuf:"bytes,1,opt,name=application_id,json=applicationId,proto3" json:"application_id,omitempty"` TracingHeader string `protobuf:"bytes,2,opt,name=tracing_header,json=tracingHeader,proto3" json:"tracing_header,omitempty"` // contains filtered or unexported fields }
func (*InitializeApplicationResponse) Descriptor
deprecated
func (*InitializeApplicationResponse) Descriptor() ([]byte, []int)
Deprecated: Use InitializeApplicationResponse.ProtoReflect.Descriptor instead.
func (*InitializeApplicationResponse) GetApplicationId ¶
func (x *InitializeApplicationResponse) GetApplicationId() string
func (*InitializeApplicationResponse) GetTracingHeader ¶
func (x *InitializeApplicationResponse) GetTracingHeader() string
func (*InitializeApplicationResponse) ProtoMessage ¶
func (*InitializeApplicationResponse) ProtoMessage()
func (*InitializeApplicationResponse) ProtoReflect ¶
func (x *InitializeApplicationResponse) ProtoReflect() protoreflect.Message
func (*InitializeApplicationResponse) Reset ¶
func (x *InitializeApplicationResponse) Reset()
func (*InitializeApplicationResponse) String ¶
func (x *InitializeApplicationResponse) String() string
type InsertScheduleWithIdRequest ¶ added in v1.15.0
type InsertScheduleWithIdRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ScheduledNext *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=scheduled_next,json=scheduledNext,proto3" json:"scheduled_next,omitempty"` // contains filtered or unexported fields }
func (*InsertScheduleWithIdRequest) Descriptor
deprecated
added in
v1.15.0
func (*InsertScheduleWithIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use InsertScheduleWithIdRequest.ProtoReflect.Descriptor instead.
func (*InsertScheduleWithIdRequest) GetId ¶ added in v1.15.0
func (x *InsertScheduleWithIdRequest) GetId() string
func (*InsertScheduleWithIdRequest) GetScheduledNext ¶ added in v1.15.0
func (x *InsertScheduleWithIdRequest) GetScheduledNext() *timestamppb.Timestamp
func (*InsertScheduleWithIdRequest) ProtoMessage ¶ added in v1.15.0
func (*InsertScheduleWithIdRequest) ProtoMessage()
func (*InsertScheduleWithIdRequest) ProtoReflect ¶ added in v1.15.0
func (x *InsertScheduleWithIdRequest) ProtoReflect() protoreflect.Message
func (*InsertScheduleWithIdRequest) Reset ¶ added in v1.15.0
func (x *InsertScheduleWithIdRequest) Reset()
func (*InsertScheduleWithIdRequest) String ¶ added in v1.15.0
func (x *InsertScheduleWithIdRequest) String() string
type MemoryInfo ¶
type MemoryInfo struct { Mem *MemoryInfo_Memory `protobuf:"bytes,1,opt,name=mem,proto3" json:"mem,omitempty"` Swap *MemoryInfo_Memory `protobuf:"bytes,2,opt,name=swap,proto3" json:"swap,omitempty"` // contains filtered or unexported fields }
func (*MemoryInfo) Descriptor
deprecated
func (*MemoryInfo) Descriptor() ([]byte, []int)
Deprecated: Use MemoryInfo.ProtoReflect.Descriptor instead.
func (*MemoryInfo) GetMem ¶
func (x *MemoryInfo) GetMem() *MemoryInfo_Memory
func (*MemoryInfo) GetSwap ¶
func (x *MemoryInfo) GetSwap() *MemoryInfo_Memory
func (*MemoryInfo) ProtoMessage ¶
func (*MemoryInfo) ProtoMessage()
func (*MemoryInfo) ProtoReflect ¶
func (x *MemoryInfo) ProtoReflect() protoreflect.Message
func (*MemoryInfo) Reset ¶
func (x *MemoryInfo) Reset()
func (*MemoryInfo) String ¶
func (x *MemoryInfo) String() string
type MemoryInfo_Memory ¶
type MemoryInfo_Memory struct { Total uint64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` Used uint64 `protobuf:"varint,2,opt,name=used,proto3" json:"used,omitempty"` Free uint64 `protobuf:"varint,3,opt,name=free,proto3" json:"free,omitempty"` UsedPercent float64 `protobuf:"fixed64,5,opt,name=used_percent,json=usedPercent,proto3" json:"used_percent,omitempty"` // contains filtered or unexported fields }
func (*MemoryInfo_Memory) Descriptor
deprecated
func (*MemoryInfo_Memory) Descriptor() ([]byte, []int)
Deprecated: Use MemoryInfo_Memory.ProtoReflect.Descriptor instead.
func (*MemoryInfo_Memory) GetFree ¶
func (x *MemoryInfo_Memory) GetFree() uint64
func (*MemoryInfo_Memory) GetShared ¶
func (x *MemoryInfo_Memory) GetShared() uint64
func (*MemoryInfo_Memory) GetTotal ¶
func (x *MemoryInfo_Memory) GetTotal() uint64
func (*MemoryInfo_Memory) GetUsed ¶
func (x *MemoryInfo_Memory) GetUsed() uint64
func (*MemoryInfo_Memory) GetUsedPercent ¶
func (x *MemoryInfo_Memory) GetUsedPercent() float64
func (*MemoryInfo_Memory) ProtoMessage ¶
func (*MemoryInfo_Memory) ProtoMessage()
func (*MemoryInfo_Memory) ProtoReflect ¶
func (x *MemoryInfo_Memory) ProtoReflect() protoreflect.Message
func (*MemoryInfo_Memory) Reset ¶
func (x *MemoryInfo_Memory) Reset()
func (*MemoryInfo_Memory) String ¶
func (x *MemoryInfo_Memory) String() string
type Metric ¶
type Metric struct { AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"` // Should be set by user from env var AgentName string `protobuf:"bytes,2,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"` CpuInfo *CpuInfo `protobuf:"bytes,3,opt,name=cpu_info,json=cpuInfo,proto3" json:"cpu_info,omitempty"` MemoryInfo *MemoryInfo `protobuf:"bytes,4,opt,name=memory_info,json=memoryInfo,proto3" json:"memory_info,omitempty"` DiskInfo *DiskInfo `protobuf:"bytes,5,opt,name=disk_info,json=diskInfo,proto3" json:"disk_info,omitempty"` NetInfo *NetInfo `protobuf:"bytes,6,opt,name=net_info,json=netInfo,proto3" json:"net_info,omitempty"` Time *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*Metric) Descriptor
deprecated
func (*Metric) GetAgentId ¶
func (*Metric) GetAgentName ¶
func (*Metric) GetCpuInfo ¶
func (*Metric) GetDiskInfo ¶
func (*Metric) GetMemoryInfo ¶
func (x *Metric) GetMemoryInfo() *MemoryInfo
func (*Metric) GetNetInfo ¶
func (*Metric) GetTime ¶
func (x *Metric) GetTime() *timestamppb.Timestamp
func (*Metric) ProtoMessage ¶
func (*Metric) ProtoMessage()
func (*Metric) ProtoReflect ¶
func (x *Metric) ProtoReflect() protoreflect.Message
type NetInfo ¶
type NetInfo struct { Interfaces map[string]*NetInfo_Interface `` /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
func (*NetInfo) Descriptor
deprecated
func (*NetInfo) GetInterfaces ¶
func (x *NetInfo) GetInterfaces() map[string]*NetInfo_Interface
func (*NetInfo) ProtoMessage ¶
func (*NetInfo) ProtoMessage()
func (*NetInfo) ProtoReflect ¶
func (x *NetInfo) ProtoReflect() protoreflect.Message
type NetInfo_Interface ¶
type NetInfo_Interface struct { BytesSent uint64 `protobuf:"varint,1,opt,name=bytes_sent,json=bytesSent,proto3" json:"bytes_sent,omitempty"` BytesRecv uint64 `protobuf:"varint,2,opt,name=bytes_recv,json=bytesRecv,proto3" json:"bytes_recv,omitempty"` PacketsSent uint64 `protobuf:"varint,3,opt,name=packets_sent,json=packetsSent,proto3" json:"packets_sent,omitempty"` PacketsRecv uint64 `protobuf:"varint,4,opt,name=packets_recv,json=packetsRecv,proto3" json:"packets_recv,omitempty"` // total number of errors while receiving ErrIn uint64 `protobuf:"varint,5,opt,name=err_in,json=errIn,proto3" json:"err_in,omitempty"` // total number of errors while sending ErrOut uint64 `protobuf:"varint,6,opt,name=err_out,json=errOut,proto3" json:"err_out,omitempty"` // total number of incoming packets which were dropped DropIn uint64 `protobuf:"varint,7,opt,name=drop_in,json=dropIn,proto3" json:"drop_in,omitempty"` // total number of outgoing packets which were dropped // (always 0 on OSX and BSD) DropOut uint64 `protobuf:"varint,8,opt,name=drop_out,json=dropOut,proto3" json:"drop_out,omitempty"` // contains filtered or unexported fields }
func (*NetInfo_Interface) Descriptor
deprecated
func (*NetInfo_Interface) Descriptor() ([]byte, []int)
Deprecated: Use NetInfo_Interface.ProtoReflect.Descriptor instead.
func (*NetInfo_Interface) GetBytesRecv ¶
func (x *NetInfo_Interface) GetBytesRecv() uint64
func (*NetInfo_Interface) GetBytesSent ¶
func (x *NetInfo_Interface) GetBytesSent() uint64
func (*NetInfo_Interface) GetDropIn ¶
func (x *NetInfo_Interface) GetDropIn() uint64
func (*NetInfo_Interface) GetDropOut ¶
func (x *NetInfo_Interface) GetDropOut() uint64
func (*NetInfo_Interface) GetErrIn ¶
func (x *NetInfo_Interface) GetErrIn() uint64
func (*NetInfo_Interface) GetErrOut ¶
func (x *NetInfo_Interface) GetErrOut() uint64
func (*NetInfo_Interface) GetPacketsRecv ¶
func (x *NetInfo_Interface) GetPacketsRecv() uint64
func (*NetInfo_Interface) GetPacketsSent ¶
func (x *NetInfo_Interface) GetPacketsSent() uint64
func (*NetInfo_Interface) ProtoMessage ¶
func (*NetInfo_Interface) ProtoMessage()
func (*NetInfo_Interface) ProtoReflect ¶
func (x *NetInfo_Interface) ProtoReflect() protoreflect.Message
func (*NetInfo_Interface) Reset ¶
func (x *NetInfo_Interface) Reset()
func (*NetInfo_Interface) String ¶
func (x *NetInfo_Interface) String() string
type NotificationManagerClient ¶ added in v1.13.0
type NotificationManagerClient interface { // protolint:disable:next MAX_LINE_LENGTH CreateNotificationMethod(ctx context.Context, in *CreateNotificationMethodRequest, opts ...grpc.CallOption) (*NotificationMethod, error) GetById(ctx context.Context, in *NotificationMethodIdRequest, opts ...grpc.CallOption) (*NotificationMethod, error) GetNotificationMethods(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetListResponse, error) DeleteById(ctx context.Context, in *NotificationMethodIdRequest, opts ...grpc.CallOption) (*NotificationMethod, error) Activate(ctx context.Context, in *NotificationMethodIdRequest, opts ...grpc.CallOption) (*NotificationMethod, error) Deactivate(ctx context.Context, in *NotificationMethodIdRequest, opts ...grpc.CallOption) (*NotificationMethod, error) Add(ctx context.Context, in *NotificationMethodRequest, opts ...grpc.CallOption) (*NotificationMethod, error) Remove(ctx context.Context, in *NotificationMethodRequest, opts ...grpc.CallOption) (*NotificationMethod, error) GetList(ctx context.Context, in *GetListRequest, opts ...grpc.CallOption) (*GetListResponse, error) Notify(ctx context.Context, in *NotifyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) }
NotificationManagerClient is the client API for NotificationManager service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewNotificationManagerClient ¶ added in v1.13.0
func NewNotificationManagerClient(cc grpc.ClientConnInterface) NotificationManagerClient
type NotificationManagerServer ¶ added in v1.13.0
type NotificationManagerServer interface { // protolint:disable:next MAX_LINE_LENGTH CreateNotificationMethod(context.Context, *CreateNotificationMethodRequest) (*NotificationMethod, error) GetById(context.Context, *NotificationMethodIdRequest) (*NotificationMethod, error) GetNotificationMethods(context.Context, *emptypb.Empty) (*GetListResponse, error) DeleteById(context.Context, *NotificationMethodIdRequest) (*NotificationMethod, error) Activate(context.Context, *NotificationMethodIdRequest) (*NotificationMethod, error) Deactivate(context.Context, *NotificationMethodIdRequest) (*NotificationMethod, error) Add(context.Context, *NotificationMethodRequest) (*NotificationMethod, error) Remove(context.Context, *NotificationMethodRequest) (*NotificationMethod, error) GetList(context.Context, *GetListRequest) (*GetListResponse, error) Notify(context.Context, *NotifyRequest) (*emptypb.Empty, error) // contains filtered or unexported methods }
NotificationManagerServer is the server API for NotificationManager service. All implementations must embed UnimplementedNotificationManagerServer for forward compatibility
type NotificationMethod ¶
type NotificationMethod struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Status NotificationMethodStatus `protobuf:"varint,3,opt,name=status,proto3,enum=squzy.v1.notification.NotificationMethodStatus" json:"status,omitempty"` Type NotificationMethodType `protobuf:"varint,4,opt,name=type,proto3,enum=squzy.v1.notification.NotificationMethodType" json:"type,omitempty"` // Types that are assignable to Method: // // *NotificationMethod_Slack // *NotificationMethod_Webhook Method isNotificationMethod_Method `protobuf_oneof:"method"` // contains filtered or unexported fields }
func (*NotificationMethod) Descriptor
deprecated
func (*NotificationMethod) Descriptor() ([]byte, []int)
Deprecated: Use NotificationMethod.ProtoReflect.Descriptor instead.
func (*NotificationMethod) GetId ¶
func (x *NotificationMethod) GetId() string
func (*NotificationMethod) GetMethod ¶
func (m *NotificationMethod) GetMethod() isNotificationMethod_Method
func (*NotificationMethod) GetName ¶
func (x *NotificationMethod) GetName() string
func (*NotificationMethod) GetSlack ¶
func (x *NotificationMethod) GetSlack() *SlackMethod
func (*NotificationMethod) GetStatus ¶
func (x *NotificationMethod) GetStatus() NotificationMethodStatus
func (*NotificationMethod) GetType ¶
func (x *NotificationMethod) GetType() NotificationMethodType
func (*NotificationMethod) GetWebhook ¶
func (x *NotificationMethod) GetWebhook() *WebHookMethod
func (*NotificationMethod) ProtoMessage ¶
func (*NotificationMethod) ProtoMessage()
func (*NotificationMethod) ProtoReflect ¶
func (x *NotificationMethod) ProtoReflect() protoreflect.Message
func (*NotificationMethod) Reset ¶
func (x *NotificationMethod) Reset()
func (*NotificationMethod) String ¶
func (x *NotificationMethod) String() string
type NotificationMethodIdRequest ¶
type NotificationMethodIdRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*NotificationMethodIdRequest) Descriptor
deprecated
func (*NotificationMethodIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use NotificationMethodIdRequest.ProtoReflect.Descriptor instead.
func (*NotificationMethodIdRequest) GetId ¶
func (x *NotificationMethodIdRequest) GetId() string
func (*NotificationMethodIdRequest) ProtoMessage ¶
func (*NotificationMethodIdRequest) ProtoMessage()
func (*NotificationMethodIdRequest) ProtoReflect ¶
func (x *NotificationMethodIdRequest) ProtoReflect() protoreflect.Message
func (*NotificationMethodIdRequest) Reset ¶
func (x *NotificationMethodIdRequest) Reset()
func (*NotificationMethodIdRequest) String ¶
func (x *NotificationMethodIdRequest) String() string
type NotificationMethodRequest ¶
type NotificationMethodRequest struct { OwnerType ComponentOwnerType `` /* 129-byte string literal not displayed */ OwnerId string `protobuf:"bytes,2,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"` NotificationMethodId string `protobuf:"bytes,3,opt,name=notification_method_id,json=notificationMethodId,proto3" json:"notification_method_id,omitempty"` // contains filtered or unexported fields }
func (*NotificationMethodRequest) Descriptor
deprecated
func (*NotificationMethodRequest) Descriptor() ([]byte, []int)
Deprecated: Use NotificationMethodRequest.ProtoReflect.Descriptor instead.
func (*NotificationMethodRequest) GetNotificationMethodId ¶
func (x *NotificationMethodRequest) GetNotificationMethodId() string
func (*NotificationMethodRequest) GetOwnerId ¶
func (x *NotificationMethodRequest) GetOwnerId() string
func (*NotificationMethodRequest) GetOwnerType ¶
func (x *NotificationMethodRequest) GetOwnerType() ComponentOwnerType
func (*NotificationMethodRequest) ProtoMessage ¶
func (*NotificationMethodRequest) ProtoMessage()
func (*NotificationMethodRequest) ProtoReflect ¶
func (x *NotificationMethodRequest) ProtoReflect() protoreflect.Message
func (*NotificationMethodRequest) Reset ¶
func (x *NotificationMethodRequest) Reset()
func (*NotificationMethodRequest) String ¶
func (x *NotificationMethodRequest) String() string
type NotificationMethodStatus ¶
type NotificationMethodStatus int32
const ( NotificationMethodStatus_NOTIFICATION_STATUS_UNSPECIFIED NotificationMethodStatus = 0 NotificationMethodStatus_NOTIFICATION_STATUS_ACTIVE NotificationMethodStatus = 1 NotificationMethodStatus_NOTIFICATION_STATUS_INACTIVE NotificationMethodStatus = 2 NotificationMethodStatus_NOTIFICATION_STATUS_REMOVED NotificationMethodStatus = 3 )
func (NotificationMethodStatus) Descriptor ¶
func (NotificationMethodStatus) Descriptor() protoreflect.EnumDescriptor
func (NotificationMethodStatus) Enum ¶
func (x NotificationMethodStatus) Enum() *NotificationMethodStatus
func (NotificationMethodStatus) EnumDescriptor
deprecated
func (NotificationMethodStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use NotificationMethodStatus.Descriptor instead.
func (NotificationMethodStatus) Number ¶
func (x NotificationMethodStatus) Number() protoreflect.EnumNumber
func (NotificationMethodStatus) String ¶
func (x NotificationMethodStatus) String() string
func (NotificationMethodStatus) Type ¶
func (NotificationMethodStatus) Type() protoreflect.EnumType
type NotificationMethodType ¶
type NotificationMethodType int32
const ( NotificationMethodType_NOTIFICATION_METHOD_UNSPECIFIED NotificationMethodType = 0 NotificationMethodType_NOTIFICATION_METHOD_WEBHOOK NotificationMethodType = 1 NotificationMethodType_NOTIFICATION_METHOD_SLACK NotificationMethodType = 2 )
func (NotificationMethodType) Descriptor ¶
func (NotificationMethodType) Descriptor() protoreflect.EnumDescriptor
func (NotificationMethodType) Enum ¶
func (x NotificationMethodType) Enum() *NotificationMethodType
func (NotificationMethodType) EnumDescriptor
deprecated
func (NotificationMethodType) EnumDescriptor() ([]byte, []int)
Deprecated: Use NotificationMethodType.Descriptor instead.
func (NotificationMethodType) Number ¶
func (x NotificationMethodType) Number() protoreflect.EnumNumber
func (NotificationMethodType) String ¶
func (x NotificationMethodType) String() string
func (NotificationMethodType) Type ¶
func (NotificationMethodType) Type() protoreflect.EnumType
type NotificationMethod_Slack ¶
type NotificationMethod_Slack struct {
Slack *SlackMethod `protobuf:"bytes,5,opt,name=slack,proto3,oneof"`
}
type NotificationMethod_Webhook ¶
type NotificationMethod_Webhook struct {
Webhook *WebHookMethod `protobuf:"bytes,6,opt,name=webhook,proto3,oneof"`
}
type NotifyRequest ¶
type NotifyRequest struct { IncidentId string `protobuf:"bytes,1,opt,name=incident_id,json=incidentId,proto3" json:"incident_id,omitempty"` OwnerType ComponentOwnerType `` /* 129-byte string literal not displayed */ // It is rule id OwnerId string `protobuf:"bytes,3,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"` // Added for user purpose RuleName string `protobuf:"bytes,4,opt,name=rule_name,json=ruleName,proto3" json:"rule_name,omitempty"` // contains filtered or unexported fields }
func (*NotifyRequest) Descriptor
deprecated
func (*NotifyRequest) Descriptor() ([]byte, []int)
Deprecated: Use NotifyRequest.ProtoReflect.Descriptor instead.
func (*NotifyRequest) GetIncidentId ¶
func (x *NotifyRequest) GetIncidentId() string
func (*NotifyRequest) GetOwnerId ¶
func (x *NotifyRequest) GetOwnerId() string
func (*NotifyRequest) GetOwnerType ¶
func (x *NotifyRequest) GetOwnerType() ComponentOwnerType
func (*NotifyRequest) GetRuleName ¶ added in v1.14.0
func (x *NotifyRequest) GetRuleName() string
func (*NotifyRequest) ProtoMessage ¶
func (*NotifyRequest) ProtoMessage()
func (*NotifyRequest) ProtoReflect ¶
func (x *NotifyRequest) ProtoReflect() protoreflect.Message
func (*NotifyRequest) Reset ¶
func (x *NotifyRequest) Reset()
func (*NotifyRequest) String ¶
func (x *NotifyRequest) String() string
type Pagination ¶
type Pagination struct { Page int32 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"` // default 0 Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` // default 20 // contains filtered or unexported fields }
func (*Pagination) Descriptor
deprecated
func (*Pagination) Descriptor() ([]byte, []int)
Deprecated: Use Pagination.ProtoReflect.Descriptor instead.
func (*Pagination) GetLimit ¶
func (x *Pagination) GetLimit() int32
func (*Pagination) GetPage ¶
func (x *Pagination) GetPage() int32
func (*Pagination) ProtoMessage ¶
func (*Pagination) ProtoMessage()
func (*Pagination) ProtoReflect ¶
func (x *Pagination) ProtoReflect() protoreflect.Message
func (*Pagination) Reset ¶
func (x *Pagination) Reset()
func (*Pagination) String ¶
func (x *Pagination) String() string
type PlatformInfo ¶
type PlatformInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Family string `protobuf:"bytes,2,opt,name=family,proto3" json:"family,omitempty"` Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*PlatformInfo) Descriptor
deprecated
func (*PlatformInfo) Descriptor() ([]byte, []int)
Deprecated: Use PlatformInfo.ProtoReflect.Descriptor instead.
func (*PlatformInfo) GetFamily ¶
func (x *PlatformInfo) GetFamily() string
func (*PlatformInfo) GetName ¶
func (x *PlatformInfo) GetName() string
func (*PlatformInfo) GetVersion ¶
func (x *PlatformInfo) GetVersion() string
func (*PlatformInfo) ProtoMessage ¶
func (*PlatformInfo) ProtoMessage()
func (*PlatformInfo) ProtoReflect ¶
func (x *PlatformInfo) ProtoReflect() protoreflect.Message
func (*PlatformInfo) Reset ¶
func (x *PlatformInfo) Reset()
func (*PlatformInfo) String ¶
func (x *PlatformInfo) String() string
type RegisterRequest ¶
type RegisterRequest struct { // Name form env AgentName string `protobuf:"bytes,1,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"` HostInfo *HostInfo `protobuf:"bytes,2,opt,name=host_info,json=hostInfo,proto3" json:"host_info,omitempty"` Time *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"` // interval for update Interval int64 `protobuf:"varint,4,opt,name=interval,proto3" json:"interval,omitempty"` // contains filtered or unexported fields }
func (*RegisterRequest) Descriptor
deprecated
func (*RegisterRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.
func (*RegisterRequest) GetAgentName ¶
func (x *RegisterRequest) GetAgentName() string
func (*RegisterRequest) GetHostInfo ¶
func (x *RegisterRequest) GetHostInfo() *HostInfo
func (*RegisterRequest) GetInterval ¶
func (x *RegisterRequest) GetInterval() int64
func (*RegisterRequest) GetTime ¶
func (x *RegisterRequest) GetTime() *timestamppb.Timestamp
func (*RegisterRequest) ProtoMessage ¶
func (*RegisterRequest) ProtoMessage()
func (*RegisterRequest) ProtoReflect ¶
func (x *RegisterRequest) ProtoReflect() protoreflect.Message
func (*RegisterRequest) Reset ¶
func (x *RegisterRequest) Reset()
func (*RegisterRequest) String ¶
func (x *RegisterRequest) String() string
type RegisterResponse ¶
type RegisterResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` EnvName string `protobuf:"bytes,2,opt,name=env_name,json=envName,proto3" json:"env_name,omitempty"` // contains filtered or unexported fields }
func (*RegisterResponse) Descriptor
deprecated
func (*RegisterResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.
func (*RegisterResponse) GetEnvName ¶
func (x *RegisterResponse) GetEnvName() string
func (*RegisterResponse) GetId ¶
func (x *RegisterResponse) GetId() string
func (*RegisterResponse) ProtoMessage ¶
func (*RegisterResponse) ProtoMessage()
func (*RegisterResponse) ProtoReflect ¶
func (x *RegisterResponse) ProtoReflect() protoreflect.Message
func (*RegisterResponse) Reset ¶
func (x *RegisterResponse) Reset()
func (*RegisterResponse) String ¶
func (x *RegisterResponse) String() string
type RemoveRequest ¶
type RemoveRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*RemoveRequest) Descriptor
deprecated
func (*RemoveRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.
func (*RemoveRequest) GetId ¶
func (x *RemoveRequest) GetId() string
func (*RemoveRequest) ProtoMessage ¶
func (*RemoveRequest) ProtoMessage()
func (*RemoveRequest) ProtoReflect ¶
func (x *RemoveRequest) ProtoReflect() protoreflect.Message
func (*RemoveRequest) Reset ¶
func (x *RemoveRequest) Reset()
func (*RemoveRequest) String ¶
func (x *RemoveRequest) String() string
type RemoveResponse ¶
type RemoveResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*RemoveResponse) Descriptor
deprecated
func (*RemoveResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoveResponse.ProtoReflect.Descriptor instead.
func (*RemoveResponse) GetId ¶
func (x *RemoveResponse) GetId() string
func (*RemoveResponse) ProtoMessage ¶
func (*RemoveResponse) ProtoMessage()
func (*RemoveResponse) ProtoReflect ¶
func (x *RemoveResponse) ProtoReflect() protoreflect.Message
func (*RemoveResponse) Reset ¶
func (x *RemoveResponse) Reset()
func (*RemoveResponse) String ¶
func (x *RemoveResponse) String() string
type Rule ¶
type Rule struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Rule string `protobuf:"bytes,2,opt,name=rule,proto3" json:"rule,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` AutoClose bool `protobuf:"varint,4,opt,name=auto_close,json=autoClose,proto3" json:"auto_close,omitempty"` OwnerType ComponentOwnerType `` /* 129-byte string literal not displayed */ OwnerId string `protobuf:"bytes,6,opt,name=owner_id,json=ownerId,proto3" json:"owner_id,omitempty"` Status RuleStatus `protobuf:"varint,7,opt,name=status,proto3,enum=squzy.v1.incident.RuleStatus" json:"status,omitempty"` Notification bool `protobuf:"varint,8,opt,name=notification,proto3" json:"notification,omitempty"` // contains filtered or unexported fields }
func (*Rule) Descriptor
deprecated
func (*Rule) GetAutoClose ¶
func (*Rule) GetNotification ¶
func (*Rule) GetOwnerId ¶
func (*Rule) GetOwnerType ¶
func (x *Rule) GetOwnerType() ComponentOwnerType
func (*Rule) GetStatus ¶
func (x *Rule) GetStatus() RuleStatus
func (*Rule) ProtoMessage ¶
func (*Rule) ProtoMessage()
func (*Rule) ProtoReflect ¶
func (x *Rule) ProtoReflect() protoreflect.Message
type RuleIdRequest ¶
type RuleIdRequest struct { RuleId string `protobuf:"bytes,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"` // contains filtered or unexported fields }
func (*RuleIdRequest) Descriptor
deprecated
func (*RuleIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use RuleIdRequest.ProtoReflect.Descriptor instead.
func (*RuleIdRequest) GetRuleId ¶
func (x *RuleIdRequest) GetRuleId() string
func (*RuleIdRequest) ProtoMessage ¶
func (*RuleIdRequest) ProtoMessage()
func (*RuleIdRequest) ProtoReflect ¶
func (x *RuleIdRequest) ProtoReflect() protoreflect.Message
func (*RuleIdRequest) Reset ¶
func (x *RuleIdRequest) Reset()
func (*RuleIdRequest) String ¶
func (x *RuleIdRequest) String() string
type RuleStatus ¶
type RuleStatus int32
const ( RuleStatus_RULE_STATUS_UNSPECIFIED RuleStatus = 0 RuleStatus_RULE_STATUS_ACTIVE RuleStatus = 1 RuleStatus_RULE_STATUS_INACTIVE RuleStatus = 2 RuleStatus_RULE_STATUS_REMOVED RuleStatus = 3 )
func (RuleStatus) Descriptor ¶
func (RuleStatus) Descriptor() protoreflect.EnumDescriptor
func (RuleStatus) Enum ¶
func (x RuleStatus) Enum() *RuleStatus
func (RuleStatus) EnumDescriptor
deprecated
func (RuleStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use RuleStatus.Descriptor instead.
func (RuleStatus) Number ¶
func (x RuleStatus) Number() protoreflect.EnumNumber
func (RuleStatus) String ¶
func (x RuleStatus) String() string
func (RuleStatus) Type ¶
func (RuleStatus) Type() protoreflect.EnumType
type Rules ¶
type Rules struct { Rules []*Rule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"` // contains filtered or unexported fields }
func (*Rules) Descriptor
deprecated
func (*Rules) ProtoMessage ¶
func (*Rules) ProtoMessage()
func (*Rules) ProtoReflect ¶
func (x *Rules) ProtoReflect() protoreflect.Message
type RunRequest ¶
type RunRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*RunRequest) Descriptor
deprecated
func (*RunRequest) Descriptor() ([]byte, []int)
Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.
func (*RunRequest) GetId ¶
func (x *RunRequest) GetId() string
func (*RunRequest) ProtoMessage ¶
func (*RunRequest) ProtoMessage()
func (*RunRequest) ProtoReflect ¶
func (x *RunRequest) ProtoReflect() protoreflect.Message
func (*RunRequest) Reset ¶
func (x *RunRequest) Reset()
func (*RunRequest) String ¶
func (x *RunRequest) String() string
type RunResponse ¶
type RunResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*RunResponse) Descriptor
deprecated
func (*RunResponse) Descriptor() ([]byte, []int)
Deprecated: Use RunResponse.ProtoReflect.Descriptor instead.
func (*RunResponse) GetId ¶
func (x *RunResponse) GetId() string
func (*RunResponse) ProtoMessage ¶
func (*RunResponse) ProtoMessage()
func (*RunResponse) ProtoReflect ¶
func (x *RunResponse) ProtoReflect() protoreflect.Message
func (*RunResponse) Reset ¶
func (x *RunResponse) Reset()
func (*RunResponse) String ¶
func (x *RunResponse) String() string
type Scheduler ¶
type Scheduler struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Type SchedulerType `protobuf:"varint,3,opt,name=type,proto3,enum=squzy.v1.monitoring.SchedulerType" json:"type,omitempty"` Status SchedulerStatus `protobuf:"varint,4,opt,name=status,proto3,enum=squzy.v1.monitoring.SchedulerStatus" json:"status,omitempty"` // How often we need execute check Interval int32 `protobuf:"varint,5,opt,name=interval,proto3" json:"interval,omitempty"` // Timeout for check request Timeout int32 `protobuf:"varint,6,opt,name=timeout,proto3" json:"timeout,omitempty"` // Config of the scheduler; // // Types that are assignable to Config: // // *Scheduler_Tcp // *Scheduler_Sitemap // *Scheduler_Grpc // *Scheduler_Http // *Scheduler_HttpValue // *Scheduler_SslExpiration // *Scheduler_Mongo // *Scheduler_Postgres // *Scheduler_Cassandra // *Scheduler_Mysql Config isScheduler_Config `protobuf_oneof:"config"` // contains filtered or unexported fields }
func (*Scheduler) Descriptor
deprecated
func (*Scheduler) GetCassandra ¶ added in v1.16.0
func (*Scheduler) GetGrpc ¶
func (x *Scheduler) GetGrpc() *GrpcConfig
func (*Scheduler) GetHttp ¶
func (x *Scheduler) GetHttp() *HttpConfig
func (*Scheduler) GetHttpValue ¶
func (x *Scheduler) GetHttpValue() *HttpJsonValueConfig
func (*Scheduler) GetInterval ¶
func (*Scheduler) GetPostgres ¶ added in v1.16.0
func (*Scheduler) GetSitemap ¶
func (x *Scheduler) GetSitemap() *SiteMapConfig
func (*Scheduler) GetSslExpiration ¶
func (x *Scheduler) GetSslExpiration() *SslExpirationConfig
func (*Scheduler) GetStatus ¶
func (x *Scheduler) GetStatus() SchedulerStatus
func (*Scheduler) GetTimeout ¶
func (*Scheduler) GetType ¶
func (x *Scheduler) GetType() SchedulerType
func (*Scheduler) ProtoMessage ¶
func (*Scheduler) ProtoMessage()
func (*Scheduler) ProtoReflect ¶
func (x *Scheduler) ProtoReflect() protoreflect.Message
type SchedulerCode ¶
type SchedulerCode int32
const ( SchedulerCode_SCHEDULER_CODE_UNSPECIFIED SchedulerCode = 0 SchedulerCode_OK SchedulerCode = 1 SchedulerCode_ERROR SchedulerCode = 2 )
func (SchedulerCode) Descriptor ¶
func (SchedulerCode) Descriptor() protoreflect.EnumDescriptor
func (SchedulerCode) Enum ¶
func (x SchedulerCode) Enum() *SchedulerCode
func (SchedulerCode) EnumDescriptor
deprecated
func (SchedulerCode) EnumDescriptor() ([]byte, []int)
Deprecated: Use SchedulerCode.Descriptor instead.
func (SchedulerCode) Number ¶
func (x SchedulerCode) Number() protoreflect.EnumNumber
func (SchedulerCode) String ¶
func (x SchedulerCode) String() string
func (SchedulerCode) Type ¶
func (SchedulerCode) Type() protoreflect.EnumType
type SchedulerResponse ¶
type SchedulerResponse struct { SchedulerId string `protobuf:"bytes,1,opt,name=scheduler_id,json=schedulerId,proto3" json:"scheduler_id,omitempty"` Snapshot *SchedulerSnapshot `protobuf:"bytes,2,opt,name=snapshot,proto3" json:"snapshot,omitempty"` // contains filtered or unexported fields }
func (*SchedulerResponse) Descriptor
deprecated
func (*SchedulerResponse) Descriptor() ([]byte, []int)
Deprecated: Use SchedulerResponse.ProtoReflect.Descriptor instead.
func (*SchedulerResponse) GetSchedulerId ¶
func (x *SchedulerResponse) GetSchedulerId() string
func (*SchedulerResponse) GetSnapshot ¶
func (x *SchedulerResponse) GetSnapshot() *SchedulerSnapshot
func (*SchedulerResponse) ProtoMessage ¶
func (*SchedulerResponse) ProtoMessage()
func (*SchedulerResponse) ProtoReflect ¶
func (x *SchedulerResponse) ProtoReflect() protoreflect.Message
func (*SchedulerResponse) Reset ¶
func (x *SchedulerResponse) Reset()
func (*SchedulerResponse) String ¶
func (x *SchedulerResponse) String() string
type SchedulerSnapshot ¶
type SchedulerSnapshot struct { Code SchedulerCode `protobuf:"varint,2,opt,name=code,proto3,enum=squzy.v1.monitoring.SchedulerCode" json:"code,omitempty"` Type SchedulerType `protobuf:"varint,3,opt,name=type,proto3,enum=squzy.v1.monitoring.SchedulerType" json:"type,omitempty"` Error *SchedulerSnapshot_Error `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"` Meta *SchedulerSnapshot_MetaData `protobuf:"bytes,5,opt,name=meta,proto3" json:"meta,omitempty"` // contains filtered or unexported fields }
func (*SchedulerSnapshot) Descriptor
deprecated
func (*SchedulerSnapshot) Descriptor() ([]byte, []int)
Deprecated: Use SchedulerSnapshot.ProtoReflect.Descriptor instead.
func (*SchedulerSnapshot) GetCode ¶
func (x *SchedulerSnapshot) GetCode() SchedulerCode
func (*SchedulerSnapshot) GetError ¶
func (x *SchedulerSnapshot) GetError() *SchedulerSnapshot_Error
func (*SchedulerSnapshot) GetMeta ¶
func (x *SchedulerSnapshot) GetMeta() *SchedulerSnapshot_MetaData
func (*SchedulerSnapshot) GetType ¶
func (x *SchedulerSnapshot) GetType() SchedulerType
func (*SchedulerSnapshot) ProtoMessage ¶
func (*SchedulerSnapshot) ProtoMessage()
func (*SchedulerSnapshot) ProtoReflect ¶
func (x *SchedulerSnapshot) ProtoReflect() protoreflect.Message
func (*SchedulerSnapshot) Reset ¶
func (x *SchedulerSnapshot) Reset()
func (*SchedulerSnapshot) String ¶
func (x *SchedulerSnapshot) String() string
type SchedulerSnapshotWithId ¶
type SchedulerSnapshotWithId struct { Snapshot *SchedulerSnapshot `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*SchedulerSnapshotWithId) Descriptor
deprecated
func (*SchedulerSnapshotWithId) Descriptor() ([]byte, []int)
Deprecated: Use SchedulerSnapshotWithId.ProtoReflect.Descriptor instead.
func (*SchedulerSnapshotWithId) GetId ¶
func (x *SchedulerSnapshotWithId) GetId() string
func (*SchedulerSnapshotWithId) GetSnapshot ¶
func (x *SchedulerSnapshotWithId) GetSnapshot() *SchedulerSnapshot
func (*SchedulerSnapshotWithId) ProtoMessage ¶
func (*SchedulerSnapshotWithId) ProtoMessage()
func (*SchedulerSnapshotWithId) ProtoReflect ¶
func (x *SchedulerSnapshotWithId) ProtoReflect() protoreflect.Message
func (*SchedulerSnapshotWithId) Reset ¶
func (x *SchedulerSnapshotWithId) Reset()
func (*SchedulerSnapshotWithId) String ¶
func (x *SchedulerSnapshotWithId) String() string
type SchedulerSnapshot_Error ¶
type SchedulerSnapshot_Error struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*SchedulerSnapshot_Error) Descriptor
deprecated
func (*SchedulerSnapshot_Error) Descriptor() ([]byte, []int)
Deprecated: Use SchedulerSnapshot_Error.ProtoReflect.Descriptor instead.
func (*SchedulerSnapshot_Error) GetMessage ¶
func (x *SchedulerSnapshot_Error) GetMessage() string
func (*SchedulerSnapshot_Error) ProtoMessage ¶
func (*SchedulerSnapshot_Error) ProtoMessage()
func (*SchedulerSnapshot_Error) ProtoReflect ¶
func (x *SchedulerSnapshot_Error) ProtoReflect() protoreflect.Message
func (*SchedulerSnapshot_Error) Reset ¶
func (x *SchedulerSnapshot_Error) Reset()
func (*SchedulerSnapshot_Error) String ¶
func (x *SchedulerSnapshot_Error) String() string
type SchedulerSnapshot_MetaData ¶
type SchedulerSnapshot_MetaData struct { StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` Value *structpb.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*SchedulerSnapshot_MetaData) Descriptor
deprecated
func (*SchedulerSnapshot_MetaData) Descriptor() ([]byte, []int)
Deprecated: Use SchedulerSnapshot_MetaData.ProtoReflect.Descriptor instead.
func (*SchedulerSnapshot_MetaData) GetEndTime ¶
func (x *SchedulerSnapshot_MetaData) GetEndTime() *timestamppb.Timestamp
func (*SchedulerSnapshot_MetaData) GetStartTime ¶
func (x *SchedulerSnapshot_MetaData) GetStartTime() *timestamppb.Timestamp
func (*SchedulerSnapshot_MetaData) GetValue ¶
func (x *SchedulerSnapshot_MetaData) GetValue() *structpb.Value
func (*SchedulerSnapshot_MetaData) ProtoMessage ¶
func (*SchedulerSnapshot_MetaData) ProtoMessage()
func (*SchedulerSnapshot_MetaData) ProtoReflect ¶
func (x *SchedulerSnapshot_MetaData) ProtoReflect() protoreflect.Message
func (*SchedulerSnapshot_MetaData) Reset ¶
func (x *SchedulerSnapshot_MetaData) Reset()
func (*SchedulerSnapshot_MetaData) String ¶
func (x *SchedulerSnapshot_MetaData) String() string
type SchedulerStatus ¶
type SchedulerStatus int32
const ( // Initial status SchedulerStatus_SCHEDULER_STATUS_UNSPECIFIED SchedulerStatus = 0 SchedulerStatus_RUNNED SchedulerStatus = 1 SchedulerStatus_STOPPED SchedulerStatus = 2 SchedulerStatus_REMOVED SchedulerStatus = 3 )
func (SchedulerStatus) Descriptor ¶
func (SchedulerStatus) Descriptor() protoreflect.EnumDescriptor
func (SchedulerStatus) Enum ¶
func (x SchedulerStatus) Enum() *SchedulerStatus
func (SchedulerStatus) EnumDescriptor
deprecated
func (SchedulerStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use SchedulerStatus.Descriptor instead.
func (SchedulerStatus) Number ¶
func (x SchedulerStatus) Number() protoreflect.EnumNumber
func (SchedulerStatus) String ¶
func (x SchedulerStatus) String() string
func (SchedulerStatus) Type ¶
func (SchedulerStatus) Type() protoreflect.EnumType
type SchedulerType ¶
type SchedulerType int32
const ( // Initial status SchedulerType_SCHEDULER_TYPE_UNSPECIFIED SchedulerType = 0 SchedulerType_TCP SchedulerType = 1 SchedulerType_GRPC SchedulerType = 2 SchedulerType_HTTP SchedulerType = 3 SchedulerType_SITE_MAP SchedulerType = 4 SchedulerType_HTTP_JSON_VALUE SchedulerType = 5 SchedulerType_SSL_EXPIRATION SchedulerType = 6 SchedulerType_MONGO SchedulerType = 7 SchedulerType_POSTGRES SchedulerType = 8 SchedulerType_CASSANDRA SchedulerType = 9 SchedulerType_MYSQL SchedulerType = 10 )
func (SchedulerType) Descriptor ¶
func (SchedulerType) Descriptor() protoreflect.EnumDescriptor
func (SchedulerType) Enum ¶
func (x SchedulerType) Enum() *SchedulerType
func (SchedulerType) EnumDescriptor
deprecated
func (SchedulerType) EnumDescriptor() ([]byte, []int)
Deprecated: Use SchedulerType.Descriptor instead.
func (SchedulerType) Number ¶
func (x SchedulerType) Number() protoreflect.EnumNumber
func (SchedulerType) String ¶
func (x SchedulerType) String() string
func (SchedulerType) Type ¶
func (SchedulerType) Type() protoreflect.EnumType
type Scheduler_Cassandra ¶ added in v1.16.0
type Scheduler_Cassandra struct {
Cassandra *DbConfig `protobuf:"bytes,15,opt,name=cassandra,proto3,oneof"`
}
type Scheduler_Grpc ¶
type Scheduler_Grpc struct {
Grpc *GrpcConfig `protobuf:"bytes,9,opt,name=grpc,proto3,oneof"`
}
type Scheduler_Http ¶
type Scheduler_Http struct {
Http *HttpConfig `protobuf:"bytes,10,opt,name=http,proto3,oneof"`
}
type Scheduler_HttpValue ¶
type Scheduler_HttpValue struct {
HttpValue *HttpJsonValueConfig `protobuf:"bytes,11,opt,name=http_value,json=httpValue,proto3,oneof"`
}
type Scheduler_Mongo ¶ added in v1.16.0
type Scheduler_Mongo struct {
Mongo *DbConfig `protobuf:"bytes,13,opt,name=mongo,proto3,oneof"`
}
type Scheduler_Mysql ¶ added in v1.16.0
type Scheduler_Mysql struct {
Mysql *DbConfig `protobuf:"bytes,16,opt,name=mysql,proto3,oneof"`
}
type Scheduler_Postgres ¶ added in v1.16.0
type Scheduler_Postgres struct {
Postgres *DbConfig `protobuf:"bytes,14,opt,name=postgres,proto3,oneof"`
}
type Scheduler_Sitemap ¶
type Scheduler_Sitemap struct {
Sitemap *SiteMapConfig `protobuf:"bytes,8,opt,name=sitemap,proto3,oneof"`
}
type Scheduler_SslExpiration ¶
type Scheduler_SslExpiration struct {
SslExpiration *SslExpirationConfig `protobuf:"bytes,12,opt,name=ssl_expiration,json=sslExpiration,proto3,oneof"`
}
type Scheduler_Tcp ¶
type Scheduler_Tcp struct {
Tcp *TcpConfig `protobuf:"bytes,7,opt,name=tcp,proto3,oneof"`
}
type SchedulersExecutorClient ¶ added in v1.13.0
type SchedulersExecutorClient interface { // protolint:disable:next MAX_LINE_LENGTH GetSchedulerList(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetSchedulerListResponse, error) GetSchedulerById(ctx context.Context, in *GetSchedulerByIdRequest, opts ...grpc.CallOption) (*Scheduler, error) Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error) Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error) Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error) Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error) }
SchedulersExecutorClient is the client API for SchedulersExecutor service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSchedulersExecutorClient ¶ added in v1.13.0
func NewSchedulersExecutorClient(cc grpc.ClientConnInterface) SchedulersExecutorClient
type SchedulersExecutorServer ¶ added in v1.13.0
type SchedulersExecutorServer interface { // protolint:disable:next MAX_LINE_LENGTH GetSchedulerList(context.Context, *emptypb.Empty) (*GetSchedulerListResponse, error) GetSchedulerById(context.Context, *GetSchedulerByIdRequest) (*Scheduler, error) Add(context.Context, *AddRequest) (*AddResponse, error) Remove(context.Context, *RemoveRequest) (*RemoveResponse, error) Run(context.Context, *RunRequest) (*RunResponse, error) Stop(context.Context, *StopRequest) (*StopResponse, error) // contains filtered or unexported methods }
SchedulersExecutorServer is the server API for SchedulersExecutor service. All implementations must embed UnimplementedSchedulersExecutorServer for forward compatibility
type SendMetricsRequest ¶
type SendMetricsRequest struct { // generated by server // // Types that are assignable to Msg: // // *SendMetricsRequest_Metric // *SendMetricsRequest_Disconnect_ Msg isSendMetricsRequest_Msg `protobuf_oneof:"msg"` // contains filtered or unexported fields }
func (*SendMetricsRequest) Descriptor
deprecated
func (*SendMetricsRequest) Descriptor() ([]byte, []int)
Deprecated: Use SendMetricsRequest.ProtoReflect.Descriptor instead.
func (*SendMetricsRequest) GetDisconnect ¶
func (x *SendMetricsRequest) GetDisconnect() *SendMetricsRequest_Disconnect
func (*SendMetricsRequest) GetMetric ¶
func (x *SendMetricsRequest) GetMetric() *Metric
func (*SendMetricsRequest) GetMsg ¶
func (m *SendMetricsRequest) GetMsg() isSendMetricsRequest_Msg
func (*SendMetricsRequest) ProtoMessage ¶
func (*SendMetricsRequest) ProtoMessage()
func (*SendMetricsRequest) ProtoReflect ¶
func (x *SendMetricsRequest) ProtoReflect() protoreflect.Message
func (*SendMetricsRequest) Reset ¶
func (x *SendMetricsRequest) Reset()
func (*SendMetricsRequest) String ¶
func (x *SendMetricsRequest) String() string
type SendMetricsRequest_Disconnect ¶
type SendMetricsRequest_Disconnect struct { AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"` Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*SendMetricsRequest_Disconnect) Descriptor
deprecated
func (*SendMetricsRequest_Disconnect) Descriptor() ([]byte, []int)
Deprecated: Use SendMetricsRequest_Disconnect.ProtoReflect.Descriptor instead.
func (*SendMetricsRequest_Disconnect) GetAgentId ¶
func (x *SendMetricsRequest_Disconnect) GetAgentId() string
func (*SendMetricsRequest_Disconnect) GetTime ¶
func (x *SendMetricsRequest_Disconnect) GetTime() *timestamppb.Timestamp
func (*SendMetricsRequest_Disconnect) ProtoMessage ¶
func (*SendMetricsRequest_Disconnect) ProtoMessage()
func (*SendMetricsRequest_Disconnect) ProtoReflect ¶
func (x *SendMetricsRequest_Disconnect) ProtoReflect() protoreflect.Message
func (*SendMetricsRequest_Disconnect) Reset ¶
func (x *SendMetricsRequest_Disconnect) Reset()
func (*SendMetricsRequest_Disconnect) String ¶
func (x *SendMetricsRequest_Disconnect) String() string
type SendMetricsRequest_Disconnect_ ¶
type SendMetricsRequest_Disconnect_ struct {
Disconnect *SendMetricsRequest_Disconnect `protobuf:"bytes,2,opt,name=disconnect,proto3,oneof"`
}
type SendMetricsRequest_Metric ¶
type SendMetricsRequest_Metric struct {
Metric *Metric `protobuf:"bytes,1,opt,name=metric,proto3,oneof"`
}
type SiteMapConfig ¶
type SiteMapConfig struct { Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` Concurrency int32 `protobuf:"varint,2,opt,name=concurrency,proto3" json:"concurrency,omitempty"` // contains filtered or unexported fields }
func (*SiteMapConfig) Descriptor
deprecated
func (*SiteMapConfig) Descriptor() ([]byte, []int)
Deprecated: Use SiteMapConfig.ProtoReflect.Descriptor instead.
func (*SiteMapConfig) GetConcurrency ¶
func (x *SiteMapConfig) GetConcurrency() int32
func (*SiteMapConfig) GetUrl ¶
func (x *SiteMapConfig) GetUrl() string
func (*SiteMapConfig) ProtoMessage ¶
func (*SiteMapConfig) ProtoMessage()
func (*SiteMapConfig) ProtoReflect ¶
func (x *SiteMapConfig) ProtoReflect() protoreflect.Message
func (*SiteMapConfig) Reset ¶
func (x *SiteMapConfig) Reset()
func (*SiteMapConfig) String ¶
func (x *SiteMapConfig) String() string
type SlackMethod ¶
type SlackMethod struct { Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` // contains filtered or unexported fields }
func (*SlackMethod) Descriptor
deprecated
func (*SlackMethod) Descriptor() ([]byte, []int)
Deprecated: Use SlackMethod.ProtoReflect.Descriptor instead.
func (*SlackMethod) GetUrl ¶
func (x *SlackMethod) GetUrl() string
func (*SlackMethod) ProtoMessage ¶
func (*SlackMethod) ProtoMessage()
func (*SlackMethod) ProtoReflect ¶
func (x *SlackMethod) ProtoReflect() protoreflect.Message
func (*SlackMethod) Reset ¶
func (x *SlackMethod) Reset()
func (*SlackMethod) String ¶
func (x *SlackMethod) String() string
type SortDirection ¶
type SortDirection int32
const ( SortDirection_SORT_DIRECTION_UNSPECIFIED SortDirection = 0 SortDirection_ASC SortDirection = 1 SortDirection_DESC SortDirection = 2 )
func (SortDirection) Descriptor ¶
func (SortDirection) Descriptor() protoreflect.EnumDescriptor
func (SortDirection) Enum ¶
func (x SortDirection) Enum() *SortDirection
func (SortDirection) EnumDescriptor
deprecated
func (SortDirection) EnumDescriptor() ([]byte, []int)
Deprecated: Use SortDirection.Descriptor instead.
func (SortDirection) Number ¶
func (x SortDirection) Number() protoreflect.EnumNumber
func (SortDirection) String ¶
func (x SortDirection) String() string
func (SortDirection) Type ¶
func (SortDirection) Type() protoreflect.EnumType
type SortIncidentList ¶
type SortIncidentList int32
const ( SortIncidentList_SORT_INCIDENT_LIST_UNSPECIFIED SortIncidentList = 0 SortIncidentList_INCIDENT_LIST_BY_START_TIME SortIncidentList = 1 SortIncidentList_INCIDENT_LIST_BY_END_TIME SortIncidentList = 2 )
func (SortIncidentList) Descriptor ¶
func (SortIncidentList) Descriptor() protoreflect.EnumDescriptor
func (SortIncidentList) Enum ¶
func (x SortIncidentList) Enum() *SortIncidentList
func (SortIncidentList) EnumDescriptor
deprecated
func (SortIncidentList) EnumDescriptor() ([]byte, []int)
Deprecated: Use SortIncidentList.Descriptor instead.
func (SortIncidentList) Number ¶
func (x SortIncidentList) Number() protoreflect.EnumNumber
func (SortIncidentList) String ¶
func (x SortIncidentList) String() string
func (SortIncidentList) Type ¶
func (SortIncidentList) Type() protoreflect.EnumType
type SortSchedulerList ¶
type SortSchedulerList int32
const ( SortSchedulerList_SORT_SCHEDULER_LIST_UNSPECIFIED SortSchedulerList = 0 SortSchedulerList_BY_START_TIME SortSchedulerList = 1 SortSchedulerList_BY_END_TIME SortSchedulerList = 2 SortSchedulerList_BY_LATENCY SortSchedulerList = 3 )
func (SortSchedulerList) Descriptor ¶
func (SortSchedulerList) Descriptor() protoreflect.EnumDescriptor
func (SortSchedulerList) Enum ¶
func (x SortSchedulerList) Enum() *SortSchedulerList
func (SortSchedulerList) EnumDescriptor
deprecated
func (SortSchedulerList) EnumDescriptor() ([]byte, []int)
Deprecated: Use SortSchedulerList.Descriptor instead.
func (SortSchedulerList) Number ¶
func (x SortSchedulerList) Number() protoreflect.EnumNumber
func (SortSchedulerList) String ¶
func (x SortSchedulerList) String() string
func (SortSchedulerList) Type ¶
func (SortSchedulerList) Type() protoreflect.EnumType
type SortTransactionList ¶
type SortTransactionList int32
const ( SortTransactionList_SORT_TRANSACTION_LIST_UNSPECIFIED SortTransactionList = 0 SortTransactionList_DURATION SortTransactionList = 1 SortTransactionList_BY_TRANSACTION_START_TIME SortTransactionList = 2 SortTransactionList_BY_TRANSACTION_END_TIME SortTransactionList = 3 )
func (SortTransactionList) Descriptor ¶
func (SortTransactionList) Descriptor() protoreflect.EnumDescriptor
func (SortTransactionList) Enum ¶
func (x SortTransactionList) Enum() *SortTransactionList
func (SortTransactionList) EnumDescriptor
deprecated
func (SortTransactionList) EnumDescriptor() ([]byte, []int)
Deprecated: Use SortTransactionList.Descriptor instead.
func (SortTransactionList) Number ¶
func (x SortTransactionList) Number() protoreflect.EnumNumber
func (SortTransactionList) String ¶
func (x SortTransactionList) String() string
func (SortTransactionList) Type ¶
func (SortTransactionList) Type() protoreflect.EnumType
type SortingIncidentList ¶
type SortingIncidentList struct { SortBy SortIncidentList `protobuf:"varint,1,opt,name=sort_by,json=sortBy,proto3,enum=squzy.v1.storage.SortIncidentList" json:"sort_by,omitempty"` Direction SortDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=squzy.v1.storage.SortDirection" json:"direction,omitempty"` // contains filtered or unexported fields }
func (*SortingIncidentList) Descriptor
deprecated
func (*SortingIncidentList) Descriptor() ([]byte, []int)
Deprecated: Use SortingIncidentList.ProtoReflect.Descriptor instead.
func (*SortingIncidentList) GetDirection ¶
func (x *SortingIncidentList) GetDirection() SortDirection
func (*SortingIncidentList) GetSortBy ¶
func (x *SortingIncidentList) GetSortBy() SortIncidentList
func (*SortingIncidentList) ProtoMessage ¶
func (*SortingIncidentList) ProtoMessage()
func (*SortingIncidentList) ProtoReflect ¶
func (x *SortingIncidentList) ProtoReflect() protoreflect.Message
func (*SortingIncidentList) Reset ¶
func (x *SortingIncidentList) Reset()
func (*SortingIncidentList) String ¶
func (x *SortingIncidentList) String() string
type SortingSchedulerList ¶
type SortingSchedulerList struct { SortBy SortSchedulerList `protobuf:"varint,1,opt,name=sort_by,json=sortBy,proto3,enum=squzy.v1.storage.SortSchedulerList" json:"sort_by,omitempty"` Direction SortDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=squzy.v1.storage.SortDirection" json:"direction,omitempty"` // contains filtered or unexported fields }
func (*SortingSchedulerList) Descriptor
deprecated
func (*SortingSchedulerList) Descriptor() ([]byte, []int)
Deprecated: Use SortingSchedulerList.ProtoReflect.Descriptor instead.
func (*SortingSchedulerList) GetDirection ¶
func (x *SortingSchedulerList) GetDirection() SortDirection
func (*SortingSchedulerList) GetSortBy ¶
func (x *SortingSchedulerList) GetSortBy() SortSchedulerList
func (*SortingSchedulerList) ProtoMessage ¶
func (*SortingSchedulerList) ProtoMessage()
func (*SortingSchedulerList) ProtoReflect ¶
func (x *SortingSchedulerList) ProtoReflect() protoreflect.Message
func (*SortingSchedulerList) Reset ¶
func (x *SortingSchedulerList) Reset()
func (*SortingSchedulerList) String ¶
func (x *SortingSchedulerList) String() string
type SortingTransactionList ¶
type SortingTransactionList struct { SortBy SortTransactionList `protobuf:"varint,1,opt,name=sort_by,json=sortBy,proto3,enum=squzy.v1.storage.SortTransactionList" json:"sort_by,omitempty"` Direction SortDirection `protobuf:"varint,2,opt,name=direction,proto3,enum=squzy.v1.storage.SortDirection" json:"direction,omitempty"` // contains filtered or unexported fields }
func (*SortingTransactionList) Descriptor
deprecated
func (*SortingTransactionList) Descriptor() ([]byte, []int)
Deprecated: Use SortingTransactionList.ProtoReflect.Descriptor instead.
func (*SortingTransactionList) GetDirection ¶
func (x *SortingTransactionList) GetDirection() SortDirection
func (*SortingTransactionList) GetSortBy ¶
func (x *SortingTransactionList) GetSortBy() SortTransactionList
func (*SortingTransactionList) ProtoMessage ¶
func (*SortingTransactionList) ProtoMessage()
func (*SortingTransactionList) ProtoReflect ¶
func (x *SortingTransactionList) ProtoReflect() protoreflect.Message
func (*SortingTransactionList) Reset ¶
func (x *SortingTransactionList) Reset()
func (*SortingTransactionList) String ¶
func (x *SortingTransactionList) String() string
type SslExpirationConfig ¶
type SslExpirationConfig struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*SslExpirationConfig) Descriptor
deprecated
func (*SslExpirationConfig) Descriptor() ([]byte, []int)
Deprecated: Use SslExpirationConfig.ProtoReflect.Descriptor instead.
func (*SslExpirationConfig) GetHost ¶
func (x *SslExpirationConfig) GetHost() string
func (*SslExpirationConfig) GetPort ¶
func (x *SslExpirationConfig) GetPort() int32
func (*SslExpirationConfig) ProtoMessage ¶
func (*SslExpirationConfig) ProtoMessage()
func (*SslExpirationConfig) ProtoReflect ¶
func (x *SslExpirationConfig) ProtoReflect() protoreflect.Message
func (*SslExpirationConfig) Reset ¶
func (x *SslExpirationConfig) Reset()
func (*SslExpirationConfig) String ¶
func (x *SslExpirationConfig) String() string
type StopRequest ¶
type StopRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*StopRequest) Descriptor
deprecated
func (*StopRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.
func (*StopRequest) GetId ¶
func (x *StopRequest) GetId() string
func (*StopRequest) ProtoMessage ¶
func (*StopRequest) ProtoMessage()
func (*StopRequest) ProtoReflect ¶
func (x *StopRequest) ProtoReflect() protoreflect.Message
func (*StopRequest) Reset ¶
func (x *StopRequest) Reset()
func (*StopRequest) String ¶
func (x *StopRequest) String() string
type StopResponse ¶
type StopResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*StopResponse) Descriptor
deprecated
func (*StopResponse) Descriptor() ([]byte, []int)
Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.
func (*StopResponse) GetId ¶
func (x *StopResponse) GetId() string
func (*StopResponse) ProtoMessage ¶
func (*StopResponse) ProtoMessage()
func (*StopResponse) ProtoReflect ¶
func (x *StopResponse) ProtoReflect() protoreflect.Message
func (*StopResponse) Reset ¶
func (x *StopResponse) Reset()
func (*StopResponse) String ¶
func (x *StopResponse) String() string
type StorageClient ¶ added in v1.13.0
type StorageClient interface { // To save info about checkers // protolint:disable:next MAX_LINE_LENGTH SaveResponseFromScheduler(ctx context.Context, in *SchedulerResponse, opts ...grpc.CallOption) (*emptypb.Empty, error) // To save info about agent // protolint:disable:next MAX_LINE_LENGTH SaveResponseFromAgent(ctx context.Context, in *Metric, opts ...grpc.CallOption) (*emptypb.Empty, error) // Save information from application monitoring // protolint:disable:next MAX_LINE_LENGTH SaveTransaction(ctx context.Context, in *TransactionInfo, opts ...grpc.CallOption) (*emptypb.Empty, error) // protolint:disable:next MAX_LINE_LENGTH GetSchedulerInformation(ctx context.Context, in *GetSchedulerInformationRequest, opts ...grpc.CallOption) (*GetSchedulerInformationResponse, error) // protolint:disable:next MAX_LINE_LENGTH GetSchedulerUptime(ctx context.Context, in *GetSchedulerUptimeRequest, opts ...grpc.CallOption) (*GetSchedulerUptimeResponse, error) // To send info about about agent // protolint:disable:next MAX_LINE_LENGTH GetAgentInformation(ctx context.Context, in *GetAgentInformationRequest, opts ...grpc.CallOption) (*GetAgentInformationResponse, error) // Return grouped transactions via group // protolint:disable:next MAX_LINE_LENGTH GetTransactionsGroup(ctx context.Context, in *GetTransactionGroupRequest, opts ...grpc.CallOption) (*GetTransactionGroupResponse, error) // Returns list of transaction via filter // protolint:disable:next MAX_LINE_LENGTH GetTransactions(ctx context.Context, in *GetTransactionsRequest, opts ...grpc.CallOption) (*GetTransactionsResponse, error) // protolint:disable:next MAX_LINE_LENGTH GetTransactionById(ctx context.Context, in *GetTransactionByIdRequest, opts ...grpc.CallOption) (*GetTransactionByIdResponse, error) // Save incident from incident service SaveIncident(ctx context.Context, in *Incident, opts ...grpc.CallOption) (*emptypb.Empty, error) // Update incident status from incident service // protolint:disable:next MAX_LINE_LENGTH UpdateIncidentStatus(ctx context.Context, in *UpdateIncidentStatusRequest, opts ...grpc.CallOption) (*Incident, error) // Get incident by ID // protolint:disable:next MAX_LINE_LENGTH GetIncidentById(ctx context.Context, in *IncidentIdRequest, opts ...grpc.CallOption) (*Incident, error) // Get incident by rule id, should be just one active incident per rule // protolint:disable:next MAX_LINE_LENGTH GetIncidentByRuleId(ctx context.Context, in *RuleIdRequest, opts ...grpc.CallOption) (*Incident, error) // Get list with filters // protolint:disable:next MAX_LINE_LENGTH GetIncidentsList(ctx context.Context, in *GetIncidentsListRequest, opts ...grpc.CallOption) (*GetIncidentsListResponse, error) }
StorageClient is the client API for Storage service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewStorageClient ¶ added in v1.13.0
func NewStorageClient(cc grpc.ClientConnInterface) StorageClient
type StorageRecord ¶
type StorageRecord struct { // Types that are assignable to Record: // // *StorageRecord_AgentMetric // *StorageRecord_Transaction // *StorageRecord_Snapshot Record isStorageRecord_Record `protobuf_oneof:"record"` // contains filtered or unexported fields }
func (*StorageRecord) Descriptor
deprecated
func (*StorageRecord) Descriptor() ([]byte, []int)
Deprecated: Use StorageRecord.ProtoReflect.Descriptor instead.
func (*StorageRecord) GetAgentMetric ¶
func (x *StorageRecord) GetAgentMetric() *Metric
func (*StorageRecord) GetRecord ¶
func (m *StorageRecord) GetRecord() isStorageRecord_Record
func (*StorageRecord) GetSnapshot ¶
func (x *StorageRecord) GetSnapshot() *SchedulerSnapshotWithId
func (*StorageRecord) GetTransaction ¶
func (x *StorageRecord) GetTransaction() *TransactionInfo
func (*StorageRecord) ProtoMessage ¶
func (*StorageRecord) ProtoMessage()
func (*StorageRecord) ProtoReflect ¶
func (x *StorageRecord) ProtoReflect() protoreflect.Message
func (*StorageRecord) Reset ¶
func (x *StorageRecord) Reset()
func (*StorageRecord) String ¶
func (x *StorageRecord) String() string
type StorageRecord_AgentMetric ¶
type StorageRecord_AgentMetric struct {
AgentMetric *Metric `protobuf:"bytes,1,opt,name=agent_metric,json=agentMetric,proto3,oneof"`
}
type StorageRecord_Snapshot ¶
type StorageRecord_Snapshot struct {
Snapshot *SchedulerSnapshotWithId `protobuf:"bytes,3,opt,name=snapshot,proto3,oneof"`
}
type StorageRecord_Transaction ¶
type StorageRecord_Transaction struct {
Transaction *TransactionInfo `protobuf:"bytes,2,opt,name=transaction,proto3,oneof"`
}
type StorageServer ¶ added in v1.13.0
type StorageServer interface { // To save info about checkers // protolint:disable:next MAX_LINE_LENGTH SaveResponseFromScheduler(context.Context, *SchedulerResponse) (*emptypb.Empty, error) // To save info about agent // protolint:disable:next MAX_LINE_LENGTH SaveResponseFromAgent(context.Context, *Metric) (*emptypb.Empty, error) // Save information from application monitoring // protolint:disable:next MAX_LINE_LENGTH SaveTransaction(context.Context, *TransactionInfo) (*emptypb.Empty, error) // protolint:disable:next MAX_LINE_LENGTH GetSchedulerInformation(context.Context, *GetSchedulerInformationRequest) (*GetSchedulerInformationResponse, error) // protolint:disable:next MAX_LINE_LENGTH GetSchedulerUptime(context.Context, *GetSchedulerUptimeRequest) (*GetSchedulerUptimeResponse, error) // To send info about about agent // protolint:disable:next MAX_LINE_LENGTH GetAgentInformation(context.Context, *GetAgentInformationRequest) (*GetAgentInformationResponse, error) // Return grouped transactions via group // protolint:disable:next MAX_LINE_LENGTH GetTransactionsGroup(context.Context, *GetTransactionGroupRequest) (*GetTransactionGroupResponse, error) // Returns list of transaction via filter // protolint:disable:next MAX_LINE_LENGTH GetTransactions(context.Context, *GetTransactionsRequest) (*GetTransactionsResponse, error) // protolint:disable:next MAX_LINE_LENGTH GetTransactionById(context.Context, *GetTransactionByIdRequest) (*GetTransactionByIdResponse, error) // Save incident from incident service SaveIncident(context.Context, *Incident) (*emptypb.Empty, error) // Update incident status from incident service // protolint:disable:next MAX_LINE_LENGTH UpdateIncidentStatus(context.Context, *UpdateIncidentStatusRequest) (*Incident, error) // Get incident by ID // protolint:disable:next MAX_LINE_LENGTH GetIncidentById(context.Context, *IncidentIdRequest) (*Incident, error) // Get incident by rule id, should be just one active incident per rule // protolint:disable:next MAX_LINE_LENGTH GetIncidentByRuleId(context.Context, *RuleIdRequest) (*Incident, error) // Get list with filters // protolint:disable:next MAX_LINE_LENGTH GetIncidentsList(context.Context, *GetIncidentsListRequest) (*GetIncidentsListResponse, error) // contains filtered or unexported methods }
StorageServer is the server API for Storage service. All implementations must embed UnimplementedStorageServer for forward compatibility
type TcpConfig ¶
type TcpConfig struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*TcpConfig) Descriptor
deprecated
func (*TcpConfig) ProtoMessage ¶
func (*TcpConfig) ProtoMessage()
func (*TcpConfig) ProtoReflect ¶
func (x *TcpConfig) ProtoReflect() protoreflect.Message
type TimeFilter ¶
type TimeFilter struct { From *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` // nil = not set start time To *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"` // nil = not set end time // contains filtered or unexported fields }
func (*TimeFilter) Descriptor
deprecated
func (*TimeFilter) Descriptor() ([]byte, []int)
Deprecated: Use TimeFilter.ProtoReflect.Descriptor instead.
func (*TimeFilter) GetFrom ¶
func (x *TimeFilter) GetFrom() *timestamppb.Timestamp
func (*TimeFilter) GetTo ¶
func (x *TimeFilter) GetTo() *timestamppb.Timestamp
func (*TimeFilter) ProtoMessage ¶
func (*TimeFilter) ProtoMessage()
func (*TimeFilter) ProtoReflect ¶
func (x *TimeFilter) ProtoReflect() protoreflect.Message
func (*TimeFilter) Reset ¶
func (x *TimeFilter) Reset()
func (*TimeFilter) String ¶
func (x *TimeFilter) String() string
type TransactionGroup ¶
type TransactionGroup struct { Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` AverageTime float64 `protobuf:"fixed64,2,opt,name=average_time,json=averageTime,proto3" json:"average_time,omitempty"` SuccessRatio float64 `protobuf:"fixed64,3,opt,name=success_ratio,json=successRatio,proto3" json:"success_ratio,omitempty"` MinTime float64 `protobuf:"fixed64,4,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"` MaxTime float64 `protobuf:"fixed64,5,opt,name=max_time,json=maxTime,proto3" json:"max_time,omitempty"` Throughput float64 `protobuf:"fixed64,6,opt,name=throughput,proto3" json:"throughput,omitempty"` // contains filtered or unexported fields }
func (*TransactionGroup) Descriptor
deprecated
func (*TransactionGroup) Descriptor() ([]byte, []int)
Deprecated: Use TransactionGroup.ProtoReflect.Descriptor instead.
func (*TransactionGroup) GetAverageTime ¶
func (x *TransactionGroup) GetAverageTime() float64
func (*TransactionGroup) GetCount ¶
func (x *TransactionGroup) GetCount() int64
func (*TransactionGroup) GetMaxTime ¶
func (x *TransactionGroup) GetMaxTime() float64
func (*TransactionGroup) GetMinTime ¶
func (x *TransactionGroup) GetMinTime() float64
func (*TransactionGroup) GetSuccessRatio ¶
func (x *TransactionGroup) GetSuccessRatio() float64
func (*TransactionGroup) GetThroughput ¶
func (x *TransactionGroup) GetThroughput() float64
func (*TransactionGroup) ProtoMessage ¶
func (*TransactionGroup) ProtoMessage()
func (*TransactionGroup) ProtoReflect ¶
func (x *TransactionGroup) ProtoReflect() protoreflect.Message
func (*TransactionGroup) Reset ¶
func (x *TransactionGroup) Reset()
func (*TransactionGroup) String ¶
func (x *TransactionGroup) String() string
type TransactionInfo ¶
type TransactionInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Application id from init request ApplicationId string `protobuf:"bytes,2,opt,name=application_id,json=applicationId,proto3" json:"application_id,omitempty"` // Parent transaction id, if "" - then first transaction ParentId string `protobuf:"bytes,3,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"` // Meta about request Meta *TransactionInfo_Meta `protobuf:"bytes,4,opt,name=meta,proto3" json:"meta,omitempty"` // Name of transactions (should be uniq per application) Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"` StartTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` EndTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` Status TransactionStatus `protobuf:"varint,8,opt,name=status,proto3,enum=squzy.v1.monitoring.TransactionStatus" json:"status,omitempty"` Type TransactionType `protobuf:"varint,9,opt,name=type,proto3,enum=squzy.v1.monitoring.TransactionType" json:"type,omitempty"` Error *TransactionInfo_Error `protobuf:"bytes,10,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*TransactionInfo) Descriptor
deprecated
func (*TransactionInfo) Descriptor() ([]byte, []int)
Deprecated: Use TransactionInfo.ProtoReflect.Descriptor instead.
func (*TransactionInfo) GetApplicationId ¶
func (x *TransactionInfo) GetApplicationId() string
func (*TransactionInfo) GetEndTime ¶
func (x *TransactionInfo) GetEndTime() *timestamppb.Timestamp
func (*TransactionInfo) GetError ¶
func (x *TransactionInfo) GetError() *TransactionInfo_Error
func (*TransactionInfo) GetId ¶
func (x *TransactionInfo) GetId() string
func (*TransactionInfo) GetMeta ¶
func (x *TransactionInfo) GetMeta() *TransactionInfo_Meta
func (*TransactionInfo) GetName ¶
func (x *TransactionInfo) GetName() string
func (*TransactionInfo) GetParentId ¶
func (x *TransactionInfo) GetParentId() string
func (*TransactionInfo) GetStartTime ¶
func (x *TransactionInfo) GetStartTime() *timestamppb.Timestamp
func (*TransactionInfo) GetStatus ¶
func (x *TransactionInfo) GetStatus() TransactionStatus
func (*TransactionInfo) GetType ¶
func (x *TransactionInfo) GetType() TransactionType
func (*TransactionInfo) ProtoMessage ¶
func (*TransactionInfo) ProtoMessage()
func (*TransactionInfo) ProtoReflect ¶
func (x *TransactionInfo) ProtoReflect() protoreflect.Message
func (*TransactionInfo) Reset ¶
func (x *TransactionInfo) Reset()
func (*TransactionInfo) String ¶
func (x *TransactionInfo) String() string
type TransactionInfo_Error ¶
type TransactionInfo_Error struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*TransactionInfo_Error) Descriptor
deprecated
func (*TransactionInfo_Error) Descriptor() ([]byte, []int)
Deprecated: Use TransactionInfo_Error.ProtoReflect.Descriptor instead.
func (*TransactionInfo_Error) GetMessage ¶
func (x *TransactionInfo_Error) GetMessage() string
func (*TransactionInfo_Error) ProtoMessage ¶
func (*TransactionInfo_Error) ProtoMessage()
func (*TransactionInfo_Error) ProtoReflect ¶
func (x *TransactionInfo_Error) ProtoReflect() protoreflect.Message
func (*TransactionInfo_Error) Reset ¶
func (x *TransactionInfo_Error) Reset()
func (*TransactionInfo_Error) String ¶
func (x *TransactionInfo_Error) String() string
type TransactionInfo_Meta ¶
type TransactionInfo_Meta struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` Method string `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"` // contains filtered or unexported fields }
func (*TransactionInfo_Meta) Descriptor
deprecated
func (*TransactionInfo_Meta) Descriptor() ([]byte, []int)
Deprecated: Use TransactionInfo_Meta.ProtoReflect.Descriptor instead.
func (*TransactionInfo_Meta) GetHost ¶
func (x *TransactionInfo_Meta) GetHost() string
func (*TransactionInfo_Meta) GetMethod ¶
func (x *TransactionInfo_Meta) GetMethod() string
func (*TransactionInfo_Meta) GetPath ¶
func (x *TransactionInfo_Meta) GetPath() string
func (*TransactionInfo_Meta) ProtoMessage ¶
func (*TransactionInfo_Meta) ProtoMessage()
func (*TransactionInfo_Meta) ProtoReflect ¶
func (x *TransactionInfo_Meta) ProtoReflect() protoreflect.Message
func (*TransactionInfo_Meta) Reset ¶
func (x *TransactionInfo_Meta) Reset()
func (*TransactionInfo_Meta) String ¶
func (x *TransactionInfo_Meta) String() string
type TransactionStatus ¶
type TransactionStatus int32
const ( TransactionStatus_TRANSACTION_CODE_UNSPECIFIED TransactionStatus = 0 TransactionStatus_TRANSACTION_SUCCESSFUL TransactionStatus = 1 TransactionStatus_TRANSACTION_FAILED TransactionStatus = 2 )
func (TransactionStatus) Descriptor ¶
func (TransactionStatus) Descriptor() protoreflect.EnumDescriptor
func (TransactionStatus) Enum ¶
func (x TransactionStatus) Enum() *TransactionStatus
func (TransactionStatus) EnumDescriptor
deprecated
func (TransactionStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use TransactionStatus.Descriptor instead.
func (TransactionStatus) Number ¶
func (x TransactionStatus) Number() protoreflect.EnumNumber
func (TransactionStatus) String ¶
func (x TransactionStatus) String() string
func (TransactionStatus) Type ¶
func (TransactionStatus) Type() protoreflect.EnumType
type TransactionType ¶
type TransactionType int32
const ( TransactionType_TRANSACTION_TYPE_UNSPECIFIED TransactionType = 0 TransactionType_TRANSACTION_TYPE_XHR TransactionType = 1 TransactionType_TRANSACTION_TYPE_FETCH TransactionType = 2 TransactionType_TRANSACTION_TYPE_WEBSOCKET TransactionType = 3 TransactionType_TRANSACTION_TYPE_HTTP TransactionType = 4 TransactionType_TRANSACTION_TYPE_GRPC TransactionType = 5 TransactionType_TRANSACTION_TYPE_DB TransactionType = 6 TransactionType_TRANSACTION_TYPE_INTERNAL TransactionType = 7 TransactionType_TRANSACTION_TYPE_ROUTER TransactionType = 8 )
func (TransactionType) Descriptor ¶
func (TransactionType) Descriptor() protoreflect.EnumDescriptor
func (TransactionType) Enum ¶
func (x TransactionType) Enum() *TransactionType
func (TransactionType) EnumDescriptor
deprecated
func (TransactionType) EnumDescriptor() ([]byte, []int)
Deprecated: Use TransactionType.Descriptor instead.
func (TransactionType) Number ¶
func (x TransactionType) Number() protoreflect.EnumNumber
func (TransactionType) String ¶
func (x TransactionType) String() string
func (TransactionType) Type ¶
func (TransactionType) Type() protoreflect.EnumType
type TypeAgentStat ¶
type TypeAgentStat int32
const ( TypeAgentStat_AGENT_STATS_TYPE_UNSPECIFIED TypeAgentStat = 0 TypeAgentStat_ALL TypeAgentStat = 1 TypeAgentStat_CPU TypeAgentStat = 2 TypeAgentStat_DISK TypeAgentStat = 3 TypeAgentStat_MEMORY TypeAgentStat = 4 TypeAgentStat_NET TypeAgentStat = 5 )
func (TypeAgentStat) Descriptor ¶
func (TypeAgentStat) Descriptor() protoreflect.EnumDescriptor
func (TypeAgentStat) Enum ¶
func (x TypeAgentStat) Enum() *TypeAgentStat
func (TypeAgentStat) EnumDescriptor
deprecated
func (TypeAgentStat) EnumDescriptor() ([]byte, []int)
Deprecated: Use TypeAgentStat.Descriptor instead.
func (TypeAgentStat) Number ¶
func (x TypeAgentStat) Number() protoreflect.EnumNumber
func (TypeAgentStat) String ¶
func (x TypeAgentStat) String() string
func (TypeAgentStat) Type ¶
func (TypeAgentStat) Type() protoreflect.EnumType
type UnRegisterRequest ¶
type UnRegisterRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*UnRegisterRequest) Descriptor
deprecated
func (*UnRegisterRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnRegisterRequest.ProtoReflect.Descriptor instead.
func (*UnRegisterRequest) GetId ¶
func (x *UnRegisterRequest) GetId() string
func (*UnRegisterRequest) GetTime ¶
func (x *UnRegisterRequest) GetTime() *timestamppb.Timestamp
func (*UnRegisterRequest) ProtoMessage ¶
func (*UnRegisterRequest) ProtoMessage()
func (*UnRegisterRequest) ProtoReflect ¶
func (x *UnRegisterRequest) ProtoReflect() protoreflect.Message
func (*UnRegisterRequest) Reset ¶
func (x *UnRegisterRequest) Reset()
func (*UnRegisterRequest) String ¶
func (x *UnRegisterRequest) String() string
type UnRegisterResponse ¶
type UnRegisterResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*UnRegisterResponse) Descriptor
deprecated
func (*UnRegisterResponse) Descriptor() ([]byte, []int)
Deprecated: Use UnRegisterResponse.ProtoReflect.Descriptor instead.
func (*UnRegisterResponse) GetId ¶
func (x *UnRegisterResponse) GetId() string
func (*UnRegisterResponse) ProtoMessage ¶
func (*UnRegisterResponse) ProtoMessage()
func (*UnRegisterResponse) ProtoReflect ¶
func (x *UnRegisterResponse) ProtoReflect() protoreflect.Message
func (*UnRegisterResponse) Reset ¶
func (x *UnRegisterResponse) Reset()
func (*UnRegisterResponse) String ¶
func (x *UnRegisterResponse) String() string
type UnimplementedAgentServerServer ¶ added in v1.13.0
type UnimplementedAgentServerServer struct { }
UnimplementedAgentServerServer must be embedded to have forward compatible implementations.
func (UnimplementedAgentServerServer) GetAgentById ¶ added in v1.13.0
func (UnimplementedAgentServerServer) GetAgentById(context.Context, *GetAgentByIdRequest) (*AgentItem, error)
func (UnimplementedAgentServerServer) GetAgentList ¶ added in v1.13.0
func (UnimplementedAgentServerServer) GetAgentList(context.Context, *emptypb.Empty) (*GetAgentListResponse, error)
func (UnimplementedAgentServerServer) GetByAgentName ¶ added in v1.13.0
func (UnimplementedAgentServerServer) GetByAgentName(context.Context, *GetByAgentNameRequest) (*GetAgentListResponse, error)
func (UnimplementedAgentServerServer) Register ¶ added in v1.13.0
func (UnimplementedAgentServerServer) Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
func (UnimplementedAgentServerServer) SendMetrics ¶ added in v1.13.0
func (UnimplementedAgentServerServer) SendMetrics(AgentServer_SendMetricsServer) error
func (UnimplementedAgentServerServer) UnRegister ¶ added in v1.13.0
func (UnimplementedAgentServerServer) UnRegister(context.Context, *UnRegisterRequest) (*UnRegisterResponse, error)
type UnimplementedApplicationMonitoringServer ¶ added in v1.13.0
type UnimplementedApplicationMonitoringServer struct { }
UnimplementedApplicationMonitoringServer must be embedded to have forward compatible implementations.
func (UnimplementedApplicationMonitoringServer) ArchiveApplicationById ¶ added in v1.13.0
func (UnimplementedApplicationMonitoringServer) ArchiveApplicationById(context.Context, *ApplicationByIdReuqest) (*Application, error)
func (UnimplementedApplicationMonitoringServer) DisableApplicationById ¶ added in v1.13.0
func (UnimplementedApplicationMonitoringServer) DisableApplicationById(context.Context, *ApplicationByIdReuqest) (*Application, error)
func (UnimplementedApplicationMonitoringServer) EnableApplicationById ¶ added in v1.13.0
func (UnimplementedApplicationMonitoringServer) EnableApplicationById(context.Context, *ApplicationByIdReuqest) (*Application, error)
func (UnimplementedApplicationMonitoringServer) GetApplicationById ¶ added in v1.13.0
func (UnimplementedApplicationMonitoringServer) GetApplicationById(context.Context, *ApplicationByIdReuqest) (*Application, error)
func (UnimplementedApplicationMonitoringServer) GetApplicationList ¶ added in v1.13.0
func (UnimplementedApplicationMonitoringServer) GetApplicationList(context.Context, *emptypb.Empty) (*GetApplicationListResponse, error)
func (UnimplementedApplicationMonitoringServer) GetApplicationListByAgentId ¶ added in v1.13.0
func (UnimplementedApplicationMonitoringServer) GetApplicationListByAgentId(context.Context, *AgentIdRequest) (*GetApplicationListResponse, error)
func (UnimplementedApplicationMonitoringServer) InitializeApplication ¶ added in v1.13.0
func (UnimplementedApplicationMonitoringServer) InitializeApplication(context.Context, *ApplicationInfo) (*InitializeApplicationResponse, error)
func (UnimplementedApplicationMonitoringServer) SaveTransaction ¶ added in v1.13.0
func (UnimplementedApplicationMonitoringServer) SaveTransaction(context.Context, *TransactionInfo) (*emptypb.Empty, error)
type UnimplementedCacheServer ¶ added in v1.15.0
type UnimplementedCacheServer struct { }
UnimplementedCacheServer must be embedded to have forward compatible implementations.
func (UnimplementedCacheServer) DeleteScheduleById ¶ added in v1.15.0
func (UnimplementedCacheServer) DeleteScheduleById(context.Context, *DeleteScheduleWithIdRequest) (*emptypb.Empty, error)
func (UnimplementedCacheServer) GetScheduleById ¶ added in v1.15.0
func (UnimplementedCacheServer) GetScheduleById(context.Context, *GetScheduleWithIdRequest) (*GetScheduleWithIdResponse, error)
func (UnimplementedCacheServer) InsertScheduleWithId ¶ added in v1.15.0
func (UnimplementedCacheServer) InsertScheduleWithId(context.Context, *InsertScheduleWithIdRequest) (*emptypb.Empty, error)
type UnimplementedIncidentServerServer ¶ added in v1.13.0
type UnimplementedIncidentServerServer struct { }
UnimplementedIncidentServerServer must be embedded to have forward compatible implementations.
func (UnimplementedIncidentServerServer) ActivateRule ¶ added in v1.13.0
func (UnimplementedIncidentServerServer) ActivateRule(context.Context, *RuleIdRequest) (*Rule, error)
func (UnimplementedIncidentServerServer) CloseIncident ¶ added in v1.13.0
func (UnimplementedIncidentServerServer) CloseIncident(context.Context, *IncidentIdRequest) (*Incident, error)
func (UnimplementedIncidentServerServer) CreateRule ¶ added in v1.13.0
func (UnimplementedIncidentServerServer) CreateRule(context.Context, *CreateRuleRequest) (*Rule, error)
func (UnimplementedIncidentServerServer) DeactivateRule ¶ added in v1.13.0
func (UnimplementedIncidentServerServer) DeactivateRule(context.Context, *RuleIdRequest) (*Rule, error)
func (UnimplementedIncidentServerServer) GetRuleById ¶ added in v1.13.0
func (UnimplementedIncidentServerServer) GetRuleById(context.Context, *RuleIdRequest) (*Rule, error)
func (UnimplementedIncidentServerServer) GetRulesByOwnerId ¶ added in v1.13.0
func (UnimplementedIncidentServerServer) GetRulesByOwnerId(context.Context, *GetRulesByOwnerIdRequest) (*Rules, error)
func (UnimplementedIncidentServerServer) ProcessRecordFromStorage ¶ added in v1.13.0
func (UnimplementedIncidentServerServer) ProcessRecordFromStorage(context.Context, *StorageRecord) (*emptypb.Empty, error)
func (UnimplementedIncidentServerServer) RemoveRule ¶ added in v1.13.0
func (UnimplementedIncidentServerServer) RemoveRule(context.Context, *RuleIdRequest) (*Rule, error)
func (UnimplementedIncidentServerServer) StudyIncident ¶ added in v1.13.0
func (UnimplementedIncidentServerServer) StudyIncident(context.Context, *IncidentIdRequest) (*Incident, error)
func (UnimplementedIncidentServerServer) ValidateRule ¶ added in v1.13.0
func (UnimplementedIncidentServerServer) ValidateRule(context.Context, *ValidateRuleRequest) (*ValidateRuleResponse, error)
type UnimplementedNotificationManagerServer ¶ added in v1.13.0
type UnimplementedNotificationManagerServer struct { }
UnimplementedNotificationManagerServer must be embedded to have forward compatible implementations.
func (UnimplementedNotificationManagerServer) Activate ¶ added in v1.13.0
func (UnimplementedNotificationManagerServer) Activate(context.Context, *NotificationMethodIdRequest) (*NotificationMethod, error)
func (UnimplementedNotificationManagerServer) CreateNotificationMethod ¶ added in v1.13.0
func (UnimplementedNotificationManagerServer) CreateNotificationMethod(context.Context, *CreateNotificationMethodRequest) (*NotificationMethod, error)
func (UnimplementedNotificationManagerServer) Deactivate ¶ added in v1.13.0
func (UnimplementedNotificationManagerServer) Deactivate(context.Context, *NotificationMethodIdRequest) (*NotificationMethod, error)
func (UnimplementedNotificationManagerServer) DeleteById ¶ added in v1.13.0
func (UnimplementedNotificationManagerServer) DeleteById(context.Context, *NotificationMethodIdRequest) (*NotificationMethod, error)
func (UnimplementedNotificationManagerServer) GetById ¶ added in v1.13.0
func (UnimplementedNotificationManagerServer) GetById(context.Context, *NotificationMethodIdRequest) (*NotificationMethod, error)
func (UnimplementedNotificationManagerServer) GetList ¶ added in v1.13.0
func (UnimplementedNotificationManagerServer) GetList(context.Context, *GetListRequest) (*GetListResponse, error)
func (UnimplementedNotificationManagerServer) GetNotificationMethods ¶ added in v1.13.0
func (UnimplementedNotificationManagerServer) GetNotificationMethods(context.Context, *emptypb.Empty) (*GetListResponse, error)
func (UnimplementedNotificationManagerServer) Notify ¶ added in v1.13.0
func (UnimplementedNotificationManagerServer) Notify(context.Context, *NotifyRequest) (*emptypb.Empty, error)
func (UnimplementedNotificationManagerServer) Remove ¶ added in v1.13.0
func (UnimplementedNotificationManagerServer) Remove(context.Context, *NotificationMethodRequest) (*NotificationMethod, error)
type UnimplementedSchedulersExecutorServer ¶ added in v1.13.0
type UnimplementedSchedulersExecutorServer struct { }
UnimplementedSchedulersExecutorServer must be embedded to have forward compatible implementations.
func (UnimplementedSchedulersExecutorServer) Add ¶ added in v1.13.0
func (UnimplementedSchedulersExecutorServer) Add(context.Context, *AddRequest) (*AddResponse, error)
func (UnimplementedSchedulersExecutorServer) GetSchedulerById ¶ added in v1.13.0
func (UnimplementedSchedulersExecutorServer) GetSchedulerById(context.Context, *GetSchedulerByIdRequest) (*Scheduler, error)
func (UnimplementedSchedulersExecutorServer) GetSchedulerList ¶ added in v1.13.0
func (UnimplementedSchedulersExecutorServer) GetSchedulerList(context.Context, *emptypb.Empty) (*GetSchedulerListResponse, error)
func (UnimplementedSchedulersExecutorServer) Remove ¶ added in v1.13.0
func (UnimplementedSchedulersExecutorServer) Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
func (UnimplementedSchedulersExecutorServer) Run ¶ added in v1.13.0
func (UnimplementedSchedulersExecutorServer) Run(context.Context, *RunRequest) (*RunResponse, error)
func (UnimplementedSchedulersExecutorServer) Stop ¶ added in v1.13.0
func (UnimplementedSchedulersExecutorServer) Stop(context.Context, *StopRequest) (*StopResponse, error)
type UnimplementedStorageServer ¶ added in v1.13.0
type UnimplementedStorageServer struct { }
UnimplementedStorageServer must be embedded to have forward compatible implementations.
func (UnimplementedStorageServer) GetAgentInformation ¶ added in v1.13.0
func (UnimplementedStorageServer) GetAgentInformation(context.Context, *GetAgentInformationRequest) (*GetAgentInformationResponse, error)
func (UnimplementedStorageServer) GetIncidentById ¶ added in v1.13.0
func (UnimplementedStorageServer) GetIncidentById(context.Context, *IncidentIdRequest) (*Incident, error)
func (UnimplementedStorageServer) GetIncidentByRuleId ¶ added in v1.13.0
func (UnimplementedStorageServer) GetIncidentByRuleId(context.Context, *RuleIdRequest) (*Incident, error)
func (UnimplementedStorageServer) GetIncidentsList ¶ added in v1.13.0
func (UnimplementedStorageServer) GetIncidentsList(context.Context, *GetIncidentsListRequest) (*GetIncidentsListResponse, error)
func (UnimplementedStorageServer) GetSchedulerInformation ¶ added in v1.13.0
func (UnimplementedStorageServer) GetSchedulerInformation(context.Context, *GetSchedulerInformationRequest) (*GetSchedulerInformationResponse, error)
func (UnimplementedStorageServer) GetSchedulerUptime ¶ added in v1.13.0
func (UnimplementedStorageServer) GetSchedulerUptime(context.Context, *GetSchedulerUptimeRequest) (*GetSchedulerUptimeResponse, error)
func (UnimplementedStorageServer) GetTransactionById ¶ added in v1.13.0
func (UnimplementedStorageServer) GetTransactionById(context.Context, *GetTransactionByIdRequest) (*GetTransactionByIdResponse, error)
func (UnimplementedStorageServer) GetTransactions ¶ added in v1.13.0
func (UnimplementedStorageServer) GetTransactions(context.Context, *GetTransactionsRequest) (*GetTransactionsResponse, error)
func (UnimplementedStorageServer) GetTransactionsGroup ¶ added in v1.13.0
func (UnimplementedStorageServer) GetTransactionsGroup(context.Context, *GetTransactionGroupRequest) (*GetTransactionGroupResponse, error)
func (UnimplementedStorageServer) SaveIncident ¶ added in v1.13.0
func (UnimplementedStorageServer) SaveResponseFromAgent ¶ added in v1.13.0
func (UnimplementedStorageServer) SaveResponseFromScheduler ¶ added in v1.13.0
func (UnimplementedStorageServer) SaveResponseFromScheduler(context.Context, *SchedulerResponse) (*emptypb.Empty, error)
func (UnimplementedStorageServer) SaveTransaction ¶ added in v1.13.0
func (UnimplementedStorageServer) SaveTransaction(context.Context, *TransactionInfo) (*emptypb.Empty, error)
func (UnimplementedStorageServer) UpdateIncidentStatus ¶ added in v1.13.0
func (UnimplementedStorageServer) UpdateIncidentStatus(context.Context, *UpdateIncidentStatusRequest) (*Incident, error)
type UnsafeAgentServerServer ¶ added in v1.15.0
type UnsafeAgentServerServer interface {
// contains filtered or unexported methods
}
UnsafeAgentServerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServerServer will result in compilation errors.
type UnsafeApplicationMonitoringServer ¶ added in v1.15.0
type UnsafeApplicationMonitoringServer interface {
// contains filtered or unexported methods
}
UnsafeApplicationMonitoringServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ApplicationMonitoringServer will result in compilation errors.
type UnsafeCacheServer ¶ added in v1.15.0
type UnsafeCacheServer interface {
// contains filtered or unexported methods
}
UnsafeCacheServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CacheServer will result in compilation errors.
type UnsafeIncidentServerServer ¶ added in v1.15.0
type UnsafeIncidentServerServer interface {
// contains filtered or unexported methods
}
UnsafeIncidentServerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IncidentServerServer will result in compilation errors.
type UnsafeNotificationManagerServer ¶ added in v1.15.0
type UnsafeNotificationManagerServer interface {
// contains filtered or unexported methods
}
UnsafeNotificationManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NotificationManagerServer will result in compilation errors.
type UnsafeSchedulersExecutorServer ¶ added in v1.15.0
type UnsafeSchedulersExecutorServer interface {
// contains filtered or unexported methods
}
UnsafeSchedulersExecutorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SchedulersExecutorServer will result in compilation errors.
type UnsafeStorageServer ¶ added in v1.15.0
type UnsafeStorageServer interface {
// contains filtered or unexported methods
}
UnsafeStorageServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StorageServer will result in compilation errors.
type UpdateIncidentStatusRequest ¶
type UpdateIncidentStatusRequest struct { IncidentId string `protobuf:"bytes,1,opt,name=incident_id,json=incidentId,proto3" json:"incident_id,omitempty"` Status IncidentStatus `protobuf:"varint,2,opt,name=status,proto3,enum=squzy.v1.incident.IncidentStatus" json:"status,omitempty"` // contains filtered or unexported fields }
func (*UpdateIncidentStatusRequest) Descriptor
deprecated
func (*UpdateIncidentStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateIncidentStatusRequest.ProtoReflect.Descriptor instead.
func (*UpdateIncidentStatusRequest) GetIncidentId ¶
func (x *UpdateIncidentStatusRequest) GetIncidentId() string
func (*UpdateIncidentStatusRequest) GetStatus ¶
func (x *UpdateIncidentStatusRequest) GetStatus() IncidentStatus
func (*UpdateIncidentStatusRequest) ProtoMessage ¶
func (*UpdateIncidentStatusRequest) ProtoMessage()
func (*UpdateIncidentStatusRequest) ProtoReflect ¶
func (x *UpdateIncidentStatusRequest) ProtoReflect() protoreflect.Message
func (*UpdateIncidentStatusRequest) Reset ¶
func (x *UpdateIncidentStatusRequest) Reset()
func (*UpdateIncidentStatusRequest) String ¶
func (x *UpdateIncidentStatusRequest) String() string
type ValidateRuleRequest ¶
type ValidateRuleRequest struct { OwnerType ComponentOwnerType `` /* 129-byte string literal not displayed */ Rule string `protobuf:"bytes,2,opt,name=rule,proto3" json:"rule,omitempty"` // contains filtered or unexported fields }
func (*ValidateRuleRequest) Descriptor
deprecated
func (*ValidateRuleRequest) Descriptor() ([]byte, []int)
Deprecated: Use ValidateRuleRequest.ProtoReflect.Descriptor instead.
func (*ValidateRuleRequest) GetOwnerType ¶
func (x *ValidateRuleRequest) GetOwnerType() ComponentOwnerType
func (*ValidateRuleRequest) GetRule ¶
func (x *ValidateRuleRequest) GetRule() string
func (*ValidateRuleRequest) ProtoMessage ¶
func (*ValidateRuleRequest) ProtoMessage()
func (*ValidateRuleRequest) ProtoReflect ¶
func (x *ValidateRuleRequest) ProtoReflect() protoreflect.Message
func (*ValidateRuleRequest) Reset ¶
func (x *ValidateRuleRequest) Reset()
func (*ValidateRuleRequest) String ¶
func (x *ValidateRuleRequest) String() string
type ValidateRuleResponse ¶
type ValidateRuleResponse struct { IsValid bool `protobuf:"varint,1,opt,name=is_valid,json=isValid,proto3" json:"is_valid,omitempty"` Error *ValidateRuleResponse_Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*ValidateRuleResponse) Descriptor
deprecated
func (*ValidateRuleResponse) Descriptor() ([]byte, []int)
Deprecated: Use ValidateRuleResponse.ProtoReflect.Descriptor instead.
func (*ValidateRuleResponse) GetError ¶
func (x *ValidateRuleResponse) GetError() *ValidateRuleResponse_Error
func (*ValidateRuleResponse) GetIsValid ¶
func (x *ValidateRuleResponse) GetIsValid() bool
func (*ValidateRuleResponse) ProtoMessage ¶
func (*ValidateRuleResponse) ProtoMessage()
func (*ValidateRuleResponse) ProtoReflect ¶
func (x *ValidateRuleResponse) ProtoReflect() protoreflect.Message
func (*ValidateRuleResponse) Reset ¶
func (x *ValidateRuleResponse) Reset()
func (*ValidateRuleResponse) String ¶
func (x *ValidateRuleResponse) String() string
type ValidateRuleResponse_Error ¶
type ValidateRuleResponse_Error struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*ValidateRuleResponse_Error) Descriptor
deprecated
func (*ValidateRuleResponse_Error) Descriptor() ([]byte, []int)
Deprecated: Use ValidateRuleResponse_Error.ProtoReflect.Descriptor instead.
func (*ValidateRuleResponse_Error) GetMessage ¶
func (x *ValidateRuleResponse_Error) GetMessage() string
func (*ValidateRuleResponse_Error) ProtoMessage ¶
func (*ValidateRuleResponse_Error) ProtoMessage()
func (*ValidateRuleResponse_Error) ProtoReflect ¶
func (x *ValidateRuleResponse_Error) ProtoReflect() protoreflect.Message
func (*ValidateRuleResponse_Error) Reset ¶
func (x *ValidateRuleResponse_Error) Reset()
func (*ValidateRuleResponse_Error) String ¶
func (x *ValidateRuleResponse_Error) String() string
type WebHookMethod ¶
type WebHookMethod struct { Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` // contains filtered or unexported fields }
func (*WebHookMethod) Descriptor
deprecated
func (*WebHookMethod) Descriptor() ([]byte, []int)
Deprecated: Use WebHookMethod.ProtoReflect.Descriptor instead.
func (*WebHookMethod) GetUrl ¶
func (x *WebHookMethod) GetUrl() string
func (*WebHookMethod) ProtoMessage ¶
func (*WebHookMethod) ProtoMessage()
func (*WebHookMethod) ProtoReflect ¶
func (x *WebHookMethod) ProtoReflect() protoreflect.Message
func (*WebHookMethod) Reset ¶
func (x *WebHookMethod) Reset()
func (*WebHookMethod) String ¶
func (x *WebHookMethod) String() string
Source Files ¶
- shared.pb.go
- squzy_agent_server.pb.go
- squzy_agent_server_grpc.pb.go
- squzy_application_monitoring.pb.go
- squzy_application_monitoring_grpc.pb.go
- squzy_cache.pb.go
- squzy_cache_grpc.pb.go
- squzy_incident_server.pb.go
- squzy_incident_server_grpc.pb.go
- squzy_monitoring.pb.go
- squzy_monitoring_grpc.pb.go
- squzy_notification_server.pb.go
- squzy_notification_server_grpc.pb.go
- squzy_storage.pb.go
- squzy_storage_grpc.pb.go