resourcepb

package
v0.5.2 Latest Latest
Warning

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

Go to latest
Published: Mar 28, 2026 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ResourcePlugin_LoadConnections_FullMethodName         = "/omniview.sdk.resource.v1.ResourcePlugin/LoadConnections"
	ResourcePlugin_StartConnection_FullMethodName         = "/omniview.sdk.resource.v1.ResourcePlugin/StartConnection"
	ResourcePlugin_StopConnection_FullMethodName          = "/omniview.sdk.resource.v1.ResourcePlugin/StopConnection"
	ResourcePlugin_CheckConnection_FullMethodName         = "/omniview.sdk.resource.v1.ResourcePlugin/CheckConnection"
	ResourcePlugin_GetConnectionNamespaces_FullMethodName = "/omniview.sdk.resource.v1.ResourcePlugin/GetConnectionNamespaces"
	ResourcePlugin_Get_FullMethodName                     = "/omniview.sdk.resource.v1.ResourcePlugin/Get"
	ResourcePlugin_List_FullMethodName                    = "/omniview.sdk.resource.v1.ResourcePlugin/List"
	ResourcePlugin_Find_FullMethodName                    = "/omniview.sdk.resource.v1.ResourcePlugin/Find"
	ResourcePlugin_Create_FullMethodName                  = "/omniview.sdk.resource.v1.ResourcePlugin/Create"
	ResourcePlugin_Update_FullMethodName                  = "/omniview.sdk.resource.v1.ResourcePlugin/Update"
	ResourcePlugin_Delete_FullMethodName                  = "/omniview.sdk.resource.v1.ResourcePlugin/Delete"
	ResourcePlugin_GetResourceGroups_FullMethodName       = "/omniview.sdk.resource.v1.ResourcePlugin/GetResourceGroups"
	ResourcePlugin_GetResourceTypes_FullMethodName        = "/omniview.sdk.resource.v1.ResourcePlugin/GetResourceTypes"
	ResourcePlugin_GetResourceCapabilities_FullMethodName = "/omniview.sdk.resource.v1.ResourcePlugin/GetResourceCapabilities"
	ResourcePlugin_GetFilterFields_FullMethodName         = "/omniview.sdk.resource.v1.ResourcePlugin/GetFilterFields"
	ResourcePlugin_GetResourceSchema_FullMethodName       = "/omniview.sdk.resource.v1.ResourcePlugin/GetResourceSchema"
	ResourcePlugin_GetEditorSchemas_FullMethodName        = "/omniview.sdk.resource.v1.ResourcePlugin/GetEditorSchemas"
	ResourcePlugin_GetActions_FullMethodName              = "/omniview.sdk.resource.v1.ResourcePlugin/GetActions"
	ResourcePlugin_ExecuteAction_FullMethodName           = "/omniview.sdk.resource.v1.ResourcePlugin/ExecuteAction"
	ResourcePlugin_StreamAction_FullMethodName            = "/omniview.sdk.resource.v1.ResourcePlugin/StreamAction"
	ResourcePlugin_ListenForEvents_FullMethodName         = "/omniview.sdk.resource.v1.ResourcePlugin/ListenForEvents"
	ResourcePlugin_EnsureResourceWatch_FullMethodName     = "/omniview.sdk.resource.v1.ResourcePlugin/EnsureResourceWatch"
	ResourcePlugin_StopResourceWatch_FullMethodName       = "/omniview.sdk.resource.v1.ResourcePlugin/StopResourceWatch"
	ResourcePlugin_WatchConnections_FullMethodName        = "/omniview.sdk.resource.v1.ResourcePlugin/WatchConnections"
	ResourcePlugin_GetWatchState_FullMethodName           = "/omniview.sdk.resource.v1.ResourcePlugin/GetWatchState"
	ResourcePlugin_GetRelationships_FullMethodName        = "/omniview.sdk.resource.v1.ResourcePlugin/GetRelationships"
	ResourcePlugin_ResolveRelationships_FullMethodName    = "/omniview.sdk.resource.v1.ResourcePlugin/ResolveRelationships"
	ResourcePlugin_GetHealth_FullMethodName               = "/omniview.sdk.resource.v1.ResourcePlugin/GetHealth"
	ResourcePlugin_GetResourceEvents_FullMethodName       = "/omniview.sdk.resource.v1.ResourcePlugin/GetResourceEvents"
)

Variables

View Source
var (
	FilterOperator_name = map[int32]string{
		0:  "FILTER_OP_UNSPECIFIED",
		1:  "FILTER_OP_EQ",
		2:  "FILTER_OP_NEQ",
		3:  "FILTER_OP_GT",
		4:  "FILTER_OP_GTE",
		5:  "FILTER_OP_LT",
		6:  "FILTER_OP_LTE",
		7:  "FILTER_OP_CONTAINS",
		8:  "FILTER_OP_PREFIX",
		9:  "FILTER_OP_SUFFIX",
		10: "FILTER_OP_REGEX",
		11: "FILTER_OP_IN",
		12: "FILTER_OP_NOT_IN",
		13: "FILTER_OP_EXISTS",
		14: "FILTER_OP_NOT_EXISTS",
		15: "FILTER_OP_HAS_KEY",
	}
	FilterOperator_value = map[string]int32{
		"FILTER_OP_UNSPECIFIED": 0,
		"FILTER_OP_EQ":          1,
		"FILTER_OP_NEQ":         2,
		"FILTER_OP_GT":          3,
		"FILTER_OP_GTE":         4,
		"FILTER_OP_LT":          5,
		"FILTER_OP_LTE":         6,
		"FILTER_OP_CONTAINS":    7,
		"FILTER_OP_PREFIX":      8,
		"FILTER_OP_SUFFIX":      9,
		"FILTER_OP_REGEX":       10,
		"FILTER_OP_IN":          11,
		"FILTER_OP_NOT_IN":      12,
		"FILTER_OP_EXISTS":      13,
		"FILTER_OP_NOT_EXISTS":  14,
		"FILTER_OP_HAS_KEY":     15,
	}
)

Enum value maps for FilterOperator.

View Source
var (
	FilterFieldType_name = map[int32]string{
		0: "FILTER_FIELD_TYPE_UNSPECIFIED",
		1: "FILTER_FIELD_TYPE_STRING",
		2: "FILTER_FIELD_TYPE_INTEGER",
		3: "FILTER_FIELD_TYPE_NUMBER",
		4: "FILTER_FIELD_TYPE_BOOLEAN",
		5: "FILTER_FIELD_TYPE_DATETIME",
		6: "FILTER_FIELD_TYPE_ENUM",
		7: "FILTER_FIELD_TYPE_MAP",
	}
	FilterFieldType_value = map[string]int32{
		"FILTER_FIELD_TYPE_UNSPECIFIED": 0,
		"FILTER_FIELD_TYPE_STRING":      1,
		"FILTER_FIELD_TYPE_INTEGER":     2,
		"FILTER_FIELD_TYPE_NUMBER":      3,
		"FILTER_FIELD_TYPE_BOOLEAN":     4,
		"FILTER_FIELD_TYPE_DATETIME":    5,
		"FILTER_FIELD_TYPE_ENUM":        6,
		"FILTER_FIELD_TYPE_MAP":         7,
	}
)

Enum value maps for FilterFieldType.

View Source
var (
	FilterLogic_name = map[int32]string{
		0: "FILTER_LOGIC_UNSPECIFIED",
		1: "FILTER_LOGIC_AND",
		2: "FILTER_LOGIC_OR",
	}
	FilterLogic_value = map[string]int32{
		"FILTER_LOGIC_UNSPECIFIED": 0,
		"FILTER_LOGIC_AND":         1,
		"FILTER_LOGIC_OR":          2,
	}
)

Enum value maps for FilterLogic.

View Source
var (
	HealthStatus_name = map[int32]string{
		0: "HEALTH_STATUS_UNSPECIFIED",
		1: "HEALTH_STATUS_HEALTHY",
		2: "HEALTH_STATUS_DEGRADED",
		3: "HEALTH_STATUS_UNHEALTHY",
		4: "HEALTH_STATUS_PENDING",
		5: "HEALTH_STATUS_UNKNOWN",
	}
	HealthStatus_value = map[string]int32{
		"HEALTH_STATUS_UNSPECIFIED": 0,
		"HEALTH_STATUS_HEALTHY":     1,
		"HEALTH_STATUS_DEGRADED":    2,
		"HEALTH_STATUS_UNHEALTHY":   3,
		"HEALTH_STATUS_PENDING":     4,
		"HEALTH_STATUS_UNKNOWN":     5,
	}
)

Enum value maps for HealthStatus.

View Source
var (
	EventSeverity_name = map[int32]string{
		0: "EVENT_SEVERITY_UNSPECIFIED",
		1: "EVENT_SEVERITY_NORMAL",
		2: "EVENT_SEVERITY_WARNING",
		3: "EVENT_SEVERITY_ERROR",
	}
	EventSeverity_value = map[string]int32{
		"EVENT_SEVERITY_UNSPECIFIED": 0,
		"EVENT_SEVERITY_NORMAL":      1,
		"EVENT_SEVERITY_WARNING":     2,
		"EVENT_SEVERITY_ERROR":       3,
	}
)

Enum value maps for EventSeverity.

View Source
var (
	RelationshipType_name = map[int32]string{
		0: "RELATIONSHIP_TYPE_UNSPECIFIED",
		1: "RELATIONSHIP_TYPE_OWNS",
		2: "RELATIONSHIP_TYPE_RUNS_ON",
		3: "RELATIONSHIP_TYPE_USES",
		4: "RELATIONSHIP_TYPE_EXPOSES",
		5: "RELATIONSHIP_TYPE_MANAGES",
		6: "RELATIONSHIP_TYPE_MEMBER_OF",
		7: "RELATIONSHIP_TYPE_SELECTS",
	}
	RelationshipType_value = map[string]int32{
		"RELATIONSHIP_TYPE_UNSPECIFIED": 0,
		"RELATIONSHIP_TYPE_OWNS":        1,
		"RELATIONSHIP_TYPE_RUNS_ON":     2,
		"RELATIONSHIP_TYPE_USES":        3,
		"RELATIONSHIP_TYPE_EXPOSES":     4,
		"RELATIONSHIP_TYPE_MANAGES":     5,
		"RELATIONSHIP_TYPE_MEMBER_OF":   6,
		"RELATIONSHIP_TYPE_SELECTS":     7,
	}
)

Enum value maps for RelationshipType.

View Source
var (
	ScaleCategory_name = map[int32]string{
		0: "SCALE_CATEGORY_UNSPECIFIED",
		1: "SCALE_CATEGORY_FEW",
		2: "SCALE_CATEGORY_MODERATE",
		3: "SCALE_CATEGORY_MANY",
	}
	ScaleCategory_value = map[string]int32{
		"SCALE_CATEGORY_UNSPECIFIED": 0,
		"SCALE_CATEGORY_FEW":         1,
		"SCALE_CATEGORY_MODERATE":    2,
		"SCALE_CATEGORY_MANY":        3,
	}
)

Enum value maps for ScaleCategory.

View Source
var (
	ActionScope_name = map[int32]string{
		0: "ACTION_SCOPE_UNSPECIFIED",
		1: "ACTION_SCOPE_INSTANCE",
		2: "ACTION_SCOPE_COLLECTION",
		3: "ACTION_SCOPE_GLOBAL",
	}
	ActionScope_value = map[string]int32{
		"ACTION_SCOPE_UNSPECIFIED": 0,
		"ACTION_SCOPE_INSTANCE":    1,
		"ACTION_SCOPE_COLLECTION":  2,
		"ACTION_SCOPE_GLOBAL":      3,
	}
)

Enum value maps for ActionScope.

View Source
var (
	WatchState_name = map[int32]string{
		0: "WATCH_STATE_UNSPECIFIED",
		1: "WATCH_STATE_SYNCING",
		2: "WATCH_STATE_SYNCED",
		3: "WATCH_STATE_ERROR",
		4: "WATCH_STATE_FAILED",
		5: "WATCH_STATE_STOPPED",
		6: "WATCH_STATE_IDLE",
		7: "WATCH_STATE_FORBIDDEN",
		8: "WATCH_STATE_SKIPPED",
	}
	WatchState_value = map[string]int32{
		"WATCH_STATE_UNSPECIFIED": 0,
		"WATCH_STATE_SYNCING":     1,
		"WATCH_STATE_SYNCED":      2,
		"WATCH_STATE_ERROR":       3,
		"WATCH_STATE_FAILED":      4,
		"WATCH_STATE_STOPPED":     5,
		"WATCH_STATE_IDLE":        6,
		"WATCH_STATE_FORBIDDEN":   7,
		"WATCH_STATE_SKIPPED":     8,
	}
)

Enum value maps for WatchState.

View Source
var File_proto_v1_resource_filter_proto protoreflect.FileDescriptor
View Source
var File_proto_v1_resource_health_proto protoreflect.FileDescriptor
View Source
var File_proto_v1_resource_relationship_proto protoreflect.FileDescriptor
View Source
var File_proto_v1_resource_resource_proto protoreflect.FileDescriptor
View Source
var File_proto_v1_resource_watch_proto protoreflect.FileDescriptor
View Source
var ResourcePlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "omniview.sdk.resource.v1.ResourcePlugin",
	HandlerType: (*ResourcePluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LoadConnections",
			Handler:    _ResourcePlugin_LoadConnections_Handler,
		},
		{
			MethodName: "StartConnection",
			Handler:    _ResourcePlugin_StartConnection_Handler,
		},
		{
			MethodName: "StopConnection",
			Handler:    _ResourcePlugin_StopConnection_Handler,
		},
		{
			MethodName: "CheckConnection",
			Handler:    _ResourcePlugin_CheckConnection_Handler,
		},
		{
			MethodName: "GetConnectionNamespaces",
			Handler:    _ResourcePlugin_GetConnectionNamespaces_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: "GetResourceGroups",
			Handler:    _ResourcePlugin_GetResourceGroups_Handler,
		},
		{
			MethodName: "GetResourceTypes",
			Handler:    _ResourcePlugin_GetResourceTypes_Handler,
		},
		{
			MethodName: "GetResourceCapabilities",
			Handler:    _ResourcePlugin_GetResourceCapabilities_Handler,
		},
		{
			MethodName: "GetFilterFields",
			Handler:    _ResourcePlugin_GetFilterFields_Handler,
		},
		{
			MethodName: "GetResourceSchema",
			Handler:    _ResourcePlugin_GetResourceSchema_Handler,
		},
		{
			MethodName: "GetEditorSchemas",
			Handler:    _ResourcePlugin_GetEditorSchemas_Handler,
		},
		{
			MethodName: "GetActions",
			Handler:    _ResourcePlugin_GetActions_Handler,
		},
		{
			MethodName: "ExecuteAction",
			Handler:    _ResourcePlugin_ExecuteAction_Handler,
		},
		{
			MethodName: "EnsureResourceWatch",
			Handler:    _ResourcePlugin_EnsureResourceWatch_Handler,
		},
		{
			MethodName: "StopResourceWatch",
			Handler:    _ResourcePlugin_StopResourceWatch_Handler,
		},
		{
			MethodName: "GetWatchState",
			Handler:    _ResourcePlugin_GetWatchState_Handler,
		},
		{
			MethodName: "GetRelationships",
			Handler:    _ResourcePlugin_GetRelationships_Handler,
		},
		{
			MethodName: "ResolveRelationships",
			Handler:    _ResourcePlugin_ResolveRelationships_Handler,
		},
		{
			MethodName: "GetHealth",
			Handler:    _ResourcePlugin_GetHealth_Handler,
		},
		{
			MethodName: "GetResourceEvents",
			Handler:    _ResourcePlugin_GetResourceEvents_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamAction",
			Handler:       _ResourcePlugin_StreamAction_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListenForEvents",
			Handler:       _ResourcePlugin_ListenForEvents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WatchConnections",
			Handler:       _ResourcePlugin_WatchConnections_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/v1/resource/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)

Functions

func RegisterResourcePluginServer

func RegisterResourcePluginServer(s grpc.ServiceRegistrar, srv ResourcePluginServer)

Types

type ActionDescriptor

type ActionDescriptor 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"`
	Scope        ActionScope `protobuf:"varint,5,opt,name=scope,proto3,enum=omniview.sdk.resource.v1.ActionScope" json:"scope,omitempty"`
	Streaming    bool        `protobuf:"varint,6,opt,name=streaming,proto3" json:"streaming,omitempty"`
	ParamsSchema []byte      `protobuf:"bytes,7,opt,name=params_schema,json=paramsSchema,proto3" json:"params_schema,omitempty"`
	OutputSchema []byte      `protobuf:"bytes,8,opt,name=output_schema,json=outputSchema,proto3" json:"output_schema,omitempty"`
	Dangerous    bool        `protobuf:"varint,9,opt,name=dangerous,proto3" json:"dangerous,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionDescriptor) Descriptor deprecated

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

Deprecated: Use ActionDescriptor.ProtoReflect.Descriptor instead.

func (*ActionDescriptor) GetDangerous

func (x *ActionDescriptor) GetDangerous() bool

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

func (x *ActionDescriptor) GetOutputSchema() []byte

func (*ActionDescriptor) GetParamsSchema

func (x *ActionDescriptor) GetParamsSchema() []byte

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 ActionInput

type ActionInput struct {
	ResourceId string           `protobuf:"bytes,1,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	Namespace  string           `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Params     *structpb.Struct `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionInput) Descriptor deprecated

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

Deprecated: Use ActionInput.ProtoReflect.Descriptor instead.

func (*ActionInput) GetNamespace

func (x *ActionInput) GetNamespace() string

func (*ActionInput) GetParams

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

func (*ActionInput) GetResourceId

func (x *ActionInput) GetResourceId() string

func (*ActionInput) ProtoMessage

func (*ActionInput) ProtoMessage()

func (*ActionInput) ProtoReflect

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

func (*ActionInput) Reset

func (x *ActionInput) Reset()

func (*ActionInput) String

func (x *ActionInput) String() string

type ActionResult

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

func (*ActionResult) Descriptor deprecated

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

Deprecated: Use ActionResult.ProtoReflect.Descriptor instead.

func (*ActionResult) GetData

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

func (*ActionResult) GetError

func (x *ActionResult) GetError() *common.ResourceError

func (*ActionResult) GetMessage

func (x *ActionResult) GetMessage() string

func (*ActionResult) GetSuccess

func (x *ActionResult) GetSuccess() bool

func (*ActionResult) ProtoMessage

func (*ActionResult) ProtoMessage()

func (*ActionResult) ProtoReflect

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

func (*ActionResult) Reset

func (x *ActionResult) Reset()

func (*ActionResult) String

func (x *ActionResult) String() string

type ActionScope

type ActionScope int32
const (
	ActionScope_ACTION_SCOPE_UNSPECIFIED ActionScope = 0
	ActionScope_ACTION_SCOPE_INSTANCE    ActionScope = 1
	ActionScope_ACTION_SCOPE_COLLECTION  ActionScope = 2
	ActionScope_ACTION_SCOPE_GLOBAL      ActionScope = 3
)

func (ActionScope) Descriptor

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

type AnnotatedEdge

type AnnotatedEdge struct {
	Edge   *RelationshipEdge `protobuf:"bytes,1,opt,name=edge,proto3" json:"edge,omitempty"`
	Target *AnnotatedNode    `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

AnnotatedEdge is a relationship edge with health on the target.

func (*AnnotatedEdge) Descriptor deprecated

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

Deprecated: Use AnnotatedEdge.ProtoReflect.Descriptor instead.

func (*AnnotatedEdge) GetEdge

func (x *AnnotatedEdge) GetEdge() *RelationshipEdge

func (*AnnotatedEdge) GetTarget

func (x *AnnotatedEdge) GetTarget() *AnnotatedNode

func (*AnnotatedEdge) ProtoMessage

func (*AnnotatedEdge) ProtoMessage()

func (*AnnotatedEdge) ProtoReflect

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

func (*AnnotatedEdge) Reset

func (x *AnnotatedEdge) Reset()

func (*AnnotatedEdge) String

func (x *AnnotatedEdge) String() string

type AnnotatedNode

type AnnotatedNode struct {
	Ref    *ResourceRef     `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Health *ResourceHealth  `protobuf:"bytes,2,opt,name=health,proto3" json:"health,omitempty"`
	Events []*ResourceEvent `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

AnnotatedNode is a resource with health and event context.

func (*AnnotatedNode) Descriptor deprecated

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

Deprecated: Use AnnotatedNode.ProtoReflect.Descriptor instead.

func (*AnnotatedNode) GetEvents

func (x *AnnotatedNode) GetEvents() []*ResourceEvent

func (*AnnotatedNode) GetHealth

func (x *AnnotatedNode) GetHealth() *ResourceHealth

func (*AnnotatedNode) GetRef

func (x *AnnotatedNode) GetRef() *ResourceRef

func (*AnnotatedNode) ProtoMessage

func (*AnnotatedNode) ProtoMessage()

func (*AnnotatedNode) ProtoReflect

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

func (*AnnotatedNode) Reset

func (x *AnnotatedNode) Reset()

func (*AnnotatedNode) String

func (x *AnnotatedNode) String() string

type AnnotatedNodeList

type AnnotatedNodeList struct {
	Nodes []*AnnotatedNode `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

AnnotatedNodeList wraps repeated AnnotatedNode for use as proto map value.

func (*AnnotatedNodeList) Descriptor deprecated

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

Deprecated: Use AnnotatedNodeList.ProtoReflect.Descriptor instead.

func (*AnnotatedNodeList) GetNodes

func (x *AnnotatedNodeList) GetNodes() []*AnnotatedNode

func (*AnnotatedNodeList) ProtoMessage

func (*AnnotatedNodeList) ProtoMessage()

func (*AnnotatedNodeList) ProtoReflect

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

func (*AnnotatedNodeList) Reset

func (x *AnnotatedNodeList) Reset()

func (*AnnotatedNodeList) String

func (x *AnnotatedNodeList) String() string

type CheckConnectionRequest added in v0.2.1

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

func (*CheckConnectionRequest) Descriptor deprecated added in v0.2.1

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

Deprecated: Use CheckConnectionRequest.ProtoReflect.Descriptor instead.

func (*CheckConnectionRequest) GetConnectionId added in v0.2.1

func (x *CheckConnectionRequest) GetConnectionId() string

func (*CheckConnectionRequest) ProtoMessage added in v0.2.1

func (*CheckConnectionRequest) ProtoMessage()

func (*CheckConnectionRequest) ProtoReflect added in v0.2.1

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

func (*CheckConnectionRequest) Reset added in v0.2.1

func (x *CheckConnectionRequest) Reset()

func (*CheckConnectionRequest) String added in v0.2.1

func (x *CheckConnectionRequest) String() string

type CheckConnectionResponse added in v0.2.1

type CheckConnectionResponse struct {
	Status *common.ConnectionStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckConnectionResponse) Descriptor deprecated added in v0.2.1

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

Deprecated: Use CheckConnectionResponse.ProtoReflect.Descriptor instead.

func (*CheckConnectionResponse) GetStatus added in v0.2.1

func (*CheckConnectionResponse) ProtoMessage added in v0.2.1

func (*CheckConnectionResponse) ProtoMessage()

func (*CheckConnectionResponse) ProtoReflect added in v0.2.1

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

func (*CheckConnectionResponse) Reset added in v0.2.1

func (x *CheckConnectionResponse) Reset()

func (*CheckConnectionResponse) String added in v0.2.1

func (x *CheckConnectionResponse) String() string

type CommonCauseResult

type CommonCauseResult struct {
	Resources          []*ResourceRef      `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	SharedDependencies []*AnnotatedNode    `protobuf:"bytes,2,rep,name=shared_dependencies,json=sharedDependencies,proto3" json:"shared_dependencies,omitempty"`
	SharedByCount      []*SharedDependency `protobuf:"bytes,3,rep,name=shared_by_count,json=sharedByCount,proto3" json:"shared_by_count,omitempty"`
	// contains filtered or unexported fields
}

CommonCauseResult identifies shared dependencies between multiple resources.

func (*CommonCauseResult) Descriptor deprecated

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

Deprecated: Use CommonCauseResult.ProtoReflect.Descriptor instead.

func (*CommonCauseResult) GetResources

func (x *CommonCauseResult) GetResources() []*ResourceRef

func (*CommonCauseResult) GetSharedByCount

func (x *CommonCauseResult) GetSharedByCount() []*SharedDependency

func (*CommonCauseResult) GetSharedDependencies

func (x *CommonCauseResult) GetSharedDependencies() []*AnnotatedNode

func (*CommonCauseResult) ProtoMessage

func (*CommonCauseResult) ProtoMessage()

func (*CommonCauseResult) ProtoReflect

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

func (*CommonCauseResult) Reset

func (x *CommonCauseResult) Reset()

func (*CommonCauseResult) String

func (x *CommonCauseResult) String() string

type ConnectionRequest

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

func (*ConnectionRequest) Descriptor deprecated

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

Deprecated: Use ConnectionRequest.ProtoReflect.Descriptor instead.

func (*ConnectionRequest) GetConnectionId

func (x *ConnectionRequest) GetConnectionId() 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 ConnectionResponse

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

func (*ConnectionResponse) Descriptor deprecated

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

Deprecated: Use ConnectionResponse.ProtoReflect.Descriptor instead.

func (*ConnectionResponse) GetConnection

func (x *ConnectionResponse) GetConnection() *common.Connection

func (*ConnectionResponse) ProtoMessage

func (*ConnectionResponse) ProtoMessage()

func (*ConnectionResponse) ProtoReflect

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

func (*ConnectionResponse) Reset

func (x *ConnectionResponse) Reset()

func (*ConnectionResponse) String

func (x *ConnectionResponse) String() string

type ConnectionStatusResponse

type ConnectionStatusResponse struct {
	Status *common.ConnectionStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionStatusResponse) Descriptor deprecated

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

Deprecated: Use ConnectionStatusResponse.ProtoReflect.Descriptor instead.

func (*ConnectionStatusResponse) GetStatus

func (*ConnectionStatusResponse) ProtoMessage

func (*ConnectionStatusResponse) ProtoMessage()

func (*ConnectionStatusResponse) ProtoReflect

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

func (*ConnectionStatusResponse) Reset

func (x *ConnectionStatusResponse) Reset()

func (*ConnectionStatusResponse) String

func (x *ConnectionStatusResponse) String() string

type CreateRequest

type CreateRequest struct {
	ResourceKey  string `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ConnectionId string `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Namespace    string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Data         []byte `protobuf:"bytes,4,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) GetConnectionId

func (x *CreateRequest) GetConnectionId() string

func (*CreateRequest) GetData

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

func (*CreateRequest) GetNamespace

func (x *CreateRequest) GetNamespace() string

func (*CreateRequest) GetResourceKey

func (x *CreateRequest) GetResourceKey() 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 {
	Data  []byte                `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Error *common.ResourceError `protobuf:"bytes,2,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() []byte

func (*CreateResponse) GetError

func (x *CreateResponse) GetError() *common.ResourceError

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 DeleteRequest

type DeleteRequest struct {
	ResourceKey        string `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ConnectionId       string `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,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"`
	GracePeriodSeconds *int32 `protobuf:"varint,5,opt,name=grace_period_seconds,json=gracePeriodSeconds,proto3,oneof" json:"grace_period_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetConnectionId

func (x *DeleteRequest) GetConnectionId() string

func (*DeleteRequest) GetGracePeriodSeconds

func (x *DeleteRequest) GetGracePeriodSeconds() int32

func (*DeleteRequest) GetId

func (x *DeleteRequest) GetId() string

func (*DeleteRequest) GetNamespace

func (x *DeleteRequest) GetNamespace() string

func (*DeleteRequest) GetResourceKey

func (x *DeleteRequest) GetResourceKey() 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"`
	Error   *common.ResourceError `protobuf:"bytes,2,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) GetError

func (x *DeleteResponse) GetError() *common.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 DependencyNode

type DependencyNode struct {
	Edge     *RelationshipEdge `protobuf:"bytes,1,opt,name=edge,proto3" json:"edge,omitempty"`
	Children []*DependencyNode `protobuf:"bytes,2,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

DependencyNode is a node in the dependency tree (self-referencing).

func (*DependencyNode) Descriptor deprecated

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

Deprecated: Use DependencyNode.ProtoReflect.Descriptor instead.

func (*DependencyNode) GetChildren

func (x *DependencyNode) GetChildren() []*DependencyNode

func (*DependencyNode) GetEdge

func (x *DependencyNode) GetEdge() *RelationshipEdge

func (*DependencyNode) ProtoMessage

func (*DependencyNode) ProtoMessage()

func (*DependencyNode) ProtoReflect

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

func (*DependencyNode) Reset

func (x *DependencyNode) Reset()

func (*DependencyNode) String

func (x *DependencyNode) String() string

type DependencyTree

type DependencyTree struct {
	Root     *ResourceRef      `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"`
	Children []*DependencyNode `protobuf:"bytes,2,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

DependencyTree is an ownership/dependency hierarchy rooted at a resource.

func (*DependencyTree) Descriptor deprecated

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

Deprecated: Use DependencyTree.ProtoReflect.Descriptor instead.

func (*DependencyTree) GetChildren

func (x *DependencyTree) GetChildren() []*DependencyNode

func (*DependencyTree) GetRoot

func (x *DependencyTree) GetRoot() *ResourceRef

func (*DependencyTree) ProtoMessage

func (*DependencyTree) ProtoMessage()

func (*DependencyTree) ProtoReflect

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

func (*DependencyTree) Reset

func (x *DependencyTree) Reset()

func (*DependencyTree) String

func (x *DependencyTree) String() string

type DiagnosticBranch

type DiagnosticBranch struct {
	Edge     *RelationshipEdge   `protobuf:"bytes,1,opt,name=edge,proto3" json:"edge,omitempty"`
	Node     *AnnotatedNode      `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	Children []*DiagnosticBranch `protobuf:"bytes,3,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

DiagnosticBranch is a node in the diagnostic tree (self-referencing).

func (*DiagnosticBranch) Descriptor deprecated

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

Deprecated: Use DiagnosticBranch.ProtoReflect.Descriptor instead.

func (*DiagnosticBranch) GetChildren

func (x *DiagnosticBranch) GetChildren() []*DiagnosticBranch

func (*DiagnosticBranch) GetEdge

func (x *DiagnosticBranch) GetEdge() *RelationshipEdge

func (*DiagnosticBranch) GetNode

func (x *DiagnosticBranch) GetNode() *AnnotatedNode

func (*DiagnosticBranch) ProtoMessage

func (*DiagnosticBranch) ProtoMessage()

func (*DiagnosticBranch) ProtoReflect

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

func (*DiagnosticBranch) Reset

func (x *DiagnosticBranch) Reset()

func (*DiagnosticBranch) String

func (x *DiagnosticBranch) String() string

type DiagnosticContext

type DiagnosticContext struct {
	Resource   []byte           `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Health     *ResourceHealth  `protobuf:"bytes,2,opt,name=health,proto3" json:"health,omitempty"`
	Events     []*ResourceEvent `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"`
	Related    []*AnnotatedEdge `protobuf:"bytes,4,rep,name=related,proto3" json:"related,omitempty"`
	OwnerChain []*AnnotatedNode `protobuf:"bytes,5,rep,name=owner_chain,json=ownerChain,proto3" json:"owner_chain,omitempty"`
	// contains filtered or unexported fields
}

DiagnosticContext is the complete debugging context for a single resource.

func (*DiagnosticContext) Descriptor deprecated

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

Deprecated: Use DiagnosticContext.ProtoReflect.Descriptor instead.

func (*DiagnosticContext) GetEvents

func (x *DiagnosticContext) GetEvents() []*ResourceEvent

func (*DiagnosticContext) GetHealth

func (x *DiagnosticContext) GetHealth() *ResourceHealth

func (*DiagnosticContext) GetOwnerChain

func (x *DiagnosticContext) GetOwnerChain() []*AnnotatedNode

func (*DiagnosticContext) GetRelated

func (x *DiagnosticContext) GetRelated() []*AnnotatedEdge

func (*DiagnosticContext) GetResource

func (x *DiagnosticContext) GetResource() []byte

func (*DiagnosticContext) ProtoMessage

func (*DiagnosticContext) ProtoMessage()

func (*DiagnosticContext) ProtoReflect

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

func (*DiagnosticContext) Reset

func (x *DiagnosticContext) Reset()

func (*DiagnosticContext) String

func (x *DiagnosticContext) String() string

type DiagnosticTree

type DiagnosticTree struct {
	Root     *AnnotatedNode      `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"`
	Children []*DiagnosticBranch `protobuf:"bytes,2,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

DiagnosticTree is a health-annotated dependency tree for UI rendering.

func (*DiagnosticTree) Descriptor deprecated

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

Deprecated: Use DiagnosticTree.ProtoReflect.Descriptor instead.

func (*DiagnosticTree) GetChildren

func (x *DiagnosticTree) GetChildren() []*DiagnosticBranch

func (*DiagnosticTree) GetRoot

func (x *DiagnosticTree) GetRoot() *AnnotatedNode

func (*DiagnosticTree) ProtoMessage

func (*DiagnosticTree) ProtoMessage()

func (*DiagnosticTree) ProtoReflect

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

func (*DiagnosticTree) Reset

func (x *DiagnosticTree) Reset()

func (*DiagnosticTree) String

func (x *DiagnosticTree) String() string

type EditorSchemasRequest

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

func (*EditorSchemasRequest) Descriptor deprecated

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

Deprecated: Use EditorSchemasRequest.ProtoReflect.Descriptor instead.

func (*EditorSchemasRequest) GetConnectionId

func (x *EditorSchemasRequest) GetConnectionId() string

func (*EditorSchemasRequest) ProtoMessage

func (*EditorSchemasRequest) ProtoMessage()

func (*EditorSchemasRequest) ProtoReflect

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

func (*EditorSchemasRequest) Reset

func (x *EditorSchemasRequest) Reset()

func (*EditorSchemasRequest) String

func (x *EditorSchemasRequest) String() string

type EditorSchemasResponse

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

func (*EditorSchemasResponse) Descriptor deprecated

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

Deprecated: Use EditorSchemasResponse.ProtoReflect.Descriptor instead.

func (*EditorSchemasResponse) GetSchemas

func (x *EditorSchemasResponse) GetSchemas() []*common.EditorSchema

func (*EditorSchemasResponse) ProtoMessage

func (*EditorSchemasResponse) ProtoMessage()

func (*EditorSchemasResponse) ProtoReflect

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

func (*EditorSchemasResponse) Reset

func (x *EditorSchemasResponse) Reset()

func (*EditorSchemasResponse) String

func (x *EditorSchemasResponse) String() string

type EventSeverity

type EventSeverity int32
const (
	EventSeverity_EVENT_SEVERITY_UNSPECIFIED EventSeverity = 0
	EventSeverity_EVENT_SEVERITY_NORMAL      EventSeverity = 1
	EventSeverity_EVENT_SEVERITY_WARNING     EventSeverity = 2
	EventSeverity_EVENT_SEVERITY_ERROR       EventSeverity = 3
)

func (EventSeverity) Descriptor

func (EventSeverity) Enum

func (x EventSeverity) Enum() *EventSeverity

func (EventSeverity) EnumDescriptor deprecated

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

Deprecated: Use EventSeverity.Descriptor instead.

func (EventSeverity) Number

func (EventSeverity) String

func (x EventSeverity) String() string

func (EventSeverity) Type

type ExecuteActionRequest

type ExecuteActionRequest struct {
	ResourceKey  string       `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ConnectionId string       `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	ActionId     string       `protobuf:"bytes,3,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	Input        *ActionInput `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	// 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) GetConnectionId

func (x *ExecuteActionRequest) GetConnectionId() string

func (*ExecuteActionRequest) GetInput

func (x *ExecuteActionRequest) GetInput() *ActionInput

func (*ExecuteActionRequest) GetResourceKey

func (x *ExecuteActionRequest) GetResourceKey() string

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 {
	Result *ActionResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteActionResponse) Descriptor deprecated

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

Deprecated: Use ExecuteActionResponse.ProtoReflect.Descriptor instead.

func (*ExecuteActionResponse) GetResult

func (x *ExecuteActionResponse) GetResult() *ActionResult

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 FilterExpression

type FilterExpression struct {
	Logic      FilterLogic         `protobuf:"varint,1,opt,name=logic,proto3,enum=omniview.sdk.resource.v1.FilterLogic" json:"logic,omitempty"`
	Predicates []*FilterPredicate  `protobuf:"bytes,2,rep,name=predicates,proto3" json:"predicates,omitempty"`
	Groups     []*FilterExpression `protobuf:"bytes,3,rep,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

FilterExpression combines predicates with a logical operator. Supports one level of nesting (AND of ORs, or OR of ANDs).

func (*FilterExpression) Descriptor deprecated

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

Deprecated: Use FilterExpression.ProtoReflect.Descriptor instead.

func (*FilterExpression) GetGroups

func (x *FilterExpression) GetGroups() []*FilterExpression

func (*FilterExpression) GetLogic

func (x *FilterExpression) GetLogic() FilterLogic

func (*FilterExpression) GetPredicates

func (x *FilterExpression) GetPredicates() []*FilterPredicate

func (*FilterExpression) ProtoMessage

func (*FilterExpression) ProtoMessage()

func (*FilterExpression) ProtoReflect

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

func (*FilterExpression) Reset

func (x *FilterExpression) Reset()

func (*FilterExpression) String

func (x *FilterExpression) String() string

type FilterField

type FilterField struct {
	Path          string           `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	DisplayName   string           `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	Description   string           `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Type          FilterFieldType  `protobuf:"varint,4,opt,name=type,proto3,enum=omniview.sdk.resource.v1.FilterFieldType" json:"type,omitempty"`
	Operators     []FilterOperator `protobuf:"varint,5,rep,packed,name=operators,proto3,enum=omniview.sdk.resource.v1.FilterOperator" json:"operators,omitempty"`
	AllowedValues []string         `protobuf:"bytes,6,rep,name=allowed_values,json=allowedValues,proto3" json:"allowed_values,omitempty"`
	Required      bool             `protobuf:"varint,7,opt,name=required,proto3" json:"required,omitempty"`
	// contains filtered or unexported fields
}

FilterField declares a filterable field for introspection.

func (*FilterField) Descriptor deprecated

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

Deprecated: Use FilterField.ProtoReflect.Descriptor instead.

func (*FilterField) GetAllowedValues

func (x *FilterField) GetAllowedValues() []string

func (*FilterField) GetDescription

func (x *FilterField) GetDescription() string

func (*FilterField) GetDisplayName

func (x *FilterField) GetDisplayName() string

func (*FilterField) GetOperators

func (x *FilterField) GetOperators() []FilterOperator

func (*FilterField) GetPath

func (x *FilterField) GetPath() string

func (*FilterField) GetRequired

func (x *FilterField) GetRequired() bool

func (*FilterField) GetType

func (x *FilterField) GetType() FilterFieldType

func (*FilterField) ProtoMessage

func (*FilterField) ProtoMessage()

func (*FilterField) ProtoReflect

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

func (*FilterField) Reset

func (x *FilterField) Reset()

func (*FilterField) String

func (x *FilterField) String() string

type FilterFieldType

type FilterFieldType int32
const (
	FilterFieldType_FILTER_FIELD_TYPE_UNSPECIFIED FilterFieldType = 0
	FilterFieldType_FILTER_FIELD_TYPE_STRING      FilterFieldType = 1
	FilterFieldType_FILTER_FIELD_TYPE_INTEGER     FilterFieldType = 2
	FilterFieldType_FILTER_FIELD_TYPE_NUMBER      FilterFieldType = 3
	FilterFieldType_FILTER_FIELD_TYPE_BOOLEAN     FilterFieldType = 4
	FilterFieldType_FILTER_FIELD_TYPE_DATETIME    FilterFieldType = 5
	FilterFieldType_FILTER_FIELD_TYPE_ENUM        FilterFieldType = 6
	FilterFieldType_FILTER_FIELD_TYPE_MAP         FilterFieldType = 7
)

func (FilterFieldType) Descriptor

func (FilterFieldType) Enum

func (x FilterFieldType) Enum() *FilterFieldType

func (FilterFieldType) EnumDescriptor deprecated

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

Deprecated: Use FilterFieldType.Descriptor instead.

func (FilterFieldType) Number

func (FilterFieldType) String

func (x FilterFieldType) String() string

func (FilterFieldType) Type

type FilterFieldsRequest

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

func (*FilterFieldsRequest) Descriptor deprecated

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

Deprecated: Use FilterFieldsRequest.ProtoReflect.Descriptor instead.

func (*FilterFieldsRequest) GetConnectionId

func (x *FilterFieldsRequest) GetConnectionId() string

func (*FilterFieldsRequest) GetResourceKey

func (x *FilterFieldsRequest) GetResourceKey() string

func (*FilterFieldsRequest) ProtoMessage

func (*FilterFieldsRequest) ProtoMessage()

func (*FilterFieldsRequest) ProtoReflect

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

func (*FilterFieldsRequest) Reset

func (x *FilterFieldsRequest) Reset()

func (*FilterFieldsRequest) String

func (x *FilterFieldsRequest) String() string

type FilterFieldsResponse

type FilterFieldsResponse struct {
	Fields []*FilterField `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterFieldsResponse) Descriptor deprecated

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

Deprecated: Use FilterFieldsResponse.ProtoReflect.Descriptor instead.

func (*FilterFieldsResponse) GetFields

func (x *FilterFieldsResponse) GetFields() []*FilterField

func (*FilterFieldsResponse) ProtoMessage

func (*FilterFieldsResponse) ProtoMessage()

func (*FilterFieldsResponse) ProtoReflect

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

func (*FilterFieldsResponse) Reset

func (x *FilterFieldsResponse) Reset()

func (*FilterFieldsResponse) String

func (x *FilterFieldsResponse) String() string

type FilterLogic

type FilterLogic int32
const (
	FilterLogic_FILTER_LOGIC_UNSPECIFIED FilterLogic = 0
	FilterLogic_FILTER_LOGIC_AND         FilterLogic = 1
	FilterLogic_FILTER_LOGIC_OR          FilterLogic = 2
)

func (FilterLogic) Descriptor

func (FilterLogic) Enum

func (x FilterLogic) Enum() *FilterLogic

func (FilterLogic) EnumDescriptor deprecated

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

Deprecated: Use FilterLogic.Descriptor instead.

func (FilterLogic) Number

func (x FilterLogic) Number() protoreflect.EnumNumber

func (FilterLogic) String

func (x FilterLogic) String() string

func (FilterLogic) Type

type FilterOperator

type FilterOperator int32
const (
	FilterOperator_FILTER_OP_UNSPECIFIED FilterOperator = 0
	FilterOperator_FILTER_OP_EQ          FilterOperator = 1
	FilterOperator_FILTER_OP_NEQ         FilterOperator = 2
	FilterOperator_FILTER_OP_GT          FilterOperator = 3
	FilterOperator_FILTER_OP_GTE         FilterOperator = 4
	FilterOperator_FILTER_OP_LT          FilterOperator = 5
	FilterOperator_FILTER_OP_LTE         FilterOperator = 6
	FilterOperator_FILTER_OP_CONTAINS    FilterOperator = 7
	FilterOperator_FILTER_OP_PREFIX      FilterOperator = 8
	FilterOperator_FILTER_OP_SUFFIX      FilterOperator = 9
	FilterOperator_FILTER_OP_REGEX       FilterOperator = 10
	FilterOperator_FILTER_OP_IN          FilterOperator = 11
	FilterOperator_FILTER_OP_NOT_IN      FilterOperator = 12
	FilterOperator_FILTER_OP_EXISTS      FilterOperator = 13
	FilterOperator_FILTER_OP_NOT_EXISTS  FilterOperator = 14
	FilterOperator_FILTER_OP_HAS_KEY     FilterOperator = 15
)

func (FilterOperator) Descriptor

func (FilterOperator) Enum

func (x FilterOperator) Enum() *FilterOperator

func (FilterOperator) EnumDescriptor deprecated

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

Deprecated: Use FilterOperator.Descriptor instead.

func (FilterOperator) Number

func (FilterOperator) String

func (x FilterOperator) String() string

func (FilterOperator) Type

type FilterPredicate

type FilterPredicate struct {
	Field    string          `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Operator FilterOperator  `protobuf:"varint,2,opt,name=operator,proto3,enum=omniview.sdk.resource.v1.FilterOperator" json:"operator,omitempty"`
	Value    *structpb.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

FilterPredicate is a single condition in a query.

func (*FilterPredicate) Descriptor deprecated

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

Deprecated: Use FilterPredicate.ProtoReflect.Descriptor instead.

func (*FilterPredicate) GetField

func (x *FilterPredicate) GetField() string

func (*FilterPredicate) GetOperator

func (x *FilterPredicate) GetOperator() FilterOperator

func (*FilterPredicate) GetValue

func (x *FilterPredicate) GetValue() *structpb.Value

func (*FilterPredicate) ProtoMessage

func (*FilterPredicate) ProtoMessage()

func (*FilterPredicate) ProtoReflect

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

func (*FilterPredicate) Reset

func (x *FilterPredicate) Reset()

func (*FilterPredicate) String

func (x *FilterPredicate) String() string

type FindRequest

type FindRequest struct {
	ResourceKey  string            `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ConnectionId string            `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Namespaces   []string          `protobuf:"bytes,3,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	Filters      *FilterExpression `protobuf:"bytes,4,opt,name=filters,proto3" json:"filters,omitempty"`
	TextQuery    string            `protobuf:"bytes,5,opt,name=text_query,json=textQuery,proto3" json:"text_query,omitempty"`
	Order        []*OrderField     `protobuf:"bytes,6,rep,name=order,proto3" json:"order,omitempty"`
	Pagination   *PaginationParams `protobuf:"bytes,7,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*FindRequest) Descriptor deprecated

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

Deprecated: Use FindRequest.ProtoReflect.Descriptor instead.

func (*FindRequest) GetConnectionId

func (x *FindRequest) GetConnectionId() string

func (*FindRequest) GetFilters

func (x *FindRequest) GetFilters() *FilterExpression

func (*FindRequest) GetNamespaces

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

func (*FindRequest) GetOrder

func (x *FindRequest) GetOrder() []*OrderField

func (*FindRequest) GetPagination

func (x *FindRequest) GetPagination() *PaginationParams

func (*FindRequest) GetResourceKey

func (x *FindRequest) GetResourceKey() string

func (*FindRequest) GetTextQuery

func (x *FindRequest) GetTextQuery() 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 {
	Items      [][]byte              `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	Total      int32                 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	NextCursor string                `protobuf:"bytes,3,opt,name=next_cursor,json=nextCursor,proto3" json:"next_cursor,omitempty"`
	Error      *common.ResourceError `protobuf:"bytes,4,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) GetError

func (x *FindResponse) GetError() *common.ResourceError

func (*FindResponse) GetItems

func (x *FindResponse) GetItems() [][]byte

func (*FindResponse) GetNextCursor

func (x *FindResponse) GetNextCursor() string

func (*FindResponse) GetTotal

func (x *FindResponse) GetTotal() int32

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 {
	ResourceKey  string `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ConnectionId string `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetActionsRequest) Descriptor deprecated

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

Deprecated: Use GetActionsRequest.ProtoReflect.Descriptor instead.

func (*GetActionsRequest) GetConnectionId

func (x *GetActionsRequest) GetConnectionId() string

func (*GetActionsRequest) GetResourceKey

func (x *GetActionsRequest) GetResourceKey() 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 GetRequest

type GetRequest struct {
	ResourceKey  string `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ConnectionId string `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,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) GetConnectionId

func (x *GetRequest) GetConnectionId() string

func (*GetRequest) GetId

func (x *GetRequest) GetId() string

func (*GetRequest) GetNamespace

func (x *GetRequest) GetNamespace() string

func (*GetRequest) GetResourceKey

func (x *GetRequest) GetResourceKey() 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 {
	Data  []byte                `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Error *common.ResourceError `protobuf:"bytes,2,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() []byte

func (*GetResponse) GetError

func (x *GetResponse) GetError() *common.ResourceError

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 GetWatchStateRequest

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

GetWatchStateRequest asks for the current watch state summary for a connection.

func (*GetWatchStateRequest) Descriptor deprecated

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

Deprecated: Use GetWatchStateRequest.ProtoReflect.Descriptor instead.

func (*GetWatchStateRequest) GetConnectionId

func (x *GetWatchStateRequest) GetConnectionId() string

func (*GetWatchStateRequest) ProtoMessage

func (*GetWatchStateRequest) ProtoMessage()

func (*GetWatchStateRequest) ProtoReflect

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

func (*GetWatchStateRequest) Reset

func (x *GetWatchStateRequest) Reset()

func (*GetWatchStateRequest) String

func (x *GetWatchStateRequest) String() string

type GetWatchStateResponse

type GetWatchStateResponse struct {
	ConnectionId    string                `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Resources       map[string]WatchState `` /* 187-byte string literal not displayed */
	ResourceCounts  map[string]int32      `` /* 178-byte string literal not displayed */
	ScopePartitions []string              `protobuf:"bytes,4,rep,name=scope_partitions,json=scopePartitions,proto3" json:"scope_partitions,omitempty"`
	// contains filtered or unexported fields
}

GetWatchStateResponse returns per-resource watch states and counts for a connection.

func (*GetWatchStateResponse) Descriptor deprecated

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

Deprecated: Use GetWatchStateResponse.ProtoReflect.Descriptor instead.

func (*GetWatchStateResponse) GetConnectionId

func (x *GetWatchStateResponse) GetConnectionId() string

func (*GetWatchStateResponse) GetResourceCounts

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

func (*GetWatchStateResponse) GetResources

func (x *GetWatchStateResponse) GetResources() map[string]WatchState

func (*GetWatchStateResponse) GetScopePartitions

func (x *GetWatchStateResponse) GetScopePartitions() []string

func (*GetWatchStateResponse) ProtoMessage

func (*GetWatchStateResponse) ProtoMessage()

func (*GetWatchStateResponse) ProtoReflect

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

func (*GetWatchStateResponse) Reset

func (x *GetWatchStateResponse) Reset()

func (*GetWatchStateResponse) String

func (x *GetWatchStateResponse) String() string

type HealthCondition

type HealthCondition struct {
	Type               string                 `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Status             string                 `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Reason             string                 `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	Message            string                 `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	LastProbeTime      *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_probe_time,json=lastProbeTime,proto3,oneof" json:"last_probe_time,omitempty"`
	LastTransitionTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=last_transition_time,json=lastTransitionTime,proto3,oneof" json:"last_transition_time,omitempty"`
	// contains filtered or unexported fields
}

HealthCondition is a single health condition (Ready, Scheduled, etc.).

func (*HealthCondition) Descriptor deprecated

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

Deprecated: Use HealthCondition.ProtoReflect.Descriptor instead.

func (*HealthCondition) GetLastProbeTime

func (x *HealthCondition) GetLastProbeTime() *timestamppb.Timestamp

func (*HealthCondition) GetLastTransitionTime

func (x *HealthCondition) GetLastTransitionTime() *timestamppb.Timestamp

func (*HealthCondition) GetMessage

func (x *HealthCondition) GetMessage() string

func (*HealthCondition) GetReason

func (x *HealthCondition) GetReason() string

func (*HealthCondition) GetStatus

func (x *HealthCondition) GetStatus() string

func (*HealthCondition) GetType

func (x *HealthCondition) GetType() string

func (*HealthCondition) ProtoMessage

func (*HealthCondition) ProtoMessage()

func (*HealthCondition) ProtoReflect

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

func (*HealthCondition) Reset

func (x *HealthCondition) Reset()

func (*HealthCondition) String

func (x *HealthCondition) String() string

type HealthRequest

type HealthRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	ResourceKey  string `protobuf:"bytes,2,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	Data         []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthRequest) Descriptor deprecated

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

Deprecated: Use HealthRequest.ProtoReflect.Descriptor instead.

func (*HealthRequest) GetConnectionId

func (x *HealthRequest) GetConnectionId() string

func (*HealthRequest) GetData

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

func (*HealthRequest) GetResourceKey

func (x *HealthRequest) GetResourceKey() string

func (*HealthRequest) ProtoMessage

func (*HealthRequest) ProtoMessage()

func (*HealthRequest) ProtoReflect

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

func (*HealthRequest) Reset

func (x *HealthRequest) Reset()

func (*HealthRequest) String

func (x *HealthRequest) String() string

type HealthResponse

type HealthResponse struct {
	Health *ResourceHealth `protobuf:"bytes,1,opt,name=health,proto3" json:"health,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthResponse) Descriptor deprecated

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

Deprecated: Use HealthResponse.ProtoReflect.Descriptor instead.

func (*HealthResponse) GetHealth

func (x *HealthResponse) GetHealth() *ResourceHealth

func (*HealthResponse) ProtoMessage

func (*HealthResponse) ProtoMessage()

func (*HealthResponse) ProtoReflect

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

func (*HealthResponse) Reset

func (x *HealthResponse) Reset()

func (*HealthResponse) String

func (x *HealthResponse) String() string

type HealthStatus

type HealthStatus int32
const (
	HealthStatus_HEALTH_STATUS_UNSPECIFIED HealthStatus = 0
	HealthStatus_HEALTH_STATUS_HEALTHY     HealthStatus = 1
	HealthStatus_HEALTH_STATUS_DEGRADED    HealthStatus = 2
	HealthStatus_HEALTH_STATUS_UNHEALTHY   HealthStatus = 3
	HealthStatus_HEALTH_STATUS_PENDING     HealthStatus = 4
	HealthStatus_HEALTH_STATUS_UNKNOWN     HealthStatus = 5
)

func (HealthStatus) Descriptor

func (HealthStatus) Enum

func (x HealthStatus) Enum() *HealthStatus

func (HealthStatus) EnumDescriptor deprecated

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

Deprecated: Use HealthStatus.Descriptor instead.

func (HealthStatus) Number

func (HealthStatus) String

func (x HealthStatus) String() string

func (HealthStatus) Type

type ImpactReport

type ImpactReport struct {
	Target               *ResourceRef                  `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	DirectDependents     map[string]*AnnotatedNodeList `` /* 183-byte string literal not displayed */
	TransitiveDependents map[string]*AnnotatedNodeList `` /* 195-byte string literal not displayed */
	Summary              string                        `protobuf:"bytes,4,opt,name=summary,proto3" json:"summary,omitempty"`
	AffectedCounts       map[string]int32              `` /* 178-byte string literal not displayed */
	// contains filtered or unexported fields
}

ImpactReport describes what would be affected by a resource failure/removal.

func (*ImpactReport) Descriptor deprecated

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

Deprecated: Use ImpactReport.ProtoReflect.Descriptor instead.

func (*ImpactReport) GetAffectedCounts

func (x *ImpactReport) GetAffectedCounts() map[string]int32

func (*ImpactReport) GetDirectDependents

func (x *ImpactReport) GetDirectDependents() map[string]*AnnotatedNodeList

func (*ImpactReport) GetSummary

func (x *ImpactReport) GetSummary() string

func (*ImpactReport) GetTarget

func (x *ImpactReport) GetTarget() *ResourceRef

func (*ImpactReport) GetTransitiveDependents

func (x *ImpactReport) GetTransitiveDependents() map[string]*AnnotatedNodeList

func (*ImpactReport) ProtoMessage

func (*ImpactReport) ProtoMessage()

func (*ImpactReport) ProtoReflect

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

func (*ImpactReport) Reset

func (x *ImpactReport) Reset()

func (*ImpactReport) String

func (x *ImpactReport) String() string

type ListRequest

type ListRequest struct {
	ResourceKey  string            `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ConnectionId string            `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Namespaces   []string          `protobuf:"bytes,3,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	Order        []*OrderField     `protobuf:"bytes,4,rep,name=order,proto3" json:"order,omitempty"`
	Pagination   *PaginationParams `protobuf:"bytes,5,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetConnectionId

func (x *ListRequest) GetConnectionId() string

func (*ListRequest) GetNamespaces

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

func (*ListRequest) GetOrder

func (x *ListRequest) GetOrder() []*OrderField

func (*ListRequest) GetPagination

func (x *ListRequest) GetPagination() *PaginationParams

func (*ListRequest) GetResourceKey

func (x *ListRequest) GetResourceKey() 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 {
	Items      [][]byte              `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	Total      int32                 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	NextCursor string                `protobuf:"bytes,3,opt,name=next_cursor,json=nextCursor,proto3" json:"next_cursor,omitempty"`
	Error      *common.ResourceError `protobuf:"bytes,4,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) GetError

func (x *ListResponse) GetError() *common.ResourceError

func (*ListResponse) GetItems

func (x *ListResponse) GetItems() [][]byte

func (*ListResponse) GetNextCursor

func (x *ListResponse) GetNextCursor() string

func (*ListResponse) GetTotal

func (x *ListResponse) GetTotal() int32

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 ListenRequest

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

ListenRequest starts the event stream.

func (*ListenRequest) Descriptor deprecated

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

Deprecated: Use ListenRequest.ProtoReflect.Descriptor instead.

func (*ListenRequest) ProtoMessage

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) ProtoReflect

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

func (*ListenRequest) Reset

func (x *ListenRequest) Reset()

func (*ListenRequest) String

func (x *ListenRequest) String() string

type LoadConnectionsRequest

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

func (*LoadConnectionsRequest) Descriptor deprecated

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

Deprecated: Use LoadConnectionsRequest.ProtoReflect.Descriptor instead.

func (*LoadConnectionsRequest) ProtoMessage

func (*LoadConnectionsRequest) ProtoMessage()

func (*LoadConnectionsRequest) ProtoReflect

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

func (*LoadConnectionsRequest) Reset

func (x *LoadConnectionsRequest) Reset()

func (*LoadConnectionsRequest) String

func (x *LoadConnectionsRequest) String() string

type LoadConnectionsResponse

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

func (*LoadConnectionsResponse) Descriptor deprecated

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

Deprecated: Use LoadConnectionsResponse.ProtoReflect.Descriptor instead.

func (*LoadConnectionsResponse) GetConnections

func (x *LoadConnectionsResponse) GetConnections() []*common.Connection

func (*LoadConnectionsResponse) ProtoMessage

func (*LoadConnectionsResponse) ProtoMessage()

func (*LoadConnectionsResponse) ProtoReflect

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

func (*LoadConnectionsResponse) Reset

func (x *LoadConnectionsResponse) Reset()

func (*LoadConnectionsResponse) String

func (x *LoadConnectionsResponse) String() string

type NamespacesResponse

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

func (*NamespacesResponse) Descriptor deprecated

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

Deprecated: Use NamespacesResponse.ProtoReflect.Descriptor instead.

func (*NamespacesResponse) GetNamespaces

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

func (*NamespacesResponse) ProtoMessage

func (*NamespacesResponse) ProtoMessage()

func (*NamespacesResponse) ProtoReflect

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

func (*NamespacesResponse) Reset

func (x *NamespacesResponse) Reset()

func (*NamespacesResponse) String

func (x *NamespacesResponse) String() string

type OrderField

type OrderField struct {
	Path       string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Descending bool   `protobuf:"varint,2,opt,name=descending,proto3" json:"descending,omitempty"`
	// contains filtered or unexported fields
}

OrderField specifies a sort field.

func (*OrderField) Descriptor deprecated

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

Deprecated: Use OrderField.ProtoReflect.Descriptor instead.

func (*OrderField) GetDescending

func (x *OrderField) GetDescending() bool

func (*OrderField) GetPath

func (x *OrderField) GetPath() string

func (*OrderField) ProtoMessage

func (*OrderField) ProtoMessage()

func (*OrderField) ProtoReflect

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

func (*OrderField) Reset

func (x *OrderField) Reset()

func (*OrderField) String

func (x *OrderField) String() string

type PaginationParams

type PaginationParams struct {
	Page     int32  `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	PageSize int32  `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	Cursor   string `protobuf:"bytes,3,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

PaginationParams supports both page-based and cursor-based pagination.

func (*PaginationParams) Descriptor deprecated

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

Deprecated: Use PaginationParams.ProtoReflect.Descriptor instead.

func (*PaginationParams) GetCursor

func (x *PaginationParams) GetCursor() string

func (*PaginationParams) GetPage

func (x *PaginationParams) GetPage() int32

func (*PaginationParams) GetPageSize

func (x *PaginationParams) GetPageSize() int32

func (*PaginationParams) ProtoMessage

func (*PaginationParams) ProtoMessage()

func (*PaginationParams) ProtoReflect

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

func (*PaginationParams) Reset

func (x *PaginationParams) Reset()

func (*PaginationParams) String

func (x *PaginationParams) String() string

type RelationshipDescriptor

type RelationshipDescriptor struct {
	Type              RelationshipType       `protobuf:"varint,1,opt,name=type,proto3,enum=omniview.sdk.resource.v1.RelationshipType" json:"type,omitempty"`
	TargetResourceKey string                 `protobuf:"bytes,2,opt,name=target_resource_key,json=targetResourceKey,proto3" json:"target_resource_key,omitempty"`
	Label             string                 `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"`
	InverseLabel      string                 `protobuf:"bytes,4,opt,name=inverse_label,json=inverseLabel,proto3" json:"inverse_label,omitempty"`
	Cardinality       string                 `protobuf:"bytes,5,opt,name=cardinality,proto3" json:"cardinality,omitempty"`
	Extractor         *RelationshipExtractor `protobuf:"bytes,6,opt,name=extractor,proto3" json:"extractor,omitempty"`
	Direction         string                 `protobuf:"bytes,7,opt,name=direction,proto3" json:"direction,omitempty"`
	TargetNamespaced  *wrapperspb.BoolValue  `protobuf:"bytes,8,opt,name=target_namespaced,json=targetNamespaced,proto3" json:"target_namespaced,omitempty"`
	// contains filtered or unexported fields
}

RelationshipDescriptor declares a relationship from one resource type to another.

func (*RelationshipDescriptor) Descriptor deprecated

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

Deprecated: Use RelationshipDescriptor.ProtoReflect.Descriptor instead.

func (*RelationshipDescriptor) GetCardinality

func (x *RelationshipDescriptor) GetCardinality() string

func (*RelationshipDescriptor) GetDirection added in v0.3.1

func (x *RelationshipDescriptor) GetDirection() string

func (*RelationshipDescriptor) GetExtractor

func (x *RelationshipDescriptor) GetExtractor() *RelationshipExtractor

func (*RelationshipDescriptor) GetInverseLabel

func (x *RelationshipDescriptor) GetInverseLabel() string

func (*RelationshipDescriptor) GetLabel

func (x *RelationshipDescriptor) GetLabel() string

func (*RelationshipDescriptor) GetTargetNamespaced added in v0.4.0

func (x *RelationshipDescriptor) GetTargetNamespaced() *wrapperspb.BoolValue

func (*RelationshipDescriptor) GetTargetResourceKey

func (x *RelationshipDescriptor) GetTargetResourceKey() string

func (*RelationshipDescriptor) GetType

func (*RelationshipDescriptor) ProtoMessage

func (*RelationshipDescriptor) ProtoMessage()

func (*RelationshipDescriptor) ProtoReflect

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

func (*RelationshipDescriptor) Reset

func (x *RelationshipDescriptor) Reset()

func (*RelationshipDescriptor) String

func (x *RelationshipDescriptor) String() string

type RelationshipEdge

type RelationshipEdge struct {
	Source      *ResourceRef            `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Target      *ResourceRef            `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Descriptor_ *RelationshipDescriptor `protobuf:"bytes,3,opt,name=descriptor,proto3" json:"descriptor,omitempty"`
	// contains filtered or unexported fields
}

RelationshipEdge is a single edge in the relationship graph.

func (*RelationshipEdge) Descriptor deprecated

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

Deprecated: Use RelationshipEdge.ProtoReflect.Descriptor instead.

func (*RelationshipEdge) GetDescriptor_

func (x *RelationshipEdge) GetDescriptor_() *RelationshipDescriptor

func (*RelationshipEdge) GetSource

func (x *RelationshipEdge) GetSource() *ResourceRef

func (*RelationshipEdge) GetTarget

func (x *RelationshipEdge) GetTarget() *ResourceRef

func (*RelationshipEdge) ProtoMessage

func (*RelationshipEdge) ProtoMessage()

func (*RelationshipEdge) ProtoReflect

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

func (*RelationshipEdge) Reset

func (x *RelationshipEdge) Reset()

func (*RelationshipEdge) String

func (x *RelationshipEdge) String() string

type RelationshipExtractor

type RelationshipExtractor struct {
	Method    string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	FieldPath string `protobuf:"bytes,2,opt,name=field_path,json=fieldPath,proto3" json:"field_path,omitempty"`
	// Deprecated: retained for wire compatibility; not used by current conversion logic.
	//
	// Deprecated: Marked as deprecated in proto/v1/resource/relationship.proto.
	OwnerRefKind  string            `protobuf:"bytes,3,opt,name=owner_ref_kind,json=ownerRefKind,proto3" json:"owner_ref_kind,omitempty"`
	LabelSelector map[string]string `` /* 174-byte string literal not displayed */
	// contains filtered or unexported fields
}

RelationshipExtractor defines how to find related resource IDs from source data.

func (*RelationshipExtractor) Descriptor deprecated

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

Deprecated: Use RelationshipExtractor.ProtoReflect.Descriptor instead.

func (*RelationshipExtractor) GetFieldPath

func (x *RelationshipExtractor) GetFieldPath() string

func (*RelationshipExtractor) GetLabelSelector

func (x *RelationshipExtractor) GetLabelSelector() map[string]string

func (*RelationshipExtractor) GetMethod

func (x *RelationshipExtractor) GetMethod() string

func (*RelationshipExtractor) GetOwnerRefKind deprecated

func (x *RelationshipExtractor) GetOwnerRefKind() string

Deprecated: Marked as deprecated in proto/v1/resource/relationship.proto.

func (*RelationshipExtractor) ProtoMessage

func (*RelationshipExtractor) ProtoMessage()

func (*RelationshipExtractor) ProtoReflect

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

func (*RelationshipExtractor) Reset

func (x *RelationshipExtractor) Reset()

func (*RelationshipExtractor) String

func (x *RelationshipExtractor) String() string

type RelationshipType

type RelationshipType int32
const (
	RelationshipType_RELATIONSHIP_TYPE_UNSPECIFIED RelationshipType = 0
	RelationshipType_RELATIONSHIP_TYPE_OWNS        RelationshipType = 1
	RelationshipType_RELATIONSHIP_TYPE_RUNS_ON     RelationshipType = 2
	RelationshipType_RELATIONSHIP_TYPE_USES        RelationshipType = 3
	RelationshipType_RELATIONSHIP_TYPE_EXPOSES     RelationshipType = 4
	RelationshipType_RELATIONSHIP_TYPE_MANAGES     RelationshipType = 5
	RelationshipType_RELATIONSHIP_TYPE_MEMBER_OF   RelationshipType = 6
	RelationshipType_RELATIONSHIP_TYPE_SELECTS     RelationshipType = 7
)

func (RelationshipType) Descriptor

func (RelationshipType) Enum

func (RelationshipType) EnumDescriptor deprecated

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

Deprecated: Use RelationshipType.Descriptor instead.

func (RelationshipType) Number

func (RelationshipType) String

func (x RelationshipType) String() string

func (RelationshipType) Type

type RelationshipsRequest

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

func (*RelationshipsRequest) Descriptor deprecated

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

Deprecated: Use RelationshipsRequest.ProtoReflect.Descriptor instead.

func (*RelationshipsRequest) GetResourceKey

func (x *RelationshipsRequest) GetResourceKey() string

func (*RelationshipsRequest) ProtoMessage

func (*RelationshipsRequest) ProtoMessage()

func (*RelationshipsRequest) ProtoReflect

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

func (*RelationshipsRequest) Reset

func (x *RelationshipsRequest) Reset()

func (*RelationshipsRequest) String

func (x *RelationshipsRequest) String() string

type RelationshipsResponse

type RelationshipsResponse struct {
	Relationships []*RelationshipDescriptor `protobuf:"bytes,1,rep,name=relationships,proto3" json:"relationships,omitempty"`
	// contains filtered or unexported fields
}

func (*RelationshipsResponse) Descriptor deprecated

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

Deprecated: Use RelationshipsResponse.ProtoReflect.Descriptor instead.

func (*RelationshipsResponse) GetRelationships

func (x *RelationshipsResponse) GetRelationships() []*RelationshipDescriptor

func (*RelationshipsResponse) ProtoMessage

func (*RelationshipsResponse) ProtoMessage()

func (*RelationshipsResponse) ProtoReflect

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

func (*RelationshipsResponse) Reset

func (x *RelationshipsResponse) Reset()

func (*RelationshipsResponse) String

func (x *RelationshipsResponse) String() string

type ResolveRelationshipsRequest

type ResolveRelationshipsRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	ResourceKey  string `protobuf:"bytes,2,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,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 (*ResolveRelationshipsRequest) Descriptor deprecated

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

Deprecated: Use ResolveRelationshipsRequest.ProtoReflect.Descriptor instead.

func (*ResolveRelationshipsRequest) GetConnectionId

func (x *ResolveRelationshipsRequest) GetConnectionId() string

func (*ResolveRelationshipsRequest) GetId

func (*ResolveRelationshipsRequest) GetNamespace

func (x *ResolveRelationshipsRequest) GetNamespace() string

func (*ResolveRelationshipsRequest) GetResourceKey

func (x *ResolveRelationshipsRequest) GetResourceKey() string

func (*ResolveRelationshipsRequest) ProtoMessage

func (*ResolveRelationshipsRequest) ProtoMessage()

func (*ResolveRelationshipsRequest) ProtoReflect

func (*ResolveRelationshipsRequest) Reset

func (x *ResolveRelationshipsRequest) Reset()

func (*ResolveRelationshipsRequest) String

func (x *ResolveRelationshipsRequest) String() string

type ResolveRelationshipsResponse

type ResolveRelationshipsResponse struct {
	Relationships []*ResolvedRelationship `protobuf:"bytes,1,rep,name=relationships,proto3" json:"relationships,omitempty"`
	// contains filtered or unexported fields
}

func (*ResolveRelationshipsResponse) Descriptor deprecated

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

Deprecated: Use ResolveRelationshipsResponse.ProtoReflect.Descriptor instead.

func (*ResolveRelationshipsResponse) GetRelationships

func (x *ResolveRelationshipsResponse) GetRelationships() []*ResolvedRelationship

func (*ResolveRelationshipsResponse) ProtoMessage

func (*ResolveRelationshipsResponse) ProtoMessage()

func (*ResolveRelationshipsResponse) ProtoReflect

func (*ResolveRelationshipsResponse) Reset

func (x *ResolveRelationshipsResponse) Reset()

func (*ResolveRelationshipsResponse) String

type ResolvedRelationship

type ResolvedRelationship struct {
	Descriptor_ *RelationshipDescriptor `protobuf:"bytes,1,opt,name=descriptor,proto3" json:"descriptor,omitempty"`
	Targets     []*ResourceRef          `protobuf:"bytes,2,rep,name=targets,proto3" json:"targets,omitempty"`
	// contains filtered or unexported fields
}

ResolvedRelationship contains actual relationship instances for a resource.

func (*ResolvedRelationship) Descriptor deprecated

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

Deprecated: Use ResolvedRelationship.ProtoReflect.Descriptor instead.

func (*ResolvedRelationship) GetDescriptor_

func (x *ResolvedRelationship) GetDescriptor_() *RelationshipDescriptor

func (*ResolvedRelationship) GetTargets

func (x *ResolvedRelationship) GetTargets() []*ResourceRef

func (*ResolvedRelationship) ProtoMessage

func (*ResolvedRelationship) ProtoMessage()

func (*ResolvedRelationship) ProtoReflect

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

func (*ResolvedRelationship) Reset

func (x *ResolvedRelationship) Reset()

func (*ResolvedRelationship) String

func (x *ResolvedRelationship) String() string

type ResourceCapabilities

type ResourceCapabilities struct {
	CanGet           bool       `protobuf:"varint,1,opt,name=can_get,json=canGet,proto3" json:"can_get,omitempty"`
	CanList          bool       `protobuf:"varint,2,opt,name=can_list,json=canList,proto3" json:"can_list,omitempty"`
	CanFind          bool       `protobuf:"varint,3,opt,name=can_find,json=canFind,proto3" json:"can_find,omitempty"`
	CanCreate        bool       `protobuf:"varint,4,opt,name=can_create,json=canCreate,proto3" json:"can_create,omitempty"`
	CanUpdate        bool       `protobuf:"varint,5,opt,name=can_update,json=canUpdate,proto3" json:"can_update,omitempty"`
	CanDelete        bool       `protobuf:"varint,6,opt,name=can_delete,json=canDelete,proto3" json:"can_delete,omitempty"`
	Watchable        bool       `protobuf:"varint,7,opt,name=watchable,proto3" json:"watchable,omitempty"`
	Filterable       bool       `protobuf:"varint,8,opt,name=filterable,proto3" json:"filterable,omitempty"`
	Searchable       bool       `protobuf:"varint,9,opt,name=searchable,proto3" json:"searchable,omitempty"`
	HasActions       bool       `protobuf:"varint,10,opt,name=has_actions,json=hasActions,proto3" json:"has_actions,omitempty"`
	HasSchema        bool       `protobuf:"varint,11,opt,name=has_schema,json=hasSchema,proto3" json:"has_schema,omitempty"`
	NamespaceScoped  bool       `protobuf:"varint,12,opt,name=namespace_scoped,json=namespaceScoped,proto3" json:"namespace_scoped,omitempty"`
	HasRelationships bool       `protobuf:"varint,13,opt,name=has_relationships,json=hasRelationships,proto3" json:"has_relationships,omitempty"`
	HasHealth        bool       `protobuf:"varint,14,opt,name=has_health,json=hasHealth,proto3" json:"has_health,omitempty"`
	HasEvents        bool       `protobuf:"varint,15,opt,name=has_events,json=hasEvents,proto3" json:"has_events,omitempty"`
	ScaleHint        *ScaleHint `protobuf:"bytes,16,opt,name=scale_hint,json=scaleHint,proto3" json:"scale_hint,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceCapabilities) Descriptor deprecated

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

Deprecated: Use ResourceCapabilities.ProtoReflect.Descriptor instead.

func (*ResourceCapabilities) GetCanCreate

func (x *ResourceCapabilities) GetCanCreate() bool

func (*ResourceCapabilities) GetCanDelete

func (x *ResourceCapabilities) GetCanDelete() bool

func (*ResourceCapabilities) GetCanFind

func (x *ResourceCapabilities) GetCanFind() bool

func (*ResourceCapabilities) GetCanGet

func (x *ResourceCapabilities) GetCanGet() bool

func (*ResourceCapabilities) GetCanList

func (x *ResourceCapabilities) GetCanList() bool

func (*ResourceCapabilities) GetCanUpdate

func (x *ResourceCapabilities) GetCanUpdate() bool

func (*ResourceCapabilities) GetFilterable

func (x *ResourceCapabilities) GetFilterable() bool

func (*ResourceCapabilities) GetHasActions

func (x *ResourceCapabilities) GetHasActions() bool

func (*ResourceCapabilities) GetHasEvents

func (x *ResourceCapabilities) GetHasEvents() bool

func (*ResourceCapabilities) GetHasHealth

func (x *ResourceCapabilities) GetHasHealth() bool

func (*ResourceCapabilities) GetHasRelationships

func (x *ResourceCapabilities) GetHasRelationships() bool

func (*ResourceCapabilities) GetHasSchema

func (x *ResourceCapabilities) GetHasSchema() bool

func (*ResourceCapabilities) GetNamespaceScoped

func (x *ResourceCapabilities) GetNamespaceScoped() bool

func (*ResourceCapabilities) GetScaleHint

func (x *ResourceCapabilities) GetScaleHint() *ScaleHint

func (*ResourceCapabilities) GetSearchable

func (x *ResourceCapabilities) GetSearchable() bool

func (*ResourceCapabilities) GetWatchable

func (x *ResourceCapabilities) GetWatchable() bool

func (*ResourceCapabilities) ProtoMessage

func (*ResourceCapabilities) ProtoMessage()

func (*ResourceCapabilities) ProtoReflect

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

func (*ResourceCapabilities) Reset

func (x *ResourceCapabilities) Reset()

func (*ResourceCapabilities) String

func (x *ResourceCapabilities) String() string

type ResourceCapabilitiesRequest

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

func (*ResourceCapabilitiesRequest) Descriptor deprecated

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

Deprecated: Use ResourceCapabilitiesRequest.ProtoReflect.Descriptor instead.

func (*ResourceCapabilitiesRequest) GetResourceKey

func (x *ResourceCapabilitiesRequest) GetResourceKey() string

func (*ResourceCapabilitiesRequest) ProtoMessage

func (*ResourceCapabilitiesRequest) ProtoMessage()

func (*ResourceCapabilitiesRequest) ProtoReflect

func (*ResourceCapabilitiesRequest) Reset

func (x *ResourceCapabilitiesRequest) Reset()

func (*ResourceCapabilitiesRequest) String

func (x *ResourceCapabilitiesRequest) String() string

type ResourceCapabilitiesResponse

type ResourceCapabilitiesResponse struct {
	Capabilities *ResourceCapabilities `protobuf:"bytes,1,opt,name=capabilities,proto3" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceCapabilitiesResponse) Descriptor deprecated

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

Deprecated: Use ResourceCapabilitiesResponse.ProtoReflect.Descriptor instead.

func (*ResourceCapabilitiesResponse) GetCapabilities

func (x *ResourceCapabilitiesResponse) GetCapabilities() *ResourceCapabilities

func (*ResourceCapabilitiesResponse) ProtoMessage

func (*ResourceCapabilitiesResponse) ProtoMessage()

func (*ResourceCapabilitiesResponse) ProtoReflect

func (*ResourceCapabilitiesResponse) Reset

func (x *ResourceCapabilitiesResponse) Reset()

func (*ResourceCapabilitiesResponse) String

type ResourceEvent

type ResourceEvent struct {
	Type      EventSeverity          `protobuf:"varint,1,opt,name=type,proto3,enum=omniview.sdk.resource.v1.EventSeverity" json:"type,omitempty"`
	Reason    string                 `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Message   string                 `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Source    string                 `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	Count     int32                  `protobuf:"varint,5,opt,name=count,proto3" json:"count,omitempty"`
	FirstSeen *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=first_seen,json=firstSeen,proto3" json:"first_seen,omitempty"`
	LastSeen  *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	// contains filtered or unexported fields
}

ResourceEvent is a diagnostic event.

func (*ResourceEvent) Descriptor deprecated

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

Deprecated: Use ResourceEvent.ProtoReflect.Descriptor instead.

func (*ResourceEvent) GetCount

func (x *ResourceEvent) GetCount() int32

func (*ResourceEvent) GetFirstSeen

func (x *ResourceEvent) GetFirstSeen() *timestamppb.Timestamp

func (*ResourceEvent) GetLastSeen

func (x *ResourceEvent) GetLastSeen() *timestamppb.Timestamp

func (*ResourceEvent) GetMessage

func (x *ResourceEvent) GetMessage() string

func (*ResourceEvent) GetReason

func (x *ResourceEvent) GetReason() string

func (*ResourceEvent) GetSource

func (x *ResourceEvent) GetSource() string

func (*ResourceEvent) GetType

func (x *ResourceEvent) GetType() EventSeverity

func (*ResourceEvent) ProtoMessage

func (*ResourceEvent) ProtoMessage()

func (*ResourceEvent) ProtoReflect

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

func (*ResourceEvent) Reset

func (x *ResourceEvent) Reset()

func (*ResourceEvent) String

func (x *ResourceEvent) String() string

type ResourceEventsRequest

type ResourceEventsRequest struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	ResourceKey  string `protobuf:"bytes,2,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,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"`
	Limit        int32  `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceEventsRequest) Descriptor deprecated

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

Deprecated: Use ResourceEventsRequest.ProtoReflect.Descriptor instead.

func (*ResourceEventsRequest) GetConnectionId

func (x *ResourceEventsRequest) GetConnectionId() string

func (*ResourceEventsRequest) GetId

func (x *ResourceEventsRequest) GetId() string

func (*ResourceEventsRequest) GetLimit

func (x *ResourceEventsRequest) GetLimit() int32

func (*ResourceEventsRequest) GetNamespace

func (x *ResourceEventsRequest) GetNamespace() string

func (*ResourceEventsRequest) GetResourceKey

func (x *ResourceEventsRequest) GetResourceKey() string

func (*ResourceEventsRequest) ProtoMessage

func (*ResourceEventsRequest) ProtoMessage()

func (*ResourceEventsRequest) ProtoReflect

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

func (*ResourceEventsRequest) Reset

func (x *ResourceEventsRequest) Reset()

func (*ResourceEventsRequest) String

func (x *ResourceEventsRequest) String() string

type ResourceEventsResponse

type ResourceEventsResponse struct {
	Events []*ResourceEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceEventsResponse) Descriptor deprecated

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

Deprecated: Use ResourceEventsResponse.ProtoReflect.Descriptor instead.

func (*ResourceEventsResponse) GetEvents

func (x *ResourceEventsResponse) GetEvents() []*ResourceEvent

func (*ResourceEventsResponse) ProtoMessage

func (*ResourceEventsResponse) ProtoMessage()

func (*ResourceEventsResponse) ProtoReflect

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

func (*ResourceEventsResponse) Reset

func (x *ResourceEventsResponse) Reset()

func (*ResourceEventsResponse) String

func (x *ResourceEventsResponse) String() string

type ResourceGroupsRequest

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

func (*ResourceGroupsRequest) Descriptor deprecated

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

Deprecated: Use ResourceGroupsRequest.ProtoReflect.Descriptor instead.

func (*ResourceGroupsRequest) GetConnectionId

func (x *ResourceGroupsRequest) GetConnectionId() string

func (*ResourceGroupsRequest) ProtoMessage

func (*ResourceGroupsRequest) ProtoMessage()

func (*ResourceGroupsRequest) ProtoReflect

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

func (*ResourceGroupsRequest) Reset

func (x *ResourceGroupsRequest) Reset()

func (*ResourceGroupsRequest) String

func (x *ResourceGroupsRequest) String() string

type ResourceGroupsResponse

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

func (*ResourceGroupsResponse) Descriptor deprecated

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

Deprecated: Use ResourceGroupsResponse.ProtoReflect.Descriptor instead.

func (*ResourceGroupsResponse) GetGroups

func (x *ResourceGroupsResponse) GetGroups() map[string]*common.ResourceGroup

func (*ResourceGroupsResponse) ProtoMessage

func (*ResourceGroupsResponse) ProtoMessage()

func (*ResourceGroupsResponse) ProtoReflect

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

func (*ResourceGroupsResponse) Reset

func (x *ResourceGroupsResponse) Reset()

func (*ResourceGroupsResponse) String

func (x *ResourceGroupsResponse) String() string

type ResourceHealth

type ResourceHealth struct {
	Status     HealthStatus           `protobuf:"varint,1,opt,name=status,proto3,enum=omniview.sdk.resource.v1.HealthStatus" json:"status,omitempty"`
	Reason     string                 `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Message    string                 `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Since      *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=since,proto3,oneof" json:"since,omitempty"`
	Conditions []*HealthCondition     `protobuf:"bytes,5,rep,name=conditions,proto3" json:"conditions,omitempty"`
	// contains filtered or unexported fields
}

ResourceHealth is the normalized health assessment for a resource.

func (*ResourceHealth) Descriptor deprecated

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

Deprecated: Use ResourceHealth.ProtoReflect.Descriptor instead.

func (*ResourceHealth) GetConditions

func (x *ResourceHealth) GetConditions() []*HealthCondition

func (*ResourceHealth) GetMessage

func (x *ResourceHealth) GetMessage() string

func (*ResourceHealth) GetReason

func (x *ResourceHealth) GetReason() string

func (*ResourceHealth) GetSince

func (x *ResourceHealth) GetSince() *timestamppb.Timestamp

func (*ResourceHealth) GetStatus

func (x *ResourceHealth) GetStatus() HealthStatus

func (*ResourceHealth) ProtoMessage

func (*ResourceHealth) ProtoMessage()

func (*ResourceHealth) ProtoReflect

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

func (*ResourceHealth) Reset

func (x *ResourceHealth) Reset()

func (*ResourceHealth) String

func (x *ResourceHealth) String() string

type ResourcePluginClient

type ResourcePluginClient interface {
	// Connection lifecycle
	LoadConnections(ctx context.Context, in *LoadConnectionsRequest, opts ...grpc.CallOption) (*LoadConnectionsResponse, error)
	StartConnection(ctx context.Context, in *ConnectionRequest, opts ...grpc.CallOption) (*ConnectionStatusResponse, error)
	StopConnection(ctx context.Context, in *ConnectionRequest, opts ...grpc.CallOption) (*ConnectionResponse, error)
	CheckConnection(ctx context.Context, in *CheckConnectionRequest, opts ...grpc.CallOption) (*CheckConnectionResponse, error)
	GetConnectionNamespaces(ctx context.Context, in *ConnectionRequest, opts ...grpc.CallOption) (*NamespacesResponse, error)
	// CRUD
	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)
	// Type information
	GetResourceGroups(ctx context.Context, in *ResourceGroupsRequest, opts ...grpc.CallOption) (*ResourceGroupsResponse, error)
	GetResourceTypes(ctx context.Context, in *ResourceTypesRequest, opts ...grpc.CallOption) (*ResourceTypesResponse, error)
	GetResourceCapabilities(ctx context.Context, in *ResourceCapabilitiesRequest, opts ...grpc.CallOption) (*ResourceCapabilitiesResponse, error)
	GetFilterFields(ctx context.Context, in *FilterFieldsRequest, opts ...grpc.CallOption) (*FilterFieldsResponse, error)
	GetResourceSchema(ctx context.Context, in *ResourceSchemaRequest, opts ...grpc.CallOption) (*ResourceSchemaResponse, error)
	GetEditorSchemas(ctx context.Context, in *EditorSchemasRequest, opts ...grpc.CallOption) (*EditorSchemasResponse, 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)
	// Watch
	ListenForEvents(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (ResourcePlugin_ListenForEventsClient, error)
	EnsureResourceWatch(ctx context.Context, in *WatchResourceRequest, opts ...grpc.CallOption) (*WatchResourceResponse, error)
	StopResourceWatch(ctx context.Context, in *WatchResourceRequest, opts ...grpc.CallOption) (*WatchResourceResponse, error)
	WatchConnections(ctx context.Context, in *WatchConnectionsRequest, opts ...grpc.CallOption) (ResourcePlugin_WatchConnectionsClient, error)
	GetWatchState(ctx context.Context, in *GetWatchStateRequest, opts ...grpc.CallOption) (*GetWatchStateResponse, error)
	// Relationships
	GetRelationships(ctx context.Context, in *RelationshipsRequest, opts ...grpc.CallOption) (*RelationshipsResponse, error)
	ResolveRelationships(ctx context.Context, in *ResolveRelationshipsRequest, opts ...grpc.CallOption) (*ResolveRelationshipsResponse, error)
	// Health
	GetHealth(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
	GetResourceEvents(ctx context.Context, in *ResourceEventsRequest, opts ...grpc.CallOption) (*ResourceEventsResponse, 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.

type ResourcePluginServer

type ResourcePluginServer interface {
	// Connection lifecycle
	LoadConnections(context.Context, *LoadConnectionsRequest) (*LoadConnectionsResponse, error)
	StartConnection(context.Context, *ConnectionRequest) (*ConnectionStatusResponse, error)
	StopConnection(context.Context, *ConnectionRequest) (*ConnectionResponse, error)
	CheckConnection(context.Context, *CheckConnectionRequest) (*CheckConnectionResponse, error)
	GetConnectionNamespaces(context.Context, *ConnectionRequest) (*NamespacesResponse, error)
	// CRUD
	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)
	// Type information
	GetResourceGroups(context.Context, *ResourceGroupsRequest) (*ResourceGroupsResponse, error)
	GetResourceTypes(context.Context, *ResourceTypesRequest) (*ResourceTypesResponse, error)
	GetResourceCapabilities(context.Context, *ResourceCapabilitiesRequest) (*ResourceCapabilitiesResponse, error)
	GetFilterFields(context.Context, *FilterFieldsRequest) (*FilterFieldsResponse, error)
	GetResourceSchema(context.Context, *ResourceSchemaRequest) (*ResourceSchemaResponse, error)
	GetEditorSchemas(context.Context, *EditorSchemasRequest) (*EditorSchemasResponse, error)
	// Actions
	GetActions(context.Context, *GetActionsRequest) (*GetActionsResponse, error)
	ExecuteAction(context.Context, *ExecuteActionRequest) (*ExecuteActionResponse, error)
	StreamAction(*ExecuteActionRequest, ResourcePlugin_StreamActionServer) error
	// Watch
	ListenForEvents(*ListenRequest, ResourcePlugin_ListenForEventsServer) error
	EnsureResourceWatch(context.Context, *WatchResourceRequest) (*WatchResourceResponse, error)
	StopResourceWatch(context.Context, *WatchResourceRequest) (*WatchResourceResponse, error)
	WatchConnections(*WatchConnectionsRequest, ResourcePlugin_WatchConnectionsServer) error
	GetWatchState(context.Context, *GetWatchStateRequest) (*GetWatchStateResponse, error)
	// Relationships
	GetRelationships(context.Context, *RelationshipsRequest) (*RelationshipsResponse, error)
	ResolveRelationships(context.Context, *ResolveRelationshipsRequest) (*ResolveRelationshipsResponse, error)
	// Health
	GetHealth(context.Context, *HealthRequest) (*HealthResponse, error)
	GetResourceEvents(context.Context, *ResourceEventsRequest) (*ResourceEventsResponse, 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() (*WatchEvent, error)
	grpc.ClientStream
}

type ResourcePlugin_ListenForEventsServer

type ResourcePlugin_ListenForEventsServer interface {
	Send(*WatchEvent) 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() (*WatchConnectionsResponse, error)
	grpc.ClientStream
}

type ResourcePlugin_WatchConnectionsServer

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

type ResourceRef

type ResourceRef struct {
	PluginId     string `protobuf:"bytes,1,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"`
	ConnectionId string `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	ResourceKey  string `protobuf:"bytes,3,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	Id           string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	Namespace    string `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"`
	DisplayName  string `protobuf:"bytes,6,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// contains filtered or unexported fields
}

ResourceRef is a reference to a specific resource instance.

func (*ResourceRef) Descriptor deprecated

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

Deprecated: Use ResourceRef.ProtoReflect.Descriptor instead.

func (*ResourceRef) GetConnectionId

func (x *ResourceRef) GetConnectionId() string

func (*ResourceRef) GetDisplayName

func (x *ResourceRef) GetDisplayName() string

func (*ResourceRef) GetId

func (x *ResourceRef) GetId() string

func (*ResourceRef) GetNamespace

func (x *ResourceRef) GetNamespace() string

func (*ResourceRef) GetPluginId

func (x *ResourceRef) GetPluginId() string

func (*ResourceRef) GetResourceKey

func (x *ResourceRef) GetResourceKey() string

func (*ResourceRef) ProtoMessage

func (*ResourceRef) ProtoMessage()

func (*ResourceRef) ProtoReflect

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

func (*ResourceRef) Reset

func (x *ResourceRef) Reset()

func (*ResourceRef) String

func (x *ResourceRef) String() string

type ResourceSchemaRequest

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

func (*ResourceSchemaRequest) Descriptor deprecated

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

Deprecated: Use ResourceSchemaRequest.ProtoReflect.Descriptor instead.

func (*ResourceSchemaRequest) GetConnectionId

func (x *ResourceSchemaRequest) GetConnectionId() string

func (*ResourceSchemaRequest) GetResourceKey

func (x *ResourceSchemaRequest) GetResourceKey() string

func (*ResourceSchemaRequest) ProtoMessage

func (*ResourceSchemaRequest) ProtoMessage()

func (*ResourceSchemaRequest) ProtoReflect

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

func (*ResourceSchemaRequest) Reset

func (x *ResourceSchemaRequest) Reset()

func (*ResourceSchemaRequest) String

func (x *ResourceSchemaRequest) String() string

type ResourceSchemaResponse

type ResourceSchemaResponse struct {
	Schema []byte `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceSchemaResponse) Descriptor deprecated

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

Deprecated: Use ResourceSchemaResponse.ProtoReflect.Descriptor instead.

func (*ResourceSchemaResponse) GetSchema

func (x *ResourceSchemaResponse) GetSchema() []byte

func (*ResourceSchemaResponse) ProtoMessage

func (*ResourceSchemaResponse) ProtoMessage()

func (*ResourceSchemaResponse) ProtoReflect

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

func (*ResourceSchemaResponse) Reset

func (x *ResourceSchemaResponse) Reset()

func (*ResourceSchemaResponse) String

func (x *ResourceSchemaResponse) String() string

type ResourceTypesRequest

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

func (*ResourceTypesRequest) Descriptor deprecated

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

Deprecated: Use ResourceTypesRequest.ProtoReflect.Descriptor instead.

func (*ResourceTypesRequest) GetConnectionId

func (x *ResourceTypesRequest) GetConnectionId() string

func (*ResourceTypesRequest) ProtoMessage

func (*ResourceTypesRequest) ProtoMessage()

func (*ResourceTypesRequest) ProtoReflect

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

func (*ResourceTypesRequest) Reset

func (x *ResourceTypesRequest) Reset()

func (*ResourceTypesRequest) String

func (x *ResourceTypesRequest) String() string

type ResourceTypesResponse

type ResourceTypesResponse struct {
	Types map[string]*common.ResourceMeta `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ResourceTypesResponse) Descriptor deprecated

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

Deprecated: Use ResourceTypesResponse.ProtoReflect.Descriptor instead.

func (*ResourceTypesResponse) GetTypes

func (x *ResourceTypesResponse) GetTypes() map[string]*common.ResourceMeta

func (*ResourceTypesResponse) ProtoMessage

func (*ResourceTypesResponse) ProtoMessage()

func (*ResourceTypesResponse) ProtoReflect

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

func (*ResourceTypesResponse) Reset

func (x *ResourceTypesResponse) Reset()

func (*ResourceTypesResponse) String

func (x *ResourceTypesResponse) String() string

type ScaleCategory

type ScaleCategory int32
const (
	ScaleCategory_SCALE_CATEGORY_UNSPECIFIED ScaleCategory = 0
	ScaleCategory_SCALE_CATEGORY_FEW         ScaleCategory = 1
	ScaleCategory_SCALE_CATEGORY_MODERATE    ScaleCategory = 2
	ScaleCategory_SCALE_CATEGORY_MANY        ScaleCategory = 3
)

func (ScaleCategory) Descriptor

func (ScaleCategory) Enum

func (x ScaleCategory) Enum() *ScaleCategory

func (ScaleCategory) EnumDescriptor deprecated

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

Deprecated: Use ScaleCategory.Descriptor instead.

func (ScaleCategory) Number

func (ScaleCategory) String

func (x ScaleCategory) String() string

func (ScaleCategory) Type

type ScaleHint

type ScaleHint struct {
	ExpectedCount   ScaleCategory `` /* 145-byte string literal not displayed */
	DefaultPageSize int32         `protobuf:"varint,2,opt,name=default_page_size,json=defaultPageSize,proto3" json:"default_page_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ScaleHint) Descriptor deprecated

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

Deprecated: Use ScaleHint.ProtoReflect.Descriptor instead.

func (*ScaleHint) GetDefaultPageSize

func (x *ScaleHint) GetDefaultPageSize() int32

func (*ScaleHint) GetExpectedCount

func (x *ScaleHint) GetExpectedCount() ScaleCategory

func (*ScaleHint) ProtoMessage

func (*ScaleHint) ProtoMessage()

func (*ScaleHint) ProtoReflect

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

func (*ScaleHint) Reset

func (x *ScaleHint) Reset()

func (*ScaleHint) String

func (x *ScaleHint) String() string

type SharedDependency

type SharedDependency struct {
	Resource   *AnnotatedNode `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	SharedBy   int32          `protobuf:"varint,2,opt,name=shared_by,json=sharedBy,proto3" json:"shared_by,omitempty"`
	TotalInput int32          `protobuf:"varint,3,opt,name=total_input,json=totalInput,proto3" json:"total_input,omitempty"`
	DependedBy []*ResourceRef `protobuf:"bytes,4,rep,name=depended_by,json=dependedBy,proto3" json:"depended_by,omitempty"`
	// contains filtered or unexported fields
}

SharedDependency groups a dependency by how many input resources share it.

func (*SharedDependency) Descriptor deprecated

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

Deprecated: Use SharedDependency.ProtoReflect.Descriptor instead.

func (*SharedDependency) GetDependedBy

func (x *SharedDependency) GetDependedBy() []*ResourceRef

func (*SharedDependency) GetResource

func (x *SharedDependency) GetResource() *AnnotatedNode

func (*SharedDependency) GetSharedBy

func (x *SharedDependency) GetSharedBy() int32

func (*SharedDependency) GetTotalInput

func (x *SharedDependency) GetTotalInput() int32

func (*SharedDependency) ProtoMessage

func (*SharedDependency) ProtoMessage()

func (*SharedDependency) ProtoReflect

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

func (*SharedDependency) Reset

func (x *SharedDependency) Reset()

func (*SharedDependency) String

func (x *SharedDependency) String() string

type StreamActionEvent

type StreamActionEvent struct {
	Type     string           `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Message  string           `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Progress float32          `protobuf:"fixed32,3,opt,name=progress,proto3" json:"progress,omitempty"`
	Data     *structpb.Struct `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

StreamActionEvent is sent during streaming actions.

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

func (x *StreamActionEvent) GetMessage() string

func (*StreamActionEvent) GetProgress

func (x *StreamActionEvent) GetProgress() float32

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 UnimplementedResourcePluginServer

type UnimplementedResourcePluginServer struct {
}

UnimplementedResourcePluginServer should be embedded to have forward compatible implementations.

func (UnimplementedResourcePluginServer) CheckConnection added in v0.2.1

func (UnimplementedResourcePluginServer) Create

func (UnimplementedResourcePluginServer) Delete

func (UnimplementedResourcePluginServer) EnsureResourceWatch

func (UnimplementedResourcePluginServer) ExecuteAction

func (UnimplementedResourcePluginServer) Find

func (UnimplementedResourcePluginServer) Get

func (UnimplementedResourcePluginServer) GetActions

func (UnimplementedResourcePluginServer) GetConnectionNamespaces

func (UnimplementedResourcePluginServer) GetEditorSchemas

func (UnimplementedResourcePluginServer) GetFilterFields

func (UnimplementedResourcePluginServer) GetHealth

func (UnimplementedResourcePluginServer) GetRelationships

func (UnimplementedResourcePluginServer) GetResourceCapabilities

func (UnimplementedResourcePluginServer) GetResourceEvents

func (UnimplementedResourcePluginServer) GetResourceGroups

func (UnimplementedResourcePluginServer) GetResourceSchema

func (UnimplementedResourcePluginServer) GetResourceTypes

func (UnimplementedResourcePluginServer) GetWatchState

func (UnimplementedResourcePluginServer) List

func (UnimplementedResourcePluginServer) ListenForEvents

func (UnimplementedResourcePluginServer) LoadConnections

func (UnimplementedResourcePluginServer) StartConnection

func (UnimplementedResourcePluginServer) StopConnection

func (UnimplementedResourcePluginServer) StopResourceWatch

func (UnimplementedResourcePluginServer) StreamAction

func (UnimplementedResourcePluginServer) Update

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 UpdateRequest

type UpdateRequest struct {
	ResourceKey  string `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ConnectionId string `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,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         []byte `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) GetConnectionId

func (x *UpdateRequest) GetConnectionId() string

func (*UpdateRequest) GetData

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

func (*UpdateRequest) GetId

func (x *UpdateRequest) GetId() string

func (*UpdateRequest) GetNamespace

func (x *UpdateRequest) GetNamespace() string

func (*UpdateRequest) GetResourceKey

func (x *UpdateRequest) GetResourceKey() 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 {
	Data  []byte                `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Error *common.ResourceError `protobuf:"bytes,2,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() []byte

func (*UpdateResponse) GetError

func (x *UpdateResponse) GetError() *common.ResourceError

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 WatchAddPayload

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

WatchAddPayload — a resource was added.

func (*WatchAddPayload) Descriptor deprecated

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

Deprecated: Use WatchAddPayload.ProtoReflect.Descriptor instead.

func (*WatchAddPayload) GetData

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

func (*WatchAddPayload) GetId

func (x *WatchAddPayload) GetId() string

func (*WatchAddPayload) GetNamespace

func (x *WatchAddPayload) GetNamespace() string

func (*WatchAddPayload) ProtoMessage

func (*WatchAddPayload) ProtoMessage()

func (*WatchAddPayload) ProtoReflect

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

func (*WatchAddPayload) Reset

func (x *WatchAddPayload) Reset()

func (*WatchAddPayload) String

func (x *WatchAddPayload) String() string

type WatchConnectionsRequest

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

WatchConnectionsRequest starts the connection change stream.

func (*WatchConnectionsRequest) Descriptor deprecated

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

Deprecated: Use WatchConnectionsRequest.ProtoReflect.Descriptor instead.

func (*WatchConnectionsRequest) ProtoMessage

func (*WatchConnectionsRequest) ProtoMessage()

func (*WatchConnectionsRequest) ProtoReflect

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

func (*WatchConnectionsRequest) Reset

func (x *WatchConnectionsRequest) Reset()

func (*WatchConnectionsRequest) String

func (x *WatchConnectionsRequest) String() string

type WatchConnectionsResponse

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

WatchConnectionsResponse is sent whenever the set of connections changes.

func (*WatchConnectionsResponse) Descriptor deprecated

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

Deprecated: Use WatchConnectionsResponse.ProtoReflect.Descriptor instead.

func (*WatchConnectionsResponse) GetConnections

func (x *WatchConnectionsResponse) GetConnections() []*common.Connection

func (*WatchConnectionsResponse) ProtoMessage

func (*WatchConnectionsResponse) ProtoMessage()

func (*WatchConnectionsResponse) ProtoReflect

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

func (*WatchConnectionsResponse) Reset

func (x *WatchConnectionsResponse) Reset()

func (*WatchConnectionsResponse) String

func (x *WatchConnectionsResponse) String() string

type WatchDeletePayload

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

WatchDeletePayload — a resource was deleted.

func (*WatchDeletePayload) Descriptor deprecated

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

Deprecated: Use WatchDeletePayload.ProtoReflect.Descriptor instead.

func (*WatchDeletePayload) GetData

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

func (*WatchDeletePayload) GetId

func (x *WatchDeletePayload) GetId() string

func (*WatchDeletePayload) GetNamespace

func (x *WatchDeletePayload) GetNamespace() string

func (*WatchDeletePayload) ProtoMessage

func (*WatchDeletePayload) ProtoMessage()

func (*WatchDeletePayload) ProtoReflect

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

func (*WatchDeletePayload) Reset

func (x *WatchDeletePayload) Reset()

func (*WatchDeletePayload) String

func (x *WatchDeletePayload) String() string

type WatchEvent

type WatchEvent struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	ResourceKey  string `protobuf:"bytes,2,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	// Types that are valid to be assigned to Event:
	//
	//	*WatchEvent_Add
	//	*WatchEvent_Update
	//	*WatchEvent_Delete
	//	*WatchEvent_State
	Event isWatchEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

WatchEvent is the unified event type sent over the ListenForEvents stream.

func (*WatchEvent) Descriptor deprecated

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

Deprecated: Use WatchEvent.ProtoReflect.Descriptor instead.

func (*WatchEvent) GetAdd

func (x *WatchEvent) GetAdd() *WatchAddPayload

func (*WatchEvent) GetConnectionId

func (x *WatchEvent) GetConnectionId() string

func (*WatchEvent) GetDelete

func (x *WatchEvent) GetDelete() *WatchDeletePayload

func (*WatchEvent) GetEvent

func (x *WatchEvent) GetEvent() isWatchEvent_Event

func (*WatchEvent) GetResourceKey

func (x *WatchEvent) GetResourceKey() string

func (*WatchEvent) GetState

func (x *WatchEvent) GetState() *WatchStateEvent

func (*WatchEvent) GetUpdate

func (x *WatchEvent) GetUpdate() *WatchUpdatePayload

func (*WatchEvent) ProtoMessage

func (*WatchEvent) ProtoMessage()

func (*WatchEvent) ProtoReflect

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

func (*WatchEvent) Reset

func (x *WatchEvent) Reset()

func (*WatchEvent) String

func (x *WatchEvent) String() string

type WatchEvent_Add

type WatchEvent_Add struct {
	Add *WatchAddPayload `protobuf:"bytes,10,opt,name=add,proto3,oneof"`
}

type WatchEvent_Delete

type WatchEvent_Delete struct {
	Delete *WatchDeletePayload `protobuf:"bytes,12,opt,name=delete,proto3,oneof"`
}

type WatchEvent_State

type WatchEvent_State struct {
	State *WatchStateEvent `protobuf:"bytes,13,opt,name=state,proto3,oneof"`
}

type WatchEvent_Update

type WatchEvent_Update struct {
	Update *WatchUpdatePayload `protobuf:"bytes,11,opt,name=update,proto3,oneof"`
}

type WatchResourceRequest

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

WatchResourceRequest asks the plugin to start/stop watching a specific resource type.

func (*WatchResourceRequest) Descriptor deprecated

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

Deprecated: Use WatchResourceRequest.ProtoReflect.Descriptor instead.

func (*WatchResourceRequest) GetConnectionId

func (x *WatchResourceRequest) GetConnectionId() string

func (*WatchResourceRequest) GetResourceKey

func (x *WatchResourceRequest) GetResourceKey() string

func (*WatchResourceRequest) ProtoMessage

func (*WatchResourceRequest) ProtoMessage()

func (*WatchResourceRequest) ProtoReflect

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

func (*WatchResourceRequest) Reset

func (x *WatchResourceRequest) Reset()

func (*WatchResourceRequest) String

func (x *WatchResourceRequest) String() string

type WatchResourceResponse

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

WatchResourceResponse confirms the watch operation.

func (*WatchResourceResponse) Descriptor deprecated

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

Deprecated: Use WatchResourceResponse.ProtoReflect.Descriptor instead.

func (*WatchResourceResponse) GetErrorMessage

func (x *WatchResourceResponse) GetErrorMessage() string

func (*WatchResourceResponse) GetSuccess

func (x *WatchResourceResponse) GetSuccess() bool

func (*WatchResourceResponse) ProtoMessage

func (*WatchResourceResponse) ProtoMessage()

func (*WatchResourceResponse) ProtoReflect

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

func (*WatchResourceResponse) Reset

func (x *WatchResourceResponse) Reset()

func (*WatchResourceResponse) String

func (x *WatchResourceResponse) String() string

type WatchState

type WatchState int32

WatchState represents the synchronization state of a resource watch.

const (
	WatchState_WATCH_STATE_UNSPECIFIED WatchState = 0
	WatchState_WATCH_STATE_SYNCING     WatchState = 1
	WatchState_WATCH_STATE_SYNCED      WatchState = 2
	WatchState_WATCH_STATE_ERROR       WatchState = 3
	WatchState_WATCH_STATE_FAILED      WatchState = 4
	WatchState_WATCH_STATE_STOPPED     WatchState = 5
	WatchState_WATCH_STATE_IDLE        WatchState = 6
	WatchState_WATCH_STATE_FORBIDDEN   WatchState = 7
	WatchState_WATCH_STATE_SKIPPED     WatchState = 8
)

func (WatchState) Descriptor

func (WatchState) Descriptor() protoreflect.EnumDescriptor

func (WatchState) Enum

func (x WatchState) Enum() *WatchState

func (WatchState) EnumDescriptor deprecated

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

Deprecated: Use WatchState.Descriptor instead.

func (WatchState) Number

func (x WatchState) Number() protoreflect.EnumNumber

func (WatchState) String

func (x WatchState) String() string

func (WatchState) Type

type WatchStateEvent

type WatchStateEvent struct {
	State         WatchState `protobuf:"varint,1,opt,name=state,proto3,enum=omniview.sdk.resource.v1.WatchState" json:"state,omitempty"`
	ResourceCount int32      `protobuf:"varint,2,opt,name=resource_count,json=resourceCount,proto3" json:"resource_count,omitempty"`
	ErrorMessage  string     `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	ErrorCode     string     `protobuf:"bytes,4,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	// contains filtered or unexported fields
}

WatchStateEvent — watch state changed for a resource type.

func (*WatchStateEvent) Descriptor deprecated

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

Deprecated: Use WatchStateEvent.ProtoReflect.Descriptor instead.

func (*WatchStateEvent) GetErrorCode

func (x *WatchStateEvent) GetErrorCode() string

func (*WatchStateEvent) GetErrorMessage

func (x *WatchStateEvent) GetErrorMessage() string

func (*WatchStateEvent) GetResourceCount

func (x *WatchStateEvent) GetResourceCount() int32

func (*WatchStateEvent) GetState

func (x *WatchStateEvent) GetState() WatchState

func (*WatchStateEvent) ProtoMessage

func (*WatchStateEvent) ProtoMessage()

func (*WatchStateEvent) ProtoReflect

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

func (*WatchStateEvent) Reset

func (x *WatchStateEvent) Reset()

func (*WatchStateEvent) String

func (x *WatchStateEvent) String() string

type WatchUpdatePayload

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

WatchUpdatePayload — a resource was modified. Only carries the new state. OldData dropped to halve wire cost (doc 12).

func (*WatchUpdatePayload) Descriptor deprecated

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

Deprecated: Use WatchUpdatePayload.ProtoReflect.Descriptor instead.

func (*WatchUpdatePayload) GetData

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

func (*WatchUpdatePayload) GetId

func (x *WatchUpdatePayload) GetId() string

func (*WatchUpdatePayload) GetNamespace

func (x *WatchUpdatePayload) GetNamespace() string

func (*WatchUpdatePayload) ProtoMessage

func (*WatchUpdatePayload) ProtoMessage()

func (*WatchUpdatePayload) ProtoReflect

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

func (*WatchUpdatePayload) Reset

func (x *WatchUpdatePayload) Reset()

func (*WatchUpdatePayload) String

func (x *WatchUpdatePayload) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL