proto

package
v1.16.0 Latest Latest
Warning

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

 Go to latest Published: Jan 1, 2024 License: MIT Imports: 12 Imported by: 28

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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)

View Source 
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)

View Source 
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)

View Source 
var File_proto_v1_shared_proto protoreflect.FileDescriptor
View Source 
var File_proto_v1_squzy_agent_server_proto protoreflect.FileDescriptor
View Source 
var File_proto_v1_squzy_application_monitoring_proto protoreflect.FileDescriptor
View Source 
var File_proto_v1_squzy_cache_proto protoreflect.FileDescriptor
View Source 
var File_proto_v1_squzy_incident_server_proto protoreflect.FileDescriptor
View Source 
var File_proto_v1_squzy_monitoring_proto protoreflect.FileDescriptor
View Source 
var File_proto_v1_squzy_notification_server_proto protoreflect.FileDescriptor
View Source 
var File_proto_v1_squzy_storage_proto protoreflect.FileDescriptor
View Source 
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)

View Source 
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)

View Source 
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)

View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use AgentItem.ProtoReflect.Descriptor instead.

func (*AgentItem) GetAgentName 

func (x *AgentItem) GetAgentName() string

func (*AgentItem) GetHostInfo 

func (x *AgentItem) GetHostInfo() *HostInfo

func (*AgentItem) GetId 

func (x *AgentItem) GetId() string

func (*AgentItem) GetInterval 

func (x *AgentItem) GetInterval() int64

func (*AgentItem) GetStatus 

func (x *AgentItem) GetStatus() AgentStatus

func (*AgentItem) ProtoMessage 

func (*AgentItem) ProtoMessage()

func (*AgentItem) ProtoReflect 

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

func (*AgentItem) Reset 

func (x *AgentItem) Reset()

func (*AgentItem) String 

func (x *AgentItem) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use CpuInfo.ProtoReflect.Descriptor instead.

func (*CpuInfo) GetCpus 

func (x *CpuInfo) GetCpus() []*CpuInfo_CPU

func (*CpuInfo) ProtoMessage 

func (*CpuInfo) ProtoMessage()

func (*CpuInfo) ProtoReflect 

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

func (*CpuInfo) Reset 

func (x *CpuInfo) Reset()

func (*CpuInfo) String 

func (x *CpuInfo) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use DbConfig.ProtoReflect.Descriptor instead.

func (*DbConfig) GetCluster added in v1.16.0 

func (x *DbConfig) GetCluster() string

func (*DbConfig) GetDbName added in v1.16.0 

func (x *DbConfig) GetDbName() string

func (*DbConfig) GetHost added in v1.16.0 

func (x *DbConfig) GetHost() string

func (*DbConfig) GetPassword added in v1.16.0 

func (x *DbConfig) GetPassword() string

func (*DbConfig) GetPort added in v1.16.0 

func (x *DbConfig) GetPort() int32

func (*DbConfig) GetUser added in v1.16.0 

func (x *DbConfig) GetUser() string

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

func (*DbConfig) Reset added in v1.16.0 

func (x *DbConfig) Reset()

func (*DbConfig) String added in v1.16.0 

func (x *DbConfig) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use DiskInfo.ProtoReflect.Descriptor instead.

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

func (*DiskInfo) Reset 

func (x *DiskInfo) Reset()

func (*DiskInfo) String 

func (x *DiskInfo) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use HostInfo.ProtoReflect.Descriptor instead.

func (*HostInfo) GetHostName 

func (x *HostInfo) GetHostName() string

func (*HostInfo) GetOs 

func (x *HostInfo) GetOs() string

func (*HostInfo) GetPlatformInfo 

func (x *HostInfo) GetPlatformInfo() *PlatformInfo

func (*HostInfo) ProtoMessage 

func (*HostInfo) ProtoMessage()

func (*HostInfo) ProtoReflect 

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

func (*HostInfo) Reset 

func (x *HostInfo) Reset()

func (*HostInfo) String 

func (x *HostInfo) String() string

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) Enum 

func (x HttpJsonValueConfig_JsonValueParseType) Enum() *HttpJsonValueConfig_JsonValueParseType

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) Descriptor() ([]byte, []int)

Deprecated: Use Incident.ProtoReflect.Descriptor instead.

func (*Incident) GetHistories 

func (x *Incident) GetHistories() []*Incident_HistoryItem

func (*Incident) GetId 

func (x *Incident) GetId() string

func (*Incident) GetRuleId 

func (x *Incident) GetRuleId() string

func (*Incident) GetStatus 

func (x *Incident) GetStatus() IncidentStatus

func (*Incident) ProtoMessage 

func (*Incident) ProtoMessage()

func (*Incident) ProtoReflect 

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

func (*Incident) Reset 

func (x *Incident) Reset()

func (*Incident) String 

func (x *Incident) String() string

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"`
	Shared      uint64  `protobuf:"varint,4,opt,name=shared,proto3" json:"shared,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) Descriptor() ([]byte, []int)

Deprecated: Use Metric.ProtoReflect.Descriptor instead.

func (*Metric) GetAgentId 

func (x *Metric) GetAgentId() string

func (*Metric) GetAgentName 

func (x *Metric) GetAgentName() string

func (*Metric) GetCpuInfo 

func (x *Metric) GetCpuInfo() *CpuInfo

func (*Metric) GetDiskInfo 

func (x *Metric) GetDiskInfo() *DiskInfo

func (*Metric) GetMemoryInfo 

func (x *Metric) GetMemoryInfo() *MemoryInfo

func (*Metric) GetNetInfo 

func (x *Metric) GetNetInfo() *NetInfo

func (*Metric) GetTime 

func (x *Metric) GetTime() *timestamppb.Timestamp

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) ProtoReflect 

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

func (*Metric) Reset 

func (x *Metric) Reset()

func (*Metric) String 

func (x *Metric) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use NetInfo.ProtoReflect.Descriptor instead.

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

func (*NetInfo) Reset 

func (x *NetInfo) Reset()

func (*NetInfo) String 

func (x *NetInfo) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Rule.ProtoReflect.Descriptor instead.

func (*Rule) GetAutoClose 

func (x *Rule) GetAutoClose() bool

func (*Rule) GetId 

func (x *Rule) GetId() string

func (*Rule) GetName 

func (x *Rule) GetName() string

func (*Rule) GetNotification 

func (x *Rule) GetNotification() bool

func (*Rule) GetOwnerId 

func (x *Rule) GetOwnerId() string

func (*Rule) GetOwnerType 

func (x *Rule) GetOwnerType() ComponentOwnerType

func (*Rule) GetRule 

func (x *Rule) GetRule() string

func (*Rule) GetStatus 

func (x *Rule) GetStatus() RuleStatus

func (*Rule) ProtoMessage 

func (*Rule) ProtoMessage()

func (*Rule) ProtoReflect 

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

func (*Rule) Reset 

func (x *Rule) Reset()

func (*Rule) String 

func (x *Rule) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Rules.ProtoReflect.Descriptor instead.

func (*Rules) GetRules 

func (x *Rules) GetRules() []*Rule

func (*Rules) ProtoMessage 

func (*Rules) ProtoMessage()

func (*Rules) ProtoReflect 

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

func (*Rules) Reset 

func (x *Rules) Reset()

func (*Rules) String 

func (x *Rules) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Scheduler.ProtoReflect.Descriptor instead.

func (*Scheduler) GetCassandra added in v1.16.0 

func (x *Scheduler) GetCassandra() *DbConfig

func (*Scheduler) GetConfig 

func (m *Scheduler) GetConfig() isScheduler_Config

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) GetId 

func (x *Scheduler) GetId() string

func (*Scheduler) GetInterval 

func (x *Scheduler) GetInterval() int32

func (*Scheduler) GetMongo added in v1.16.0 

func (x *Scheduler) GetMongo() *DbConfig

func (*Scheduler) GetMysql added in v1.16.0 

func (x *Scheduler) GetMysql() *DbConfig

func (*Scheduler) GetName 

func (x *Scheduler) GetName() string

func (*Scheduler) GetPostgres added in v1.16.0 

func (x *Scheduler) GetPostgres() *DbConfig

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) GetTcp 

func (x *Scheduler) GetTcp() *TcpConfig

func (*Scheduler) GetTimeout 

func (x *Scheduler) GetTimeout() int32

func (*Scheduler) GetType 

func (x *Scheduler) GetType() SchedulerType

func (*Scheduler) ProtoMessage 

func (*Scheduler) ProtoMessage()

func (*Scheduler) ProtoReflect 

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

func (*Scheduler) Reset 

func (x *Scheduler) Reset()

func (*Scheduler) String 

func (x *Scheduler) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use TcpConfig.ProtoReflect.Descriptor instead.

func (*TcpConfig) GetHost 

func (x *TcpConfig) GetHost() string

func (*TcpConfig) GetPort 

func (x *TcpConfig) GetPort() int32

func (*TcpConfig) ProtoMessage 

func (*TcpConfig) ProtoMessage()

func (*TcpConfig) ProtoReflect 

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

func (*TcpConfig) Reset 

func (x *TcpConfig) Reset()

func (*TcpConfig) String 

func (x *TcpConfig) String() string

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) Add added in v1.13.0 

func (UnimplementedNotificationManagerServer) Add(context.Context, *NotificationMethodRequest) (*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) SaveIncident(context.Context, *Incident) (*emptypb.Empty, error)

func (UnimplementedStorageServer) SaveResponseFromAgent added in v1.13.0 

func (UnimplementedStorageServer) SaveResponseFromAgent(context.Context, *Metric) (*emptypb.Empty, error)

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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.