proto

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Feb 25, 2026 License: AGPL-3.0 Imports: 15 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	Stream_Subscribe_FullMethodName = "/com.omniview.pluginsdk.Stream/Subscribe"
	Stream_Run_FullMethodName       = "/com.omniview.pluginsdk.Stream/Run"
	Stream_Publish_FullMethodName   = "/com.omniview.pluginsdk.Stream/Publish"
)
View Source 
const (
	ExecPlugin_GetSupportedResources_FullMethodName = "/com.omniview.pluginsdk.ExecPlugin/GetSupportedResources"
	ExecPlugin_GetSession_FullMethodName            = "/com.omniview.pluginsdk.ExecPlugin/GetSession"
	ExecPlugin_ListSessions_FullMethodName          = "/com.omniview.pluginsdk.ExecPlugin/ListSessions"
	ExecPlugin_CreateSession_FullMethodName         = "/com.omniview.pluginsdk.ExecPlugin/CreateSession"
	ExecPlugin_AttachSession_FullMethodName         = "/com.omniview.pluginsdk.ExecPlugin/AttachSession"
	ExecPlugin_DetachSession_FullMethodName         = "/com.omniview.pluginsdk.ExecPlugin/DetachSession"
	ExecPlugin_CloseSession_FullMethodName          = "/com.omniview.pluginsdk.ExecPlugin/CloseSession"
	ExecPlugin_ResizeSession_FullMethodName         = "/com.omniview.pluginsdk.ExecPlugin/ResizeSession"
	ExecPlugin_Stream_FullMethodName                = "/com.omniview.pluginsdk.ExecPlugin/Stream"
)
View Source 
const (
	PluginLifecycle_GetInfo_FullMethodName         = "/com.omniview.pluginsdk.PluginLifecycle/GetInfo"
	PluginLifecycle_GetCapabilities_FullMethodName = "/com.omniview.pluginsdk.PluginLifecycle/GetCapabilities"
	PluginLifecycle_HealthCheck_FullMethodName     = "/com.omniview.pluginsdk.PluginLifecycle/HealthCheck"
)
View Source 
const (
	LogPlugin_GetSupportedResources_FullMethodName = "/com.omniview.pluginsdk.LogPlugin/GetSupportedResources"
	LogPlugin_CreateSession_FullMethodName         = "/com.omniview.pluginsdk.LogPlugin/CreateSession"
	LogPlugin_GetSession_FullMethodName            = "/com.omniview.pluginsdk.LogPlugin/GetSession"
	LogPlugin_ListSessions_FullMethodName          = "/com.omniview.pluginsdk.LogPlugin/ListSessions"
	LogPlugin_CloseSession_FullMethodName          = "/com.omniview.pluginsdk.LogPlugin/CloseSession"
	LogPlugin_UpdateSessionOptions_FullMethodName  = "/com.omniview.pluginsdk.LogPlugin/UpdateSessionOptions"
	LogPlugin_Stream_FullMethodName                = "/com.omniview.pluginsdk.LogPlugin/Stream"
)
View Source 
const (
	MetricPlugin_GetSupportedResources_FullMethodName = "/com.omniview.pluginsdk.MetricPlugin/GetSupportedResources"
	MetricPlugin_Query_FullMethodName                 = "/com.omniview.pluginsdk.MetricPlugin/Query"
	MetricPlugin_StreamMetrics_FullMethodName         = "/com.omniview.pluginsdk.MetricPlugin/StreamMetrics"
)
View Source 
const (
	NetworkerPlugin_GetSupportedPortForwardTargets_FullMethodName = "/com.omniview.pluginsdk.NetworkerPlugin/GetSupportedPortForwardTargets"
	NetworkerPlugin_GetPortForwardSession_FullMethodName          = "/com.omniview.pluginsdk.NetworkerPlugin/GetPortForwardSession"
	NetworkerPlugin_ListPortForwardSessions_FullMethodName        = "/com.omniview.pluginsdk.NetworkerPlugin/ListPortForwardSessions"
	NetworkerPlugin_FindPortForwardSessions_FullMethodName        = "/com.omniview.pluginsdk.NetworkerPlugin/FindPortForwardSessions"
	NetworkerPlugin_StartPortForwardSession_FullMethodName        = "/com.omniview.pluginsdk.NetworkerPlugin/StartPortForwardSession"
	NetworkerPlugin_ClosePortForwardSession_FullMethodName        = "/com.omniview.pluginsdk.NetworkerPlugin/ClosePortForwardSession"
)
View Source 
const (
	ResourcePlugin_GetResourceGroups_FullMethodName         = "/com.omniview.pluginsdk.ResourcePlugin/GetResourceGroups"
	ResourcePlugin_GetResourceGroup_FullMethodName          = "/com.omniview.pluginsdk.ResourcePlugin/GetResourceGroup"
	ResourcePlugin_GetResourceTypes_FullMethodName          = "/com.omniview.pluginsdk.ResourcePlugin/GetResourceTypes"
	ResourcePlugin_GetResourceType_FullMethodName           = "/com.omniview.pluginsdk.ResourcePlugin/GetResourceType"
	ResourcePlugin_HasResourceType_FullMethodName           = "/com.omniview.pluginsdk.ResourcePlugin/HasResourceType"
	ResourcePlugin_GetResourceDefinition_FullMethodName     = "/com.omniview.pluginsdk.ResourcePlugin/GetResourceDefinition"
	ResourcePlugin_StartConnection_FullMethodName           = "/com.omniview.pluginsdk.ResourcePlugin/StartConnection"
	ResourcePlugin_StopConnection_FullMethodName            = "/com.omniview.pluginsdk.ResourcePlugin/StopConnection"
	ResourcePlugin_LoadConnections_FullMethodName           = "/com.omniview.pluginsdk.ResourcePlugin/LoadConnections"
	ResourcePlugin_ListConnections_FullMethodName           = "/com.omniview.pluginsdk.ResourcePlugin/ListConnections"
	ResourcePlugin_GetConnection_FullMethodName             = "/com.omniview.pluginsdk.ResourcePlugin/GetConnection"
	ResourcePlugin_GetConnectionNamespaces_FullMethodName   = "/com.omniview.pluginsdk.ResourcePlugin/GetConnectionNamespaces"
	ResourcePlugin_UpdateConnection_FullMethodName          = "/com.omniview.pluginsdk.ResourcePlugin/UpdateConnection"
	ResourcePlugin_DeleteConnection_FullMethodName          = "/com.omniview.pluginsdk.ResourcePlugin/DeleteConnection"
	ResourcePlugin_WatchConnections_FullMethodName          = "/com.omniview.pluginsdk.ResourcePlugin/WatchConnections"
	ResourcePlugin_Get_FullMethodName                       = "/com.omniview.pluginsdk.ResourcePlugin/Get"
	ResourcePlugin_List_FullMethodName                      = "/com.omniview.pluginsdk.ResourcePlugin/List"
	ResourcePlugin_Find_FullMethodName                      = "/com.omniview.pluginsdk.ResourcePlugin/Find"
	ResourcePlugin_Create_FullMethodName                    = "/com.omniview.pluginsdk.ResourcePlugin/Create"
	ResourcePlugin_Update_FullMethodName                    = "/com.omniview.pluginsdk.ResourcePlugin/Update"
	ResourcePlugin_Delete_FullMethodName                    = "/com.omniview.pluginsdk.ResourcePlugin/Delete"
	ResourcePlugin_HasInformer_FullMethodName               = "/com.omniview.pluginsdk.ResourcePlugin/HasInformer"
	ResourcePlugin_StartConnectionInformer_FullMethodName   = "/com.omniview.pluginsdk.ResourcePlugin/StartConnectionInformer"
	ResourcePlugin_StopConnectionInformer_FullMethodName    = "/com.omniview.pluginsdk.ResourcePlugin/StopConnectionInformer"
	ResourcePlugin_ListenForEvents_FullMethodName           = "/com.omniview.pluginsdk.ResourcePlugin/ListenForEvents"
	ResourcePlugin_GetInformerState_FullMethodName          = "/com.omniview.pluginsdk.ResourcePlugin/GetInformerState"
	ResourcePlugin_EnsureInformerForResource_FullMethodName = "/com.omniview.pluginsdk.ResourcePlugin/EnsureInformerForResource"
	ResourcePlugin_GetLayout_FullMethodName                 = "/com.omniview.pluginsdk.ResourcePlugin/GetLayout"
	ResourcePlugin_GetDefaultLayout_FullMethodName          = "/com.omniview.pluginsdk.ResourcePlugin/GetDefaultLayout"
	ResourcePlugin_SetLayout_FullMethodName                 = "/com.omniview.pluginsdk.ResourcePlugin/SetLayout"
	ResourcePlugin_GetActions_FullMethodName                = "/com.omniview.pluginsdk.ResourcePlugin/GetActions"
	ResourcePlugin_ExecuteAction_FullMethodName             = "/com.omniview.pluginsdk.ResourcePlugin/ExecuteAction"
	ResourcePlugin_StreamAction_FullMethodName              = "/com.omniview.pluginsdk.ResourcePlugin/StreamAction"
	ResourcePlugin_GetEditorSchemas_FullMethodName          = "/com.omniview.pluginsdk.ResourcePlugin/GetEditorSchemas"
)
View Source 
const (
	SettingsPlugin_ListSettings_FullMethodName    = "/com.omniview.pluginsdk.SettingsPlugin/ListSettings"
	SettingsPlugin_GetSetting_FullMethodName      = "/com.omniview.pluginsdk.SettingsPlugin/GetSetting"
	SettingsPlugin_GetSettingValue_FullMethodName = "/com.omniview.pluginsdk.SettingsPlugin/GetSettingValue"
	SettingsPlugin_SetSetting_FullMethodName      = "/com.omniview.pluginsdk.SettingsPlugin/SetSetting"
	SettingsPlugin_SetSettings_FullMethodName     = "/com.omniview.pluginsdk.SettingsPlugin/SetSettings"
)
View Source 
const (
	Command_Call_FullMethodName = "/com.omniview.pluginsdk.Command/Call"
)

Variables

View Source 
var (
	SubscribeStreamResponse_Status_name = map[int32]string{
		0: "OK",
		1: "NOT_FOUND",
		2: "PERMISSION_DENIED",
	}
	SubscribeStreamResponse_Status_value = map[string]int32{
		"OK":                0,
		"NOT_FOUND":         1,
		"PERMISSION_DENIED": 2,
	}
)

Enum value maps for SubscribeStreamResponse_Status.

View Source 
var (
	PublishStreamResponse_Status_name = map[int32]string{
		0: "OK",
		1: "NOT_FOUND",
		2: "PERMISSION_DENIED",
	}
	PublishStreamResponse_Status_value = map[string]int32{
		"OK":                0,
		"NOT_FOUND":         1,
		"PERMISSION_DENIED": 2,
	}
)

Enum value maps for PublishStreamResponse_Status.

View Source 
var (
	StreamSignal_name = map[int32]string{
		0:  "NONE",
		1:  "CLOSE",
		2:  "SIGINT",
		3:  "SIGQUIT",
		4:  "SIGTERM",
		5:  "SIGKILL",
		6:  "SIGHUP",
		7:  "SIGUSR1",
		8:  "SIGUSR2",
		9:  "SIGWINCH",
		10: "ERROR",
	}
	StreamSignal_value = map[string]int32{
		"NONE":     0,
		"CLOSE":    1,
		"SIGINT":   2,
		"SIGQUIT":  3,
		"SIGTERM":  4,
		"SIGKILL":  5,
		"SIGHUP":   6,
		"SIGUSR1":  7,
		"SIGUSR2":  8,
		"SIGWINCH": 9,
		"ERROR":    10,
	}
)

Enum value maps for StreamSignal.

View Source 
var (
	StreamOutput_Target_name = map[int32]string{
		0: "STDOUT",
		1: "STDERR",
	}
	StreamOutput_Target_value = map[string]int32{
		"STDOUT": 0,
		"STDERR": 1,
	}
)

Enum value maps for StreamOutput_Target.

View Source 
var (
	ServingStatus_name = map[int32]string{
		0: "UNKNOWN",
		1: "SERVING",
		2: "NOT_SERVING",
	}
	ServingStatus_value = map[string]int32{
		"UNKNOWN":     0,
		"SERVING":     1,
		"NOT_SERVING": 2,
	}
)

Enum value maps for ServingStatus.

View Source 
var (
	LogLineOrigin_name = map[int32]string{
		0: "LOG_LINE_ORIGIN_CURRENT",
		1: "LOG_LINE_ORIGIN_PREVIOUS",
		2: "LOG_LINE_ORIGIN_SYSTEM",
	}
	LogLineOrigin_value = map[string]int32{
		"LOG_LINE_ORIGIN_CURRENT":  0,
		"LOG_LINE_ORIGIN_PREVIOUS": 1,
		"LOG_LINE_ORIGIN_SYSTEM":   2,
	}
)

Enum value maps for LogLineOrigin.

View Source 
var (
	LogStreamEventType_name = map[int32]string{
		0: "LOG_STREAM_EVENT_SOURCE_ADDED",
		1: "LOG_STREAM_EVENT_SOURCE_REMOVED",
		2: "LOG_STREAM_EVENT_STREAM_ERROR",
		3: "LOG_STREAM_EVENT_RECONNECTING",
		4: "LOG_STREAM_EVENT_RECONNECTED",
		5: "LOG_STREAM_EVENT_STREAM_ENDED",
	}
	LogStreamEventType_value = map[string]int32{
		"LOG_STREAM_EVENT_SOURCE_ADDED":   0,
		"LOG_STREAM_EVENT_SOURCE_REMOVED": 1,
		"LOG_STREAM_EVENT_STREAM_ERROR":   2,
		"LOG_STREAM_EVENT_RECONNECTING":   3,
		"LOG_STREAM_EVENT_RECONNECTED":    4,
		"LOG_STREAM_EVENT_STREAM_ENDED":   5,
	}
)

Enum value maps for LogStreamEventType.

View Source 
var (
	LogStreamCommand_name = map[int32]string{
		0: "LOG_STREAM_COMMAND_PAUSE",
		1: "LOG_STREAM_COMMAND_RESUME",
		2: "LOG_STREAM_COMMAND_CLOSE",
	}
	LogStreamCommand_value = map[string]int32{
		"LOG_STREAM_COMMAND_PAUSE":  0,
		"LOG_STREAM_COMMAND_RESUME": 1,
		"LOG_STREAM_COMMAND_CLOSE":  2,
	}
)

Enum value maps for LogStreamCommand.

View Source 
var (
	LogSessionStatus_name = map[int32]string{
		0: "LOG_SESSION_STATUS_ACTIVE",
		1: "LOG_SESSION_STATUS_PAUSED",
		2: "LOG_SESSION_STATUS_CLOSED",
		3: "LOG_SESSION_STATUS_ERROR",
	}
	LogSessionStatus_value = map[string]int32{
		"LOG_SESSION_STATUS_ACTIVE": 0,
		"LOG_SESSION_STATUS_PAUSED": 1,
		"LOG_SESSION_STATUS_CLOSED": 2,
		"LOG_SESSION_STATUS_ERROR":  3,
	}
)

Enum value maps for LogSessionStatus.

View Source 
var (
	MetricUnit_name = map[int32]string{
		0:  "METRIC_UNIT_NONE",
		1:  "METRIC_UNIT_BYTES",
		2:  "METRIC_UNIT_KB",
		3:  "METRIC_UNIT_MB",
		4:  "METRIC_UNIT_GB",
		5:  "METRIC_UNIT_PERCENTAGE",
		6:  "METRIC_UNIT_MILLISECONDS",
		7:  "METRIC_UNIT_SECONDS",
		8:  "METRIC_UNIT_COUNT",
		9:  "METRIC_UNIT_OPS_PER_SEC",
		10: "METRIC_UNIT_BYTES_PER_SEC",
		11: "METRIC_UNIT_MILLICORES",
		12: "METRIC_UNIT_CORES",
	}
	MetricUnit_value = map[string]int32{
		"METRIC_UNIT_NONE":          0,
		"METRIC_UNIT_BYTES":         1,
		"METRIC_UNIT_KB":            2,
		"METRIC_UNIT_MB":            3,
		"METRIC_UNIT_GB":            4,
		"METRIC_UNIT_PERCENTAGE":    5,
		"METRIC_UNIT_MILLISECONDS":  6,
		"METRIC_UNIT_SECONDS":       7,
		"METRIC_UNIT_COUNT":         8,
		"METRIC_UNIT_OPS_PER_SEC":   9,
		"METRIC_UNIT_BYTES_PER_SEC": 10,
		"METRIC_UNIT_MILLICORES":    11,
		"METRIC_UNIT_CORES":         12,
	}
)

Enum value maps for MetricUnit.

View Source 
var (
	MetricShape_name = map[int32]string{
		0: "METRIC_SHAPE_CURRENT",
		1: "METRIC_SHAPE_TIMESERIES",
		2: "METRIC_SHAPE_AGGREGATE",
	}
	MetricShape_value = map[string]int32{
		"METRIC_SHAPE_CURRENT":    0,
		"METRIC_SHAPE_TIMESERIES": 1,
		"METRIC_SHAPE_AGGREGATE":  2,
	}
)

Enum value maps for MetricShape.

View Source 
var (
	MetricStreamCommand_name = map[int32]string{
		0: "METRIC_STREAM_COMMAND_SUBSCRIBE",
		1: "METRIC_STREAM_COMMAND_UNSUBSCRIBE",
		2: "METRIC_STREAM_COMMAND_CLOSE",
	}
	MetricStreamCommand_value = map[string]int32{
		"METRIC_STREAM_COMMAND_SUBSCRIBE":   0,
		"METRIC_STREAM_COMMAND_UNSUBSCRIBE": 1,
		"METRIC_STREAM_COMMAND_CLOSE":       2,
	}
)

Enum value maps for MetricStreamCommand.

View Source 
var (
	PortForwardProtocol_name = map[int32]string{
		0: "TCP",
		1: "UDP",
	}
	PortForwardProtocol_value = map[string]int32{
		"TCP": 0,
		"UDP": 1,
	}
)

Enum value maps for PortForwardProtocol.

View Source 
var (
	PortForwardSession_SessionState_name = map[int32]string{
		0: "ACTIVE",
		1: "PAUSED",
		2: "STOPPED",
		3: "FAILED",
	}
	PortForwardSession_SessionState_value = map[string]int32{
		"ACTIVE":  0,
		"PAUSED":  1,
		"STOPPED": 2,
		"FAILED":  3,
	}
)

Enum value maps for PortForwardSession_SessionState.

View Source 
var (
	ActionScope_name = map[int32]string{
		0: "ACTION_SCOPE_INSTANCE",
		1: "ACTION_SCOPE_TYPE",
	}
	ActionScope_value = map[string]int32{
		"ACTION_SCOPE_INSTANCE": 0,
		"ACTION_SCOPE_TYPE":     1,
	}
)

Enum value maps for ActionScope.

View Source 
var (
	ColumnDef_Alignment_name = map[int32]string{
		0: "LEFT",
		1: "RIGHT",
		2: "CENTER",
	}
	ColumnDef_Alignment_value = map[string]int32{
		"LEFT":   0,
		"RIGHT":  1,
		"CENTER": 2,
	}
)

Enum value maps for ColumnDef_Alignment.

View Source 
var (
	ColumnDef_AccessorPriority_name = map[int32]string{
		0: "ALL",
		1: "FIRST",
		2: "LAST",
	}
	ColumnDef_AccessorPriority_value = map[string]int32{
		"ALL":   0,
		"FIRST": 1,
		"LAST":  2,
	}
)

Enum value maps for ColumnDef_AccessorPriority.

View Source 
var (
	ColumnDef_Formatter_name = map[int32]string{
		0:  "NONE",
		1:  "BYTES",
		2:  "DURATION",
		3:  "PERCENT",
		4:  "TIME",
		5:  "AGE",
		6:  "SUM",
		7:  "COUNT",
		8:  "AVG",
		9:  "MAX",
		10: "MIN",
	}
	ColumnDef_Formatter_value = map[string]int32{
		"NONE":     0,
		"BYTES":    1,
		"DURATION": 2,
		"PERCENT":  3,
		"TIME":     4,
		"AGE":      5,
		"SUM":      6,
		"COUNT":    7,
		"AVG":      8,
		"MAX":      9,
		"MIN":      10,
	}
)

Enum value maps for ColumnDef_Formatter.

View Source 
var (
	ResourceAction_Variant_name = map[int32]string{
		0: "EXEC",
		1: "LOGS",
		2: "CUSTOM",
	}
	ResourceAction_Variant_value = map[string]int32{
		"EXEC":   0,
		"LOGS":   1,
		"CUSTOM": 2,
	}
)

Enum value maps for ResourceAction_Variant.

View Source 
var (
	ConnectionStatus_Status_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "CONNECTED",
		2:  "DISCONNECTED",
		3:  "PENDING",
		4:  "FAILED",
		5:  "ERROR",
		6:  "UNAUTHORIZED",
		7:  "FORBIDDEN",
		8:  "BAD_REQUEST",
		9:  "NOT_FOUND",
		10: "TIMEOUT",
		11: "UNAVAILABLE",
		12: "REQUEST_ENTITY_TOO_LARGE",
	}
	ConnectionStatus_Status_value = map[string]int32{
		"UNKNOWN":                  0,
		"CONNECTED":                1,
		"DISCONNECTED":             2,
		"PENDING":                  3,
		"FAILED":                   4,
		"ERROR":                    5,
		"UNAUTHORIZED":             6,
		"FORBIDDEN":                7,
		"BAD_REQUEST":              8,
		"NOT_FOUND":                9,
		"TIMEOUT":                  10,
		"UNAVAILABLE":              11,
		"REQUEST_ENTITY_TOO_LARGE": 12,
	}
)

Enum value maps for ConnectionStatus_Status.

View Source 
var (
	InformerSyncPolicy_name = map[int32]string{
		0: "SYNC_ON_CONNECT",
		1: "SYNC_ON_FIRST_QUERY",
		2: "SYNC_NEVER",
	}
	InformerSyncPolicy_value = map[string]int32{
		"SYNC_ON_CONNECT":     0,
		"SYNC_ON_FIRST_QUERY": 1,
		"SYNC_NEVER":          2,
	}
)

Enum value maps for InformerSyncPolicy.

View Source 
var (
	InformerResourceState_name = map[int32]string{
		0: "INFORMER_PENDING",
		1: "INFORMER_SYNCING",
		2: "INFORMER_SYNCED",
		3: "INFORMER_ERROR",
		4: "INFORMER_CANCELLED",
	}
	InformerResourceState_value = map[string]int32{
		"INFORMER_PENDING":   0,
		"INFORMER_SYNCING":   1,
		"INFORMER_SYNCED":    2,
		"INFORMER_ERROR":     3,
		"INFORMER_CANCELLED": 4,
	}
)

Enum value maps for InformerResourceState.

View Source 
var (
	SettingType_name = map[int32]string{
		0: "TEXT",
		1: "INTEGER",
		2: "FLOAT",
		3: "TOGGLE",
		4: "COLOR",
		5: "DATETIME",
		6: "PASSWORD",
	}
	SettingType_value = map[string]int32{
		"TEXT":     0,
		"INTEGER":  1,
		"FLOAT":    2,
		"TOGGLE":   3,
		"COLOR":    4,
		"DATETIME": 5,
		"PASSWORD": 6,
	}
)

Enum value maps for SettingType.

View Source 
var (
	VisualResourceComponent_ComponentType_name = map[int32]string{
		0: "SIDEBAR",
		1: "TABLE",
		2: "TABLE_ROW",
		3: "TABLE_CELL",
	}
	VisualResourceComponent_ComponentType_value = map[string]int32{
		"SIDEBAR":    0,
		"TABLE":      1,
		"TABLE_ROW":  2,
		"TABLE_CELL": 3,
	}
)

Enum value maps for VisualResourceComponent_ComponentType.

View Source 
var Command_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.omniview.pluginsdk.Command",
	HandlerType: (*CommandServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Call",
			Handler:    _Command_Call_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/command.proto",
}

Command_ServiceDesc is the grpc.ServiceDesc for Command 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 ExecPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.omniview.pluginsdk.ExecPlugin",
	HandlerType: (*ExecPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSupportedResources",
			Handler:    _ExecPlugin_GetSupportedResources_Handler,
		},
		{
			MethodName: "GetSession",
			Handler:    _ExecPlugin_GetSession_Handler,
		},
		{
			MethodName: "ListSessions",
			Handler:    _ExecPlugin_ListSessions_Handler,
		},
		{
			MethodName: "CreateSession",
			Handler:    _ExecPlugin_CreateSession_Handler,
		},
		{
			MethodName: "AttachSession",
			Handler:    _ExecPlugin_AttachSession_Handler,
		},
		{
			MethodName: "DetachSession",
			Handler:    _ExecPlugin_DetachSession_Handler,
		},
		{
			MethodName: "CloseSession",
			Handler:    _ExecPlugin_CloseSession_Handler,
		},
		{
			MethodName: "ResizeSession",
			Handler:    _ExecPlugin_ResizeSession_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Stream",
			Handler:       _ExecPlugin_Stream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "proto/exec.proto",
}

ExecPlugin_ServiceDesc is the grpc.ServiceDesc for ExecPlugin 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_command_proto protoreflect.FileDescriptor
View Source 
var File_proto_exec_proto protoreflect.FileDescriptor
View Source 
var File_proto_lifecycle_proto protoreflect.FileDescriptor
View Source 
var File_proto_logs_proto protoreflect.FileDescriptor
View Source 
var File_proto_metric_proto protoreflect.FileDescriptor
View Source 
var File_proto_networker_proto protoreflect.FileDescriptor
View Source 
var File_proto_resource_common_proto protoreflect.FileDescriptor
View Source 
var File_proto_resource_connection_proto protoreflect.FileDescriptor
View Source 
var File_proto_resource_informer_proto protoreflect.FileDescriptor
View Source 
var File_proto_resource_layout_proto protoreflect.FileDescriptor
View Source 
var File_proto_resource_proto protoreflect.FileDescriptor
View Source 
var File_proto_settings_proto protoreflect.FileDescriptor
View Source 
var LogPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.omniview.pluginsdk.LogPlugin",
	HandlerType: (*LogPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSupportedResources",
			Handler:    _LogPlugin_GetSupportedResources_Handler,
		},
		{
			MethodName: "CreateSession",
			Handler:    _LogPlugin_CreateSession_Handler,
		},
		{
			MethodName: "GetSession",
			Handler:    _LogPlugin_GetSession_Handler,
		},
		{
			MethodName: "ListSessions",
			Handler:    _LogPlugin_ListSessions_Handler,
		},
		{
			MethodName: "CloseSession",
			Handler:    _LogPlugin_CloseSession_Handler,
		},
		{
			MethodName: "UpdateSessionOptions",
			Handler:    _LogPlugin_UpdateSessionOptions_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Stream",
			Handler:       _LogPlugin_Stream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "proto/logs.proto",
}

LogPlugin_ServiceDesc is the grpc.ServiceDesc for LogPlugin 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 MetricPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.omniview.pluginsdk.MetricPlugin",
	HandlerType: (*MetricPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSupportedResources",
			Handler:    _MetricPlugin_GetSupportedResources_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _MetricPlugin_Query_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamMetrics",
			Handler:       _MetricPlugin_StreamMetrics_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "proto/metric.proto",
}

MetricPlugin_ServiceDesc is the grpc.ServiceDesc for MetricPlugin 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 NetworkerPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.omniview.pluginsdk.NetworkerPlugin",
	HandlerType: (*NetworkerPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSupportedPortForwardTargets",
			Handler:    _NetworkerPlugin_GetSupportedPortForwardTargets_Handler,
		},
		{
			MethodName: "GetPortForwardSession",
			Handler:    _NetworkerPlugin_GetPortForwardSession_Handler,
		},
		{
			MethodName: "ListPortForwardSessions",
			Handler:    _NetworkerPlugin_ListPortForwardSessions_Handler,
		},
		{
			MethodName: "FindPortForwardSessions",
			Handler:    _NetworkerPlugin_FindPortForwardSessions_Handler,
		},
		{
			MethodName: "StartPortForwardSession",
			Handler:    _NetworkerPlugin_StartPortForwardSession_Handler,
		},
		{
			MethodName: "ClosePortForwardSession",
			Handler:    _NetworkerPlugin_ClosePortForwardSession_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/networker.proto",
}

NetworkerPlugin_ServiceDesc is the grpc.ServiceDesc for NetworkerPlugin 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 PluginLifecycle_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.omniview.pluginsdk.PluginLifecycle",
	HandlerType: (*PluginLifecycleServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetInfo",
			Handler:    _PluginLifecycle_GetInfo_Handler,
		},
		{
			MethodName: "GetCapabilities",
			Handler:    _PluginLifecycle_GetCapabilities_Handler,
		},
		{
			MethodName: "HealthCheck",
			Handler:    _PluginLifecycle_HealthCheck_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/lifecycle.proto",
}

PluginLifecycle_ServiceDesc is the grpc.ServiceDesc for PluginLifecycle 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 ResourcePlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.omniview.pluginsdk.ResourcePlugin",
	HandlerType: (*ResourcePluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetResourceGroups",
			Handler:    _ResourcePlugin_GetResourceGroups_Handler,
		},
		{
			MethodName: "GetResourceGroup",
			Handler:    _ResourcePlugin_GetResourceGroup_Handler,
		},
		{
			MethodName: "GetResourceTypes",
			Handler:    _ResourcePlugin_GetResourceTypes_Handler,
		},
		{
			MethodName: "GetResourceType",
			Handler:    _ResourcePlugin_GetResourceType_Handler,
		},
		{
			MethodName: "HasResourceType",
			Handler:    _ResourcePlugin_HasResourceType_Handler,
		},
		{
			MethodName: "GetResourceDefinition",
			Handler:    _ResourcePlugin_GetResourceDefinition_Handler,
		},
		{
			MethodName: "StartConnection",
			Handler:    _ResourcePlugin_StartConnection_Handler,
		},
		{
			MethodName: "StopConnection",
			Handler:    _ResourcePlugin_StopConnection_Handler,
		},
		{
			MethodName: "LoadConnections",
			Handler:    _ResourcePlugin_LoadConnections_Handler,
		},
		{
			MethodName: "ListConnections",
			Handler:    _ResourcePlugin_ListConnections_Handler,
		},
		{
			MethodName: "GetConnection",
			Handler:    _ResourcePlugin_GetConnection_Handler,
		},
		{
			MethodName: "GetConnectionNamespaces",
			Handler:    _ResourcePlugin_GetConnectionNamespaces_Handler,
		},
		{
			MethodName: "UpdateConnection",
			Handler:    _ResourcePlugin_UpdateConnection_Handler,
		},
		{
			MethodName: "DeleteConnection",
			Handler:    _ResourcePlugin_DeleteConnection_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _ResourcePlugin_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _ResourcePlugin_List_Handler,
		},
		{
			MethodName: "Find",
			Handler:    _ResourcePlugin_Find_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _ResourcePlugin_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _ResourcePlugin_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ResourcePlugin_Delete_Handler,
		},
		{
			MethodName: "HasInformer",
			Handler:    _ResourcePlugin_HasInformer_Handler,
		},
		{
			MethodName: "StartConnectionInformer",
			Handler:    _ResourcePlugin_StartConnectionInformer_Handler,
		},
		{
			MethodName: "StopConnectionInformer",
			Handler:    _ResourcePlugin_StopConnectionInformer_Handler,
		},
		{
			MethodName: "GetInformerState",
			Handler:    _ResourcePlugin_GetInformerState_Handler,
		},
		{
			MethodName: "EnsureInformerForResource",
			Handler:    _ResourcePlugin_EnsureInformerForResource_Handler,
		},
		{
			MethodName: "GetLayout",
			Handler:    _ResourcePlugin_GetLayout_Handler,
		},
		{
			MethodName: "GetDefaultLayout",
			Handler:    _ResourcePlugin_GetDefaultLayout_Handler,
		},
		{
			MethodName: "SetLayout",
			Handler:    _ResourcePlugin_SetLayout_Handler,
		},
		{
			MethodName: "GetActions",
			Handler:    _ResourcePlugin_GetActions_Handler,
		},
		{
			MethodName: "ExecuteAction",
			Handler:    _ResourcePlugin_ExecuteAction_Handler,
		},
		{
			MethodName: "GetEditorSchemas",
			Handler:    _ResourcePlugin_GetEditorSchemas_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchConnections",
			Handler:       _ResourcePlugin_WatchConnections_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListenForEvents",
			Handler:       _ResourcePlugin_ListenForEvents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamAction",
			Handler:       _ResourcePlugin_StreamAction_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/resource.proto",
}

ResourcePlugin_ServiceDesc is the grpc.ServiceDesc for ResourcePlugin 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 SettingsPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.omniview.pluginsdk.SettingsPlugin",
	HandlerType: (*SettingsPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListSettings",
			Handler:    _SettingsPlugin_ListSettings_Handler,
		},
		{
			MethodName: "GetSetting",
			Handler:    _SettingsPlugin_GetSetting_Handler,
		},
		{
			MethodName: "GetSettingValue",
			Handler:    _SettingsPlugin_GetSettingValue_Handler,
		},
		{
			MethodName: "SetSetting",
			Handler:    _SettingsPlugin_SetSetting_Handler,
		},
		{
			MethodName: "SetSettings",
			Handler:    _SettingsPlugin_SetSettings_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/settings.proto",
}

SettingsPlugin_ServiceDesc is the grpc.ServiceDesc for SettingsPlugin 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 Stream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.omniview.pluginsdk.Stream",
	HandlerType: (*StreamServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Subscribe",
			Handler:    _Stream_Subscribe_Handler,
		},
		{
			MethodName: "Publish",
			Handler:    _Stream_Publish_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Run",
			Handler:       _Stream_Run_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/command.proto",
}

Stream_ServiceDesc is the grpc.ServiceDesc for Stream service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterCommandServer 

func RegisterCommandServer(s grpc.ServiceRegistrar, srv CommandServer)

func RegisterExecPluginServer 

func RegisterExecPluginServer(s grpc.ServiceRegistrar, srv ExecPluginServer)

func RegisterLogPluginServer 

func RegisterLogPluginServer(s grpc.ServiceRegistrar, srv LogPluginServer)

func RegisterMetricPluginServer 

func RegisterMetricPluginServer(s grpc.ServiceRegistrar, srv MetricPluginServer)

func RegisterNetworkerPluginServer 

func RegisterNetworkerPluginServer(s grpc.ServiceRegistrar, srv NetworkerPluginServer)

func RegisterPluginLifecycleServer added in v0.1.1 

func RegisterPluginLifecycleServer(s grpc.ServiceRegistrar, srv PluginLifecycleServer)

func RegisterResourcePluginServer 

func RegisterResourcePluginServer(s grpc.ServiceRegistrar, srv ResourcePluginServer)

func RegisterSettingsPluginServer 

func RegisterSettingsPluginServer(s grpc.ServiceRegistrar, srv SettingsPluginServer)

func RegisterStreamServer 

func RegisterStreamServer(s grpc.ServiceRegistrar, srv StreamServer)

Types

type ActionDescriptor 

type ActionDescriptor struct {
	Id          string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                                // e.g., "upgrade", "rollback", "dry-run"
	Label       string      `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`                                          // "Upgrade Release"
	Description string      `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`                              // Human-readable description
	Icon        string      `protobuf:"bytes,4,opt,name=icon,proto3" json:"icon,omitempty"`                                            // Icon identifier (react-icons)
	Scope       ActionScope `protobuf:"varint,5,opt,name=scope,proto3,enum=com.omniview.pluginsdk.ActionScope" json:"scope,omitempty"` // INSTANCE or TYPE
	Streaming   bool        `protobuf:"varint,6,opt,name=streaming,proto3" json:"streaming,omitempty"`                                 // Whether this returns a streaming response
	// contains filtered or unexported fields
}

Describes an available action on a resource type

func (*ActionDescriptor) Descriptor deprecated 

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

Deprecated: Use ActionDescriptor.ProtoReflect.Descriptor instead.

func (*ActionDescriptor) GetDescription 

func (x *ActionDescriptor) GetDescription() string

func (*ActionDescriptor) GetIcon 

func (x *ActionDescriptor) GetIcon() string

func (*ActionDescriptor) GetId 

func (x *ActionDescriptor) GetId() string

func (*ActionDescriptor) GetLabel 

func (x *ActionDescriptor) GetLabel() string

func (*ActionDescriptor) GetScope 

func (x *ActionDescriptor) GetScope() ActionScope

func (*ActionDescriptor) GetStreaming 

func (x *ActionDescriptor) GetStreaming() bool

func (*ActionDescriptor) ProtoMessage 

func (*ActionDescriptor) ProtoMessage()

func (*ActionDescriptor) ProtoReflect 

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

func (*ActionDescriptor) Reset 

func (x *ActionDescriptor) Reset()

func (*ActionDescriptor) String 

func (x *ActionDescriptor) String() string

type ActionScope 

type ActionScope int32
const (
	ActionScope_ACTION_SCOPE_INSTANCE ActionScope = 0 // Operates on a specific resource (needs id/namespace)
	ActionScope_ACTION_SCOPE_TYPE     ActionScope = 1 // Operates on the resource type level (no specific resource)
)

func (ActionScope) Descriptor 

func (ActionScope) Descriptor() protoreflect.EnumDescriptor

func (ActionScope) Enum 

func (x ActionScope) Enum() *ActionScope

func (ActionScope) EnumDescriptor deprecated 

func (ActionScope) EnumDescriptor() ([]byte, []int)

Deprecated: Use ActionScope.Descriptor instead.

func (ActionScope) Number 

func (x ActionScope) Number() protoreflect.EnumNumber

func (ActionScope) String 

func (x ActionScope) String() string

func (ActionScope) Type 

func (ActionScope) Type() protoreflect.EnumType

type AggregateValue 

type AggregateValue struct {
	MetricId string               `protobuf:"bytes,1,opt,name=metric_id,json=metricId,proto3" json:"metric_id,omitempty"`
	Min      float64              `protobuf:"fixed64,2,opt,name=min,proto3" json:"min,omitempty"`
	Max      float64              `protobuf:"fixed64,3,opt,name=max,proto3" json:"max,omitempty"`
	Avg      float64              `protobuf:"fixed64,4,opt,name=avg,proto3" json:"avg,omitempty"`
	Sum      float64              `protobuf:"fixed64,5,opt,name=sum,proto3" json:"sum,omitempty"`
	P50      float64              `protobuf:"fixed64,6,opt,name=p50,proto3" json:"p50,omitempty"`
	P90      float64              `protobuf:"fixed64,7,opt,name=p90,proto3" json:"p90,omitempty"`
	P99      float64              `protobuf:"fixed64,8,opt,name=p99,proto3" json:"p99,omitempty"`
	Count    int64                `protobuf:"varint,9,opt,name=count,proto3" json:"count,omitempty"`
	Window   *durationpb.Duration `protobuf:"bytes,10,opt,name=window,proto3" json:"window,omitempty"`
	Labels   map[string]string    `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AggregateValue) Descriptor deprecated 

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

Deprecated: Use AggregateValue.ProtoReflect.Descriptor instead.

func (*AggregateValue) GetAvg 

func (x *AggregateValue) GetAvg() float64

func (*AggregateValue) GetCount 

func (x *AggregateValue) GetCount() int64

func (*AggregateValue) GetLabels 

func (x *AggregateValue) GetLabels() map[string]string

func (*AggregateValue) GetMax 

func (x *AggregateValue) GetMax() float64

func (*AggregateValue) GetMetricId 

func (x *AggregateValue) GetMetricId() string

func (*AggregateValue) GetMin 

func (x *AggregateValue) GetMin() float64

func (*AggregateValue) GetP50 

func (x *AggregateValue) GetP50() float64

func (*AggregateValue) GetP90 

func (x *AggregateValue) GetP90() float64

func (*AggregateValue) GetP99 

func (x *AggregateValue) GetP99() float64

func (*AggregateValue) GetSum 

func (x *AggregateValue) GetSum() float64

func (*AggregateValue) GetWindow 

func (x *AggregateValue) GetWindow() *durationpb.Duration

func (*AggregateValue) ProtoMessage 

func (*AggregateValue) ProtoMessage()

func (*AggregateValue) ProtoReflect 

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

func (*AggregateValue) Reset 

func (x *AggregateValue) Reset()

func (*AggregateValue) String 

func (x *AggregateValue) String() string

type AttachSessionRequest 

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

func (*AttachSessionRequest) Descriptor deprecated 

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

Deprecated: Use AttachSessionRequest.ProtoReflect.Descriptor instead.

func (*AttachSessionRequest) GetId 

func (x *AttachSessionRequest) GetId() string

func (*AttachSessionRequest) ProtoMessage 

func (*AttachSessionRequest) ProtoMessage()

func (*AttachSessionRequest) ProtoReflect 

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

func (*AttachSessionRequest) Reset 

func (x *AttachSessionRequest) Reset()

func (*AttachSessionRequest) String 

func (x *AttachSessionRequest) String() string

type AttachSessionResponse 

type AttachSessionResponse struct {
	Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Buffer  []byte   `protobuf:"bytes,2,opt,name=buffer,proto3" json:"buffer,omitempty"`
	// contains filtered or unexported fields
}

func (*AttachSessionResponse) Descriptor deprecated 

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

Deprecated: Use AttachSessionResponse.ProtoReflect.Descriptor instead.

func (*AttachSessionResponse) GetBuffer 

func (x *AttachSessionResponse) GetBuffer() []byte

func (*AttachSessionResponse) GetSession 

func (x *AttachSessionResponse) GetSession() *Session

func (*AttachSessionResponse) ProtoMessage 

func (*AttachSessionResponse) ProtoMessage()

func (*AttachSessionResponse) ProtoReflect 

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

func (*AttachSessionResponse) Reset 

func (x *AttachSessionResponse) Reset()

func (*AttachSessionResponse) String 

func (x *AttachSessionResponse) String() string

type CallCommandRequest 

type CallCommandRequest struct {
	PluginContext *PluginContext         `protobuf:"bytes,1,opt,name=plugin_context,json=pluginContext,proto3" json:"plugin_context,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"`
	Url           string                 `protobuf:"bytes,4,opt,name=url,proto3" json:"url,omitempty"`
	Headers       map[string]*StringList `` /* 141-byte string literal not displayed */
	Body          []byte                 `protobuf:"bytes,6,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*CallCommandRequest) Descriptor deprecated 

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

Deprecated: Use CallCommandRequest.ProtoReflect.Descriptor instead.

func (*CallCommandRequest) GetBody 

func (x *CallCommandRequest) GetBody() []byte

func (*CallCommandRequest) GetHeaders 

func (x *CallCommandRequest) GetHeaders() map[string]*StringList

func (*CallCommandRequest) GetMethod 

func (x *CallCommandRequest) GetMethod() string

func (*CallCommandRequest) GetPath 

func (x *CallCommandRequest) GetPath() string

func (*CallCommandRequest) GetPluginContext 

func (x *CallCommandRequest) GetPluginContext() *PluginContext

func (*CallCommandRequest) GetUrl 

func (x *CallCommandRequest) GetUrl() string

func (*CallCommandRequest) ProtoMessage 

func (*CallCommandRequest) ProtoMessage()

func (*CallCommandRequest) ProtoReflect 

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

func (*CallCommandRequest) Reset 

func (x *CallCommandRequest) Reset()

func (*CallCommandRequest) String 

func (x *CallCommandRequest) String() string

type CallCommandResponse 

type CallCommandResponse struct {
	Code    int32                  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Headers map[string]*StringList `` /* 141-byte string literal not displayed */
	Body    []byte                 `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*CallCommandResponse) Descriptor deprecated 

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

Deprecated: Use CallCommandResponse.ProtoReflect.Descriptor instead.

func (*CallCommandResponse) GetBody 

func (x *CallCommandResponse) GetBody() []byte

func (*CallCommandResponse) GetCode 

func (x *CallCommandResponse) GetCode() int32

func (*CallCommandResponse) GetHeaders 

func (x *CallCommandResponse) GetHeaders() map[string]*StringList

func (*CallCommandResponse) ProtoMessage 

func (*CallCommandResponse) ProtoMessage()

func (*CallCommandResponse) ProtoReflect 

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

func (*CallCommandResponse) Reset 

func (x *CallCommandResponse) Reset()

func (*CallCommandResponse) String 

func (x *CallCommandResponse) String() string

type CloseLogSessionResponse 

type CloseLogSessionResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseLogSessionResponse) Descriptor deprecated 

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

Deprecated: Use CloseLogSessionResponse.ProtoReflect.Descriptor instead.

func (*CloseLogSessionResponse) GetError 

func (x *CloseLogSessionResponse) GetError() string

func (*CloseLogSessionResponse) GetSuccess 

func (x *CloseLogSessionResponse) GetSuccess() bool

func (*CloseLogSessionResponse) ProtoMessage 

func (*CloseLogSessionResponse) ProtoMessage()

func (*CloseLogSessionResponse) ProtoReflect 

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

func (*CloseLogSessionResponse) Reset 

func (x *CloseLogSessionResponse) Reset()

func (*CloseLogSessionResponse) String 

func (x *CloseLogSessionResponse) String() string

type CloseSessionRequest 

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

func (*CloseSessionRequest) Descriptor deprecated 

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

Deprecated: Use CloseSessionRequest.ProtoReflect.Descriptor instead.

func (*CloseSessionRequest) GetId 

func (x *CloseSessionRequest) GetId() string

func (*CloseSessionRequest) ProtoMessage 

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) ProtoReflect 

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

func (*CloseSessionRequest) Reset 

func (x *CloseSessionRequest) Reset()

func (*CloseSessionRequest) String 

func (x *CloseSessionRequest) String() string

type CloseSessionResponse 

type CloseSessionResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseSessionResponse) Descriptor deprecated 

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

Deprecated: Use CloseSessionResponse.ProtoReflect.Descriptor instead.

func (*CloseSessionResponse) GetError 

func (x *CloseSessionResponse) GetError() string

func (*CloseSessionResponse) GetSuccess 

func (x *CloseSessionResponse) GetSuccess() bool

func (*CloseSessionResponse) ProtoMessage 

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) ProtoReflect 

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

func (*CloseSessionResponse) Reset 

func (x *CloseSessionResponse) Reset()

func (*CloseSessionResponse) String 

func (x *CloseSessionResponse) String() string

type ColumnDef 

type ColumnDef struct {
	Id               string                     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Header           string                     `protobuf:"bytes,2,opt,name=header,proto3" json:"header,omitempty"`
	Accessors        string                     `protobuf:"bytes,3,opt,name=accessors,proto3" json:"accessors,omitempty"`
	ColorMap         map[string]string          `` /* 159-byte string literal not displayed */
	Color            string                     `protobuf:"bytes,5,opt,name=color,proto3" json:"color,omitempty"`
	Alignment        ColumnDef_Alignment        `protobuf:"varint,6,opt,name=alignment,proto3,enum=com.omniview.pluginsdk.ColumnDef_Alignment" json:"alignment,omitempty"`
	Hidden           bool                       `protobuf:"varint,7,opt,name=hidden,proto3" json:"hidden,omitempty"`
	Width            int32                      `protobuf:"varint,8,opt,name=width,proto3" json:"width,omitempty"`
	Formatter        ColumnDef_Formatter        `protobuf:"varint,9,opt,name=formatter,proto3,enum=com.omniview.pluginsdk.ColumnDef_Formatter" json:"formatter,omitempty"`
	Component        string                     `protobuf:"bytes,10,opt,name=component,proto3" json:"component,omitempty"`
	ComponentParams  *anypb.Any                 `protobuf:"bytes,11,opt,name=component_params,json=componentParams,proto3" json:"component_params,omitempty"`
	ResourceLink     *ResourceLink              `protobuf:"bytes,12,opt,name=resource_link,json=resourceLink,proto3" json:"resource_link,omitempty"`
	AccessorPriority ColumnDef_AccessorPriority `` /* 166-byte string literal not displayed */
	ValueMap         map[string]string          `` /* 160-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ColumnDef) Descriptor deprecated 

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

Deprecated: Use ColumnDef.ProtoReflect.Descriptor instead.

func (*ColumnDef) GetAccessorPriority 

func (x *ColumnDef) GetAccessorPriority() ColumnDef_AccessorPriority

func (*ColumnDef) GetAccessors 

func (x *ColumnDef) GetAccessors() string

func (*ColumnDef) GetAlignment 

func (x *ColumnDef) GetAlignment() ColumnDef_Alignment

func (*ColumnDef) GetColor 

func (x *ColumnDef) GetColor() string

func (*ColumnDef) GetColorMap 

func (x *ColumnDef) GetColorMap() map[string]string

func (*ColumnDef) GetComponent 

func (x *ColumnDef) GetComponent() string

func (*ColumnDef) GetComponentParams 

func (x *ColumnDef) GetComponentParams() *anypb.Any

func (*ColumnDef) GetFormatter 

func (x *ColumnDef) GetFormatter() ColumnDef_Formatter

func (*ColumnDef) GetHeader 

func (x *ColumnDef) GetHeader() string

func (*ColumnDef) GetHidden 

func (x *ColumnDef) GetHidden() bool

func (*ColumnDef) GetId 

func (x *ColumnDef) GetId() string
func (x *ColumnDef) GetResourceLink() *ResourceLink

func (*ColumnDef) GetValueMap 

func (x *ColumnDef) GetValueMap() map[string]string

func (*ColumnDef) GetWidth 

func (x *ColumnDef) GetWidth() int32

func (*ColumnDef) ProtoMessage 

func (*ColumnDef) ProtoMessage()

func (*ColumnDef) ProtoReflect 

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

func (*ColumnDef) Reset 

func (x *ColumnDef) Reset()

func (*ColumnDef) String 

func (x *ColumnDef) String() string

type ColumnDef_AccessorPriority 

type ColumnDef_AccessorPriority int32
const (
	ColumnDef_ALL   ColumnDef_AccessorPriority = 0
	ColumnDef_FIRST ColumnDef_AccessorPriority = 1
	ColumnDef_LAST  ColumnDef_AccessorPriority = 2
)

func (ColumnDef_AccessorPriority) Descriptor 

func (ColumnDef_AccessorPriority) Descriptor() protoreflect.EnumDescriptor

func (ColumnDef_AccessorPriority) Enum 

func (x ColumnDef_AccessorPriority) Enum() *ColumnDef_AccessorPriority

func (ColumnDef_AccessorPriority) EnumDescriptor deprecated 

func (ColumnDef_AccessorPriority) EnumDescriptor() ([]byte, []int)

Deprecated: Use ColumnDef_AccessorPriority.Descriptor instead.

func (ColumnDef_AccessorPriority) Number 

func (x ColumnDef_AccessorPriority) Number() protoreflect.EnumNumber

func (ColumnDef_AccessorPriority) String 

func (x ColumnDef_AccessorPriority) String() string

func (ColumnDef_AccessorPriority) Type 

func (ColumnDef_AccessorPriority) Type() protoreflect.EnumType

type ColumnDef_Alignment 

type ColumnDef_Alignment int32
const (
	ColumnDef_LEFT   ColumnDef_Alignment = 0
	ColumnDef_RIGHT  ColumnDef_Alignment = 1
	ColumnDef_CENTER ColumnDef_Alignment = 2
)

func (ColumnDef_Alignment) Descriptor 

func (ColumnDef_Alignment) Descriptor() protoreflect.EnumDescriptor

func (ColumnDef_Alignment) Enum 

func (x ColumnDef_Alignment) Enum() *ColumnDef_Alignment

func (ColumnDef_Alignment) EnumDescriptor deprecated 

func (ColumnDef_Alignment) EnumDescriptor() ([]byte, []int)

Deprecated: Use ColumnDef_Alignment.Descriptor instead.

func (ColumnDef_Alignment) Number 

func (x ColumnDef_Alignment) Number() protoreflect.EnumNumber

func (ColumnDef_Alignment) String 

func (x ColumnDef_Alignment) String() string

func (ColumnDef_Alignment) Type 

func (ColumnDef_Alignment) Type() protoreflect.EnumType

type ColumnDef_Formatter 

type ColumnDef_Formatter int32
const (
	ColumnDef_NONE     ColumnDef_Formatter = 0
	ColumnDef_BYTES    ColumnDef_Formatter = 1
	ColumnDef_DURATION ColumnDef_Formatter = 2
	ColumnDef_PERCENT  ColumnDef_Formatter = 3
	ColumnDef_TIME     ColumnDef_Formatter = 4
	ColumnDef_AGE      ColumnDef_Formatter = 5
	ColumnDef_SUM      ColumnDef_Formatter = 6
	ColumnDef_COUNT    ColumnDef_Formatter = 7
	ColumnDef_AVG      ColumnDef_Formatter = 8
	ColumnDef_MAX      ColumnDef_Formatter = 9
	ColumnDef_MIN      ColumnDef_Formatter = 10
)

func (ColumnDef_Formatter) Descriptor 

func (ColumnDef_Formatter) Descriptor() protoreflect.EnumDescriptor

func (ColumnDef_Formatter) Enum 

func (x ColumnDef_Formatter) Enum() *ColumnDef_Formatter

func (ColumnDef_Formatter) EnumDescriptor deprecated 

func (ColumnDef_Formatter) EnumDescriptor() ([]byte, []int)

Deprecated: Use ColumnDef_Formatter.Descriptor instead.

func (ColumnDef_Formatter) Number 

func (x ColumnDef_Formatter) Number() protoreflect.EnumNumber

func (ColumnDef_Formatter) String 

func (x ColumnDef_Formatter) String() string

func (ColumnDef_Formatter) Type 

func (ColumnDef_Formatter) Type() protoreflect.EnumType

type CommandClient 

type CommandClient interface {
	Call(ctx context.Context, in *CallCommandRequest, opts ...grpc.CallOption) (*CallCommandResponse, error)
}

CommandClient is the client API for Command 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 NewCommandClient 

func NewCommandClient(cc grpc.ClientConnInterface) CommandClient

type CommandServer 

type CommandServer interface {
	Call(context.Context, *CallCommandRequest) (*CallCommandResponse, error)
}

CommandServer is the server API for Command service. All implementations should embed UnimplementedCommandServer for forward compatibility

type Connection 

type Connection struct {
	Id          string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Uid         string                 `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	Name        string                 `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Description string                 `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Avatar      string                 `protobuf:"bytes,5,opt,name=avatar,proto3" json:"avatar,omitempty"`
	ExpiryTime  *durationpb.Duration   `protobuf:"bytes,6,opt,name=expiry_time,json=expiryTime,proto3" json:"expiry_time,omitempty"`
	LastRefresh *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_refresh,json=lastRefresh,proto3" json:"last_refresh,omitempty"`
	Data        *structpb.Struct       `protobuf:"bytes,8,opt,name=data,proto3" json:"data,omitempty"`
	Labels      *structpb.Struct       `protobuf:"bytes,9,opt,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

Connection represents a connection to a authenticate backend target.

func (*Connection) Descriptor deprecated 

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

Deprecated: Use Connection.ProtoReflect.Descriptor instead.

func (*Connection) GetAvatar 

func (x *Connection) GetAvatar() string

func (*Connection) GetData 

func (x *Connection) GetData() *structpb.Struct

func (*Connection) GetDescription 

func (x *Connection) GetDescription() string

func (*Connection) GetExpiryTime 

func (x *Connection) GetExpiryTime() *durationpb.Duration

func (*Connection) GetId 

func (x *Connection) GetId() string

func (*Connection) GetLabels 

func (x *Connection) GetLabels() *structpb.Struct

func (*Connection) GetLastRefresh 

func (x *Connection) GetLastRefresh() *timestamppb.Timestamp

func (*Connection) GetName 

func (x *Connection) GetName() string

func (*Connection) GetUid 

func (x *Connection) GetUid() string

func (*Connection) ProtoMessage 

func (*Connection) ProtoMessage()

func (*Connection) ProtoReflect 

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

func (*Connection) Reset 

func (x *Connection) Reset()

func (*Connection) String 

func (x *Connection) String() string

type ConnectionList 

type ConnectionList struct {
	Connections []*Connection `protobuf:"bytes,1,rep,name=connections,proto3" json:"connections,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionList) Descriptor deprecated 

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

Deprecated: Use ConnectionList.ProtoReflect.Descriptor instead.

func (*ConnectionList) GetConnections 

func (x *ConnectionList) GetConnections() []*Connection

func (*ConnectionList) ProtoMessage 

func (*ConnectionList) ProtoMessage()

func (*ConnectionList) ProtoReflect 

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

func (*ConnectionList) Reset 

func (x *ConnectionList) Reset()

func (*ConnectionList) String 

func (x *ConnectionList) String() string

type ConnectionNamespacesResponse 

type ConnectionNamespacesResponse struct {
	Namespaces []string `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionNamespacesResponse) Descriptor deprecated 

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

Deprecated: Use ConnectionNamespacesResponse.ProtoReflect.Descriptor instead.

func (*ConnectionNamespacesResponse) GetNamespaces 

func (x *ConnectionNamespacesResponse) GetNamespaces() []string

func (*ConnectionNamespacesResponse) ProtoMessage 

func (*ConnectionNamespacesResponse) ProtoMessage()

func (*ConnectionNamespacesResponse) ProtoReflect 

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

func (*ConnectionNamespacesResponse) Reset 

func (x *ConnectionNamespacesResponse) Reset()

func (*ConnectionNamespacesResponse) String 

func (x *ConnectionNamespacesResponse) String() string

type ConnectionRequest 

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

func (*ConnectionRequest) Descriptor deprecated 

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

Deprecated: Use ConnectionRequest.ProtoReflect.Descriptor instead.

func (*ConnectionRequest) GetId 

func (x *ConnectionRequest) GetId() string

func (*ConnectionRequest) ProtoMessage 

func (*ConnectionRequest) ProtoMessage()

func (*ConnectionRequest) ProtoReflect 

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

func (*ConnectionRequest) Reset 

func (x *ConnectionRequest) Reset()

func (*ConnectionRequest) String 

func (x *ConnectionRequest) String() string

type ConnectionStatus 

type ConnectionStatus struct {
	Connection *Connection             `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"`
	Status     ConnectionStatus_Status `protobuf:"varint,2,opt,name=status,proto3,enum=com.omniview.pluginsdk.ConnectionStatus_Status" json:"status,omitempty"`
	Error      string                  `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Details    string                  `protobuf:"bytes,4,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionStatus) Descriptor deprecated 

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

Deprecated: Use ConnectionStatus.ProtoReflect.Descriptor instead.

func (*ConnectionStatus) GetConnection 

func (x *ConnectionStatus) GetConnection() *Connection

func (*ConnectionStatus) GetDetails 

func (x *ConnectionStatus) GetDetails() string

func (*ConnectionStatus) GetError 

func (x *ConnectionStatus) GetError() string

func (*ConnectionStatus) GetStatus 

func (x *ConnectionStatus) GetStatus() ConnectionStatus_Status

func (*ConnectionStatus) ProtoMessage 

func (*ConnectionStatus) ProtoMessage()

func (*ConnectionStatus) ProtoReflect 

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

func (*ConnectionStatus) Reset 

func (x *ConnectionStatus) Reset()

func (*ConnectionStatus) String 

func (x *ConnectionStatus) String() string

type ConnectionStatus_Status 

type ConnectionStatus_Status int32
const (
	ConnectionStatus_UNKNOWN                  ConnectionStatus_Status = 0
	ConnectionStatus_CONNECTED                ConnectionStatus_Status = 1
	ConnectionStatus_DISCONNECTED             ConnectionStatus_Status = 2
	ConnectionStatus_PENDING                  ConnectionStatus_Status = 3
	ConnectionStatus_FAILED                   ConnectionStatus_Status = 4
	ConnectionStatus_ERROR                    ConnectionStatus_Status = 5
	ConnectionStatus_UNAUTHORIZED             ConnectionStatus_Status = 6
	ConnectionStatus_FORBIDDEN                ConnectionStatus_Status = 7
	ConnectionStatus_BAD_REQUEST              ConnectionStatus_Status = 8
	ConnectionStatus_NOT_FOUND                ConnectionStatus_Status = 9
	ConnectionStatus_TIMEOUT                  ConnectionStatus_Status = 10
	ConnectionStatus_UNAVAILABLE              ConnectionStatus_Status = 11
	ConnectionStatus_REQUEST_ENTITY_TOO_LARGE ConnectionStatus_Status = 12
)

func (ConnectionStatus_Status) Descriptor 

func (ConnectionStatus_Status) Descriptor() protoreflect.EnumDescriptor

func (ConnectionStatus_Status) Enum 

func (x ConnectionStatus_Status) Enum() *ConnectionStatus_Status

func (ConnectionStatus_Status) EnumDescriptor deprecated 

func (ConnectionStatus_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use ConnectionStatus_Status.Descriptor instead.

func (ConnectionStatus_Status) Number 

func (x ConnectionStatus_Status) Number() protoreflect.EnumNumber

func (ConnectionStatus_Status) String 

func (x ConnectionStatus_Status) String() string

func (ConnectionStatus_Status) Type 

func (ConnectionStatus_Status) Type() protoreflect.EnumType

type CreateLogSessionRequest 

type CreateLogSessionRequest struct {
	ResourceKey  string             `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ResourceId   string             `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	ResourceData *structpb.Struct   `protobuf:"bytes,3,opt,name=resource_data,json=resourceData,proto3" json:"resource_data,omitempty"`
	Options      *LogSessionOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateLogSessionRequest) Descriptor deprecated 

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

Deprecated: Use CreateLogSessionRequest.ProtoReflect.Descriptor instead.

func (*CreateLogSessionRequest) GetOptions 

func (x *CreateLogSessionRequest) GetOptions() *LogSessionOptions

func (*CreateLogSessionRequest) GetResourceData 

func (x *CreateLogSessionRequest) GetResourceData() *structpb.Struct

func (*CreateLogSessionRequest) GetResourceId 

func (x *CreateLogSessionRequest) GetResourceId() string

func (*CreateLogSessionRequest) GetResourceKey 

func (x *CreateLogSessionRequest) GetResourceKey() string

func (*CreateLogSessionRequest) ProtoMessage 

func (*CreateLogSessionRequest) ProtoMessage()

func (*CreateLogSessionRequest) ProtoReflect 

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

func (*CreateLogSessionRequest) Reset 

func (x *CreateLogSessionRequest) Reset()

func (*CreateLogSessionRequest) String 

func (x *CreateLogSessionRequest) String() string

type CreateLogSessionResponse 

type CreateLogSessionResponse struct {
	Session *LogSession `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Success bool        `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Error   string      `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateLogSessionResponse) Descriptor deprecated 

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

Deprecated: Use CreateLogSessionResponse.ProtoReflect.Descriptor instead.

func (*CreateLogSessionResponse) GetError 

func (x *CreateLogSessionResponse) GetError() string

func (*CreateLogSessionResponse) GetSession 

func (x *CreateLogSessionResponse) GetSession() *LogSession

func (*CreateLogSessionResponse) GetSuccess 

func (x *CreateLogSessionResponse) GetSuccess() bool

func (*CreateLogSessionResponse) ProtoMessage 

func (*CreateLogSessionResponse) ProtoMessage()

func (*CreateLogSessionResponse) ProtoReflect 

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

func (*CreateLogSessionResponse) Reset 

func (x *CreateLogSessionResponse) Reset()

func (*CreateLogSessionResponse) String 

func (x *CreateLogSessionResponse) String() string

type CreateRequest 

type CreateRequest struct {
	Key       string           `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Context   string           `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"`
	Id        string           `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Namespace string           `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Data      *structpb.Struct `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRequest) Descriptor deprecated 

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetContext 

func (x *CreateRequest) GetContext() string

func (*CreateRequest) GetData 

func (x *CreateRequest) GetData() *structpb.Struct

func (*CreateRequest) GetId 

func (x *CreateRequest) GetId() string

func (*CreateRequest) GetKey 

func (x *CreateRequest) GetKey() string

func (*CreateRequest) GetNamespace 

func (x *CreateRequest) GetNamespace() string

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect 

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

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) String 

func (x *CreateRequest) String() string

type CreateResponse 

type CreateResponse struct {
	Success bool             `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Data    *structpb.Struct `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Error   *ResourceError   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateResponse) Descriptor deprecated 

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) GetData 

func (x *CreateResponse) GetData() *structpb.Struct

func (*CreateResponse) GetError 

func (x *CreateResponse) GetError() *ResourceError

func (*CreateResponse) GetSuccess 

func (x *CreateResponse) GetSuccess() bool

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect 

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

func (*CreateResponse) Reset 

func (x *CreateResponse) Reset()

func (*CreateResponse) String 

func (x *CreateResponse) String() string

type CreateSessionRequest 

type CreateSessionRequest struct {
	Id      string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Command string            `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	Tty     bool              `protobuf:"varint,3,opt,name=tty,proto3" json:"tty,omitempty"`
	Params  map[string]string `` /* 139-byte string literal not displayed */
	Labels  map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateSessionRequest) Descriptor deprecated 

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

Deprecated: Use CreateSessionRequest.ProtoReflect.Descriptor instead.

func (*CreateSessionRequest) GetCommand 

func (x *CreateSessionRequest) GetCommand() string

func (*CreateSessionRequest) GetId 

func (x *CreateSessionRequest) GetId() string

func (*CreateSessionRequest) GetLabels 

func (x *CreateSessionRequest) GetLabels() map[string]string

func (*CreateSessionRequest) GetParams 

func (x *CreateSessionRequest) GetParams() map[string]string

func (*CreateSessionRequest) GetTty 

func (x *CreateSessionRequest) GetTty() bool

func (*CreateSessionRequest) ProtoMessage 

func (*CreateSessionRequest) ProtoMessage()

func (*CreateSessionRequest) ProtoReflect 

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

func (*CreateSessionRequest) Reset 

func (x *CreateSessionRequest) Reset()

func (*CreateSessionRequest) String 

func (x *CreateSessionRequest) String() string

type CreateSessionResponse 

type CreateSessionResponse struct {
	Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Success bool     `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Error   string   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSessionResponse) Descriptor deprecated 

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

Deprecated: Use CreateSessionResponse.ProtoReflect.Descriptor instead.

func (*CreateSessionResponse) GetError 

func (x *CreateSessionResponse) GetError() string

func (*CreateSessionResponse) GetSession 

func (x *CreateSessionResponse) GetSession() *Session

func (*CreateSessionResponse) GetSuccess 

func (x *CreateSessionResponse) GetSuccess() bool

func (*CreateSessionResponse) ProtoMessage 

func (*CreateSessionResponse) ProtoMessage()

func (*CreateSessionResponse) ProtoReflect 

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

func (*CreateSessionResponse) Reset 

func (x *CreateSessionResponse) Reset()

func (*CreateSessionResponse) String 

func (x *CreateSessionResponse) String() string

type CurrentValue 

type CurrentValue struct {
	MetricId  string                 `protobuf:"bytes,1,opt,name=metric_id,json=metricId,proto3" json:"metric_id,omitempty"`
	Value     float64                `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Labels    map[string]string      `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CurrentValue) Descriptor deprecated 

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

Deprecated: Use CurrentValue.ProtoReflect.Descriptor instead.

func (*CurrentValue) GetLabels 

func (x *CurrentValue) GetLabels() map[string]string

func (*CurrentValue) GetMetricId 

func (x *CurrentValue) GetMetricId() string

func (*CurrentValue) GetTimestamp 

func (x *CurrentValue) GetTimestamp() *timestamppb.Timestamp

func (*CurrentValue) GetValue 

func (x *CurrentValue) GetValue() float64

func (*CurrentValue) ProtoMessage 

func (*CurrentValue) ProtoMessage()

func (*CurrentValue) ProtoReflect 

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

func (*CurrentValue) Reset 

func (x *CurrentValue) Reset()

func (*CurrentValue) String 

func (x *CurrentValue) String() string

type DataPoint 

type DataPoint struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     float64                `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
	Labels    map[string]string      `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DataPoint) Descriptor deprecated 

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

Deprecated: Use DataPoint.ProtoReflect.Descriptor instead.

func (*DataPoint) GetLabels 

func (x *DataPoint) GetLabels() map[string]string

func (*DataPoint) GetTimestamp 

func (x *DataPoint) GetTimestamp() *timestamppb.Timestamp

func (*DataPoint) GetValue 

func (x *DataPoint) GetValue() float64

func (*DataPoint) ProtoMessage 

func (*DataPoint) ProtoMessage()

func (*DataPoint) ProtoReflect 

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

func (*DataPoint) Reset 

func (x *DataPoint) Reset()

func (*DataPoint) String 

func (x *DataPoint) String() string

type DeleteRequest 

type DeleteRequest struct {
	Key       string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Context   string `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"`
	Id        string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetContext 

func (x *DeleteRequest) GetContext() string

func (*DeleteRequest) GetId 

func (x *DeleteRequest) GetId() string

func (*DeleteRequest) GetKey 

func (x *DeleteRequest) GetKey() string

func (*DeleteRequest) GetNamespace 

func (x *DeleteRequest) GetNamespace() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

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

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	Success bool             `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Data    *structpb.Struct `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Error   *ResourceError   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetData 

func (x *DeleteResponse) GetData() *structpb.Struct

func (*DeleteResponse) GetError 

func (x *DeleteResponse) GetError() *ResourceError

func (*DeleteResponse) GetSuccess 

func (x *DeleteResponse) GetSuccess() bool

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

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

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type EditorSchema 

type EditorSchema struct {
	ResourceKey string `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"` // e.g., "core::v1::Pod", "helm::release::myapp"
	FileMatch   string `protobuf:"bytes,2,opt,name=file_match,json=fileMatch,proto3" json:"file_match,omitempty"`       // glob pattern for Monaco (e.g., "**/core::v1::Pod/*.yaml")
	Uri         string `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"`                                    // schema identifier URI
	Url         string `protobuf:"bytes,4,opt,name=url,proto3" json:"url,omitempty"`                                    // optional: fetch schema from URL
	Content     []byte `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`                            // optional: inline JSON schema content
	Language    string `protobuf:"bytes,6,opt,name=language,proto3" json:"language,omitempty"`                          // "yaml" or "json"
	// contains filtered or unexported fields
}

func (*EditorSchema) Descriptor deprecated 

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

Deprecated: Use EditorSchema.ProtoReflect.Descriptor instead.

func (*EditorSchema) GetContent 

func (x *EditorSchema) GetContent() []byte

func (*EditorSchema) GetFileMatch 

func (x *EditorSchema) GetFileMatch() string

func (*EditorSchema) GetLanguage 

func (x *EditorSchema) GetLanguage() string

func (*EditorSchema) GetResourceKey 

func (x *EditorSchema) GetResourceKey() string

func (*EditorSchema) GetUri 

func (x *EditorSchema) GetUri() string

func (*EditorSchema) GetUrl 

func (x *EditorSchema) GetUrl() string

func (*EditorSchema) ProtoMessage 

func (*EditorSchema) ProtoMessage()

func (*EditorSchema) ProtoReflect 

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

func (*EditorSchema) Reset 

func (x *EditorSchema) Reset()

func (*EditorSchema) String 

func (x *EditorSchema) String() string

type EditorSchemaList 

type EditorSchemaList struct {
	Schemas []*EditorSchema `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"`
	// contains filtered or unexported fields
}

func (*EditorSchemaList) Descriptor deprecated 

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

Deprecated: Use EditorSchemaList.ProtoReflect.Descriptor instead.

func (*EditorSchemaList) GetSchemas 

func (x *EditorSchemaList) GetSchemas() []*EditorSchema

func (*EditorSchemaList) ProtoMessage 

func (*EditorSchemaList) ProtoMessage()

func (*EditorSchemaList) ProtoReflect 

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

func (*EditorSchemaList) Reset 

func (x *EditorSchemaList) Reset()

func (*EditorSchemaList) String 

func (x *EditorSchemaList) String() string

type EnsureInformerRequest 

type EnsureInformerRequest struct {
	Connection  string `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"`
	ResourceKey string `protobuf:"bytes,2,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	// contains filtered or unexported fields
}

func (*EnsureInformerRequest) Descriptor deprecated 

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

Deprecated: Use EnsureInformerRequest.ProtoReflect.Descriptor instead.

func (*EnsureInformerRequest) GetConnection 

func (x *EnsureInformerRequest) GetConnection() string

func (*EnsureInformerRequest) GetResourceKey 

func (x *EnsureInformerRequest) GetResourceKey() string

func (*EnsureInformerRequest) ProtoMessage 

func (*EnsureInformerRequest) ProtoMessage()

func (*EnsureInformerRequest) ProtoReflect 

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

func (*EnsureInformerRequest) Reset 

func (x *EnsureInformerRequest) Reset()

func (*EnsureInformerRequest) String 

func (x *EnsureInformerRequest) String() string

type ExecHandler 

type ExecHandler struct {
	Plugin         string                       `protobuf:"bytes,1,opt,name=plugin,proto3" json:"plugin,omitempty"`
	Resource       string                       `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
	TargetBuilder  *ResourceActionTargetBuilder `protobuf:"bytes,3,opt,name=target_builder,json=targetBuilder,proto3" json:"target_builder,omitempty"`
	DefaultCommand []string                     `protobuf:"bytes,4,rep,name=default_command,json=defaultCommand,proto3" json:"default_command,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecHandler) Descriptor deprecated 

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

Deprecated: Use ExecHandler.ProtoReflect.Descriptor instead.

func (*ExecHandler) GetDefaultCommand 

func (x *ExecHandler) GetDefaultCommand() []string

func (*ExecHandler) GetPlugin 

func (x *ExecHandler) GetPlugin() string

func (*ExecHandler) GetResource 

func (x *ExecHandler) GetResource() string

func (*ExecHandler) GetTargetBuilder 

func (x *ExecHandler) GetTargetBuilder() *ResourceActionTargetBuilder

func (*ExecHandler) ProtoMessage 

func (*ExecHandler) ProtoMessage()

func (*ExecHandler) ProtoReflect 

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

func (*ExecHandler) Reset 

func (x *ExecHandler) Reset()

func (*ExecHandler) String 

func (x *ExecHandler) String() string

type ExecPluginClient 

type ExecPluginClient interface {
	GetSupportedResources(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetSupportedResourcesResponse, error)
	GetSession(ctx context.Context, in *GetSessionRequest, opts ...grpc.CallOption) (*GetSessionResponse, error)
	ListSessions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListSessionsResponse, error)
	CreateSession(ctx context.Context, in *SessionOptions, opts ...grpc.CallOption) (*CreateSessionResponse, error)
	AttachSession(ctx context.Context, in *AttachSessionRequest, opts ...grpc.CallOption) (*AttachSessionResponse, error)
	DetachSession(ctx context.Context, in *AttachSessionRequest, opts ...grpc.CallOption) (*AttachSessionResponse, error)
	CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)
	ResizeSession(ctx context.Context, in *ResizeSessionRequest, opts ...grpc.CallOption) (*ResizeSessionResponse, error)
	// Multiplexed stream for input and output
	Stream(ctx context.Context, opts ...grpc.CallOption) (ExecPlugin_StreamClient, error)
}

ExecPluginClient is the client API for ExecPlugin 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 NewExecPluginClient 

func NewExecPluginClient(cc grpc.ClientConnInterface) ExecPluginClient

type ExecPluginServer 

type ExecPluginServer interface {
	GetSupportedResources(context.Context, *emptypb.Empty) (*GetSupportedResourcesResponse, error)
	GetSession(context.Context, *GetSessionRequest) (*GetSessionResponse, error)
	ListSessions(context.Context, *emptypb.Empty) (*ListSessionsResponse, error)
	CreateSession(context.Context, *SessionOptions) (*CreateSessionResponse, error)
	AttachSession(context.Context, *AttachSessionRequest) (*AttachSessionResponse, error)
	DetachSession(context.Context, *AttachSessionRequest) (*AttachSessionResponse, error)
	CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
	ResizeSession(context.Context, *ResizeSessionRequest) (*ResizeSessionResponse, error)
	// Multiplexed stream for input and output
	Stream(ExecPlugin_StreamServer) error
}

ExecPluginServer is the server API for ExecPlugin service. All implementations should embed UnimplementedExecPluginServer for forward compatibility

type ExecPlugin_StreamClient 

type ExecPlugin_StreamClient interface {
	Send(*StreamInput) error
	Recv() (*StreamOutput, error)
	grpc.ClientStream
}

type ExecPlugin_StreamServer 

type ExecPlugin_StreamServer interface {
	Send(*StreamOutput) error
	Recv() (*StreamInput, error)
	grpc.ServerStream
}

type ExecuteActionRequest 

type ExecuteActionRequest struct {
	Key       string           `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`                           // Resource type key
	Context   string           `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"`                   // Connection ID
	ActionId  string           `protobuf:"bytes,3,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"` // Action identifier
	Id        string           `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`                             // Resource ID (for INSTANCE scope)
	Namespace string           `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"`               // Resource namespace
	Params    *structpb.Struct `protobuf:"bytes,6,opt,name=params,proto3" json:"params,omitempty"`                     // Action-specific parameters
	// contains filtered or unexported fields
}

func (*ExecuteActionRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteActionRequest.ProtoReflect.Descriptor instead.

func (*ExecuteActionRequest) GetActionId 

func (x *ExecuteActionRequest) GetActionId() string

func (*ExecuteActionRequest) GetContext 

func (x *ExecuteActionRequest) GetContext() string

func (*ExecuteActionRequest) GetId 

func (x *ExecuteActionRequest) GetId() string

func (*ExecuteActionRequest) GetKey 

func (x *ExecuteActionRequest) GetKey() string

func (*ExecuteActionRequest) GetNamespace 

func (x *ExecuteActionRequest) GetNamespace() string

func (*ExecuteActionRequest) GetParams 

func (x *ExecuteActionRequest) GetParams() *structpb.Struct

func (*ExecuteActionRequest) ProtoMessage 

func (*ExecuteActionRequest) ProtoMessage()

func (*ExecuteActionRequest) ProtoReflect 

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

func (*ExecuteActionRequest) Reset 

func (x *ExecuteActionRequest) Reset()

func (*ExecuteActionRequest) String 

func (x *ExecuteActionRequest) String() string

type ExecuteActionResponse 

type ExecuteActionResponse struct {
	Success bool             `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Data    *structpb.Struct `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`       // Action result
	Message string           `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` // Human-readable message
	// contains filtered or unexported fields
}

func (*ExecuteActionResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteActionResponse.ProtoReflect.Descriptor instead.

func (*ExecuteActionResponse) GetData 

func (x *ExecuteActionResponse) GetData() *structpb.Struct

func (*ExecuteActionResponse) GetMessage 

func (x *ExecuteActionResponse) GetMessage() string

func (*ExecuteActionResponse) GetSuccess 

func (x *ExecuteActionResponse) GetSuccess() bool

func (*ExecuteActionResponse) ProtoMessage 

func (*ExecuteActionResponse) ProtoMessage()

func (*ExecuteActionResponse) ProtoReflect 

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

func (*ExecuteActionResponse) Reset 

func (x *ExecuteActionResponse) Reset()

func (*ExecuteActionResponse) String 

func (x *ExecuteActionResponse) String() string

type FindPortForwardSessionRequest 

type FindPortForwardSessionRequest struct {
	ResourceId   string `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	ConnectionId string `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FindPortForwardSessionRequest) Descriptor deprecated 

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

Deprecated: Use FindPortForwardSessionRequest.ProtoReflect.Descriptor instead.

func (*FindPortForwardSessionRequest) GetConnectionId 

func (x *FindPortForwardSessionRequest) GetConnectionId() string

func (*FindPortForwardSessionRequest) GetResourceId 

func (x *FindPortForwardSessionRequest) GetResourceId() string

func (*FindPortForwardSessionRequest) ProtoMessage 

func (*FindPortForwardSessionRequest) ProtoMessage()

func (*FindPortForwardSessionRequest) ProtoReflect 

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

func (*FindPortForwardSessionRequest) Reset 

func (x *FindPortForwardSessionRequest) Reset()

func (*FindPortForwardSessionRequest) String 

func (x *FindPortForwardSessionRequest) String() string

type FindRequest 

type FindRequest struct {
	Key        string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Context    string   `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"`
	Namespaces []string `protobuf:"bytes,3,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

func (*FindRequest) Descriptor deprecated 

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

Deprecated: Use FindRequest.ProtoReflect.Descriptor instead.

func (*FindRequest) GetContext 

func (x *FindRequest) GetContext() string

func (*FindRequest) GetKey 

func (x *FindRequest) GetKey() string

func (*FindRequest) GetNamespaces 

func (x *FindRequest) GetNamespaces() []string

func (*FindRequest) ProtoMessage 

func (*FindRequest) ProtoMessage()

func (*FindRequest) ProtoReflect 

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

func (*FindRequest) Reset 

func (x *FindRequest) Reset()

func (*FindRequest) String 

func (x *FindRequest) String() string

type FindResponse 

type FindResponse struct {
	Success bool               `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Data    []*structpb.Struct `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	Error   *ResourceError     `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*FindResponse) Descriptor deprecated 

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

Deprecated: Use FindResponse.ProtoReflect.Descriptor instead.

func (*FindResponse) GetData 

func (x *FindResponse) GetData() []*structpb.Struct

func (*FindResponse) GetError 

func (x *FindResponse) GetError() *ResourceError

func (*FindResponse) GetSuccess 

func (x *FindResponse) GetSuccess() bool

func (*FindResponse) ProtoMessage 

func (*FindResponse) ProtoMessage()

func (*FindResponse) ProtoReflect 

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

func (*FindResponse) Reset 

func (x *FindResponse) Reset()

func (*FindResponse) String 

func (x *FindResponse) String() string

type GetActionsRequest 

type GetActionsRequest struct {
	Key     string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`         // Resource type key (e.g., "helm::v1::Release")
	Context string `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"` // Connection ID
	// contains filtered or unexported fields
}

func (*GetActionsRequest) Descriptor deprecated 

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

Deprecated: Use GetActionsRequest.ProtoReflect.Descriptor instead.

func (*GetActionsRequest) GetContext 

func (x *GetActionsRequest) GetContext() string

func (*GetActionsRequest) GetKey 

func (x *GetActionsRequest) GetKey() string

func (*GetActionsRequest) ProtoMessage 

func (*GetActionsRequest) ProtoMessage()

func (*GetActionsRequest) ProtoReflect 

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

func (*GetActionsRequest) Reset 

func (x *GetActionsRequest) Reset()

func (*GetActionsRequest) String 

func (x *GetActionsRequest) String() string

type GetActionsResponse 

type GetActionsResponse struct {
	Actions []*ActionDescriptor `protobuf:"bytes,1,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetActionsResponse) Descriptor deprecated 

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

Deprecated: Use GetActionsResponse.ProtoReflect.Descriptor instead.

func (*GetActionsResponse) GetActions 

func (x *GetActionsResponse) GetActions() []*ActionDescriptor

func (*GetActionsResponse) ProtoMessage 

func (*GetActionsResponse) ProtoMessage()

func (*GetActionsResponse) ProtoReflect 

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

func (*GetActionsResponse) Reset 

func (x *GetActionsResponse) Reset()

func (*GetActionsResponse) String 

func (x *GetActionsResponse) String() string

type GetCapabilitiesResponse added in v0.1.1 

type GetCapabilitiesResponse struct {
	Capabilities []string `protobuf:"bytes,1,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCapabilitiesResponse) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use GetCapabilitiesResponse.ProtoReflect.Descriptor instead.

func (*GetCapabilitiesResponse) GetCapabilities added in v0.1.1 

func (x *GetCapabilitiesResponse) GetCapabilities() []string

func (*GetCapabilitiesResponse) ProtoMessage added in v0.1.1 

func (*GetCapabilitiesResponse) ProtoMessage()

func (*GetCapabilitiesResponse) ProtoReflect added in v0.1.1 

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

func (*GetCapabilitiesResponse) Reset added in v0.1.1 

func (x *GetCapabilitiesResponse) Reset()

func (*GetCapabilitiesResponse) String added in v0.1.1 

func (x *GetCapabilitiesResponse) String() string

type GetEditorSchemasRequest 

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

func (*GetEditorSchemasRequest) Descriptor deprecated 

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

Deprecated: Use GetEditorSchemasRequest.ProtoReflect.Descriptor instead.

func (*GetEditorSchemasRequest) GetConnectionId 

func (x *GetEditorSchemasRequest) GetConnectionId() string

func (*GetEditorSchemasRequest) ProtoMessage 

func (*GetEditorSchemasRequest) ProtoMessage()

func (*GetEditorSchemasRequest) ProtoReflect 

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

func (*GetEditorSchemasRequest) Reset 

func (x *GetEditorSchemasRequest) Reset()

func (*GetEditorSchemasRequest) String 

func (x *GetEditorSchemasRequest) String() string

type GetInfoResponse added in v0.1.1 

type GetInfoResponse struct {
	PluginId           string `protobuf:"bytes,1,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"`
	Version            string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	SdkProtocolVersion int32  `protobuf:"varint,3,opt,name=sdk_protocol_version,json=sdkProtocolVersion,proto3" json:"sdk_protocol_version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInfoResponse) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use GetInfoResponse.ProtoReflect.Descriptor instead.

func (*GetInfoResponse) GetPluginId added in v0.1.1 

func (x *GetInfoResponse) GetPluginId() string

func (*GetInfoResponse) GetSdkProtocolVersion added in v0.1.1 

func (x *GetInfoResponse) GetSdkProtocolVersion() int32

func (*GetInfoResponse) GetVersion added in v0.1.1 

func (x *GetInfoResponse) GetVersion() string

func (*GetInfoResponse) ProtoMessage added in v0.1.1 

func (*GetInfoResponse) ProtoMessage()

func (*GetInfoResponse) ProtoReflect added in v0.1.1 

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

func (*GetInfoResponse) Reset added in v0.1.1 

func (x *GetInfoResponse) Reset()

func (*GetInfoResponse) String added in v0.1.1 

func (x *GetInfoResponse) String() string

type GetInformerStateRequest 

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

func (*GetInformerStateRequest) Descriptor deprecated 

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

Deprecated: Use GetInformerStateRequest.ProtoReflect.Descriptor instead.

func (*GetInformerStateRequest) GetConnection 

func (x *GetInformerStateRequest) GetConnection() string

func (*GetInformerStateRequest) ProtoMessage 

func (*GetInformerStateRequest) ProtoMessage()

func (*GetInformerStateRequest) ProtoReflect 

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

func (*GetInformerStateRequest) Reset 

func (x *GetInformerStateRequest) Reset()

func (*GetInformerStateRequest) String 

func (x *GetInformerStateRequest) String() string

type GetLayoutRequest 

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

func (*GetLayoutRequest) Descriptor deprecated 

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

Deprecated: Use GetLayoutRequest.ProtoReflect.Descriptor instead.

func (*GetLayoutRequest) GetId 

func (x *GetLayoutRequest) GetId() string

func (*GetLayoutRequest) ProtoMessage 

func (*GetLayoutRequest) ProtoMessage()

func (*GetLayoutRequest) ProtoReflect 

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

func (*GetLayoutRequest) Reset 

func (x *GetLayoutRequest) Reset()

func (*GetLayoutRequest) String 

func (x *GetLayoutRequest) String() string

type GetRequest 

type GetRequest struct {
	Key       string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Context   string `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"`
	Id        string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetContext 

func (x *GetRequest) GetContext() string

func (*GetRequest) GetId 

func (x *GetRequest) GetId() string

func (*GetRequest) GetKey 

func (x *GetRequest) GetKey() string

func (*GetRequest) GetNamespace 

func (x *GetRequest) GetNamespace() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Success bool             `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Data    *structpb.Struct `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Error   *ResourceError   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetData 

func (x *GetResponse) GetData() *structpb.Struct

func (*GetResponse) GetError 

func (x *GetResponse) GetError() *ResourceError

func (*GetResponse) GetSuccess 

func (x *GetResponse) GetSuccess() bool

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

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

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type GetSessionRequest 

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

func (*GetSessionRequest) Descriptor deprecated 

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

Deprecated: Use GetSessionRequest.ProtoReflect.Descriptor instead.

func (*GetSessionRequest) GetId 

func (x *GetSessionRequest) GetId() string

func (*GetSessionRequest) ProtoMessage 

func (*GetSessionRequest) ProtoMessage()

func (*GetSessionRequest) ProtoReflect 

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

func (*GetSessionRequest) Reset 

func (x *GetSessionRequest) Reset()

func (*GetSessionRequest) String 

func (x *GetSessionRequest) String() string

type GetSessionResponse 

type GetSessionResponse struct {
	Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Success bool     `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Error   string   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSessionResponse) Descriptor deprecated 

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

Deprecated: Use GetSessionResponse.ProtoReflect.Descriptor instead.

func (*GetSessionResponse) GetError 

func (x *GetSessionResponse) GetError() string

func (*GetSessionResponse) GetSession 

func (x *GetSessionResponse) GetSession() *Session

func (*GetSessionResponse) GetSuccess 

func (x *GetSessionResponse) GetSuccess() bool

func (*GetSessionResponse) ProtoMessage 

func (*GetSessionResponse) ProtoMessage()

func (*GetSessionResponse) ProtoReflect 

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

func (*GetSessionResponse) Reset 

func (x *GetSessionResponse) Reset()

func (*GetSessionResponse) String 

func (x *GetSessionResponse) String() string

type GetSettingRequest 

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

func (*GetSettingRequest) Descriptor deprecated 

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

Deprecated: Use GetSettingRequest.ProtoReflect.Descriptor instead.

func (*GetSettingRequest) GetId 

func (x *GetSettingRequest) GetId() string

func (*GetSettingRequest) ProtoMessage 

func (*GetSettingRequest) ProtoMessage()

func (*GetSettingRequest) ProtoReflect 

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

func (*GetSettingRequest) Reset 

func (x *GetSettingRequest) Reset()

func (*GetSettingRequest) String 

func (x *GetSettingRequest) String() string

type GetSettingValueRequest 

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

func (*GetSettingValueRequest) Descriptor deprecated 

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

Deprecated: Use GetSettingValueRequest.ProtoReflect.Descriptor instead.

func (*GetSettingValueRequest) GetId 

func (x *GetSettingValueRequest) GetId() string

func (*GetSettingValueRequest) ProtoMessage 

func (*GetSettingValueRequest) ProtoMessage()

func (*GetSettingValueRequest) ProtoReflect 

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

func (*GetSettingValueRequest) Reset 

func (x *GetSettingValueRequest) Reset()

func (*GetSettingValueRequest) String 

func (x *GetSettingValueRequest) String() string

type GetSettingValueResponse 

type GetSettingValueResponse struct {
	Value *anypb.Any `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSettingValueResponse) Descriptor deprecated 

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

Deprecated: Use GetSettingValueResponse.ProtoReflect.Descriptor instead.

func (*GetSettingValueResponse) GetValue 

func (x *GetSettingValueResponse) GetValue() *anypb.Any

func (*GetSettingValueResponse) ProtoMessage 

func (*GetSettingValueResponse) ProtoMessage()

func (*GetSettingValueResponse) ProtoReflect 

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

func (*GetSettingValueResponse) Reset 

func (x *GetSettingValueResponse) Reset()

func (*GetSettingValueResponse) String 

func (x *GetSettingValueResponse) String() string

type GetSupportedLogResourcesResponse 

type GetSupportedLogResourcesResponse struct {
	Handlers []*LogHandler `protobuf:"bytes,1,rep,name=handlers,proto3" json:"handlers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSupportedLogResourcesResponse) Descriptor deprecated 

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

Deprecated: Use GetSupportedLogResourcesResponse.ProtoReflect.Descriptor instead.

func (*GetSupportedLogResourcesResponse) GetHandlers 

func (x *GetSupportedLogResourcesResponse) GetHandlers() []*LogHandler

func (*GetSupportedLogResourcesResponse) ProtoMessage 

func (*GetSupportedLogResourcesResponse) ProtoMessage()

func (*GetSupportedLogResourcesResponse) ProtoReflect 

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

func (*GetSupportedLogResourcesResponse) Reset 

func (x *GetSupportedLogResourcesResponse) Reset()

func (*GetSupportedLogResourcesResponse) String 

func (x *GetSupportedLogResourcesResponse) String() string

type GetSupportedMetricResourcesResponse 

type GetSupportedMetricResourcesResponse struct {
	Provider *MetricProviderInfo `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
	Handlers []*MetricHandler    `protobuf:"bytes,2,rep,name=handlers,proto3" json:"handlers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSupportedMetricResourcesResponse) Descriptor deprecated 

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

Deprecated: Use GetSupportedMetricResourcesResponse.ProtoReflect.Descriptor instead.

func (*GetSupportedMetricResourcesResponse) GetHandlers 

func (x *GetSupportedMetricResourcesResponse) GetHandlers() []*MetricHandler

func (*GetSupportedMetricResourcesResponse) GetProvider 

func (x *GetSupportedMetricResourcesResponse) GetProvider() *MetricProviderInfo

func (*GetSupportedMetricResourcesResponse) ProtoMessage 

func (*GetSupportedMetricResourcesResponse) ProtoMessage()

func (*GetSupportedMetricResourcesResponse) ProtoReflect 

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

func (*GetSupportedMetricResourcesResponse) Reset 

func (x *GetSupportedMetricResourcesResponse) Reset()

func (*GetSupportedMetricResourcesResponse) String 

func (x *GetSupportedMetricResourcesResponse) String() string

type GetSupportedPortForwardTargetsResponse 

type GetSupportedPortForwardTargetsResponse struct {
	Resources []string `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSupportedPortForwardTargetsResponse) Descriptor deprecated 

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

Deprecated: Use GetSupportedPortForwardTargetsResponse.ProtoReflect.Descriptor instead.

func (*GetSupportedPortForwardTargetsResponse) GetResources 

func (x *GetSupportedPortForwardTargetsResponse) GetResources() []string

func (*GetSupportedPortForwardTargetsResponse) ProtoMessage 

func (*GetSupportedPortForwardTargetsResponse) ProtoMessage()

func (*GetSupportedPortForwardTargetsResponse) ProtoReflect 

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

func (*GetSupportedPortForwardTargetsResponse) Reset 

func (x *GetSupportedPortForwardTargetsResponse) Reset()

func (*GetSupportedPortForwardTargetsResponse) String 

func (x *GetSupportedPortForwardTargetsResponse) String() string

type GetSupportedResourcesResponse 

type GetSupportedResourcesResponse struct {
	Handlers []*ExecHandler `protobuf:"bytes,1,rep,name=handlers,proto3" json:"handlers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSupportedResourcesResponse) Descriptor deprecated 

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

Deprecated: Use GetSupportedResourcesResponse.ProtoReflect.Descriptor instead.

func (*GetSupportedResourcesResponse) GetHandlers 

func (x *GetSupportedResourcesResponse) GetHandlers() []*ExecHandler

func (*GetSupportedResourcesResponse) ProtoMessage 

func (*GetSupportedResourcesResponse) ProtoMessage()

func (*GetSupportedResourcesResponse) ProtoReflect 

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

func (*GetSupportedResourcesResponse) Reset 

func (x *GetSupportedResourcesResponse) Reset()

func (*GetSupportedResourcesResponse) String 

func (x *GetSupportedResourcesResponse) String() string

type HasInformerRequest 

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

func (*HasInformerRequest) Descriptor deprecated 

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

Deprecated: Use HasInformerRequest.ProtoReflect.Descriptor instead.

func (*HasInformerRequest) GetConnection 

func (x *HasInformerRequest) GetConnection() string

func (*HasInformerRequest) ProtoMessage 

func (*HasInformerRequest) ProtoMessage()

func (*HasInformerRequest) ProtoReflect 

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

func (*HasInformerRequest) Reset 

func (x *HasInformerRequest) Reset()

func (*HasInformerRequest) String 

func (x *HasInformerRequest) String() string

type HealthCheckResponse added in v0.1.1 

type HealthCheckResponse struct {
	Status ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=com.omniview.pluginsdk.ServingStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckResponse) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.

func (*HealthCheckResponse) GetStatus added in v0.1.1 

func (x *HealthCheckResponse) GetStatus() ServingStatus

func (*HealthCheckResponse) ProtoMessage added in v0.1.1 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) ProtoReflect added in v0.1.1 

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

func (*HealthCheckResponse) Reset added in v0.1.1 

func (x *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String added in v0.1.1 

func (x *HealthCheckResponse) String() string

type InformerAddEvent 

type InformerAddEvent struct {
	Data *structpb.Struct `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*InformerAddEvent) Descriptor deprecated 

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

Deprecated: Use InformerAddEvent.ProtoReflect.Descriptor instead.

func (*InformerAddEvent) GetData 

func (x *InformerAddEvent) GetData() *structpb.Struct

func (*InformerAddEvent) ProtoMessage 

func (*InformerAddEvent) ProtoMessage()

func (*InformerAddEvent) ProtoReflect 

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

func (*InformerAddEvent) Reset 

func (x *InformerAddEvent) Reset()

func (*InformerAddEvent) String 

func (x *InformerAddEvent) String() string

type InformerConnectionSummary 

type InformerConnectionSummary struct {
	Connection     string                           `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"`
	Resources      map[string]InformerResourceState `` /* 196-byte string literal not displayed */
	ResourceCounts map[string]int32                 `` /* 178-byte string literal not displayed */
	TotalResources int32                            `protobuf:"varint,4,opt,name=total_resources,json=totalResources,proto3" json:"total_resources,omitempty"`
	SyncedCount    int32                            `protobuf:"varint,5,opt,name=synced_count,json=syncedCount,proto3" json:"synced_count,omitempty"`
	ErrorCount     int32                            `protobuf:"varint,6,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
	// contains filtered or unexported fields
}

InformerConnectionSummary provides an aggregate view of all informer states for a connection.

func (*InformerConnectionSummary) Descriptor deprecated 

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

Deprecated: Use InformerConnectionSummary.ProtoReflect.Descriptor instead.

func (*InformerConnectionSummary) GetConnection 

func (x *InformerConnectionSummary) GetConnection() string

func (*InformerConnectionSummary) GetErrorCount 

func (x *InformerConnectionSummary) GetErrorCount() int32

func (*InformerConnectionSummary) GetResourceCounts 

func (x *InformerConnectionSummary) GetResourceCounts() map[string]int32

func (*InformerConnectionSummary) GetResources 

func (x *InformerConnectionSummary) GetResources() map[string]InformerResourceState

func (*InformerConnectionSummary) GetSyncedCount 

func (x *InformerConnectionSummary) GetSyncedCount() int32

func (*InformerConnectionSummary) GetTotalResources 

func (x *InformerConnectionSummary) GetTotalResources() int32

func (*InformerConnectionSummary) ProtoMessage 

func (*InformerConnectionSummary) ProtoMessage()

func (*InformerConnectionSummary) ProtoReflect 

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

func (*InformerConnectionSummary) Reset 

func (x *InformerConnectionSummary) Reset()

func (*InformerConnectionSummary) String 

func (x *InformerConnectionSummary) String() string

type InformerDeleteEvent 

type InformerDeleteEvent struct {
	Data *structpb.Struct `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*InformerDeleteEvent) Descriptor deprecated 

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

Deprecated: Use InformerDeleteEvent.ProtoReflect.Descriptor instead.

func (*InformerDeleteEvent) GetData 

func (x *InformerDeleteEvent) GetData() *structpb.Struct

func (*InformerDeleteEvent) ProtoMessage 

func (*InformerDeleteEvent) ProtoMessage()

func (*InformerDeleteEvent) ProtoReflect 

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

func (*InformerDeleteEvent) Reset 

func (x *InformerDeleteEvent) Reset()

func (*InformerDeleteEvent) String 

func (x *InformerDeleteEvent) String() string

type InformerEvent 

type InformerEvent struct {
	Key        string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Connection string `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	Id         string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Namespace  string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Types that are valid to be assigned to Action:
	//
	//	*InformerEvent_Add
	//	*InformerEvent_Update
	//	*InformerEvent_Delete
	//	*InformerEvent_State
	Action isInformerEvent_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

func (*InformerEvent) Descriptor deprecated 

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

Deprecated: Use InformerEvent.ProtoReflect.Descriptor instead.

func (*InformerEvent) GetAction 

func (x *InformerEvent) GetAction() isInformerEvent_Action

func (*InformerEvent) GetAdd 

func (x *InformerEvent) GetAdd() *InformerAddEvent

func (*InformerEvent) GetConnection 

func (x *InformerEvent) GetConnection() string

func (*InformerEvent) GetDelete 

func (x *InformerEvent) GetDelete() *InformerDeleteEvent

func (*InformerEvent) GetId 

func (x *InformerEvent) GetId() string

func (*InformerEvent) GetKey 

func (x *InformerEvent) GetKey() string

func (*InformerEvent) GetNamespace 

func (x *InformerEvent) GetNamespace() string

func (*InformerEvent) GetState 

func (x *InformerEvent) GetState() *InformerStateEvent

func (*InformerEvent) GetUpdate 

func (x *InformerEvent) GetUpdate() *InformerUpdateEvent

func (*InformerEvent) ProtoMessage 

func (*InformerEvent) ProtoMessage()

func (*InformerEvent) ProtoReflect 

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

func (*InformerEvent) Reset 

func (x *InformerEvent) Reset()

func (*InformerEvent) String 

func (x *InformerEvent) String() string

type InformerEvent_Add 

type InformerEvent_Add struct {
	Add *InformerAddEvent `protobuf:"bytes,5,opt,name=add,proto3,oneof"`
}

type InformerEvent_Delete 

type InformerEvent_Delete struct {
	Delete *InformerDeleteEvent `protobuf:"bytes,7,opt,name=delete,proto3,oneof"`
}

type InformerEvent_State 

type InformerEvent_State struct {
	State *InformerStateEvent `protobuf:"bytes,8,opt,name=state,proto3,oneof"`
}

type InformerEvent_Update 

type InformerEvent_Update struct {
	Update *InformerUpdateEvent `protobuf:"bytes,6,opt,name=update,proto3,oneof"`
}

type InformerResourceState 

type InformerResourceState int32

Informer resource state represents the sync state of a single resource type's informer. 

const (
	InformerResourceState_INFORMER_PENDING   InformerResourceState = 0
	InformerResourceState_INFORMER_SYNCING   InformerResourceState = 1
	InformerResourceState_INFORMER_SYNCED    InformerResourceState = 2
	InformerResourceState_INFORMER_ERROR     InformerResourceState = 3
	InformerResourceState_INFORMER_CANCELLED InformerResourceState = 4
)

func (InformerResourceState) Descriptor 

func (InformerResourceState) Descriptor() protoreflect.EnumDescriptor

func (InformerResourceState) Enum 

func (x InformerResourceState) Enum() *InformerResourceState

func (InformerResourceState) EnumDescriptor deprecated 

func (InformerResourceState) EnumDescriptor() ([]byte, []int)

Deprecated: Use InformerResourceState.Descriptor instead.

func (InformerResourceState) Number 

func (x InformerResourceState) Number() protoreflect.EnumNumber

func (InformerResourceState) String 

func (x InformerResourceState) String() string

func (InformerResourceState) Type 

func (InformerResourceState) Type() protoreflect.EnumType

type InformerStateEvent 

type InformerStateEvent struct {
	Connection    string                `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"`
	ResourceKey   string                `protobuf:"bytes,2,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	State         InformerResourceState `protobuf:"varint,3,opt,name=state,proto3,enum=com.omniview.pluginsdk.InformerResourceState" json:"state,omitempty"`
	ResourceCount int32                 `protobuf:"varint,4,opt,name=resource_count,json=resourceCount,proto3" json:"resource_count,omitempty"`
	TotalCount    int32                 `protobuf:"varint,5,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"` // -1 if unknown
	Error         *ResourceError        `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`                              // from resource_common.proto
	// contains filtered or unexported fields
}

InformerStateEvent is emitted when a resource's informer state changes.

func (*InformerStateEvent) Descriptor deprecated 

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

Deprecated: Use InformerStateEvent.ProtoReflect.Descriptor instead.

func (*InformerStateEvent) GetConnection 

func (x *InformerStateEvent) GetConnection() string

func (*InformerStateEvent) GetError 

func (x *InformerStateEvent) GetError() *ResourceError

func (*InformerStateEvent) GetResourceCount 

func (x *InformerStateEvent) GetResourceCount() int32

func (*InformerStateEvent) GetResourceKey 

func (x *InformerStateEvent) GetResourceKey() string

func (*InformerStateEvent) GetState 

func (x *InformerStateEvent) GetState() InformerResourceState

func (*InformerStateEvent) GetTotalCount 

func (x *InformerStateEvent) GetTotalCount() int32

func (*InformerStateEvent) ProtoMessage 

func (*InformerStateEvent) ProtoMessage()

func (*InformerStateEvent) ProtoReflect 

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

func (*InformerStateEvent) Reset 

func (x *InformerStateEvent) Reset()

func (*InformerStateEvent) String 

func (x *InformerStateEvent) String() string

type InformerSyncPolicy 

type InformerSyncPolicy int32

Informer sync policy controls when an informer starts. 

const (
	InformerSyncPolicy_SYNC_ON_CONNECT     InformerSyncPolicy = 0
	InformerSyncPolicy_SYNC_ON_FIRST_QUERY InformerSyncPolicy = 1
	InformerSyncPolicy_SYNC_NEVER          InformerSyncPolicy = 2
)

func (InformerSyncPolicy) Descriptor 

func (InformerSyncPolicy) Descriptor() protoreflect.EnumDescriptor

func (InformerSyncPolicy) Enum 

func (x InformerSyncPolicy) Enum() *InformerSyncPolicy

func (InformerSyncPolicy) EnumDescriptor deprecated 

func (InformerSyncPolicy) EnumDescriptor() ([]byte, []int)

Deprecated: Use InformerSyncPolicy.Descriptor instead.

func (InformerSyncPolicy) Number 

func (x InformerSyncPolicy) Number() protoreflect.EnumNumber

func (InformerSyncPolicy) String 

func (x InformerSyncPolicy) String() string

func (InformerSyncPolicy) Type 

func (InformerSyncPolicy) Type() protoreflect.EnumType

type InformerUpdateEvent 

type InformerUpdateEvent struct {
	OldData *structpb.Struct `protobuf:"bytes,1,opt,name=old_data,json=oldData,proto3" json:"old_data,omitempty"`
	NewData *structpb.Struct `protobuf:"bytes,2,opt,name=new_data,json=newData,proto3" json:"new_data,omitempty"`
	// contains filtered or unexported fields
}

func (*InformerUpdateEvent) Descriptor deprecated 

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

Deprecated: Use InformerUpdateEvent.ProtoReflect.Descriptor instead.

func (*InformerUpdateEvent) GetNewData 

func (x *InformerUpdateEvent) GetNewData() *structpb.Struct

func (*InformerUpdateEvent) GetOldData 

func (x *InformerUpdateEvent) GetOldData() *structpb.Struct

func (*InformerUpdateEvent) ProtoMessage 

func (*InformerUpdateEvent) ProtoMessage()

func (*InformerUpdateEvent) ProtoReflect 

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

func (*InformerUpdateEvent) Reset 

func (x *InformerUpdateEvent) Reset()

func (*InformerUpdateEvent) String 

func (x *InformerUpdateEvent) String() string

type Layout 

type Layout struct {
	Items []*LayoutItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*Layout) Descriptor deprecated 

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

Deprecated: Use Layout.ProtoReflect.Descriptor instead.

func (*Layout) GetItems 

func (x *Layout) GetItems() []*LayoutItem

func (*Layout) ProtoMessage 

func (*Layout) ProtoMessage()

func (*Layout) ProtoReflect 

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

func (*Layout) Reset 

func (x *Layout) Reset()

func (*Layout) String 

func (x *Layout) String() string

type LayoutItem 

type LayoutItem struct {
	Id          string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Label       string        `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Icon        string        `protobuf:"bytes,3,opt,name=icon,proto3" json:"icon,omitempty"`
	Description string        `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Items       []*LayoutItem `protobuf:"bytes,5,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

An item within a display layout.

func (*LayoutItem) Descriptor deprecated 

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

Deprecated: Use LayoutItem.ProtoReflect.Descriptor instead.

func (*LayoutItem) GetDescription 

func (x *LayoutItem) GetDescription() string

func (*LayoutItem) GetIcon 

func (x *LayoutItem) GetIcon() string

func (*LayoutItem) GetId 

func (x *LayoutItem) GetId() string

func (*LayoutItem) GetItems 

func (x *LayoutItem) GetItems() []*LayoutItem

func (*LayoutItem) GetLabel 

func (x *LayoutItem) GetLabel() string

func (*LayoutItem) ProtoMessage 

func (*LayoutItem) ProtoMessage()

func (*LayoutItem) ProtoReflect 

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

func (*LayoutItem) Reset 

func (x *LayoutItem) Reset()

func (*LayoutItem) String 

func (x *LayoutItem) String() string

type ListLogSessionsResponse 

type ListLogSessionsResponse struct {
	Sessions []*LogSession `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
	Success  bool          `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Error    string        `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ListLogSessionsResponse) Descriptor deprecated 

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

Deprecated: Use ListLogSessionsResponse.ProtoReflect.Descriptor instead.

func (*ListLogSessionsResponse) GetError 

func (x *ListLogSessionsResponse) GetError() string

func (*ListLogSessionsResponse) GetSessions 

func (x *ListLogSessionsResponse) GetSessions() []*LogSession

func (*ListLogSessionsResponse) GetSuccess 

func (x *ListLogSessionsResponse) GetSuccess() bool

func (*ListLogSessionsResponse) ProtoMessage 

func (*ListLogSessionsResponse) ProtoMessage()

func (*ListLogSessionsResponse) ProtoReflect 

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

func (*ListLogSessionsResponse) Reset 

func (x *ListLogSessionsResponse) Reset()

func (*ListLogSessionsResponse) String 

func (x *ListLogSessionsResponse) String() string

type ListRequest 

type ListRequest struct {
	Key        string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Context    string   `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"`
	Namespaces []string `protobuf:"bytes,3,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetContext 

func (x *ListRequest) GetContext() string

func (*ListRequest) GetKey 

func (x *ListRequest) GetKey() string

func (*ListRequest) GetNamespaces 

func (x *ListRequest) GetNamespaces() []string

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListResponse 

type ListResponse struct {
	Success bool               `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Data    []*structpb.Struct `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	Error   *ResourceError     `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetData 

func (x *ListResponse) GetData() []*structpb.Struct

func (*ListResponse) GetError 

func (x *ListResponse) GetError() *ResourceError

func (*ListResponse) GetSuccess 

func (x *ListResponse) GetSuccess() bool

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type ListSessionsResponse 

type ListSessionsResponse struct {
	Sessions []*Session `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
	Success  bool       `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Error    string     `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSessionsResponse) Descriptor deprecated 

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

Deprecated: Use ListSessionsResponse.ProtoReflect.Descriptor instead.

func (*ListSessionsResponse) GetError 

func (x *ListSessionsResponse) GetError() string

func (*ListSessionsResponse) GetSessions 

func (x *ListSessionsResponse) GetSessions() []*Session

func (*ListSessionsResponse) GetSuccess 

func (x *ListSessionsResponse) GetSuccess() bool

func (*ListSessionsResponse) ProtoMessage 

func (*ListSessionsResponse) ProtoMessage()

func (*ListSessionsResponse) ProtoReflect 

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

func (*ListSessionsResponse) Reset 

func (x *ListSessionsResponse) Reset()

func (*ListSessionsResponse) String 

func (x *ListSessionsResponse) String() string

type ListSettingsResponse 

type ListSettingsResponse struct {
	Settings map[string]*Setting `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListSettingsResponse) Descriptor deprecated 

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

Deprecated: Use ListSettingsResponse.ProtoReflect.Descriptor instead.

func (*ListSettingsResponse) GetSettings 

func (x *ListSettingsResponse) GetSettings() map[string]*Setting

func (*ListSettingsResponse) ProtoMessage 

func (*ListSettingsResponse) ProtoMessage()

func (*ListSettingsResponse) ProtoReflect 

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

func (*ListSettingsResponse) Reset 

func (x *ListSettingsResponse) Reset()

func (*ListSettingsResponse) String 

func (x *ListSettingsResponse) String() string

type LogHandler 

type LogHandler struct {
	Plugin        string                       `protobuf:"bytes,1,opt,name=plugin,proto3" json:"plugin,omitempty"`
	Resource      string                       `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
	TargetBuilder *ResourceActionTargetBuilder `protobuf:"bytes,3,opt,name=target_builder,json=targetBuilder,proto3" json:"target_builder,omitempty"`
	// contains filtered or unexported fields
}

func (*LogHandler) Descriptor deprecated 

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

Deprecated: Use LogHandler.ProtoReflect.Descriptor instead.

func (*LogHandler) GetPlugin 

func (x *LogHandler) GetPlugin() string

func (*LogHandler) GetResource 

func (x *LogHandler) GetResource() string

func (*LogHandler) GetTargetBuilder 

func (x *LogHandler) GetTargetBuilder() *ResourceActionTargetBuilder

func (*LogHandler) ProtoMessage 

func (*LogHandler) ProtoMessage()

func (*LogHandler) ProtoReflect 

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

func (*LogHandler) Reset 

func (x *LogHandler) Reset()

func (*LogHandler) String 

func (x *LogHandler) String() string

type LogLine 

type LogLine struct {
	SessionId string                 `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	SourceId  string                 `protobuf:"bytes,2,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	Labels    map[string]string      `` /* 139-byte string literal not displayed */
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Content   []byte                 `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
	Origin    LogLineOrigin          `protobuf:"varint,6,opt,name=origin,proto3,enum=com.omniview.pluginsdk.LogLineOrigin" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

func (*LogLine) Descriptor deprecated 

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

Deprecated: Use LogLine.ProtoReflect.Descriptor instead.

func (*LogLine) GetContent 

func (x *LogLine) GetContent() []byte

func (*LogLine) GetLabels 

func (x *LogLine) GetLabels() map[string]string

func (*LogLine) GetOrigin 

func (x *LogLine) GetOrigin() LogLineOrigin

func (*LogLine) GetSessionId 

func (x *LogLine) GetSessionId() string

func (*LogLine) GetSourceId 

func (x *LogLine) GetSourceId() string

func (*LogLine) GetTimestamp 

func (x *LogLine) GetTimestamp() *timestamppb.Timestamp

func (*LogLine) ProtoMessage 

func (*LogLine) ProtoMessage()

func (*LogLine) ProtoReflect 

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

func (*LogLine) Reset 

func (x *LogLine) Reset()

func (*LogLine) String 

func (x *LogLine) String() string

type LogLineOrigin 

type LogLineOrigin int32
const (
	LogLineOrigin_LOG_LINE_ORIGIN_CURRENT  LogLineOrigin = 0
	LogLineOrigin_LOG_LINE_ORIGIN_PREVIOUS LogLineOrigin = 1
	LogLineOrigin_LOG_LINE_ORIGIN_SYSTEM   LogLineOrigin = 2
)

func (LogLineOrigin) Descriptor 

func (LogLineOrigin) Descriptor() protoreflect.EnumDescriptor

func (LogLineOrigin) Enum 

func (x LogLineOrigin) Enum() *LogLineOrigin

func (LogLineOrigin) EnumDescriptor deprecated 

func (LogLineOrigin) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogLineOrigin.Descriptor instead.

func (LogLineOrigin) Number 

func (x LogLineOrigin) Number() protoreflect.EnumNumber

func (LogLineOrigin) String 

func (x LogLineOrigin) String() string

func (LogLineOrigin) Type 

func (LogLineOrigin) Type() protoreflect.EnumType

type LogPluginClient 

type LogPluginClient interface {
	GetSupportedResources(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetSupportedLogResourcesResponse, error)
	CreateSession(ctx context.Context, in *CreateLogSessionRequest, opts ...grpc.CallOption) (*CreateLogSessionResponse, error)
	GetSession(ctx context.Context, in *LogSessionByIdRequest, opts ...grpc.CallOption) (*LogSessionByIdResponse, error)
	ListSessions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListLogSessionsResponse, error)
	CloseSession(ctx context.Context, in *LogSessionByIdRequest, opts ...grpc.CallOption) (*CloseLogSessionResponse, error)
	UpdateSessionOptions(ctx context.Context, in *UpdateLogSessionOptionsRequest, opts ...grpc.CallOption) (*LogSessionByIdResponse, error)
	Stream(ctx context.Context, opts ...grpc.CallOption) (LogPlugin_StreamClient, error)
}

LogPluginClient is the client API for LogPlugin 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 NewLogPluginClient 

func NewLogPluginClient(cc grpc.ClientConnInterface) LogPluginClient

type LogPluginServer 

type LogPluginServer interface {
	GetSupportedResources(context.Context, *emptypb.Empty) (*GetSupportedLogResourcesResponse, error)
	CreateSession(context.Context, *CreateLogSessionRequest) (*CreateLogSessionResponse, error)
	GetSession(context.Context, *LogSessionByIdRequest) (*LogSessionByIdResponse, error)
	ListSessions(context.Context, *emptypb.Empty) (*ListLogSessionsResponse, error)
	CloseSession(context.Context, *LogSessionByIdRequest) (*CloseLogSessionResponse, error)
	UpdateSessionOptions(context.Context, *UpdateLogSessionOptionsRequest) (*LogSessionByIdResponse, error)
	Stream(LogPlugin_StreamServer) error
}

LogPluginServer is the server API for LogPlugin service. All implementations should embed UnimplementedLogPluginServer for forward compatibility

type LogPlugin_StreamClient 

type LogPlugin_StreamClient interface {
	Send(*LogStreamInput) error
	Recv() (*LogStreamOutput, error)
	grpc.ClientStream
}

type LogPlugin_StreamServer 

type LogPlugin_StreamServer interface {
	Send(*LogStreamOutput) error
	Recv() (*LogStreamInput, error)
	grpc.ServerStream
}

type LogSession 

type LogSession struct {
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	PluginId      string                 `protobuf:"bytes,2,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"`
	ConnectionId  string                 `protobuf:"bytes,3,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	ResourceKey   string                 `protobuf:"bytes,4,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ResourceId    string                 `protobuf:"bytes,5,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	Options       *LogSessionOptions     `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
	Status        LogSessionStatus       `protobuf:"varint,7,opt,name=status,proto3,enum=com.omniview.pluginsdk.LogSessionStatus" json:"status,omitempty"`
	ActiveSources []*LogSource           `protobuf:"bytes,8,rep,name=active_sources,json=activeSources,proto3" json:"active_sources,omitempty"`
	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*LogSession) Descriptor deprecated 

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

Deprecated: Use LogSession.ProtoReflect.Descriptor instead.

func (*LogSession) GetActiveSources 

func (x *LogSession) GetActiveSources() []*LogSource

func (*LogSession) GetConnectionId 

func (x *LogSession) GetConnectionId() string

func (*LogSession) GetCreatedAt 

func (x *LogSession) GetCreatedAt() *timestamppb.Timestamp

func (*LogSession) GetId 

func (x *LogSession) GetId() string

func (*LogSession) GetOptions 

func (x *LogSession) GetOptions() *LogSessionOptions

func (*LogSession) GetPluginId 

func (x *LogSession) GetPluginId() string

func (*LogSession) GetResourceId 

func (x *LogSession) GetResourceId() string

func (*LogSession) GetResourceKey 

func (x *LogSession) GetResourceKey() string

func (*LogSession) GetStatus 

func (x *LogSession) GetStatus() LogSessionStatus

func (*LogSession) ProtoMessage 

func (*LogSession) ProtoMessage()

func (*LogSession) ProtoReflect 

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

func (*LogSession) Reset 

func (x *LogSession) Reset()

func (*LogSession) String 

func (x *LogSession) String() string

type LogSessionByIdRequest 

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

func (*LogSessionByIdRequest) Descriptor deprecated 

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

Deprecated: Use LogSessionByIdRequest.ProtoReflect.Descriptor instead.

func (*LogSessionByIdRequest) GetSessionId 

func (x *LogSessionByIdRequest) GetSessionId() string

func (*LogSessionByIdRequest) ProtoMessage 

func (*LogSessionByIdRequest) ProtoMessage()

func (*LogSessionByIdRequest) ProtoReflect 

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

func (*LogSessionByIdRequest) Reset 

func (x *LogSessionByIdRequest) Reset()

func (*LogSessionByIdRequest) String 

func (x *LogSessionByIdRequest) String() string

type LogSessionByIdResponse 

type LogSessionByIdResponse struct {
	Session *LogSession `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Success bool        `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Error   string      `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*LogSessionByIdResponse) Descriptor deprecated 

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

Deprecated: Use LogSessionByIdResponse.ProtoReflect.Descriptor instead.

func (*LogSessionByIdResponse) GetError 

func (x *LogSessionByIdResponse) GetError() string

func (*LogSessionByIdResponse) GetSession 

func (x *LogSessionByIdResponse) GetSession() *LogSession

func (*LogSessionByIdResponse) GetSuccess 

func (x *LogSessionByIdResponse) GetSuccess() bool

func (*LogSessionByIdResponse) ProtoMessage 

func (*LogSessionByIdResponse) ProtoMessage()

func (*LogSessionByIdResponse) ProtoReflect 

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

func (*LogSessionByIdResponse) Reset 

func (x *LogSessionByIdResponse) Reset()

func (*LogSessionByIdResponse) String 

func (x *LogSessionByIdResponse) String() string

type LogSessionOptions 

type LogSessionOptions struct {
	Target              string                 `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	Follow              bool                   `protobuf:"varint,2,opt,name=follow,proto3" json:"follow,omitempty"`
	IncludePrevious     bool                   `protobuf:"varint,3,opt,name=include_previous,json=includePrevious,proto3" json:"include_previous,omitempty"`
	IncludeTimestamps   bool                   `protobuf:"varint,4,opt,name=include_timestamps,json=includeTimestamps,proto3" json:"include_timestamps,omitempty"`
	TailLines           int64                  `protobuf:"varint,5,opt,name=tail_lines,json=tailLines,proto3" json:"tail_lines,omitempty"`
	SinceSeconds        int64                  `protobuf:"varint,6,opt,name=since_seconds,json=sinceSeconds,proto3" json:"since_seconds,omitempty"`
	SinceTime           *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=since_time,json=sinceTime,proto3" json:"since_time,omitempty"`
	LimitBytes          int64                  `protobuf:"varint,8,opt,name=limit_bytes,json=limitBytes,proto3" json:"limit_bytes,omitempty"`
	IncludeSourceEvents bool                   `protobuf:"varint,9,opt,name=include_source_events,json=includeSourceEvents,proto3" json:"include_source_events,omitempty"`
	Params              map[string]string      `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LogSessionOptions) Descriptor deprecated 

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

Deprecated: Use LogSessionOptions.ProtoReflect.Descriptor instead.

func (*LogSessionOptions) GetFollow 

func (x *LogSessionOptions) GetFollow() bool

func (*LogSessionOptions) GetIncludePrevious 

func (x *LogSessionOptions) GetIncludePrevious() bool

func (*LogSessionOptions) GetIncludeSourceEvents 

func (x *LogSessionOptions) GetIncludeSourceEvents() bool

func (*LogSessionOptions) GetIncludeTimestamps 

func (x *LogSessionOptions) GetIncludeTimestamps() bool

func (*LogSessionOptions) GetLimitBytes 

func (x *LogSessionOptions) GetLimitBytes() int64

func (*LogSessionOptions) GetParams 

func (x *LogSessionOptions) GetParams() map[string]string

func (*LogSessionOptions) GetSinceSeconds 

func (x *LogSessionOptions) GetSinceSeconds() int64

func (*LogSessionOptions) GetSinceTime 

func (x *LogSessionOptions) GetSinceTime() *timestamppb.Timestamp

func (*LogSessionOptions) GetTailLines 

func (x *LogSessionOptions) GetTailLines() int64

func (*LogSessionOptions) GetTarget 

func (x *LogSessionOptions) GetTarget() string

func (*LogSessionOptions) ProtoMessage 

func (*LogSessionOptions) ProtoMessage()

func (*LogSessionOptions) ProtoReflect 

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

func (*LogSessionOptions) Reset 

func (x *LogSessionOptions) Reset()

func (*LogSessionOptions) String 

func (x *LogSessionOptions) String() string

type LogSessionStatus 

type LogSessionStatus int32
const (
	LogSessionStatus_LOG_SESSION_STATUS_ACTIVE LogSessionStatus = 0
	LogSessionStatus_LOG_SESSION_STATUS_PAUSED LogSessionStatus = 1
	LogSessionStatus_LOG_SESSION_STATUS_CLOSED LogSessionStatus = 2
	LogSessionStatus_LOG_SESSION_STATUS_ERROR  LogSessionStatus = 3
)

func (LogSessionStatus) Descriptor 

func (LogSessionStatus) Descriptor() protoreflect.EnumDescriptor

func (LogSessionStatus) Enum 

func (x LogSessionStatus) Enum() *LogSessionStatus

func (LogSessionStatus) EnumDescriptor deprecated 

func (LogSessionStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogSessionStatus.Descriptor instead.

func (LogSessionStatus) Number 

func (x LogSessionStatus) Number() protoreflect.EnumNumber

func (LogSessionStatus) String 

func (x LogSessionStatus) String() string

func (LogSessionStatus) Type 

func (LogSessionStatus) Type() protoreflect.EnumType

type LogSource 

type LogSource struct {
	Id     string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LogSource) Descriptor deprecated 

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

Deprecated: Use LogSource.ProtoReflect.Descriptor instead.

func (*LogSource) GetId 

func (x *LogSource) GetId() string

func (*LogSource) GetLabels 

func (x *LogSource) GetLabels() map[string]string

func (*LogSource) ProtoMessage 

func (*LogSource) ProtoMessage()

func (*LogSource) ProtoReflect 

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

func (*LogSource) Reset 

func (x *LogSource) Reset()

func (*LogSource) String 

func (x *LogSource) String() string

type LogStreamCommand 

type LogStreamCommand int32
const (
	LogStreamCommand_LOG_STREAM_COMMAND_PAUSE  LogStreamCommand = 0
	LogStreamCommand_LOG_STREAM_COMMAND_RESUME LogStreamCommand = 1
	LogStreamCommand_LOG_STREAM_COMMAND_CLOSE  LogStreamCommand = 2
)

func (LogStreamCommand) Descriptor 

func (LogStreamCommand) Descriptor() protoreflect.EnumDescriptor

func (LogStreamCommand) Enum 

func (x LogStreamCommand) Enum() *LogStreamCommand

func (LogStreamCommand) EnumDescriptor deprecated 

func (LogStreamCommand) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogStreamCommand.Descriptor instead.

func (LogStreamCommand) Number 

func (x LogStreamCommand) Number() protoreflect.EnumNumber

func (LogStreamCommand) String 

func (x LogStreamCommand) String() string

func (LogStreamCommand) Type 

func (LogStreamCommand) Type() protoreflect.EnumType

type LogStreamEvent 

type LogStreamEvent struct {
	Type      LogStreamEventType     `protobuf:"varint,1,opt,name=type,proto3,enum=com.omniview.pluginsdk.LogStreamEventType" json:"type,omitempty"`
	SourceId  string                 `protobuf:"bytes,2,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	Message   string                 `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*LogStreamEvent) Descriptor deprecated 

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

Deprecated: Use LogStreamEvent.ProtoReflect.Descriptor instead.

func (*LogStreamEvent) GetMessage 

func (x *LogStreamEvent) GetMessage() string

func (*LogStreamEvent) GetSourceId 

func (x *LogStreamEvent) GetSourceId() string

func (*LogStreamEvent) GetTimestamp 

func (x *LogStreamEvent) GetTimestamp() *timestamppb.Timestamp

func (*LogStreamEvent) GetType 

func (x *LogStreamEvent) GetType() LogStreamEventType

func (*LogStreamEvent) ProtoMessage 

func (*LogStreamEvent) ProtoMessage()

func (*LogStreamEvent) ProtoReflect 

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

func (*LogStreamEvent) Reset 

func (x *LogStreamEvent) Reset()

func (*LogStreamEvent) String 

func (x *LogStreamEvent) String() string

type LogStreamEventType 

type LogStreamEventType int32
const (
	LogStreamEventType_LOG_STREAM_EVENT_SOURCE_ADDED   LogStreamEventType = 0
	LogStreamEventType_LOG_STREAM_EVENT_SOURCE_REMOVED LogStreamEventType = 1
	LogStreamEventType_LOG_STREAM_EVENT_STREAM_ERROR   LogStreamEventType = 2
	LogStreamEventType_LOG_STREAM_EVENT_RECONNECTING   LogStreamEventType = 3
	LogStreamEventType_LOG_STREAM_EVENT_RECONNECTED    LogStreamEventType = 4
	LogStreamEventType_LOG_STREAM_EVENT_STREAM_ENDED   LogStreamEventType = 5
)

func (LogStreamEventType) Descriptor 

func (LogStreamEventType) Descriptor() protoreflect.EnumDescriptor

func (LogStreamEventType) Enum 

func (x LogStreamEventType) Enum() *LogStreamEventType

func (LogStreamEventType) EnumDescriptor deprecated 

func (LogStreamEventType) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogStreamEventType.Descriptor instead.

func (LogStreamEventType) Number 

func (x LogStreamEventType) Number() protoreflect.EnumNumber

func (LogStreamEventType) String 

func (x LogStreamEventType) String() string

func (LogStreamEventType) Type 

func (LogStreamEventType) Type() protoreflect.EnumType

type LogStreamInput 

type LogStreamInput struct {
	SessionId string           `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Command   LogStreamCommand `protobuf:"varint,2,opt,name=command,proto3,enum=com.omniview.pluginsdk.LogStreamCommand" json:"command,omitempty"`
	// contains filtered or unexported fields
}

func (*LogStreamInput) Descriptor deprecated 

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

Deprecated: Use LogStreamInput.ProtoReflect.Descriptor instead.

func (*LogStreamInput) GetCommand 

func (x *LogStreamInput) GetCommand() LogStreamCommand

func (*LogStreamInput) GetSessionId 

func (x *LogStreamInput) GetSessionId() string

func (*LogStreamInput) ProtoMessage 

func (*LogStreamInput) ProtoMessage()

func (*LogStreamInput) ProtoReflect 

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

func (*LogStreamInput) Reset 

func (x *LogStreamInput) Reset()

func (*LogStreamInput) String 

func (x *LogStreamInput) String() string

type LogStreamOutput 

type LogStreamOutput struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Types that are valid to be assigned to Payload:
	//
	//	*LogStreamOutput_Line
	//	*LogStreamOutput_Event
	Payload isLogStreamOutput_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*LogStreamOutput) Descriptor deprecated 

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

Deprecated: Use LogStreamOutput.ProtoReflect.Descriptor instead.

func (*LogStreamOutput) GetEvent 

func (x *LogStreamOutput) GetEvent() *LogStreamEvent

func (*LogStreamOutput) GetLine 

func (x *LogStreamOutput) GetLine() *LogLine

func (*LogStreamOutput) GetPayload 

func (x *LogStreamOutput) GetPayload() isLogStreamOutput_Payload

func (*LogStreamOutput) GetSessionId 

func (x *LogStreamOutput) GetSessionId() string

func (*LogStreamOutput) ProtoMessage 

func (*LogStreamOutput) ProtoMessage()

func (*LogStreamOutput) ProtoReflect 

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

func (*LogStreamOutput) Reset 

func (x *LogStreamOutput) Reset()

func (*LogStreamOutput) String 

func (x *LogStreamOutput) String() string

type LogStreamOutput_Event 

type LogStreamOutput_Event struct {
	Event *LogStreamEvent `protobuf:"bytes,3,opt,name=event,proto3,oneof"`
}

type LogStreamOutput_Line 

type LogStreamOutput_Line struct {
	Line *LogLine `protobuf:"bytes,2,opt,name=line,proto3,oneof"`
}

type MetricColorRange 

type MetricColorRange struct {
	Min   float64 `protobuf:"fixed64,1,opt,name=min,proto3" json:"min,omitempty"`
	Max   float64 `protobuf:"fixed64,2,opt,name=max,proto3" json:"max,omitempty"`
	Color string  `protobuf:"bytes,3,opt,name=color,proto3" json:"color,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricColorRange) Descriptor deprecated 

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

Deprecated: Use MetricColorRange.ProtoReflect.Descriptor instead.

func (*MetricColorRange) GetColor 

func (x *MetricColorRange) GetColor() string

func (*MetricColorRange) GetMax 

func (x *MetricColorRange) GetMax() float64

func (*MetricColorRange) GetMin 

func (x *MetricColorRange) GetMin() float64

func (*MetricColorRange) ProtoMessage 

func (*MetricColorRange) ProtoMessage()

func (*MetricColorRange) ProtoReflect 

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

func (*MetricColorRange) Reset 

func (x *MetricColorRange) Reset()

func (*MetricColorRange) String 

func (x *MetricColorRange) String() string

type MetricDescriptor 

type MetricDescriptor 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"`
	Unit            MetricUnit          `protobuf:"varint,3,opt,name=unit,proto3,enum=com.omniview.pluginsdk.MetricUnit" json:"unit,omitempty"`
	Icon            string              `protobuf:"bytes,4,opt,name=icon,proto3" json:"icon,omitempty"`
	ColorRanges     []*MetricColorRange `protobuf:"bytes,5,rep,name=color_ranges,json=colorRanges,proto3" json:"color_ranges,omitempty"`
	FormatString    string              `protobuf:"bytes,6,opt,name=format_string,json=formatString,proto3" json:"format_string,omitempty"`
	SupportedShapes []MetricShape       `` /* 154-byte string literal not displayed */
	ChartGroup      string              `protobuf:"bytes,8,opt,name=chart_group,json=chartGroup,proto3" json:"chart_group,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricDescriptor) Descriptor deprecated 

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

Deprecated: Use MetricDescriptor.ProtoReflect.Descriptor instead.

func (*MetricDescriptor) GetChartGroup 

func (x *MetricDescriptor) GetChartGroup() string

func (*MetricDescriptor) GetColorRanges 

func (x *MetricDescriptor) GetColorRanges() []*MetricColorRange

func (*MetricDescriptor) GetFormatString 

func (x *MetricDescriptor) GetFormatString() string

func (*MetricDescriptor) GetIcon 

func (x *MetricDescriptor) GetIcon() string

func (*MetricDescriptor) GetId 

func (x *MetricDescriptor) GetId() string

func (*MetricDescriptor) GetName 

func (x *MetricDescriptor) GetName() string

func (*MetricDescriptor) GetSupportedShapes 

func (x *MetricDescriptor) GetSupportedShapes() []MetricShape

func (*MetricDescriptor) GetUnit 

func (x *MetricDescriptor) GetUnit() MetricUnit

func (*MetricDescriptor) ProtoMessage 

func (*MetricDescriptor) ProtoMessage()

func (*MetricDescriptor) ProtoReflect 

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

func (*MetricDescriptor) Reset 

func (x *MetricDescriptor) Reset()

func (*MetricDescriptor) String 

func (x *MetricDescriptor) String() string

type MetricHandler 

type MetricHandler struct {
	Resource string              `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Metrics  []*MetricDescriptor `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricHandler) Descriptor deprecated 

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

Deprecated: Use MetricHandler.ProtoReflect.Descriptor instead.

func (*MetricHandler) GetMetrics 

func (x *MetricHandler) GetMetrics() []*MetricDescriptor

func (*MetricHandler) GetResource 

func (x *MetricHandler) GetResource() string

func (*MetricHandler) ProtoMessage 

func (*MetricHandler) ProtoMessage()

func (*MetricHandler) ProtoReflect 

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

func (*MetricHandler) Reset 

func (x *MetricHandler) Reset()

func (*MetricHandler) String 

func (x *MetricHandler) String() string

type MetricPluginClient 

type MetricPluginClient interface {
	GetSupportedResources(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetSupportedMetricResourcesResponse, error)
	Query(ctx context.Context, in *QueryMetricsRequest, opts ...grpc.CallOption) (*QueryMetricsResponse, error)
	StreamMetrics(ctx context.Context, opts ...grpc.CallOption) (MetricPlugin_StreamMetricsClient, error)
}

MetricPluginClient is the client API for MetricPlugin 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 NewMetricPluginClient 

func NewMetricPluginClient(cc grpc.ClientConnInterface) MetricPluginClient

type MetricPluginServer 

type MetricPluginServer interface {
	GetSupportedResources(context.Context, *emptypb.Empty) (*GetSupportedMetricResourcesResponse, error)
	Query(context.Context, *QueryMetricsRequest) (*QueryMetricsResponse, error)
	StreamMetrics(MetricPlugin_StreamMetricsServer) error
}

MetricPluginServer is the server API for MetricPlugin service. All implementations should embed UnimplementedMetricPluginServer for forward compatibility

type MetricPlugin_StreamMetricsClient 

type MetricPlugin_StreamMetricsClient interface {
	Send(*MetricStreamInput) error
	Recv() (*MetricStreamOutput, error)
	grpc.ClientStream
}

type MetricPlugin_StreamMetricsServer 

type MetricPlugin_StreamMetricsServer interface {
	Send(*MetricStreamOutput) error
	Recv() (*MetricStreamInput, error)
	grpc.ServerStream
}

type MetricProviderInfo 

type MetricProviderInfo 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"`
	Icon        string `protobuf:"bytes,3,opt,name=icon,proto3" json:"icon,omitempty"`
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricProviderInfo) Descriptor deprecated 

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

Deprecated: Use MetricProviderInfo.ProtoReflect.Descriptor instead.

func (*MetricProviderInfo) GetDescription 

func (x *MetricProviderInfo) GetDescription() string

func (*MetricProviderInfo) GetIcon 

func (x *MetricProviderInfo) GetIcon() string

func (*MetricProviderInfo) GetId 

func (x *MetricProviderInfo) GetId() string

func (*MetricProviderInfo) GetName 

func (x *MetricProviderInfo) GetName() string

func (*MetricProviderInfo) ProtoMessage 

func (*MetricProviderInfo) ProtoMessage()

func (*MetricProviderInfo) ProtoReflect 

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

func (*MetricProviderInfo) Reset 

func (x *MetricProviderInfo) Reset()

func (*MetricProviderInfo) String 

func (x *MetricProviderInfo) String() string

type MetricResult 

type MetricResult struct {

	// Types that are valid to be assigned to Result:
	//
	//	*MetricResult_TimeSeries
	//	*MetricResult_CurrentValue
	//	*MetricResult_AggregateValue
	Result isMetricResult_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*MetricResult) Descriptor deprecated 

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

Deprecated: Use MetricResult.ProtoReflect.Descriptor instead.

func (*MetricResult) GetAggregateValue 

func (x *MetricResult) GetAggregateValue() *AggregateValue

func (*MetricResult) GetCurrentValue 

func (x *MetricResult) GetCurrentValue() *CurrentValue

func (*MetricResult) GetResult 

func (x *MetricResult) GetResult() isMetricResult_Result

func (*MetricResult) GetTimeSeries 

func (x *MetricResult) GetTimeSeries() *TimeSeries

func (*MetricResult) ProtoMessage 

func (*MetricResult) ProtoMessage()

func (*MetricResult) ProtoReflect 

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

func (*MetricResult) Reset 

func (x *MetricResult) Reset()

func (*MetricResult) String 

func (x *MetricResult) String() string

type MetricResult_AggregateValue 

type MetricResult_AggregateValue struct {
	AggregateValue *AggregateValue `protobuf:"bytes,3,opt,name=aggregate_value,json=aggregateValue,proto3,oneof"`
}

type MetricResult_CurrentValue 

type MetricResult_CurrentValue struct {
	CurrentValue *CurrentValue `protobuf:"bytes,2,opt,name=current_value,json=currentValue,proto3,oneof"`
}

type MetricResult_TimeSeries 

type MetricResult_TimeSeries struct {
	TimeSeries *TimeSeries `protobuf:"bytes,1,opt,name=time_series,json=timeSeries,proto3,oneof"`
}

type MetricShape 

type MetricShape int32
const (
	MetricShape_METRIC_SHAPE_CURRENT    MetricShape = 0
	MetricShape_METRIC_SHAPE_TIMESERIES MetricShape = 1
	MetricShape_METRIC_SHAPE_AGGREGATE  MetricShape = 2
)

func (MetricShape) Descriptor 

func (MetricShape) Descriptor() protoreflect.EnumDescriptor

func (MetricShape) Enum 

func (x MetricShape) Enum() *MetricShape

func (MetricShape) EnumDescriptor deprecated 

func (MetricShape) EnumDescriptor() ([]byte, []int)

Deprecated: Use MetricShape.Descriptor instead.

func (MetricShape) Number 

func (x MetricShape) Number() protoreflect.EnumNumber

func (MetricShape) String 

func (x MetricShape) String() string

func (MetricShape) Type 

func (MetricShape) Type() protoreflect.EnumType

type MetricStreamCommand 

type MetricStreamCommand int32
const (
	MetricStreamCommand_METRIC_STREAM_COMMAND_SUBSCRIBE   MetricStreamCommand = 0
	MetricStreamCommand_METRIC_STREAM_COMMAND_UNSUBSCRIBE MetricStreamCommand = 1
	MetricStreamCommand_METRIC_STREAM_COMMAND_CLOSE       MetricStreamCommand = 2
)

func (MetricStreamCommand) Descriptor 

func (MetricStreamCommand) Descriptor() protoreflect.EnumDescriptor

func (MetricStreamCommand) Enum 

func (x MetricStreamCommand) Enum() *MetricStreamCommand

func (MetricStreamCommand) EnumDescriptor deprecated 

func (MetricStreamCommand) EnumDescriptor() ([]byte, []int)

Deprecated: Use MetricStreamCommand.Descriptor instead.

func (MetricStreamCommand) Number 

func (x MetricStreamCommand) Number() protoreflect.EnumNumber

func (MetricStreamCommand) String 

func (x MetricStreamCommand) String() string

func (MetricStreamCommand) Type 

func (MetricStreamCommand) Type() protoreflect.EnumType

type MetricStreamInput 

type MetricStreamInput struct {
	SubscriptionId    string               `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	Command           MetricStreamCommand  `protobuf:"varint,2,opt,name=command,proto3,enum=com.omniview.pluginsdk.MetricStreamCommand" json:"command,omitempty"`
	ResourceKey       string               `protobuf:"bytes,3,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ResourceId        string               `protobuf:"bytes,4,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	ResourceNamespace string               `protobuf:"bytes,5,opt,name=resource_namespace,json=resourceNamespace,proto3" json:"resource_namespace,omitempty"`
	ResourceData      *structpb.Struct     `protobuf:"bytes,6,opt,name=resource_data,json=resourceData,proto3" json:"resource_data,omitempty"`
	MetricIds         []string             `protobuf:"bytes,7,rep,name=metric_ids,json=metricIds,proto3" json:"metric_ids,omitempty"`
	Interval          *durationpb.Duration `protobuf:"bytes,8,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricStreamInput) Descriptor deprecated 

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

Deprecated: Use MetricStreamInput.ProtoReflect.Descriptor instead.

func (*MetricStreamInput) GetCommand 

func (x *MetricStreamInput) GetCommand() MetricStreamCommand

func (*MetricStreamInput) GetInterval 

func (x *MetricStreamInput) GetInterval() *durationpb.Duration

func (*MetricStreamInput) GetMetricIds 

func (x *MetricStreamInput) GetMetricIds() []string

func (*MetricStreamInput) GetResourceData 

func (x *MetricStreamInput) GetResourceData() *structpb.Struct

func (*MetricStreamInput) GetResourceId 

func (x *MetricStreamInput) GetResourceId() string

func (*MetricStreamInput) GetResourceKey 

func (x *MetricStreamInput) GetResourceKey() string

func (*MetricStreamInput) GetResourceNamespace 

func (x *MetricStreamInput) GetResourceNamespace() string

func (*MetricStreamInput) GetSubscriptionId 

func (x *MetricStreamInput) GetSubscriptionId() string

func (*MetricStreamInput) ProtoMessage 

func (*MetricStreamInput) ProtoMessage()

func (*MetricStreamInput) ProtoReflect 

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

func (*MetricStreamInput) Reset 

func (x *MetricStreamInput) Reset()

func (*MetricStreamInput) String 

func (x *MetricStreamInput) String() string

type MetricStreamOutput 

type MetricStreamOutput struct {
	SubscriptionId string                 `protobuf:"bytes,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	Results        []*MetricResult        `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	Timestamp      *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Error          string                 `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricStreamOutput) Descriptor deprecated 

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

Deprecated: Use MetricStreamOutput.ProtoReflect.Descriptor instead.

func (*MetricStreamOutput) GetError 

func (x *MetricStreamOutput) GetError() string

func (*MetricStreamOutput) GetResults 

func (x *MetricStreamOutput) GetResults() []*MetricResult

func (*MetricStreamOutput) GetSubscriptionId 

func (x *MetricStreamOutput) GetSubscriptionId() string

func (*MetricStreamOutput) GetTimestamp 

func (x *MetricStreamOutput) GetTimestamp() *timestamppb.Timestamp

func (*MetricStreamOutput) ProtoMessage 

func (*MetricStreamOutput) ProtoMessage()

func (*MetricStreamOutput) ProtoReflect 

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

func (*MetricStreamOutput) Reset 

func (x *MetricStreamOutput) Reset()

func (*MetricStreamOutput) String 

func (x *MetricStreamOutput) String() string

type MetricUnit 

type MetricUnit int32
const (
	MetricUnit_METRIC_UNIT_NONE          MetricUnit = 0
	MetricUnit_METRIC_UNIT_BYTES         MetricUnit = 1
	MetricUnit_METRIC_UNIT_KB            MetricUnit = 2
	MetricUnit_METRIC_UNIT_MB            MetricUnit = 3
	MetricUnit_METRIC_UNIT_GB            MetricUnit = 4
	MetricUnit_METRIC_UNIT_PERCENTAGE    MetricUnit = 5
	MetricUnit_METRIC_UNIT_MILLISECONDS  MetricUnit = 6
	MetricUnit_METRIC_UNIT_SECONDS       MetricUnit = 7
	MetricUnit_METRIC_UNIT_COUNT         MetricUnit = 8
	MetricUnit_METRIC_UNIT_OPS_PER_SEC   MetricUnit = 9
	MetricUnit_METRIC_UNIT_BYTES_PER_SEC MetricUnit = 10
	MetricUnit_METRIC_UNIT_MILLICORES    MetricUnit = 11
	MetricUnit_METRIC_UNIT_CORES         MetricUnit = 12
)

func (MetricUnit) Descriptor 

func (MetricUnit) Descriptor() protoreflect.EnumDescriptor

func (MetricUnit) Enum 

func (x MetricUnit) Enum() *MetricUnit

func (MetricUnit) EnumDescriptor deprecated 

func (MetricUnit) EnumDescriptor() ([]byte, []int)

Deprecated: Use MetricUnit.Descriptor instead.

func (MetricUnit) Number 

func (x MetricUnit) Number() protoreflect.EnumNumber

func (MetricUnit) String 

func (x MetricUnit) String() string

func (MetricUnit) Type 

func (MetricUnit) Type() protoreflect.EnumType

type NetworkerPluginClient 

type NetworkerPluginClient interface {
	// Resource Forwarding Management
	GetSupportedPortForwardTargets(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetSupportedPortForwardTargetsResponse, error)
	GetPortForwardSession(ctx context.Context, in *PortForwardSessionByIdRequest, opts ...grpc.CallOption) (*PortForwardSessionByIdResponse, error)
	ListPortForwardSessions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PortForwardSessionListResponse, error)
	FindPortForwardSessions(ctx context.Context, in *FindPortForwardSessionRequest, opts ...grpc.CallOption) (*PortForwardSessionListResponse, error)
	StartPortForwardSession(ctx context.Context, in *PortForwardSessionOptions, opts ...grpc.CallOption) (*PortForwardSessionByIdResponse, error)
	ClosePortForwardSession(ctx context.Context, in *PortForwardSessionByIdRequest, opts ...grpc.CallOption) (*PortForwardSessionByIdResponse, error)
}

NetworkerPluginClient is the client API for NetworkerPlugin 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 NewNetworkerPluginClient 

func NewNetworkerPluginClient(cc grpc.ClientConnInterface) NetworkerPluginClient

type NetworkerPluginServer 

type NetworkerPluginServer interface {
	// Resource Forwarding Management
	GetSupportedPortForwardTargets(context.Context, *emptypb.Empty) (*GetSupportedPortForwardTargetsResponse, error)
	GetPortForwardSession(context.Context, *PortForwardSessionByIdRequest) (*PortForwardSessionByIdResponse, error)
	ListPortForwardSessions(context.Context, *emptypb.Empty) (*PortForwardSessionListResponse, error)
	FindPortForwardSessions(context.Context, *FindPortForwardSessionRequest) (*PortForwardSessionListResponse, error)
	StartPortForwardSession(context.Context, *PortForwardSessionOptions) (*PortForwardSessionByIdResponse, error)
	ClosePortForwardSession(context.Context, *PortForwardSessionByIdRequest) (*PortForwardSessionByIdResponse, error)
}

NetworkerPluginServer is the server API for NetworkerPlugin service. All implementations should embed UnimplementedNetworkerPluginServer for forward compatibility

type PluginContext 

type PluginContext struct {

	// source plugin calling the API.
	PluginId string `protobuf:"bytes,1,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"`
	// settings for the plugin
	PluginSettings map[string]string `` /* 177-byte string literal not displayed */
	// global IDE settings
	GlobalSettings map[string]string `` /* 177-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PluginContext) Descriptor deprecated 

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

Deprecated: Use PluginContext.ProtoReflect.Descriptor instead.

func (*PluginContext) GetGlobalSettings 

func (x *PluginContext) GetGlobalSettings() map[string]string

func (*PluginContext) GetPluginId 

func (x *PluginContext) GetPluginId() string

func (*PluginContext) GetPluginSettings 

func (x *PluginContext) GetPluginSettings() map[string]string

func (*PluginContext) ProtoMessage 

func (*PluginContext) ProtoMessage()

func (*PluginContext) ProtoReflect 

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

func (*PluginContext) Reset 

func (x *PluginContext) Reset()

func (*PluginContext) String 

func (x *PluginContext) String() string

type PluginLifecycleClient added in v0.1.1 

type PluginLifecycleClient interface {
	// GetInfo returns plugin identification and version information.
	GetInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetInfoResponse, error)
	// GetCapabilities returns the list of capabilities this plugin serves.
	// Replaces exception-based gRPC probing on the host side.
	GetCapabilities(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetCapabilitiesResponse, error)
	// HealthCheck returns the current health status of the plugin process.
	HealthCheck(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}

PluginLifecycleClient is the client API for PluginLifecycle 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 NewPluginLifecycleClient added in v0.1.1 

func NewPluginLifecycleClient(cc grpc.ClientConnInterface) PluginLifecycleClient

type PluginLifecycleServer added in v0.1.1 

type PluginLifecycleServer interface {
	// GetInfo returns plugin identification and version information.
	GetInfo(context.Context, *emptypb.Empty) (*GetInfoResponse, error)
	// GetCapabilities returns the list of capabilities this plugin serves.
	// Replaces exception-based gRPC probing on the host side.
	GetCapabilities(context.Context, *emptypb.Empty) (*GetCapabilitiesResponse, error)
	// HealthCheck returns the current health status of the plugin process.
	HealthCheck(context.Context, *emptypb.Empty) (*HealthCheckResponse, error)
}

PluginLifecycleServer is the server API for PluginLifecycle service. All implementations should embed UnimplementedPluginLifecycleServer for forward compatibility

type PortForwardProtocol 

type PortForwardProtocol int32
const (
	PortForwardProtocol_TCP PortForwardProtocol = 0
	PortForwardProtocol_UDP PortForwardProtocol = 1
)

func (PortForwardProtocol) Descriptor 

func (PortForwardProtocol) Descriptor() protoreflect.EnumDescriptor

func (PortForwardProtocol) Enum 

func (x PortForwardProtocol) Enum() *PortForwardProtocol

func (PortForwardProtocol) EnumDescriptor deprecated 

func (PortForwardProtocol) EnumDescriptor() ([]byte, []int)

Deprecated: Use PortForwardProtocol.Descriptor instead.

func (PortForwardProtocol) Number 

func (x PortForwardProtocol) Number() protoreflect.EnumNumber

func (PortForwardProtocol) String 

func (x PortForwardProtocol) String() string

func (PortForwardProtocol) Type 

func (PortForwardProtocol) Type() protoreflect.EnumType

type PortForwardResourceConnection 

type PortForwardResourceConnection struct {
	ConnectionId string           `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	PluginId     string           `protobuf:"bytes,2,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"`
	ResourceId   string           `protobuf:"bytes,3,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	ResourceKey  string           `protobuf:"bytes,4,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ResourceData *structpb.Struct `protobuf:"bytes,5,opt,name=resource_data,json=resourceData,proto3" json:"resource_data,omitempty"`
	// contains filtered or unexported fields
}

Port forwarding can happen to a resource via it's resource parameter, or via a static connection to a specific address and port. This message encapsulates the options for the connection to a resource.

func (*PortForwardResourceConnection) Descriptor deprecated 

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

Deprecated: Use PortForwardResourceConnection.ProtoReflect.Descriptor instead.

func (*PortForwardResourceConnection) GetConnectionId 

func (x *PortForwardResourceConnection) GetConnectionId() string

func (*PortForwardResourceConnection) GetPluginId 

func (x *PortForwardResourceConnection) GetPluginId() string

func (*PortForwardResourceConnection) GetResourceData 

func (x *PortForwardResourceConnection) GetResourceData() *structpb.Struct

func (*PortForwardResourceConnection) GetResourceId 

func (x *PortForwardResourceConnection) GetResourceId() string

func (*PortForwardResourceConnection) GetResourceKey 

func (x *PortForwardResourceConnection) GetResourceKey() string

func (*PortForwardResourceConnection) ProtoMessage 

func (*PortForwardResourceConnection) ProtoMessage()

func (*PortForwardResourceConnection) ProtoReflect 

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

func (*PortForwardResourceConnection) Reset 

func (x *PortForwardResourceConnection) Reset()

func (*PortForwardResourceConnection) String 

func (x *PortForwardResourceConnection) String() string

type PortForwardSession 

type PortForwardSession struct {
	Id         string                          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	LocalPort  int32                           `protobuf:"varint,2,opt,name=local_port,json=localPort,proto3" json:"local_port,omitempty"`
	RemotePort int32                           `protobuf:"varint,3,opt,name=remote_port,json=remotePort,proto3" json:"remote_port,omitempty"`
	Protocol   PortForwardProtocol             `protobuf:"varint,4,opt,name=protocol,proto3,enum=com.omniview.pluginsdk.PortForwardProtocol" json:"protocol,omitempty"`
	CreatedAt  *timestamppb.Timestamp          `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt  *timestamppb.Timestamp          `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Labels     map[string]string               `` /* 139-byte string literal not displayed */
	State      PortForwardSession_SessionState `protobuf:"varint,8,opt,name=state,proto3,enum=com.omniview.pluginsdk.PortForwardSession_SessionState" json:"state,omitempty"`
	Encryption *PortForwardSessionEncryption   `protobuf:"bytes,9,opt,name=encryption,proto3" json:"encryption,omitempty"`
	// Types that are valid to be assigned to Connection:
	//
	//	*PortForwardSession_ResourceConnection
	//	*PortForwardSession_StaticConnection
	Connection isPortForwardSession_Connection `protobuf_oneof:"connection"`
	// contains filtered or unexported fields
}

An active port forwarding session that is used to forward network traffic from a remote resource to the local machine. Common use cases include: - Kubernetes port forwarding - AWS SSM port forwarding - SSH port forwarding

func (*PortForwardSession) Descriptor deprecated 

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

Deprecated: Use PortForwardSession.ProtoReflect.Descriptor instead.

func (*PortForwardSession) GetConnection 

func (x *PortForwardSession) GetConnection() isPortForwardSession_Connection

func (*PortForwardSession) GetCreatedAt 

func (x *PortForwardSession) GetCreatedAt() *timestamppb.Timestamp

func (*PortForwardSession) GetEncryption 

func (x *PortForwardSession) GetEncryption() *PortForwardSessionEncryption

func (*PortForwardSession) GetId 

func (x *PortForwardSession) GetId() string

func (*PortForwardSession) GetLabels 

func (x *PortForwardSession) GetLabels() map[string]string

func (*PortForwardSession) GetLocalPort 

func (x *PortForwardSession) GetLocalPort() int32

func (*PortForwardSession) GetProtocol 

func (x *PortForwardSession) GetProtocol() PortForwardProtocol

func (*PortForwardSession) GetRemotePort 

func (x *PortForwardSession) GetRemotePort() int32

func (*PortForwardSession) GetResourceConnection 

func (x *PortForwardSession) GetResourceConnection() *PortForwardResourceConnection

func (*PortForwardSession) GetState 

func (x *PortForwardSession) GetState() PortForwardSession_SessionState

func (*PortForwardSession) GetStaticConnection 

func (x *PortForwardSession) GetStaticConnection() *PortForwardStaticConnection

func (*PortForwardSession) GetUpdatedAt 

func (x *PortForwardSession) GetUpdatedAt() *timestamppb.Timestamp

func (*PortForwardSession) ProtoMessage 

func (*PortForwardSession) ProtoMessage()

func (*PortForwardSession) ProtoReflect 

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

func (*PortForwardSession) Reset 

func (x *PortForwardSession) Reset()

func (*PortForwardSession) String 

func (x *PortForwardSession) String() string

type PortForwardSessionByIdRequest 

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

func (*PortForwardSessionByIdRequest) Descriptor deprecated 

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

Deprecated: Use PortForwardSessionByIdRequest.ProtoReflect.Descriptor instead.

func (*PortForwardSessionByIdRequest) GetId 

func (x *PortForwardSessionByIdRequest) GetId() string

func (*PortForwardSessionByIdRequest) ProtoMessage 

func (*PortForwardSessionByIdRequest) ProtoMessage()

func (*PortForwardSessionByIdRequest) ProtoReflect 

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

func (*PortForwardSessionByIdRequest) Reset 

func (x *PortForwardSessionByIdRequest) Reset()

func (*PortForwardSessionByIdRequest) String 

func (x *PortForwardSessionByIdRequest) String() string

type PortForwardSessionByIdResponse 

type PortForwardSessionByIdResponse struct {
	Session *PortForwardSession `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*PortForwardSessionByIdResponse) Descriptor deprecated 

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

Deprecated: Use PortForwardSessionByIdResponse.ProtoReflect.Descriptor instead.

func (*PortForwardSessionByIdResponse) GetSession 

func (x *PortForwardSessionByIdResponse) GetSession() *PortForwardSession

func (*PortForwardSessionByIdResponse) ProtoMessage 

func (*PortForwardSessionByIdResponse) ProtoMessage()

func (*PortForwardSessionByIdResponse) ProtoReflect 

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

func (*PortForwardSessionByIdResponse) Reset 

func (x *PortForwardSessionByIdResponse) Reset()

func (*PortForwardSessionByIdResponse) String 

func (x *PortForwardSessionByIdResponse) String() string

type PortForwardSessionEncryption 

type PortForwardSessionEncryption struct {
	Enabled   bool   `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Algorithm string `protobuf:"bytes,2,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	Key       string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*PortForwardSessionEncryption) Descriptor deprecated 

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

Deprecated: Use PortForwardSessionEncryption.ProtoReflect.Descriptor instead.

func (*PortForwardSessionEncryption) GetAlgorithm 

func (x *PortForwardSessionEncryption) GetAlgorithm() string

func (*PortForwardSessionEncryption) GetEnabled 

func (x *PortForwardSessionEncryption) GetEnabled() bool

func (*PortForwardSessionEncryption) GetKey 

func (x *PortForwardSessionEncryption) GetKey() string

func (*PortForwardSessionEncryption) ProtoMessage 

func (*PortForwardSessionEncryption) ProtoMessage()

func (*PortForwardSessionEncryption) ProtoReflect 

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

func (*PortForwardSessionEncryption) Reset 

func (x *PortForwardSessionEncryption) Reset()

func (*PortForwardSessionEncryption) String 

func (x *PortForwardSessionEncryption) String() string

type PortForwardSessionListResponse 

type PortForwardSessionListResponse struct {
	Sessions []*PortForwardSession `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
	// contains filtered or unexported fields
}

func (*PortForwardSessionListResponse) Descriptor deprecated 

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

Deprecated: Use PortForwardSessionListResponse.ProtoReflect.Descriptor instead.

func (*PortForwardSessionListResponse) GetSessions 

func (x *PortForwardSessionListResponse) GetSessions() []*PortForwardSession

func (*PortForwardSessionListResponse) ProtoMessage 

func (*PortForwardSessionListResponse) ProtoMessage()

func (*PortForwardSessionListResponse) ProtoReflect 

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

func (*PortForwardSessionListResponse) Reset 

func (x *PortForwardSessionListResponse) Reset()

func (*PortForwardSessionListResponse) String 

func (x *PortForwardSessionListResponse) String() string

type PortForwardSessionOptions 

type PortForwardSessionOptions struct {
	LocalPort  int32                         `protobuf:"varint,1,opt,name=local_port,json=localPort,proto3" json:"local_port,omitempty"`
	RemotePort int32                         `protobuf:"varint,2,opt,name=remote_port,json=remotePort,proto3" json:"remote_port,omitempty"`
	Protocol   PortForwardProtocol           `protobuf:"varint,3,opt,name=protocol,proto3,enum=com.omniview.pluginsdk.PortForwardProtocol" json:"protocol,omitempty"`
	Labels     map[string]string             `` /* 139-byte string literal not displayed */
	Params     map[string]string             `` /* 139-byte string literal not displayed */
	Encryption *PortForwardSessionEncryption `protobuf:"bytes,6,opt,name=encryption,proto3" json:"encryption,omitempty"`
	// Types that are valid to be assigned to Connection:
	//
	//	*PortForwardSessionOptions_ResourceConnection
	//	*PortForwardSessionOptions_StaticConnection
	Connection isPortForwardSessionOptions_Connection `protobuf_oneof:"connection"`
	// contains filtered or unexported fields
}

Options for creating a new port forwarding session

func (*PortForwardSessionOptions) Descriptor deprecated 

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

Deprecated: Use PortForwardSessionOptions.ProtoReflect.Descriptor instead.

func (*PortForwardSessionOptions) GetConnection 

func (x *PortForwardSessionOptions) GetConnection() isPortForwardSessionOptions_Connection

func (*PortForwardSessionOptions) GetEncryption 

func (x *PortForwardSessionOptions) GetEncryption() *PortForwardSessionEncryption

func (*PortForwardSessionOptions) GetLabels 

func (x *PortForwardSessionOptions) GetLabels() map[string]string

func (*PortForwardSessionOptions) GetLocalPort 

func (x *PortForwardSessionOptions) GetLocalPort() int32

func (*PortForwardSessionOptions) GetParams 

func (x *PortForwardSessionOptions) GetParams() map[string]string

func (*PortForwardSessionOptions) GetProtocol 

func (x *PortForwardSessionOptions) GetProtocol() PortForwardProtocol

func (*PortForwardSessionOptions) GetRemotePort 

func (x *PortForwardSessionOptions) GetRemotePort() int32

func (*PortForwardSessionOptions) GetResourceConnection 

func (x *PortForwardSessionOptions) GetResourceConnection() *PortForwardResourceConnection

func (*PortForwardSessionOptions) GetStaticConnection 

func (x *PortForwardSessionOptions) GetStaticConnection() *PortForwardStaticConnection

func (*PortForwardSessionOptions) ProtoMessage 

func (*PortForwardSessionOptions) ProtoMessage()

func (*PortForwardSessionOptions) ProtoReflect 

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

func (*PortForwardSessionOptions) Reset 

func (x *PortForwardSessionOptions) Reset()

func (*PortForwardSessionOptions) String 

func (x *PortForwardSessionOptions) String() string

type PortForwardSessionOptions_ResourceConnection 

type PortForwardSessionOptions_ResourceConnection struct {
	ResourceConnection *PortForwardResourceConnection `protobuf:"bytes,10,opt,name=resource_connection,json=resourceConnection,proto3,oneof"`
}

type PortForwardSessionOptions_StaticConnection 

type PortForwardSessionOptions_StaticConnection struct {
	StaticConnection *PortForwardStaticConnection `protobuf:"bytes,11,opt,name=static_connection,json=staticConnection,proto3,oneof"`
}

type PortForwardSession_ResourceConnection 

type PortForwardSession_ResourceConnection struct {
	ResourceConnection *PortForwardResourceConnection `protobuf:"bytes,20,opt,name=resource_connection,json=resourceConnection,proto3,oneof"`
}

type PortForwardSession_SessionState 

type PortForwardSession_SessionState int32
const (
	PortForwardSession_ACTIVE  PortForwardSession_SessionState = 0
	PortForwardSession_PAUSED  PortForwardSession_SessionState = 1
	PortForwardSession_STOPPED PortForwardSession_SessionState = 2
	PortForwardSession_FAILED  PortForwardSession_SessionState = 3
)

func (PortForwardSession_SessionState) Descriptor 

func (PortForwardSession_SessionState) Descriptor() protoreflect.EnumDescriptor

func (PortForwardSession_SessionState) Enum 

func (x PortForwardSession_SessionState) Enum() *PortForwardSession_SessionState

func (PortForwardSession_SessionState) EnumDescriptor deprecated 

func (PortForwardSession_SessionState) EnumDescriptor() ([]byte, []int)

Deprecated: Use PortForwardSession_SessionState.Descriptor instead.

func (PortForwardSession_SessionState) Number 

func (x PortForwardSession_SessionState) Number() protoreflect.EnumNumber

func (PortForwardSession_SessionState) String 

func (x PortForwardSession_SessionState) String() string

func (PortForwardSession_SessionState) Type 

func (PortForwardSession_SessionState) Type() protoreflect.EnumType

type PortForwardSession_StaticConnection 

type PortForwardSession_StaticConnection struct {
	StaticConnection *PortForwardStaticConnection `protobuf:"bytes,21,opt,name=static_connection,json=staticConnection,proto3,oneof"`
}

type PortForwardStaticConnection 

type PortForwardStaticConnection struct {

	// IPv4 or IPv6 address
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*PortForwardStaticConnection) Descriptor deprecated 

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

Deprecated: Use PortForwardStaticConnection.ProtoReflect.Descriptor instead.

func (*PortForwardStaticConnection) GetAddress 

func (x *PortForwardStaticConnection) GetAddress() string

func (*PortForwardStaticConnection) ProtoMessage 

func (*PortForwardStaticConnection) ProtoMessage()

func (*PortForwardStaticConnection) ProtoReflect 

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

func (*PortForwardStaticConnection) Reset 

func (x *PortForwardStaticConnection) Reset()

func (*PortForwardStaticConnection) String 

func (x *PortForwardStaticConnection) String() string

type PublishStreamRequest 

type PublishStreamRequest struct {
	PluginContext *PluginContext `protobuf:"bytes,1,opt,name=plugin_context,json=pluginContext,proto3" json:"plugin_context,omitempty"`
	// path part of a channel.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// data that user wants to publish into a stream
	// (only JSON-encoded at the moment).
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishStreamRequest) Descriptor deprecated 

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

Deprecated: Use PublishStreamRequest.ProtoReflect.Descriptor instead.

func (*PublishStreamRequest) GetData 

func (x *PublishStreamRequest) GetData() []byte

func (*PublishStreamRequest) GetPath 

func (x *PublishStreamRequest) GetPath() string

func (*PublishStreamRequest) GetPluginContext 

func (x *PublishStreamRequest) GetPluginContext() *PluginContext

func (*PublishStreamRequest) ProtoMessage 

func (*PublishStreamRequest) ProtoMessage()

func (*PublishStreamRequest) ProtoReflect 

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

func (*PublishStreamRequest) Reset 

func (x *PublishStreamRequest) Reset()

func (*PublishStreamRequest) String 

func (x *PublishStreamRequest) String() string

type PublishStreamResponse 

type PublishStreamResponse struct {
	Status PublishStreamResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=com.omniview.pluginsdk.PublishStreamResponse_Status" json:"status,omitempty"`
	Data   []byte                       `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishStreamResponse) Descriptor deprecated 

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

Deprecated: Use PublishStreamResponse.ProtoReflect.Descriptor instead.

func (*PublishStreamResponse) GetData 

func (x *PublishStreamResponse) GetData() []byte

func (*PublishStreamResponse) GetStatus 

func (x *PublishStreamResponse) GetStatus() PublishStreamResponse_Status

func (*PublishStreamResponse) ProtoMessage 

func (*PublishStreamResponse) ProtoMessage()

func (*PublishStreamResponse) ProtoReflect 

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

func (*PublishStreamResponse) Reset 

func (x *PublishStreamResponse) Reset()

func (*PublishStreamResponse) String 

func (x *PublishStreamResponse) String() string

type PublishStreamResponse_Status 

type PublishStreamResponse_Status int32
const (
	PublishStreamResponse_OK                PublishStreamResponse_Status = 0
	PublishStreamResponse_NOT_FOUND         PublishStreamResponse_Status = 1
	PublishStreamResponse_PERMISSION_DENIED PublishStreamResponse_Status = 2
)

func (PublishStreamResponse_Status) Descriptor 

func (PublishStreamResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (PublishStreamResponse_Status) Enum 

func (x PublishStreamResponse_Status) Enum() *PublishStreamResponse_Status

func (PublishStreamResponse_Status) EnumDescriptor deprecated 

func (PublishStreamResponse_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use PublishStreamResponse_Status.Descriptor instead.

func (PublishStreamResponse_Status) Number 

func (x PublishStreamResponse_Status) Number() protoreflect.EnumNumber

func (PublishStreamResponse_Status) String 

func (x PublishStreamResponse_Status) String() string

func (PublishStreamResponse_Status) Type 

func (PublishStreamResponse_Status) Type() protoreflect.EnumType

type QueryMetricsRequest 

type QueryMetricsRequest struct {
	ResourceKey       string                 `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ResourceId        string                 `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	ResourceNamespace string                 `protobuf:"bytes,3,opt,name=resource_namespace,json=resourceNamespace,proto3" json:"resource_namespace,omitempty"`
	ResourceData      *structpb.Struct       `protobuf:"bytes,4,opt,name=resource_data,json=resourceData,proto3" json:"resource_data,omitempty"`
	MetricIds         []string               `protobuf:"bytes,5,rep,name=metric_ids,json=metricIds,proto3" json:"metric_ids,omitempty"`
	Shape             MetricShape            `protobuf:"varint,6,opt,name=shape,proto3,enum=com.omniview.pluginsdk.MetricShape" json:"shape,omitempty"`
	StartTime         *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime           *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Step              *durationpb.Duration   `protobuf:"bytes,9,opt,name=step,proto3" json:"step,omitempty"`
	Params            map[string]string      `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*QueryMetricsRequest) Descriptor deprecated 

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

Deprecated: Use QueryMetricsRequest.ProtoReflect.Descriptor instead.

func (*QueryMetricsRequest) GetEndTime 

func (x *QueryMetricsRequest) GetEndTime() *timestamppb.Timestamp

func (*QueryMetricsRequest) GetMetricIds 

func (x *QueryMetricsRequest) GetMetricIds() []string

func (*QueryMetricsRequest) GetParams 

func (x *QueryMetricsRequest) GetParams() map[string]string

func (*QueryMetricsRequest) GetResourceData 

func (x *QueryMetricsRequest) GetResourceData() *structpb.Struct

func (*QueryMetricsRequest) GetResourceId 

func (x *QueryMetricsRequest) GetResourceId() string

func (*QueryMetricsRequest) GetResourceKey 

func (x *QueryMetricsRequest) GetResourceKey() string

func (*QueryMetricsRequest) GetResourceNamespace 

func (x *QueryMetricsRequest) GetResourceNamespace() string

func (*QueryMetricsRequest) GetShape 

func (x *QueryMetricsRequest) GetShape() MetricShape

func (*QueryMetricsRequest) GetStartTime 

func (x *QueryMetricsRequest) GetStartTime() *timestamppb.Timestamp

func (*QueryMetricsRequest) GetStep 

func (x *QueryMetricsRequest) GetStep() *durationpb.Duration

func (*QueryMetricsRequest) ProtoMessage 

func (*QueryMetricsRequest) ProtoMessage()

func (*QueryMetricsRequest) ProtoReflect 

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

func (*QueryMetricsRequest) Reset 

func (x *QueryMetricsRequest) Reset()

func (*QueryMetricsRequest) String 

func (x *QueryMetricsRequest) String() string

type QueryMetricsResponse 

type QueryMetricsResponse struct {
	Success bool            `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Results []*MetricResult `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	Error   string          `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryMetricsResponse) Descriptor deprecated 

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

Deprecated: Use QueryMetricsResponse.ProtoReflect.Descriptor instead.

func (*QueryMetricsResponse) GetError 

func (x *QueryMetricsResponse) GetError() string

func (*QueryMetricsResponse) GetResults 

func (x *QueryMetricsResponse) GetResults() []*MetricResult

func (*QueryMetricsResponse) GetSuccess 

func (x *QueryMetricsResponse) GetSuccess() bool

func (*QueryMetricsResponse) ProtoMessage 

func (*QueryMetricsResponse) ProtoMessage()

func (*QueryMetricsResponse) ProtoReflect 

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

func (*QueryMetricsResponse) Reset 

func (x *QueryMetricsResponse) Reset()

func (*QueryMetricsResponse) String 

func (x *QueryMetricsResponse) String() string

type ResizeSessionRequest 

type ResizeSessionRequest struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Rows int32  `protobuf:"varint,2,opt,name=rows,proto3" json:"rows,omitempty"`
	Cols int32  `protobuf:"varint,3,opt,name=cols,proto3" json:"cols,omitempty"`
	// contains filtered or unexported fields
}

func (*ResizeSessionRequest) Descriptor deprecated 

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

Deprecated: Use ResizeSessionRequest.ProtoReflect.Descriptor instead.

func (*ResizeSessionRequest) GetCols 

func (x *ResizeSessionRequest) GetCols() int32

func (*ResizeSessionRequest) GetId 

func (x *ResizeSessionRequest) GetId() string

func (*ResizeSessionRequest) GetRows 

func (x *ResizeSessionRequest) GetRows() int32

func (*ResizeSessionRequest) ProtoMessage 

func (*ResizeSessionRequest) ProtoMessage()

func (*ResizeSessionRequest) ProtoReflect 

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

func (*ResizeSessionRequest) Reset 

func (x *ResizeSessionRequest) Reset()

func (*ResizeSessionRequest) String 

func (x *ResizeSessionRequest) String() string

type ResizeSessionResponse 

type ResizeSessionResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ResizeSessionResponse) Descriptor deprecated 

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

Deprecated: Use ResizeSessionResponse.ProtoReflect.Descriptor instead.

func (*ResizeSessionResponse) GetError 

func (x *ResizeSessionResponse) GetError() string

func (*ResizeSessionResponse) GetSuccess 

func (x *ResizeSessionResponse) GetSuccess() bool

func (*ResizeSessionResponse) ProtoMessage 

func (*ResizeSessionResponse) ProtoMessage()

func (*ResizeSessionResponse) ProtoReflect 

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

func (*ResizeSessionResponse) Reset 

func (x *ResizeSessionResponse) Reset()

func (*ResizeSessionResponse) String 

func (x *ResizeSessionResponse) String() string

type ResourceAction 

type ResourceAction struct {
	Id             string                         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Label          string                         `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Description    string                         `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Icon           string                         `protobuf:"bytes,4,opt,name=icon,proto3" json:"icon,omitempty"`
	Variant        ResourceAction_Variant         `protobuf:"varint,5,opt,name=variant,proto3,enum=com.omniview.pluginsdk.ResourceAction_Variant" json:"variant,omitempty"`
	Targets        []*ResourceActionTarget        `protobuf:"bytes,6,rep,name=targets,proto3" json:"targets,omitempty"`
	TargetBuilders []*ResourceActionTargetBuilder `protobuf:"bytes,7,rep,name=target_builders,json=targetBuilders,proto3" json:"target_builders,omitempty"`
	Selectors      map[string]string              `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ResourceAction) Descriptor deprecated 

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

Deprecated: Use ResourceAction.ProtoReflect.Descriptor instead.

func (*ResourceAction) GetDescription 

func (x *ResourceAction) GetDescription() string

func (*ResourceAction) GetIcon 

func (x *ResourceAction) GetIcon() string

func (*ResourceAction) GetId 

func (x *ResourceAction) GetId() string

func (*ResourceAction) GetLabel 

func (x *ResourceAction) GetLabel() string

func (*ResourceAction) GetSelectors 

func (x *ResourceAction) GetSelectors() map[string]string

func (*ResourceAction) GetTargetBuilders 

func (x *ResourceAction) GetTargetBuilders() []*ResourceActionTargetBuilder

func (*ResourceAction) GetTargets 

func (x *ResourceAction) GetTargets() []*ResourceActionTarget

func (*ResourceAction) GetVariant 

func (x *ResourceAction) GetVariant() ResourceAction_Variant

func (*ResourceAction) ProtoMessage 

func (*ResourceAction) ProtoMessage()

func (*ResourceAction) ProtoReflect 

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

func (*ResourceAction) Reset 

func (x *ResourceAction) Reset()

func (*ResourceAction) String 

func (x *ResourceAction) String() string

type ResourceActionTarget 

type ResourceActionTarget struct {
	Label       string            `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Icon        string            `protobuf:"bytes,2,opt,name=icon,proto3" json:"icon,omitempty"`
	Description string            `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Selectors   map[string]string `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

Static target for an action. Defining this outside as we need to use this for the other plugin actions

func (*ResourceActionTarget) Descriptor deprecated 

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

Deprecated: Use ResourceActionTarget.ProtoReflect.Descriptor instead.

func (*ResourceActionTarget) GetDescription 

func (x *ResourceActionTarget) GetDescription() string

func (*ResourceActionTarget) GetIcon 

func (x *ResourceActionTarget) GetIcon() string

func (*ResourceActionTarget) GetLabel 

func (x *ResourceActionTarget) GetLabel() string

func (*ResourceActionTarget) GetSelectors 

func (x *ResourceActionTarget) GetSelectors() map[string]string

func (*ResourceActionTarget) ProtoMessage 

func (*ResourceActionTarget) ProtoMessage()

func (*ResourceActionTarget) ProtoReflect 

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

func (*ResourceActionTarget) Reset 

func (x *ResourceActionTarget) Reset()

func (*ResourceActionTarget) String 

func (x *ResourceActionTarget) String() string

type ResourceActionTargetBuilder 

type ResourceActionTargetBuilder struct {
	Label         string            `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	LabelSelector string            `protobuf:"bytes,2,opt,name=label_selector,json=labelSelector,proto3" json:"label_selector,omitempty"`
	Paths         []string          `protobuf:"bytes,3,rep,name=paths,proto3" json:"paths,omitempty"`
	Selectors     map[string]string `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

Builder to generate a dynamic list of targets

func (*ResourceActionTargetBuilder) Descriptor deprecated 

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

Deprecated: Use ResourceActionTargetBuilder.ProtoReflect.Descriptor instead.

func (*ResourceActionTargetBuilder) GetLabel 

func (x *ResourceActionTargetBuilder) GetLabel() string

func (*ResourceActionTargetBuilder) GetLabelSelector 

func (x *ResourceActionTargetBuilder) GetLabelSelector() string

func (*ResourceActionTargetBuilder) GetPaths 

func (x *ResourceActionTargetBuilder) GetPaths() []string

func (*ResourceActionTargetBuilder) GetSelectors 

func (x *ResourceActionTargetBuilder) GetSelectors() map[string]string

func (*ResourceActionTargetBuilder) ProtoMessage 

func (*ResourceActionTargetBuilder) ProtoMessage()

func (*ResourceActionTargetBuilder) ProtoReflect 

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

func (*ResourceActionTargetBuilder) Reset 

func (x *ResourceActionTargetBuilder) Reset()

func (*ResourceActionTargetBuilder) String 

func (x *ResourceActionTargetBuilder) String() string

type ResourceAction_Variant 

type ResourceAction_Variant int32

Built in action types, or a custom action. 

const (
	ResourceAction_EXEC   ResourceAction_Variant = 0
	ResourceAction_LOGS   ResourceAction_Variant = 1
	ResourceAction_CUSTOM ResourceAction_Variant = 2
)

func (ResourceAction_Variant) Descriptor 

func (ResourceAction_Variant) Descriptor() protoreflect.EnumDescriptor

func (ResourceAction_Variant) Enum 

func (x ResourceAction_Variant) Enum() *ResourceAction_Variant

func (ResourceAction_Variant) EnumDescriptor deprecated 

func (ResourceAction_Variant) EnumDescriptor() ([]byte, []int)

Deprecated: Use ResourceAction_Variant.Descriptor instead.

func (ResourceAction_Variant) Number 

func (x ResourceAction_Variant) Number() protoreflect.EnumNumber

func (ResourceAction_Variant) String 

func (x ResourceAction_Variant) String() string

func (ResourceAction_Variant) Type 

func (ResourceAction_Variant) Type() protoreflect.EnumType

type ResourceDefinition 

type ResourceDefinition struct {
	IdAccessor          string       `protobuf:"bytes,1,opt,name=id_accessor,json=idAccessor,proto3" json:"id_accessor,omitempty"`
	NamespaceAccessor   string       `protobuf:"bytes,2,opt,name=namespace_accessor,json=namespaceAccessor,proto3" json:"namespace_accessor,omitempty"`
	MemoAccessor        string       `protobuf:"bytes,3,opt,name=memo_accessor,json=memoAccessor,proto3" json:"memo_accessor,omitempty"`
	ColumnDefs          []*ColumnDef `protobuf:"bytes,4,rep,name=column_defs,json=columnDefs,proto3" json:"column_defs,omitempty"`
	SupportedOperations []int32      `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ResourceDefinition) Descriptor deprecated 

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

Deprecated: Use ResourceDefinition.ProtoReflect.Descriptor instead.

func (*ResourceDefinition) GetColumnDefs 

func (x *ResourceDefinition) GetColumnDefs() []*ColumnDef

func (*ResourceDefinition) GetIdAccessor 

func (x *ResourceDefinition) GetIdAccessor() string

func (*ResourceDefinition) GetMemoAccessor 

func (x *ResourceDefinition) GetMemoAccessor() string

func (*ResourceDefinition) GetNamespaceAccessor 

func (x *ResourceDefinition) GetNamespaceAccessor() string

func (*ResourceDefinition) GetSupportedOperations 

func (x *ResourceDefinition) GetSupportedOperations() []int32

func (*ResourceDefinition) ProtoMessage 

func (*ResourceDefinition) ProtoMessage()

func (*ResourceDefinition) ProtoReflect 

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

func (*ResourceDefinition) Reset 

func (x *ResourceDefinition) Reset()

func (*ResourceDefinition) String 

func (x *ResourceDefinition) String() string

type ResourceError 

type ResourceError struct {
	Code        string   `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`               // e.g. "FORBIDDEN", "NOT_FOUND", "INTERNAL"
	Title       string   `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`             // human-readable title, e.g. "Access denied"
	Message     string   `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`         // detailed error message
	Suggestions []string `protobuf:"bytes,4,rep,name=suggestions,proto3" json:"suggestions,omitempty"` // user-facing suggestions
	// contains filtered or unexported fields
}

ResourceError is a structured error shared across resource sub-protos. Used by CRUD responses, informer state events, and anywhere a structured error needs to cross the gRPC boundary.

func (*ResourceError) Descriptor deprecated 

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

Deprecated: Use ResourceError.ProtoReflect.Descriptor instead.

func (*ResourceError) GetCode 

func (x *ResourceError) GetCode() string

func (*ResourceError) GetMessage 

func (x *ResourceError) GetMessage() string

func (*ResourceError) GetSuggestions 

func (x *ResourceError) GetSuggestions() []string

func (*ResourceError) GetTitle 

func (x *ResourceError) GetTitle() string

func (*ResourceError) ProtoMessage 

func (*ResourceError) ProtoMessage()

func (*ResourceError) ProtoReflect 

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

func (*ResourceError) Reset 

func (x *ResourceError) Reset()

func (*ResourceError) String 

func (x *ResourceError) String() string

type ResourceGroup 

type ResourceGroup 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"`
	Description string                  `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Icon        string                  `protobuf:"bytes,4,opt,name=icon,proto3" json:"icon,omitempty"`
	Resources   *VersionedResourceTypes `protobuf:"bytes,5,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceGroup) Descriptor deprecated 

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

Deprecated: Use ResourceGroup.ProtoReflect.Descriptor instead.

func (*ResourceGroup) GetDescription 

func (x *ResourceGroup) GetDescription() string

func (*ResourceGroup) GetIcon 

func (x *ResourceGroup) GetIcon() string

func (*ResourceGroup) GetId 

func (x *ResourceGroup) GetId() string

func (*ResourceGroup) GetName 

func (x *ResourceGroup) GetName() string

func (*ResourceGroup) GetResources 

func (x *ResourceGroup) GetResources() *VersionedResourceTypes

func (*ResourceGroup) ProtoMessage 

func (*ResourceGroup) ProtoMessage()

func (*ResourceGroup) ProtoReflect 

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

func (*ResourceGroup) Reset 

func (x *ResourceGroup) Reset()

func (*ResourceGroup) String 

func (x *ResourceGroup) String() string

type ResourceGroupListRequest 

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

func (*ResourceGroupListRequest) Descriptor deprecated 

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

Deprecated: Use ResourceGroupListRequest.ProtoReflect.Descriptor instead.

func (*ResourceGroupListRequest) GetConnectionId 

func (x *ResourceGroupListRequest) GetConnectionId() string

func (*ResourceGroupListRequest) ProtoMessage 

func (*ResourceGroupListRequest) ProtoMessage()

func (*ResourceGroupListRequest) ProtoReflect 

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

func (*ResourceGroupListRequest) Reset 

func (x *ResourceGroupListRequest) Reset()

func (*ResourceGroupListRequest) String 

func (x *ResourceGroupListRequest) String() string

type ResourceGroupListResponse 

type ResourceGroupListResponse struct {
	Groups map[string]*ResourceGroup `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ResourceGroupListResponse) Descriptor deprecated 

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

Deprecated: Use ResourceGroupListResponse.ProtoReflect.Descriptor instead.

func (*ResourceGroupListResponse) GetGroups 

func (x *ResourceGroupListResponse) GetGroups() map[string]*ResourceGroup

func (*ResourceGroupListResponse) ProtoMessage 

func (*ResourceGroupListResponse) ProtoMessage()

func (*ResourceGroupListResponse) ProtoReflect 

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

func (*ResourceGroupListResponse) Reset 

func (x *ResourceGroupListResponse) Reset()

func (*ResourceGroupListResponse) String 

func (x *ResourceGroupListResponse) String() string

type ResourceGroupRequest 

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

func (*ResourceGroupRequest) Descriptor deprecated 

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

Deprecated: Use ResourceGroupRequest.ProtoReflect.Descriptor instead.

func (*ResourceGroupRequest) GetId 

func (x *ResourceGroupRequest) GetId() string

func (*ResourceGroupRequest) ProtoMessage 

func (*ResourceGroupRequest) ProtoMessage()

func (*ResourceGroupRequest) ProtoReflect 

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

func (*ResourceGroupRequest) Reset 

func (x *ResourceGroupRequest) Reset()

func (*ResourceGroupRequest) String 

func (x *ResourceGroupRequest) String() string
type ResourceLink struct {
	IdAccessor        string            `protobuf:"bytes,1,opt,name=id_accessor,json=idAccessor,proto3" json:"id_accessor,omitempty"`
	NamespaceAccessor string            `protobuf:"bytes,2,opt,name=namespace_accessor,json=namespaceAccessor,proto3" json:"namespace_accessor,omitempty"`
	Key               string            `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	KeyAccessor       string            `protobuf:"bytes,4,opt,name=key_accessor,json=keyAccessor,proto3" json:"key_accessor,omitempty"`
	KeyMap            map[string]string `` /* 153-byte string literal not displayed */
	DetailExtractors  map[string]string `` /* 183-byte string literal not displayed */
	Namespaced        bool              `protobuf:"varint,7,opt,name=namespaced,proto3" json:"namespaced,omitempty"`
	DisplayId         bool              `protobuf:"varint,8,opt,name=display_id,json=displayId,proto3" json:"display_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceLink) Descriptor deprecated 

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

Deprecated: Use ResourceLink.ProtoReflect.Descriptor instead.

func (*ResourceLink) GetDetailExtractors 

func (x *ResourceLink) GetDetailExtractors() map[string]string

func (*ResourceLink) GetDisplayId 

func (x *ResourceLink) GetDisplayId() bool

func (*ResourceLink) GetIdAccessor 

func (x *ResourceLink) GetIdAccessor() string

func (*ResourceLink) GetKey 

func (x *ResourceLink) GetKey() string

func (*ResourceLink) GetKeyAccessor 

func (x *ResourceLink) GetKeyAccessor() string

func (*ResourceLink) GetKeyMap 

func (x *ResourceLink) GetKeyMap() map[string]string

func (*ResourceLink) GetNamespaceAccessor 

func (x *ResourceLink) GetNamespaceAccessor() string

func (*ResourceLink) GetNamespaced 

func (x *ResourceLink) GetNamespaced() bool

func (*ResourceLink) ProtoMessage 

func (*ResourceLink) ProtoMessage()

func (*ResourceLink) ProtoReflect 

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

func (*ResourceLink) Reset 

func (x *ResourceLink) Reset()

func (*ResourceLink) String 

func (x *ResourceLink) String() string

type ResourceMeta 

type ResourceMeta struct {
	Group       string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Version     string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Kind        string `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Category    string `protobuf:"bytes,5,opt,name=category,proto3" json:"category,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceMeta) Descriptor deprecated 

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

Deprecated: Use ResourceMeta.ProtoReflect.Descriptor instead.

func (*ResourceMeta) GetCategory 

func (x *ResourceMeta) GetCategory() string

func (*ResourceMeta) GetDescription 

func (x *ResourceMeta) GetDescription() string

func (*ResourceMeta) GetGroup 

func (x *ResourceMeta) GetGroup() string

func (*ResourceMeta) GetKind 

func (x *ResourceMeta) GetKind() string

func (*ResourceMeta) GetVersion 

func (x *ResourceMeta) GetVersion() string

func (*ResourceMeta) ProtoMessage 

func (*ResourceMeta) ProtoMessage()

func (*ResourceMeta) ProtoReflect 

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

func (*ResourceMeta) Reset 

func (x *ResourceMeta) Reset()

func (*ResourceMeta) String 

func (x *ResourceMeta) String() string

type ResourcePluginClient 

type ResourcePluginClient interface {
	// Types
	GetResourceGroups(ctx context.Context, in *ResourceGroupListRequest, opts ...grpc.CallOption) (*ResourceGroupListResponse, error)
	GetResourceGroup(ctx context.Context, in *ResourceGroupRequest, opts ...grpc.CallOption) (*ResourceGroup, error)
	GetResourceTypes(ctx context.Context, in *ResourceTypeListRequest, opts ...grpc.CallOption) (*ResourceTypes, error)
	GetResourceType(ctx context.Context, in *ResourceTypeRequest, opts ...grpc.CallOption) (*ResourceMeta, error)
	HasResourceType(ctx context.Context, in *ResourceTypeRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)
	GetResourceDefinition(ctx context.Context, in *ResourceTypeRequest, opts ...grpc.CallOption) (*ResourceDefinition, error)
	// Connection
	StartConnection(ctx context.Context, in *ConnectionRequest, opts ...grpc.CallOption) (*ConnectionStatus, error)
	StopConnection(ctx context.Context, in *ConnectionRequest, opts ...grpc.CallOption) (*Connection, error)
	LoadConnections(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ConnectionList, error)
	ListConnections(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ConnectionList, error)
	GetConnection(ctx context.Context, in *ConnectionRequest, opts ...grpc.CallOption) (*Connection, error)
	GetConnectionNamespaces(ctx context.Context, in *ConnectionRequest, opts ...grpc.CallOption) (*ConnectionNamespacesResponse, error)
	UpdateConnection(ctx context.Context, in *UpdateConnectionRequest, opts ...grpc.CallOption) (*Connection, error)
	DeleteConnection(ctx context.Context, in *ConnectionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	WatchConnections(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (ResourcePlugin_WatchConnectionsClient, error)
	// Resource
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	Find(ctx context.Context, in *FindRequest, opts ...grpc.CallOption) (*FindResponse, error)
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Informers
	HasInformer(ctx context.Context, in *HasInformerRequest, opts ...grpc.CallOption) (*wrapperspb.BoolValue, error)
	StartConnectionInformer(ctx context.Context, in *StartConnectionInformerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	StopConnectionInformer(ctx context.Context, in *StopConnectionInformerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListenForEvents(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (ResourcePlugin_ListenForEventsClient, error)
	GetInformerState(ctx context.Context, in *GetInformerStateRequest, opts ...grpc.CallOption) (*InformerConnectionSummary, error)
	EnsureInformerForResource(ctx context.Context, in *EnsureInformerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Layout
	GetLayout(ctx context.Context, in *GetLayoutRequest, opts ...grpc.CallOption) (*Layout, error)
	GetDefaultLayout(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Layout, error)
	SetLayout(ctx context.Context, in *SetLayoutRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Actions
	GetActions(ctx context.Context, in *GetActionsRequest, opts ...grpc.CallOption) (*GetActionsResponse, error)
	ExecuteAction(ctx context.Context, in *ExecuteActionRequest, opts ...grpc.CallOption) (*ExecuteActionResponse, error)
	StreamAction(ctx context.Context, in *ExecuteActionRequest, opts ...grpc.CallOption) (ResourcePlugin_StreamActionClient, error)
	// Schemas
	GetEditorSchemas(ctx context.Context, in *GetEditorSchemasRequest, opts ...grpc.CallOption) (*EditorSchemaList, error)
}

ResourcePluginClient is the client API for ResourcePlugin 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 NewResourcePluginClient 

func NewResourcePluginClient(cc grpc.ClientConnInterface) ResourcePluginClient

type ResourcePluginServer 

type ResourcePluginServer interface {
	// Types
	GetResourceGroups(context.Context, *ResourceGroupListRequest) (*ResourceGroupListResponse, error)
	GetResourceGroup(context.Context, *ResourceGroupRequest) (*ResourceGroup, error)
	GetResourceTypes(context.Context, *ResourceTypeListRequest) (*ResourceTypes, error)
	GetResourceType(context.Context, *ResourceTypeRequest) (*ResourceMeta, error)
	HasResourceType(context.Context, *ResourceTypeRequest) (*wrapperspb.BoolValue, error)
	GetResourceDefinition(context.Context, *ResourceTypeRequest) (*ResourceDefinition, error)
	// Connection
	StartConnection(context.Context, *ConnectionRequest) (*ConnectionStatus, error)
	StopConnection(context.Context, *ConnectionRequest) (*Connection, error)
	LoadConnections(context.Context, *emptypb.Empty) (*ConnectionList, error)
	ListConnections(context.Context, *emptypb.Empty) (*ConnectionList, error)
	GetConnection(context.Context, *ConnectionRequest) (*Connection, error)
	GetConnectionNamespaces(context.Context, *ConnectionRequest) (*ConnectionNamespacesResponse, error)
	UpdateConnection(context.Context, *UpdateConnectionRequest) (*Connection, error)
	DeleteConnection(context.Context, *ConnectionRequest) (*emptypb.Empty, error)
	WatchConnections(*emptypb.Empty, ResourcePlugin_WatchConnectionsServer) error
	// Resource
	Get(context.Context, *GetRequest) (*GetResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	Find(context.Context, *FindRequest) (*FindResponse, error)
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// Informers
	HasInformer(context.Context, *HasInformerRequest) (*wrapperspb.BoolValue, error)
	StartConnectionInformer(context.Context, *StartConnectionInformerRequest) (*emptypb.Empty, error)
	StopConnectionInformer(context.Context, *StopConnectionInformerRequest) (*emptypb.Empty, error)
	ListenForEvents(*emptypb.Empty, ResourcePlugin_ListenForEventsServer) error
	GetInformerState(context.Context, *GetInformerStateRequest) (*InformerConnectionSummary, error)
	EnsureInformerForResource(context.Context, *EnsureInformerRequest) (*emptypb.Empty, error)
	// Layout
	GetLayout(context.Context, *GetLayoutRequest) (*Layout, error)
	GetDefaultLayout(context.Context, *emptypb.Empty) (*Layout, error)
	SetLayout(context.Context, *SetLayoutRequest) (*emptypb.Empty, error)
	// Actions
	GetActions(context.Context, *GetActionsRequest) (*GetActionsResponse, error)
	ExecuteAction(context.Context, *ExecuteActionRequest) (*ExecuteActionResponse, error)
	StreamAction(*ExecuteActionRequest, ResourcePlugin_StreamActionServer) error
	// Schemas
	GetEditorSchemas(context.Context, *GetEditorSchemasRequest) (*EditorSchemaList, error)
}

ResourcePluginServer is the server API for ResourcePlugin service. All implementations should embed UnimplementedResourcePluginServer for forward compatibility

type ResourcePlugin_ListenForEventsClient 

type ResourcePlugin_ListenForEventsClient interface {
	Recv() (*InformerEvent, error)
	grpc.ClientStream
}

type ResourcePlugin_ListenForEventsServer 

type ResourcePlugin_ListenForEventsServer interface {
	Send(*InformerEvent) error
	grpc.ServerStream
}

type ResourcePlugin_StreamActionClient 

type ResourcePlugin_StreamActionClient interface {
	Recv() (*StreamActionEvent, error)
	grpc.ClientStream
}

type ResourcePlugin_StreamActionServer 

type ResourcePlugin_StreamActionServer interface {
	Send(*StreamActionEvent) error
	grpc.ServerStream
}

type ResourcePlugin_WatchConnectionsClient 

type ResourcePlugin_WatchConnectionsClient interface {
	Recv() (*ConnectionList, error)
	grpc.ClientStream
}

type ResourcePlugin_WatchConnectionsServer 

type ResourcePlugin_WatchConnectionsServer interface {
	Send(*ConnectionList) error
	grpc.ServerStream
}

type ResourceTypeListRequest 

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

func (*ResourceTypeListRequest) Descriptor deprecated 

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

Deprecated: Use ResourceTypeListRequest.ProtoReflect.Descriptor instead.

func (*ResourceTypeListRequest) GetConnectionId 

func (x *ResourceTypeListRequest) GetConnectionId() string

func (*ResourceTypeListRequest) ProtoMessage 

func (*ResourceTypeListRequest) ProtoMessage()

func (*ResourceTypeListRequest) ProtoReflect 

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

func (*ResourceTypeListRequest) Reset 

func (x *ResourceTypeListRequest) Reset()

func (*ResourceTypeListRequest) String 

func (x *ResourceTypeListRequest) String() string

type ResourceTypeRequest 

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

func (*ResourceTypeRequest) Descriptor deprecated 

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

Deprecated: Use ResourceTypeRequest.ProtoReflect.Descriptor instead.

func (*ResourceTypeRequest) GetId 

func (x *ResourceTypeRequest) GetId() string

func (*ResourceTypeRequest) ProtoMessage 

func (*ResourceTypeRequest) ProtoMessage()

func (*ResourceTypeRequest) ProtoReflect 

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

func (*ResourceTypeRequest) Reset 

func (x *ResourceTypeRequest) Reset()

func (*ResourceTypeRequest) String 

func (x *ResourceTypeRequest) String() string

type ResourceTypes 

type ResourceTypes struct {
	Types []*ResourceMeta `protobuf:"bytes,1,rep,name=types,proto3" json:"types,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceTypes) Descriptor deprecated 

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

Deprecated: Use ResourceTypes.ProtoReflect.Descriptor instead.

func (*ResourceTypes) GetTypes 

func (x *ResourceTypes) GetTypes() []*ResourceMeta

func (*ResourceTypes) ProtoMessage 

func (*ResourceTypes) ProtoMessage()

func (*ResourceTypes) ProtoReflect 

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

func (*ResourceTypes) Reset 

func (x *ResourceTypes) Reset()

func (*ResourceTypes) String 

func (x *ResourceTypes) String() string

type RunStreamRequest 

type RunStreamRequest struct {
	PluginContext *PluginContext `protobuf:"bytes,1,opt,name=plugin_context,json=pluginContext,proto3" json:"plugin_context,omitempty"`
	Path          string         `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*RunStreamRequest) Descriptor deprecated 

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

Deprecated: Use RunStreamRequest.ProtoReflect.Descriptor instead.

func (*RunStreamRequest) GetPath 

func (x *RunStreamRequest) GetPath() string

func (*RunStreamRequest) GetPluginContext 

func (x *RunStreamRequest) GetPluginContext() *PluginContext

func (*RunStreamRequest) ProtoMessage 

func (*RunStreamRequest) ProtoMessage()

func (*RunStreamRequest) ProtoReflect 

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

func (*RunStreamRequest) Reset 

func (x *RunStreamRequest) Reset()

func (*RunStreamRequest) String 

func (x *RunStreamRequest) String() string

type ServingStatus added in v0.1.1 

type ServingStatus int32
const (
	ServingStatus_UNKNOWN     ServingStatus = 0
	ServingStatus_SERVING     ServingStatus = 1
	ServingStatus_NOT_SERVING ServingStatus = 2
)

func (ServingStatus) Descriptor added in v0.1.1 

func (ServingStatus) Descriptor() protoreflect.EnumDescriptor

func (ServingStatus) Enum added in v0.1.1 

func (x ServingStatus) Enum() *ServingStatus

func (ServingStatus) EnumDescriptor deprecated added in v0.1.1 

func (ServingStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use ServingStatus.Descriptor instead.

func (ServingStatus) Number added in v0.1.1 

func (x ServingStatus) Number() protoreflect.EnumNumber

func (ServingStatus) String added in v0.1.1 

func (x ServingStatus) String() string

func (ServingStatus) Type added in v0.1.1 

func (ServingStatus) Type() protoreflect.EnumType

type Session 

type Session struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Attached  bool                   `protobuf:"varint,2,opt,name=attached,proto3" json:"attached,omitempty"`
	Command   []string               `protobuf:"bytes,3,rep,name=command,proto3" json:"command,omitempty"`
	Params    map[string]string      `` /* 139-byte string literal not displayed */
	Labels    map[string]string      `` /* 139-byte string literal not displayed */
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Session) Descriptor deprecated 

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

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetAttached 

func (x *Session) GetAttached() bool

func (*Session) GetCommand 

func (x *Session) GetCommand() []string

func (*Session) GetCreatedAt 

func (x *Session) GetCreatedAt() *timestamppb.Timestamp

func (*Session) GetId 

func (x *Session) GetId() string

func (*Session) GetLabels 

func (x *Session) GetLabels() map[string]string

func (*Session) GetParams 

func (x *Session) GetParams() map[string]string

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) ProtoReflect 

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

func (*Session) Reset 

func (x *Session) Reset()

func (*Session) String 

func (x *Session) String() string

type SessionOptions 

type SessionOptions struct {
	Id             string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Command        []string          `protobuf:"bytes,2,rep,name=command,proto3" json:"command,omitempty"`
	Tty            bool              `protobuf:"varint,3,opt,name=tty,proto3" json:"tty,omitempty"`
	Params         map[string]string `` /* 139-byte string literal not displayed */
	Labels         map[string]string `` /* 139-byte string literal not displayed */
	ResourcePlugin string            `protobuf:"bytes,6,opt,name=resource_plugin,json=resourcePlugin,proto3" json:"resource_plugin,omitempty"`
	ResourceKey    string            `protobuf:"bytes,7,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ResourceData   *structpb.Struct  `protobuf:"bytes,8,opt,name=resource_data,json=resourceData,proto3" json:"resource_data,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionOptions) Descriptor deprecated 

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

Deprecated: Use SessionOptions.ProtoReflect.Descriptor instead.

func (*SessionOptions) GetCommand 

func (x *SessionOptions) GetCommand() []string

func (*SessionOptions) GetId 

func (x *SessionOptions) GetId() string

func (*SessionOptions) GetLabels 

func (x *SessionOptions) GetLabels() map[string]string

func (*SessionOptions) GetParams 

func (x *SessionOptions) GetParams() map[string]string

func (*SessionOptions) GetResourceData 

func (x *SessionOptions) GetResourceData() *structpb.Struct

func (*SessionOptions) GetResourceKey 

func (x *SessionOptions) GetResourceKey() string

func (*SessionOptions) GetResourcePlugin 

func (x *SessionOptions) GetResourcePlugin() string

func (*SessionOptions) GetTty 

func (x *SessionOptions) GetTty() bool

func (*SessionOptions) ProtoMessage 

func (*SessionOptions) ProtoMessage()

func (*SessionOptions) ProtoReflect 

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

func (*SessionOptions) Reset 

func (x *SessionOptions) Reset()

func (*SessionOptions) String 

func (x *SessionOptions) String() string

type SetLayoutRequest 

type SetLayoutRequest struct {
	Id     string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Layout *Layout `protobuf:"bytes,2,opt,name=layout,proto3" json:"layout,omitempty"`
	// contains filtered or unexported fields
}

func (*SetLayoutRequest) Descriptor deprecated 

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

Deprecated: Use SetLayoutRequest.ProtoReflect.Descriptor instead.

func (*SetLayoutRequest) GetId 

func (x *SetLayoutRequest) GetId() string

func (*SetLayoutRequest) GetLayout 

func (x *SetLayoutRequest) GetLayout() *Layout

func (*SetLayoutRequest) ProtoMessage 

func (*SetLayoutRequest) ProtoMessage()

func (*SetLayoutRequest) ProtoReflect 

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

func (*SetLayoutRequest) Reset 

func (x *SetLayoutRequest) Reset()

func (*SetLayoutRequest) String 

func (x *SetLayoutRequest) String() string

type SetSettingRequest 

type SetSettingRequest struct {
	Id    string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Value *anypb.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SetSettingRequest) Descriptor deprecated 

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

Deprecated: Use SetSettingRequest.ProtoReflect.Descriptor instead.

func (*SetSettingRequest) GetId 

func (x *SetSettingRequest) GetId() string

func (*SetSettingRequest) GetValue 

func (x *SetSettingRequest) GetValue() *anypb.Any

func (*SetSettingRequest) ProtoMessage 

func (*SetSettingRequest) ProtoMessage()

func (*SetSettingRequest) ProtoReflect 

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

func (*SetSettingRequest) Reset 

func (x *SetSettingRequest) Reset()

func (*SetSettingRequest) String 

func (x *SetSettingRequest) String() string

type SetSettingsRequest 

type SetSettingsRequest struct {
	Settings map[string]*anypb.Any `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SetSettingsRequest) Descriptor deprecated 

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

Deprecated: Use SetSettingsRequest.ProtoReflect.Descriptor instead.

func (*SetSettingsRequest) GetSettings 

func (x *SetSettingsRequest) GetSettings() map[string]*anypb.Any

func (*SetSettingsRequest) ProtoMessage 

func (*SetSettingsRequest) ProtoMessage()

func (*SetSettingsRequest) ProtoReflect 

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

func (*SetSettingsRequest) Reset 

func (x *SetSettingsRequest) Reset()

func (*SetSettingsRequest) String 

func (x *SetSettingsRequest) String() string

type Setting 

type Setting struct {
	Id            string                `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Label         string                `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Description   string                `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Type          SettingType           `protobuf:"varint,4,opt,name=type,proto3,enum=com.omniview.pluginsdk.SettingType" json:"type,omitempty"`
	Value         *anypb.Any            `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	Default       *anypb.Any            `protobuf:"bytes,6,opt,name=default,proto3" json:"default,omitempty"`
	Options       []*SettingOption      `protobuf:"bytes,7,rep,name=options,proto3" json:"options,omitempty"`
	FileSelection *SettingFileSelection `protobuf:"bytes,8,opt,name=file_selection,json=fileSelection,proto3,oneof" json:"file_selection,omitempty"`
	// contains filtered or unexported fields
}

func (*Setting) Descriptor deprecated 

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

Deprecated: Use Setting.ProtoReflect.Descriptor instead.

func (*Setting) GetDefault 

func (x *Setting) GetDefault() *anypb.Any

func (*Setting) GetDescription 

func (x *Setting) GetDescription() string

func (*Setting) GetFileSelection 

func (x *Setting) GetFileSelection() *SettingFileSelection

func (*Setting) GetId 

func (x *Setting) GetId() string

func (*Setting) GetLabel 

func (x *Setting) GetLabel() string

func (*Setting) GetOptions 

func (x *Setting) GetOptions() []*SettingOption

func (*Setting) GetType 

func (x *Setting) GetType() SettingType

func (*Setting) GetValue 

func (x *Setting) GetValue() *anypb.Any

func (*Setting) ProtoMessage 

func (*Setting) ProtoMessage()

func (*Setting) ProtoReflect 

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

func (*Setting) Reset 

func (x *Setting) Reset()

func (*Setting) String 

func (x *Setting) String() string

type SettingFileSelection 

type SettingFileSelection struct {
	Enabled      bool     `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	AllowFolders bool     `protobuf:"varint,2,opt,name=allow_folders,json=allowFolders,proto3" json:"allow_folders,omitempty"`
	Extensions   []string `protobuf:"bytes,3,rep,name=extensions,proto3" json:"extensions,omitempty"`
	Multiple     bool     `protobuf:"varint,4,opt,name=multiple,proto3" json:"multiple,omitempty"`
	Relative     bool     `protobuf:"varint,5,opt,name=relative,proto3" json:"relative,omitempty"`
	DefaultPath  string   `protobuf:"bytes,6,opt,name=default_path,json=defaultPath,proto3" json:"default_path,omitempty"`
	// contains filtered or unexported fields
}

func (*SettingFileSelection) Descriptor deprecated 

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

Deprecated: Use SettingFileSelection.ProtoReflect.Descriptor instead.

func (*SettingFileSelection) GetAllowFolders 

func (x *SettingFileSelection) GetAllowFolders() bool

func (*SettingFileSelection) GetDefaultPath 

func (x *SettingFileSelection) GetDefaultPath() string

func (*SettingFileSelection) GetEnabled 

func (x *SettingFileSelection) GetEnabled() bool

func (*SettingFileSelection) GetExtensions 

func (x *SettingFileSelection) GetExtensions() []string

func (*SettingFileSelection) GetMultiple 

func (x *SettingFileSelection) GetMultiple() bool

func (*SettingFileSelection) GetRelative 

func (x *SettingFileSelection) GetRelative() bool

func (*SettingFileSelection) ProtoMessage 

func (*SettingFileSelection) ProtoMessage()

func (*SettingFileSelection) ProtoReflect 

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

func (*SettingFileSelection) Reset 

func (x *SettingFileSelection) Reset()

func (*SettingFileSelection) String 

func (x *SettingFileSelection) String() string

type SettingOption 

type SettingOption struct {
	Label       string     `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Description string     `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Value       *anypb.Any `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SettingOption) Descriptor deprecated 

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

Deprecated: Use SettingOption.ProtoReflect.Descriptor instead.

func (*SettingOption) GetDescription 

func (x *SettingOption) GetDescription() string

func (*SettingOption) GetLabel 

func (x *SettingOption) GetLabel() string

func (*SettingOption) GetValue 

func (x *SettingOption) GetValue() *anypb.Any

func (*SettingOption) ProtoMessage 

func (*SettingOption) ProtoMessage()

func (*SettingOption) ProtoReflect 

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

func (*SettingOption) Reset 

func (x *SettingOption) Reset()

func (*SettingOption) String 

func (x *SettingOption) String() string

type SettingType 

type SettingType int32
const (
	SettingType_TEXT     SettingType = 0
	SettingType_INTEGER  SettingType = 1
	SettingType_FLOAT    SettingType = 2
	SettingType_TOGGLE   SettingType = 3
	SettingType_COLOR    SettingType = 4
	SettingType_DATETIME SettingType = 5
	SettingType_PASSWORD SettingType = 6
)

func (SettingType) Descriptor 

func (SettingType) Descriptor() protoreflect.EnumDescriptor

func (SettingType) Enum 

func (x SettingType) Enum() *SettingType

func (SettingType) EnumDescriptor deprecated 

func (SettingType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SettingType.Descriptor instead.

func (SettingType) Number 

func (x SettingType) Number() protoreflect.EnumNumber

func (SettingType) String 

func (x SettingType) String() string

func (SettingType) Type 

func (SettingType) Type() protoreflect.EnumType

type SettingsCategory 

type SettingsCategory struct {
	Id          string              `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Label       string              `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Description string              `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Icon        string              `protobuf:"bytes,4,opt,name=icon,proto3" json:"icon,omitempty"`
	Settings    map[string]*Setting `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SettingsCategory) Descriptor deprecated 

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

Deprecated: Use SettingsCategory.ProtoReflect.Descriptor instead.

func (*SettingsCategory) GetDescription 

func (x *SettingsCategory) GetDescription() string

func (*SettingsCategory) GetIcon 

func (x *SettingsCategory) GetIcon() string

func (*SettingsCategory) GetId 

func (x *SettingsCategory) GetId() string

func (*SettingsCategory) GetLabel 

func (x *SettingsCategory) GetLabel() string

func (*SettingsCategory) GetSettings 

func (x *SettingsCategory) GetSettings() map[string]*Setting

func (*SettingsCategory) ProtoMessage 

func (*SettingsCategory) ProtoMessage()

func (*SettingsCategory) ProtoReflect 

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

func (*SettingsCategory) Reset 

func (x *SettingsCategory) Reset()

func (*SettingsCategory) String 

func (x *SettingsCategory) String() string

type SettingsPluginClient 

type SettingsPluginClient interface {
	ListSettings(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListSettingsResponse, error)
	GetSetting(ctx context.Context, in *GetSettingRequest, opts ...grpc.CallOption) (*Setting, error)
	GetSettingValue(ctx context.Context, in *GetSettingValueRequest, opts ...grpc.CallOption) (*GetSettingValueResponse, error)
	SetSetting(ctx context.Context, in *SetSettingRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SetSettings(ctx context.Context, in *SetSettingsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

SettingsPluginClient is the client API for SettingsPlugin 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 NewSettingsPluginClient 

func NewSettingsPluginClient(cc grpc.ClientConnInterface) SettingsPluginClient

type SettingsPluginServer 

type SettingsPluginServer interface {
	ListSettings(context.Context, *emptypb.Empty) (*ListSettingsResponse, error)
	GetSetting(context.Context, *GetSettingRequest) (*Setting, error)
	GetSettingValue(context.Context, *GetSettingValueRequest) (*GetSettingValueResponse, error)
	SetSetting(context.Context, *SetSettingRequest) (*emptypb.Empty, error)
	SetSettings(context.Context, *SetSettingsRequest) (*emptypb.Empty, error)
}

SettingsPluginServer is the server API for SettingsPlugin service. All implementations should embed UnimplementedSettingsPluginServer for forward compatibility

type StartConnectionInformerRequest 

type StartConnectionInformerRequest struct {
	Key        string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Connection string `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

func (*StartConnectionInformerRequest) Descriptor deprecated 

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

Deprecated: Use StartConnectionInformerRequest.ProtoReflect.Descriptor instead.

func (*StartConnectionInformerRequest) GetConnection 

func (x *StartConnectionInformerRequest) GetConnection() string

func (*StartConnectionInformerRequest) GetKey 

func (x *StartConnectionInformerRequest) GetKey() string

func (*StartConnectionInformerRequest) ProtoMessage 

func (*StartConnectionInformerRequest) ProtoMessage()

func (*StartConnectionInformerRequest) ProtoReflect 

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

func (*StartConnectionInformerRequest) Reset 

func (x *StartConnectionInformerRequest) Reset()

func (*StartConnectionInformerRequest) String 

func (x *StartConnectionInformerRequest) String() string

type StopConnectionInformerRequest 

type StopConnectionInformerRequest struct {
	Key        string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Connection string `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

func (*StopConnectionInformerRequest) Descriptor deprecated 

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

Deprecated: Use StopConnectionInformerRequest.ProtoReflect.Descriptor instead.

func (*StopConnectionInformerRequest) GetConnection 

func (x *StopConnectionInformerRequest) GetConnection() string

func (*StopConnectionInformerRequest) GetKey 

func (x *StopConnectionInformerRequest) GetKey() string

func (*StopConnectionInformerRequest) ProtoMessage 

func (*StopConnectionInformerRequest) ProtoMessage()

func (*StopConnectionInformerRequest) ProtoReflect 

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

func (*StopConnectionInformerRequest) Reset 

func (x *StopConnectionInformerRequest) Reset()

func (*StopConnectionInformerRequest) String 

func (x *StopConnectionInformerRequest) String() string

type StreamActionEvent 

type StreamActionEvent struct {
	Type string           `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` // "progress", "output", "error", "complete"
	Data *structpb.Struct `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Streaming action events (for long-running actions like test, lint)

func (*StreamActionEvent) Descriptor deprecated 

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

Deprecated: Use StreamActionEvent.ProtoReflect.Descriptor instead.

func (*StreamActionEvent) GetData 

func (x *StreamActionEvent) GetData() *structpb.Struct

func (*StreamActionEvent) GetType 

func (x *StreamActionEvent) GetType() string

func (*StreamActionEvent) ProtoMessage 

func (*StreamActionEvent) ProtoMessage()

func (*StreamActionEvent) ProtoReflect 

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

func (*StreamActionEvent) Reset 

func (x *StreamActionEvent) Reset()

func (*StreamActionEvent) String 

func (x *StreamActionEvent) String() string

type StreamClient 

type StreamClient interface {
	Subscribe(ctx context.Context, in *SubscribeStreamRequest, opts ...grpc.CallOption) (*SubscribeStreamResponse, error)
	Run(ctx context.Context, in *RunStreamRequest, opts ...grpc.CallOption) (Stream_RunClient, error)
	Publish(ctx context.Context, in *PublishStreamRequest, opts ...grpc.CallOption) (*PublishStreamResponse, error)
}

StreamClient is the client API for Stream 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 NewStreamClient 

func NewStreamClient(cc grpc.ClientConnInterface) StreamClient

type StreamError 

type StreamError struct {
	Title         string   `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Message       string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Suggestion    string   `protobuf:"bytes,3,opt,name=suggestion,proto3" json:"suggestion,omitempty"`
	Retryable     bool     `protobuf:"varint,4,opt,name=retryable,proto3" json:"retryable,omitempty"`
	RetryCommands []string `protobuf:"bytes,5,rep,name=retry_commands,json=retryCommands,proto3" json:"retry_commands,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamError) Descriptor deprecated 

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

Deprecated: Use StreamError.ProtoReflect.Descriptor instead.

func (*StreamError) GetMessage 

func (x *StreamError) GetMessage() string

func (*StreamError) GetRetryCommands 

func (x *StreamError) GetRetryCommands() []string

func (*StreamError) GetRetryable 

func (x *StreamError) GetRetryable() bool

func (*StreamError) GetSuggestion 

func (x *StreamError) GetSuggestion() string

func (*StreamError) GetTitle 

func (x *StreamError) GetTitle() string

func (*StreamError) ProtoMessage 

func (*StreamError) ProtoMessage()

func (*StreamError) ProtoReflect 

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

func (*StreamError) Reset 

func (x *StreamError) Reset()

func (*StreamError) String 

func (x *StreamError) String() string

type StreamInput 

type StreamInput struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamInput) Descriptor deprecated 

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

Deprecated: Use StreamInput.ProtoReflect.Descriptor instead.

func (*StreamInput) GetData 

func (x *StreamInput) GetData() []byte

func (*StreamInput) GetId 

func (x *StreamInput) GetId() string

func (*StreamInput) ProtoMessage 

func (*StreamInput) ProtoMessage()

func (*StreamInput) ProtoReflect 

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

func (*StreamInput) Reset 

func (x *StreamInput) Reset()

func (*StreamInput) String 

func (x *StreamInput) String() string

type StreamOutput 

type StreamOutput struct {
	Id     string              `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Target StreamOutput_Target `protobuf:"varint,2,opt,name=target,proto3,enum=com.omniview.pluginsdk.StreamOutput_Target" json:"target,omitempty"`
	Data   []byte              `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Signal StreamSignal        `protobuf:"varint,4,opt,name=signal,proto3,enum=com.omniview.pluginsdk.StreamSignal" json:"signal,omitempty"`
	Error  *StreamError        `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamOutput) Descriptor deprecated 

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

Deprecated: Use StreamOutput.ProtoReflect.Descriptor instead.

func (*StreamOutput) GetData 

func (x *StreamOutput) GetData() []byte

func (*StreamOutput) GetError 

func (x *StreamOutput) GetError() *StreamError

func (*StreamOutput) GetId 

func (x *StreamOutput) GetId() string

func (*StreamOutput) GetSignal 

func (x *StreamOutput) GetSignal() StreamSignal

func (*StreamOutput) GetTarget 

func (x *StreamOutput) GetTarget() StreamOutput_Target

func (*StreamOutput) ProtoMessage 

func (*StreamOutput) ProtoMessage()

func (*StreamOutput) ProtoReflect 

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

func (*StreamOutput) Reset 

func (x *StreamOutput) Reset()

func (*StreamOutput) String 

func (x *StreamOutput) String() string

type StreamOutput_Target 

type StreamOutput_Target int32
const (
	StreamOutput_STDOUT StreamOutput_Target = 0
	StreamOutput_STDERR StreamOutput_Target = 1
)

func (StreamOutput_Target) Descriptor 

func (StreamOutput_Target) Descriptor() protoreflect.EnumDescriptor

func (StreamOutput_Target) Enum 

func (x StreamOutput_Target) Enum() *StreamOutput_Target

func (StreamOutput_Target) EnumDescriptor deprecated 

func (StreamOutput_Target) EnumDescriptor() ([]byte, []int)

Deprecated: Use StreamOutput_Target.Descriptor instead.

func (StreamOutput_Target) Number 

func (x StreamOutput_Target) Number() protoreflect.EnumNumber

func (StreamOutput_Target) String 

func (x StreamOutput_Target) String() string

func (StreamOutput_Target) Type 

func (StreamOutput_Target) Type() protoreflect.EnumType

type StreamPacket 

type StreamPacket struct {

	// JSON-encoded data to publish into a channel.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPacket) Descriptor deprecated 

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

Deprecated: Use StreamPacket.ProtoReflect.Descriptor instead.

func (*StreamPacket) GetData 

func (x *StreamPacket) GetData() []byte

func (*StreamPacket) ProtoMessage 

func (*StreamPacket) ProtoMessage()

func (*StreamPacket) ProtoReflect 

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

func (*StreamPacket) Reset 

func (x *StreamPacket) Reset()

func (*StreamPacket) String 

func (x *StreamPacket) String() string

type StreamServer 

type StreamServer interface {
	Subscribe(context.Context, *SubscribeStreamRequest) (*SubscribeStreamResponse, error)
	Run(*RunStreamRequest, Stream_RunServer) error
	Publish(context.Context, *PublishStreamRequest) (*PublishStreamResponse, error)
}

StreamServer is the server API for Stream service. All implementations should embed UnimplementedStreamServer for forward compatibility

type StreamSignal 

type StreamSignal int32
const (
	StreamSignal_NONE     StreamSignal = 0
	StreamSignal_CLOSE    StreamSignal = 1
	StreamSignal_SIGINT   StreamSignal = 2
	StreamSignal_SIGQUIT  StreamSignal = 3
	StreamSignal_SIGTERM  StreamSignal = 4
	StreamSignal_SIGKILL  StreamSignal = 5
	StreamSignal_SIGHUP   StreamSignal = 6
	StreamSignal_SIGUSR1  StreamSignal = 7
	StreamSignal_SIGUSR2  StreamSignal = 8
	StreamSignal_SIGWINCH StreamSignal = 9
	StreamSignal_ERROR    StreamSignal = 10
)

func (StreamSignal) Descriptor 

func (StreamSignal) Descriptor() protoreflect.EnumDescriptor

func (StreamSignal) Enum 

func (x StreamSignal) Enum() *StreamSignal

func (StreamSignal) EnumDescriptor deprecated 

func (StreamSignal) EnumDescriptor() ([]byte, []int)

Deprecated: Use StreamSignal.Descriptor instead.

func (StreamSignal) Number 

func (x StreamSignal) Number() protoreflect.EnumNumber

func (StreamSignal) String 

func (x StreamSignal) String() string

func (StreamSignal) Type 

func (StreamSignal) Type() protoreflect.EnumType

type Stream_RunClient 

type Stream_RunClient interface {
	Recv() (*StreamPacket, error)
	grpc.ClientStream
}

type Stream_RunServer 

type Stream_RunServer interface {
	Send(*StreamPacket) error
	grpc.ServerStream
}

type StringList 

type StringList struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*StringList) Descriptor deprecated 

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

Deprecated: Use StringList.ProtoReflect.Descriptor instead.

func (*StringList) GetValues 

func (x *StringList) GetValues() []string

func (*StringList) ProtoMessage 

func (*StringList) ProtoMessage()

func (*StringList) ProtoReflect 

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

func (*StringList) Reset 

func (x *StringList) Reset()

func (*StringList) String 

func (x *StringList) String() string

type SubscribeStreamRequest 

type SubscribeStreamRequest struct {
	PluginContext *PluginContext `protobuf:"bytes,1,opt,name=plugin_context,json=pluginContext,proto3" json:"plugin_context,omitempty"`
	// path part of channel.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeStreamRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeStreamRequest.ProtoReflect.Descriptor instead.

func (*SubscribeStreamRequest) GetPath 

func (x *SubscribeStreamRequest) GetPath() string

func (*SubscribeStreamRequest) GetPluginContext 

func (x *SubscribeStreamRequest) GetPluginContext() *PluginContext

func (*SubscribeStreamRequest) ProtoMessage 

func (*SubscribeStreamRequest) ProtoMessage()

func (*SubscribeStreamRequest) ProtoReflect 

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

func (*SubscribeStreamRequest) Reset 

func (x *SubscribeStreamRequest) Reset()

func (*SubscribeStreamRequest) String 

func (x *SubscribeStreamRequest) String() string

type SubscribeStreamResponse 

type SubscribeStreamResponse struct {

	// status of subscribe response.
	Status SubscribeStreamResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=com.omniview.pluginsdk.SubscribeStreamResponse_Status" json:"status,omitempty"`
	// JSON-encoded data to return to a client in a successful
	// subscription result.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeStreamResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeStreamResponse.ProtoReflect.Descriptor instead.

func (*SubscribeStreamResponse) GetData 

func (x *SubscribeStreamResponse) GetData() []byte

func (*SubscribeStreamResponse) GetStatus 

func (x *SubscribeStreamResponse) GetStatus() SubscribeStreamResponse_Status

func (*SubscribeStreamResponse) ProtoMessage 

func (*SubscribeStreamResponse) ProtoMessage()

func (*SubscribeStreamResponse) ProtoReflect 

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

func (*SubscribeStreamResponse) Reset 

func (x *SubscribeStreamResponse) Reset()

func (*SubscribeStreamResponse) String 

func (x *SubscribeStreamResponse) String() string

type SubscribeStreamResponse_Status 

type SubscribeStreamResponse_Status int32
const (
	SubscribeStreamResponse_OK                SubscribeStreamResponse_Status = 0
	SubscribeStreamResponse_NOT_FOUND         SubscribeStreamResponse_Status = 1
	SubscribeStreamResponse_PERMISSION_DENIED SubscribeStreamResponse_Status = 2
)

func (SubscribeStreamResponse_Status) Descriptor 

func (SubscribeStreamResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (SubscribeStreamResponse_Status) Enum 

func (x SubscribeStreamResponse_Status) Enum() *SubscribeStreamResponse_Status

func (SubscribeStreamResponse_Status) EnumDescriptor deprecated 

func (SubscribeStreamResponse_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use SubscribeStreamResponse_Status.Descriptor instead.

func (SubscribeStreamResponse_Status) Number 

func (x SubscribeStreamResponse_Status) Number() protoreflect.EnumNumber

func (SubscribeStreamResponse_Status) String 

func (x SubscribeStreamResponse_Status) String() string

func (SubscribeStreamResponse_Status) Type 

func (SubscribeStreamResponse_Status) Type() protoreflect.EnumType

type TimeSeries 

type TimeSeries struct {
	MetricId   string            `protobuf:"bytes,1,opt,name=metric_id,json=metricId,proto3" json:"metric_id,omitempty"`
	DataPoints []*DataPoint      `protobuf:"bytes,2,rep,name=data_points,json=dataPoints,proto3" json:"data_points,omitempty"`
	Labels     map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TimeSeries) Descriptor deprecated 

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

Deprecated: Use TimeSeries.ProtoReflect.Descriptor instead.

func (*TimeSeries) GetDataPoints 

func (x *TimeSeries) GetDataPoints() []*DataPoint

func (*TimeSeries) GetLabels 

func (x *TimeSeries) GetLabels() map[string]string

func (*TimeSeries) GetMetricId 

func (x *TimeSeries) GetMetricId() string

func (*TimeSeries) ProtoMessage 

func (*TimeSeries) ProtoMessage()

func (*TimeSeries) ProtoReflect 

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

func (*TimeSeries) Reset 

func (x *TimeSeries) Reset()

func (*TimeSeries) String 

func (x *TimeSeries) String() string

type UnimplementedCommandServer 

type UnimplementedCommandServer struct {
}

UnimplementedCommandServer should be embedded to have forward compatible implementations.

func (UnimplementedCommandServer) Call 

func (UnimplementedCommandServer) Call(context.Context, *CallCommandRequest) (*CallCommandResponse, error)

type UnimplementedExecPluginServer 

type UnimplementedExecPluginServer struct {
}

UnimplementedExecPluginServer should be embedded to have forward compatible implementations.

func (UnimplementedExecPluginServer) AttachSession 

func (UnimplementedExecPluginServer) AttachSession(context.Context, *AttachSessionRequest) (*AttachSessionResponse, error)

func (UnimplementedExecPluginServer) CloseSession 

func (UnimplementedExecPluginServer) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)

func (UnimplementedExecPluginServer) CreateSession 

func (UnimplementedExecPluginServer) CreateSession(context.Context, *SessionOptions) (*CreateSessionResponse, error)

func (UnimplementedExecPluginServer) DetachSession 

func (UnimplementedExecPluginServer) DetachSession(context.Context, *AttachSessionRequest) (*AttachSessionResponse, error)

func (UnimplementedExecPluginServer) GetSession 

func (UnimplementedExecPluginServer) GetSession(context.Context, *GetSessionRequest) (*GetSessionResponse, error)

func (UnimplementedExecPluginServer) GetSupportedResources 

func (UnimplementedExecPluginServer) GetSupportedResources(context.Context, *emptypb.Empty) (*GetSupportedResourcesResponse, error)

func (UnimplementedExecPluginServer) ListSessions 

func (UnimplementedExecPluginServer) ListSessions(context.Context, *emptypb.Empty) (*ListSessionsResponse, error)

func (UnimplementedExecPluginServer) ResizeSession 

func (UnimplementedExecPluginServer) ResizeSession(context.Context, *ResizeSessionRequest) (*ResizeSessionResponse, error)

func (UnimplementedExecPluginServer) Stream 

func (UnimplementedExecPluginServer) Stream(ExecPlugin_StreamServer) error

type UnimplementedLogPluginServer 

type UnimplementedLogPluginServer struct {
}

UnimplementedLogPluginServer should be embedded to have forward compatible implementations.

func (UnimplementedLogPluginServer) CloseSession 

func (UnimplementedLogPluginServer) CloseSession(context.Context, *LogSessionByIdRequest) (*CloseLogSessionResponse, error)

func (UnimplementedLogPluginServer) CreateSession 

func (UnimplementedLogPluginServer) CreateSession(context.Context, *CreateLogSessionRequest) (*CreateLogSessionResponse, error)

func (UnimplementedLogPluginServer) GetSession 

func (UnimplementedLogPluginServer) GetSession(context.Context, *LogSessionByIdRequest) (*LogSessionByIdResponse, error)

func (UnimplementedLogPluginServer) GetSupportedResources 

func (UnimplementedLogPluginServer) GetSupportedResources(context.Context, *emptypb.Empty) (*GetSupportedLogResourcesResponse, error)

func (UnimplementedLogPluginServer) ListSessions 

func (UnimplementedLogPluginServer) ListSessions(context.Context, *emptypb.Empty) (*ListLogSessionsResponse, error)

func (UnimplementedLogPluginServer) Stream 

func (UnimplementedLogPluginServer) Stream(LogPlugin_StreamServer) error

func (UnimplementedLogPluginServer) UpdateSessionOptions 

func (UnimplementedLogPluginServer) UpdateSessionOptions(context.Context, *UpdateLogSessionOptionsRequest) (*LogSessionByIdResponse, error)

type UnimplementedMetricPluginServer 

type UnimplementedMetricPluginServer struct {
}

UnimplementedMetricPluginServer should be embedded to have forward compatible implementations.

func (UnimplementedMetricPluginServer) GetSupportedResources 

func (UnimplementedMetricPluginServer) GetSupportedResources(context.Context, *emptypb.Empty) (*GetSupportedMetricResourcesResponse, error)

func (UnimplementedMetricPluginServer) Query 

func (UnimplementedMetricPluginServer) Query(context.Context, *QueryMetricsRequest) (*QueryMetricsResponse, error)

func (UnimplementedMetricPluginServer) StreamMetrics 

func (UnimplementedMetricPluginServer) StreamMetrics(MetricPlugin_StreamMetricsServer) error

type UnimplementedNetworkerPluginServer 

type UnimplementedNetworkerPluginServer struct {
}

UnimplementedNetworkerPluginServer should be embedded to have forward compatible implementations.

func (UnimplementedNetworkerPluginServer) ClosePortForwardSession 

func (UnimplementedNetworkerPluginServer) ClosePortForwardSession(context.Context, *PortForwardSessionByIdRequest) (*PortForwardSessionByIdResponse, error)

func (UnimplementedNetworkerPluginServer) FindPortForwardSessions 

func (UnimplementedNetworkerPluginServer) FindPortForwardSessions(context.Context, *FindPortForwardSessionRequest) (*PortForwardSessionListResponse, error)

func (UnimplementedNetworkerPluginServer) GetPortForwardSession 

func (UnimplementedNetworkerPluginServer) GetPortForwardSession(context.Context, *PortForwardSessionByIdRequest) (*PortForwardSessionByIdResponse, error)

func (UnimplementedNetworkerPluginServer) GetSupportedPortForwardTargets 

func (UnimplementedNetworkerPluginServer) GetSupportedPortForwardTargets(context.Context, *emptypb.Empty) (*GetSupportedPortForwardTargetsResponse, error)

func (UnimplementedNetworkerPluginServer) ListPortForwardSessions 

func (UnimplementedNetworkerPluginServer) ListPortForwardSessions(context.Context, *emptypb.Empty) (*PortForwardSessionListResponse, error)

func (UnimplementedNetworkerPluginServer) StartPortForwardSession 

func (UnimplementedNetworkerPluginServer) StartPortForwardSession(context.Context, *PortForwardSessionOptions) (*PortForwardSessionByIdResponse, error)

type UnimplementedPluginLifecycleServer added in v0.1.1 

type UnimplementedPluginLifecycleServer struct {
}

UnimplementedPluginLifecycleServer should be embedded to have forward compatible implementations.

func (UnimplementedPluginLifecycleServer) GetCapabilities added in v0.1.1 

func (UnimplementedPluginLifecycleServer) GetCapabilities(context.Context, *emptypb.Empty) (*GetCapabilitiesResponse, error)

func (UnimplementedPluginLifecycleServer) GetInfo added in v0.1.1 

func (UnimplementedPluginLifecycleServer) GetInfo(context.Context, *emptypb.Empty) (*GetInfoResponse, error)

func (UnimplementedPluginLifecycleServer) HealthCheck added in v0.1.1 

func (UnimplementedPluginLifecycleServer) HealthCheck(context.Context, *emptypb.Empty) (*HealthCheckResponse, error)

type UnimplementedResourcePluginServer 

type UnimplementedResourcePluginServer struct {
}

UnimplementedResourcePluginServer should be embedded to have forward compatible implementations.

func (UnimplementedResourcePluginServer) Create 

func (UnimplementedResourcePluginServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)

func (UnimplementedResourcePluginServer) Delete 

func (UnimplementedResourcePluginServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedResourcePluginServer) DeleteConnection 

func (UnimplementedResourcePluginServer) DeleteConnection(context.Context, *ConnectionRequest) (*emptypb.Empty, error)

func (UnimplementedResourcePluginServer) EnsureInformerForResource 

func (UnimplementedResourcePluginServer) EnsureInformerForResource(context.Context, *EnsureInformerRequest) (*emptypb.Empty, error)

func (UnimplementedResourcePluginServer) ExecuteAction 

func (UnimplementedResourcePluginServer) ExecuteAction(context.Context, *ExecuteActionRequest) (*ExecuteActionResponse, error)

func (UnimplementedResourcePluginServer) Find 

func (UnimplementedResourcePluginServer) Find(context.Context, *FindRequest) (*FindResponse, error)

func (UnimplementedResourcePluginServer) Get 

func (UnimplementedResourcePluginServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedResourcePluginServer) GetActions 

func (UnimplementedResourcePluginServer) GetActions(context.Context, *GetActionsRequest) (*GetActionsResponse, error)

func (UnimplementedResourcePluginServer) GetConnection 

func (UnimplementedResourcePluginServer) GetConnection(context.Context, *ConnectionRequest) (*Connection, error)

func (UnimplementedResourcePluginServer) GetConnectionNamespaces 

func (UnimplementedResourcePluginServer) GetConnectionNamespaces(context.Context, *ConnectionRequest) (*ConnectionNamespacesResponse, error)

func (UnimplementedResourcePluginServer) GetDefaultLayout 

func (UnimplementedResourcePluginServer) GetDefaultLayout(context.Context, *emptypb.Empty) (*Layout, error)

func (UnimplementedResourcePluginServer) GetEditorSchemas 

func (UnimplementedResourcePluginServer) GetEditorSchemas(context.Context, *GetEditorSchemasRequest) (*EditorSchemaList, error)

func (UnimplementedResourcePluginServer) GetInformerState 

func (UnimplementedResourcePluginServer) GetInformerState(context.Context, *GetInformerStateRequest) (*InformerConnectionSummary, error)

func (UnimplementedResourcePluginServer) GetLayout 

func (UnimplementedResourcePluginServer) GetLayout(context.Context, *GetLayoutRequest) (*Layout, error)

func (UnimplementedResourcePluginServer) GetResourceDefinition 

func (UnimplementedResourcePluginServer) GetResourceDefinition(context.Context, *ResourceTypeRequest) (*ResourceDefinition, error)

func (UnimplementedResourcePluginServer) GetResourceGroup 

func (UnimplementedResourcePluginServer) GetResourceGroup(context.Context, *ResourceGroupRequest) (*ResourceGroup, error)

func (UnimplementedResourcePluginServer) GetResourceGroups 

func (UnimplementedResourcePluginServer) GetResourceGroups(context.Context, *ResourceGroupListRequest) (*ResourceGroupListResponse, error)

func (UnimplementedResourcePluginServer) GetResourceType 

func (UnimplementedResourcePluginServer) GetResourceType(context.Context, *ResourceTypeRequest) (*ResourceMeta, error)

func (UnimplementedResourcePluginServer) GetResourceTypes 

func (UnimplementedResourcePluginServer) GetResourceTypes(context.Context, *ResourceTypeListRequest) (*ResourceTypes, error)

func (UnimplementedResourcePluginServer) HasInformer 

func (UnimplementedResourcePluginServer) HasInformer(context.Context, *HasInformerRequest) (*wrapperspb.BoolValue, error)

func (UnimplementedResourcePluginServer) HasResourceType 

func (UnimplementedResourcePluginServer) HasResourceType(context.Context, *ResourceTypeRequest) (*wrapperspb.BoolValue, error)

func (UnimplementedResourcePluginServer) List 

func (UnimplementedResourcePluginServer) List(context.Context, *ListRequest) (*ListResponse, error)

func (UnimplementedResourcePluginServer) ListConnections 

func (UnimplementedResourcePluginServer) ListConnections(context.Context, *emptypb.Empty) (*ConnectionList, error)

func (UnimplementedResourcePluginServer) ListenForEvents 

func (UnimplementedResourcePluginServer) ListenForEvents(*emptypb.Empty, ResourcePlugin_ListenForEventsServer) error

func (UnimplementedResourcePluginServer) LoadConnections 

func (UnimplementedResourcePluginServer) LoadConnections(context.Context, *emptypb.Empty) (*ConnectionList, error)

func (UnimplementedResourcePluginServer) SetLayout 

func (UnimplementedResourcePluginServer) SetLayout(context.Context, *SetLayoutRequest) (*emptypb.Empty, error)

func (UnimplementedResourcePluginServer) StartConnection 

func (UnimplementedResourcePluginServer) StartConnection(context.Context, *ConnectionRequest) (*ConnectionStatus, error)

func (UnimplementedResourcePluginServer) StartConnectionInformer 

func (UnimplementedResourcePluginServer) StartConnectionInformer(context.Context, *StartConnectionInformerRequest) (*emptypb.Empty, error)

func (UnimplementedResourcePluginServer) StopConnection 

func (UnimplementedResourcePluginServer) StopConnection(context.Context, *ConnectionRequest) (*Connection, error)

func (UnimplementedResourcePluginServer) StopConnectionInformer 

func (UnimplementedResourcePluginServer) StopConnectionInformer(context.Context, *StopConnectionInformerRequest) (*emptypb.Empty, error)

func (UnimplementedResourcePluginServer) StreamAction 

func (UnimplementedResourcePluginServer) StreamAction(*ExecuteActionRequest, ResourcePlugin_StreamActionServer) error

func (UnimplementedResourcePluginServer) Update 

func (UnimplementedResourcePluginServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)

func (UnimplementedResourcePluginServer) UpdateConnection 

func (UnimplementedResourcePluginServer) UpdateConnection(context.Context, *UpdateConnectionRequest) (*Connection, error)

func (UnimplementedResourcePluginServer) WatchConnections 

func (UnimplementedResourcePluginServer) WatchConnections(*emptypb.Empty, ResourcePlugin_WatchConnectionsServer) error

type UnimplementedSettingsPluginServer 

type UnimplementedSettingsPluginServer struct {
}

UnimplementedSettingsPluginServer should be embedded to have forward compatible implementations.

func (UnimplementedSettingsPluginServer) GetSetting 

func (UnimplementedSettingsPluginServer) GetSetting(context.Context, *GetSettingRequest) (*Setting, error)

func (UnimplementedSettingsPluginServer) GetSettingValue 

func (UnimplementedSettingsPluginServer) GetSettingValue(context.Context, *GetSettingValueRequest) (*GetSettingValueResponse, error)

func (UnimplementedSettingsPluginServer) ListSettings 

func (UnimplementedSettingsPluginServer) ListSettings(context.Context, *emptypb.Empty) (*ListSettingsResponse, error)

func (UnimplementedSettingsPluginServer) SetSetting 

func (UnimplementedSettingsPluginServer) SetSetting(context.Context, *SetSettingRequest) (*emptypb.Empty, error)

func (UnimplementedSettingsPluginServer) SetSettings 

func (UnimplementedSettingsPluginServer) SetSettings(context.Context, *SetSettingsRequest) (*emptypb.Empty, error)

type UnimplementedStreamServer 

type UnimplementedStreamServer struct {
}

UnimplementedStreamServer should be embedded to have forward compatible implementations.

func (UnimplementedStreamServer) Publish 

func (UnimplementedStreamServer) Publish(context.Context, *PublishStreamRequest) (*PublishStreamResponse, error)

func (UnimplementedStreamServer) Run 

func (UnimplementedStreamServer) Run(*RunStreamRequest, Stream_RunServer) error

func (UnimplementedStreamServer) Subscribe 

func (UnimplementedStreamServer) Subscribe(context.Context, *SubscribeStreamRequest) (*SubscribeStreamResponse, error)

type UnsafeCommandServer 

type UnsafeCommandServer interface {
	// contains filtered or unexported methods
}

UnsafeCommandServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CommandServer will result in compilation errors.

type UnsafeExecPluginServer 

type UnsafeExecPluginServer interface {
	// contains filtered or unexported methods
}

UnsafeExecPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExecPluginServer will result in compilation errors.

type UnsafeLogPluginServer 

type UnsafeLogPluginServer interface {
	// contains filtered or unexported methods
}

UnsafeLogPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogPluginServer will result in compilation errors.

type UnsafeMetricPluginServer 

type UnsafeMetricPluginServer interface {
	// contains filtered or unexported methods
}

UnsafeMetricPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetricPluginServer will result in compilation errors.

type UnsafeNetworkerPluginServer 

type UnsafeNetworkerPluginServer interface {
	// contains filtered or unexported methods
}

UnsafeNetworkerPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NetworkerPluginServer will result in compilation errors.

type UnsafePluginLifecycleServer added in v0.1.1 

type UnsafePluginLifecycleServer interface {
	// contains filtered or unexported methods
}

UnsafePluginLifecycleServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PluginLifecycleServer will result in compilation errors.

type UnsafeResourcePluginServer 

type UnsafeResourcePluginServer interface {
	// contains filtered or unexported methods
}

UnsafeResourcePluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ResourcePluginServer will result in compilation errors.

type UnsafeSettingsPluginServer 

type UnsafeSettingsPluginServer interface {
	// contains filtered or unexported methods
}

UnsafeSettingsPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SettingsPluginServer will result in compilation errors.

type UnsafeStreamServer 

type UnsafeStreamServer interface {
	// contains filtered or unexported methods
}

UnsafeStreamServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamServer will result in compilation errors.

type UpdateConnectionRequest 

type UpdateConnectionRequest struct {
	Id          string                  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Avatar      *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=avatar,proto3" json:"avatar,omitempty"`
	Labels      *structpb.Struct        `protobuf:"bytes,5,opt,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConnectionRequest) Descriptor deprecated 

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

Deprecated: Use UpdateConnectionRequest.ProtoReflect.Descriptor instead.

func (*UpdateConnectionRequest) GetAvatar 

func (x *UpdateConnectionRequest) GetAvatar() *wrapperspb.StringValue

func (*UpdateConnectionRequest) GetDescription 

func (x *UpdateConnectionRequest) GetDescription() *wrapperspb.StringValue

func (*UpdateConnectionRequest) GetId 

func (x *UpdateConnectionRequest) GetId() string

func (*UpdateConnectionRequest) GetLabels 

func (x *UpdateConnectionRequest) GetLabels() *structpb.Struct

func (*UpdateConnectionRequest) GetName 

func (x *UpdateConnectionRequest) GetName() *wrapperspb.StringValue

func (*UpdateConnectionRequest) ProtoMessage 

func (*UpdateConnectionRequest) ProtoMessage()

func (*UpdateConnectionRequest) ProtoReflect 

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

func (*UpdateConnectionRequest) Reset 

func (x *UpdateConnectionRequest) Reset()

func (*UpdateConnectionRequest) String 

func (x *UpdateConnectionRequest) String() string

type UpdateLogSessionOptionsRequest 

type UpdateLogSessionOptionsRequest struct {
	SessionId string             `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Options   *LogSessionOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateLogSessionOptionsRequest) Descriptor deprecated 

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

Deprecated: Use UpdateLogSessionOptionsRequest.ProtoReflect.Descriptor instead.

func (*UpdateLogSessionOptionsRequest) GetOptions 

func (x *UpdateLogSessionOptionsRequest) GetOptions() *LogSessionOptions

func (*UpdateLogSessionOptionsRequest) GetSessionId 

func (x *UpdateLogSessionOptionsRequest) GetSessionId() string

func (*UpdateLogSessionOptionsRequest) ProtoMessage 

func (*UpdateLogSessionOptionsRequest) ProtoMessage()

func (*UpdateLogSessionOptionsRequest) ProtoReflect 

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

func (*UpdateLogSessionOptionsRequest) Reset 

func (x *UpdateLogSessionOptionsRequest) Reset()

func (*UpdateLogSessionOptionsRequest) String 

func (x *UpdateLogSessionOptionsRequest) String() string

type UpdateRequest 

type UpdateRequest struct {
	Key       string           `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Context   string           `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"`
	Id        string           `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Namespace string           `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Data      *structpb.Struct `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) GetContext 

func (x *UpdateRequest) GetContext() string

func (*UpdateRequest) GetData 

func (x *UpdateRequest) GetData() *structpb.Struct

func (*UpdateRequest) GetId 

func (x *UpdateRequest) GetId() string

func (*UpdateRequest) GetKey 

func (x *UpdateRequest) GetKey() string

func (*UpdateRequest) GetNamespace 

func (x *UpdateRequest) GetNamespace() string

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) ProtoReflect 

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

func (*UpdateRequest) Reset 

func (x *UpdateRequest) Reset()

func (*UpdateRequest) String 

func (x *UpdateRequest) String() string

type UpdateResponse 

type UpdateResponse struct {
	Success bool             `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Data    *structpb.Struct `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Error   *ResourceError   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateResponse) Descriptor deprecated 

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

Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.

func (*UpdateResponse) GetData 

func (x *UpdateResponse) GetData() *structpb.Struct

func (*UpdateResponse) GetError 

func (x *UpdateResponse) GetError() *ResourceError

func (*UpdateResponse) GetSuccess 

func (x *UpdateResponse) GetSuccess() bool

func (*UpdateResponse) ProtoMessage 

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) ProtoReflect 

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

func (*UpdateResponse) Reset 

func (x *UpdateResponse) Reset()

func (*UpdateResponse) String 

func (x *UpdateResponse) String() string

type VersionedResourceTypes 

type VersionedResourceTypes struct {
	Versions map[string]*ResourceTypes `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*VersionedResourceTypes) Descriptor deprecated 

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

Deprecated: Use VersionedResourceTypes.ProtoReflect.Descriptor instead.

func (*VersionedResourceTypes) GetVersions 

func (x *VersionedResourceTypes) GetVersions() map[string]*ResourceTypes

func (*VersionedResourceTypes) ProtoMessage 

func (*VersionedResourceTypes) ProtoMessage()

func (*VersionedResourceTypes) ProtoReflect 

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

func (*VersionedResourceTypes) Reset 

func (x *VersionedResourceTypes) Reset()

func (*VersionedResourceTypes) String 

func (x *VersionedResourceTypes) String() string

type VisualComponentList 

type VisualComponentList struct {
	Resource []*VisualResourceComponent `protobuf:"bytes,1,rep,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

VisualComponentList is a list of all the visual components provided by the plugin, grouped by the section they are applicable to.

func (*VisualComponentList) Descriptor deprecated 

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

Deprecated: Use VisualComponentList.ProtoReflect.Descriptor instead.

func (*VisualComponentList) GetResource 

func (x *VisualComponentList) GetResource() []*VisualResourceComponent

func (*VisualComponentList) ProtoMessage 

func (*VisualComponentList) ProtoMessage()

func (*VisualComponentList) ProtoReflect 

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

func (*VisualComponentList) Reset 

func (x *VisualComponentList) Reset()

func (*VisualComponentList) String 

func (x *VisualComponentList) String() string

type VisualResourceComponent 

type VisualResourceComponent struct {

	// The unique identifier of the component.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The plugin for which this component is applicable.
	Plugin string `protobuf:"bytes,2,opt,name=plugin,proto3" json:"plugin,omitempty"`
	// The type of the component.
	Type VisualResourceComponent_ComponentType `` /* 128-byte string literal not displayed */
	// The resources for which this component is applicable.
	Resources []string `protobuf:"bytes,4,rep,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

VisualResourceComponent is a visual component that can be displayed in the UI within a resource.

func (*VisualResourceComponent) Descriptor deprecated 

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

Deprecated: Use VisualResourceComponent.ProtoReflect.Descriptor instead.

func (*VisualResourceComponent) GetId 

func (x *VisualResourceComponent) GetId() string

func (*VisualResourceComponent) GetPlugin 

func (x *VisualResourceComponent) GetPlugin() string

func (*VisualResourceComponent) GetResources 

func (x *VisualResourceComponent) GetResources() []string

func (*VisualResourceComponent) GetType 

func (x *VisualResourceComponent) GetType() VisualResourceComponent_ComponentType

func (*VisualResourceComponent) ProtoMessage 

func (*VisualResourceComponent) ProtoMessage()

func (*VisualResourceComponent) ProtoReflect 

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

func (*VisualResourceComponent) Reset 

func (x *VisualResourceComponent) Reset()

func (*VisualResourceComponent) String 

func (x *VisualResourceComponent) String() string

type VisualResourceComponent_ComponentType 

type VisualResourceComponent_ComponentType int32
const (
	VisualResourceComponent_SIDEBAR    VisualResourceComponent_ComponentType = 0
	VisualResourceComponent_TABLE      VisualResourceComponent_ComponentType = 1
	VisualResourceComponent_TABLE_ROW  VisualResourceComponent_ComponentType = 2
	VisualResourceComponent_TABLE_CELL VisualResourceComponent_ComponentType = 3
)

func (VisualResourceComponent_ComponentType) Descriptor 

func (VisualResourceComponent_ComponentType) Descriptor() protoreflect.EnumDescriptor

func (VisualResourceComponent_ComponentType) Enum 

func (x VisualResourceComponent_ComponentType) Enum() *VisualResourceComponent_ComponentType

func (VisualResourceComponent_ComponentType) EnumDescriptor deprecated 

func (VisualResourceComponent_ComponentType) EnumDescriptor() ([]byte, []int)

Deprecated: Use VisualResourceComponent_ComponentType.Descriptor instead.

func (VisualResourceComponent_ComponentType) Number 

func (x VisualResourceComponent_ComponentType) Number() protoreflect.EnumNumber

func (VisualResourceComponent_ComponentType) String 

func (x VisualResourceComponent_ComponentType) String() string

func (VisualResourceComponent_ComponentType) Type 

func (VisualResourceComponent_ComponentType) Type() protoreflect.EnumType

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.