usertasksv1

package
v0.0.0-...-9153ed0 Latest Latest
Warning

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

 Go to latest Published: Jan 27, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	UserTaskService_CreateUserTask_FullMethodName             = "/teleport.usertasks.v1.UserTaskService/CreateUserTask"
	UserTaskService_UpsertUserTask_FullMethodName             = "/teleport.usertasks.v1.UserTaskService/UpsertUserTask"
	UserTaskService_GetUserTask_FullMethodName                = "/teleport.usertasks.v1.UserTaskService/GetUserTask"
	UserTaskService_ListUserTasks_FullMethodName              = "/teleport.usertasks.v1.UserTaskService/ListUserTasks"
	UserTaskService_ListUserTasksByIntegration_FullMethodName = "/teleport.usertasks.v1.UserTaskService/ListUserTasksByIntegration"
	UserTaskService_UpdateUserTask_FullMethodName             = "/teleport.usertasks.v1.UserTaskService/UpdateUserTask"
	UserTaskService_DeleteUserTask_FullMethodName             = "/teleport.usertasks.v1.UserTaskService/DeleteUserTask"
)

Variables

View Source 
var File_teleport_usertasks_v1_user_tasks_proto protoreflect.FileDescriptor
View Source 
var File_teleport_usertasks_v1_user_tasks_service_proto protoreflect.FileDescriptor
View Source 
var UserTaskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "teleport.usertasks.v1.UserTaskService",
	HandlerType: (*UserTaskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateUserTask",
			Handler:    _UserTaskService_CreateUserTask_Handler,
		},
		{
			MethodName: "UpsertUserTask",
			Handler:    _UserTaskService_UpsertUserTask_Handler,
		},
		{
			MethodName: "GetUserTask",
			Handler:    _UserTaskService_GetUserTask_Handler,
		},
		{
			MethodName: "ListUserTasks",
			Handler:    _UserTaskService_ListUserTasks_Handler,
		},
		{
			MethodName: "ListUserTasksByIntegration",
			Handler:    _UserTaskService_ListUserTasksByIntegration_Handler,
		},
		{
			MethodName: "UpdateUserTask",
			Handler:    _UserTaskService_UpdateUserTask_Handler,
		},
		{
			MethodName: "DeleteUserTask",
			Handler:    _UserTaskService_DeleteUserTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "teleport/usertasks/v1/user_tasks_service.proto",
}

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

Functions

func RegisterUserTaskServiceServer 

func RegisterUserTaskServiceServer(s grpc.ServiceRegistrar, srv UserTaskServiceServer)

Types

type CreateUserTaskRequest 

type CreateUserTaskRequest struct {
	UserTask *UserTask `protobuf:"bytes,1,opt,name=user_task,json=userTask,proto3" json:"user_task,omitempty"`
	// contains filtered or unexported fields
}

CreateUserTaskRequest is a request to create a User Task.

func (*CreateUserTaskRequest) Descriptor deprecated 

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

Deprecated: Use CreateUserTaskRequest.ProtoReflect.Descriptor instead.

func (*CreateUserTaskRequest) GetUserTask 

func (x *CreateUserTaskRequest) GetUserTask() *UserTask

func (*CreateUserTaskRequest) ProtoMessage 

func (*CreateUserTaskRequest) ProtoMessage()

func (*CreateUserTaskRequest) ProtoReflect 

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

func (*CreateUserTaskRequest) Reset 

func (x *CreateUserTaskRequest) Reset()

func (*CreateUserTaskRequest) String 

func (x *CreateUserTaskRequest) String() string

type DeleteUserTaskRequest 

type DeleteUserTaskRequest struct {

	// Name is the name of the User Task to delete.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

DeleteUserTaskRequest is a request to delete a User Task.

func (*DeleteUserTaskRequest) Descriptor deprecated 

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

Deprecated: Use DeleteUserTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteUserTaskRequest) GetName 

func (x *DeleteUserTaskRequest) GetName() string

func (*DeleteUserTaskRequest) ProtoMessage 

func (*DeleteUserTaskRequest) ProtoMessage()

func (*DeleteUserTaskRequest) ProtoReflect 

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

func (*DeleteUserTaskRequest) Reset 

func (x *DeleteUserTaskRequest) Reset()

func (*DeleteUserTaskRequest) String 

func (x *DeleteUserTaskRequest) String() string

type DiscoverEC2 

type DiscoverEC2 struct {

	// Instances maps an instance id to the result of enrolling that instance into teleport.
	Instances map[string]*DiscoverEC2Instance `` /* 145-byte string literal not displayed */
	// AccountID is the AWS Account ID for the instances.
	AccountId string `protobuf:"bytes,2,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// Region is the AWS Region where Teleport failed to enroll EC2 instances.
	Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	// SSMDocument is the Amazon Systems Manager SSM Document name that was used to install teleport on the instance.
	// In Amazon console, the document is at:
	// https://REGION.console.aws.amazon.com/systems-manager/documents/SSM_DOCUMENT/description
	SsmDocument string `protobuf:"bytes,4,opt,name=ssm_document,json=ssmDocument,proto3" json:"ssm_document,omitempty"`
	// InstallerScript is the Teleport installer script that was used to install teleport on the instance.
	InstallerScript string `protobuf:"bytes,5,opt,name=installer_script,json=installerScript,proto3" json:"installer_script,omitempty"`
	// contains filtered or unexported fields
}

DiscoverEC2 contains the instances that failed to auto-enroll into the cluster.

func (*DiscoverEC2) Descriptor deprecated 

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

Deprecated: Use DiscoverEC2.ProtoReflect.Descriptor instead.

func (*DiscoverEC2) GetAccountId 

func (x *DiscoverEC2) GetAccountId() string

func (*DiscoverEC2) GetInstallerScript 

func (x *DiscoverEC2) GetInstallerScript() string

func (*DiscoverEC2) GetInstances 

func (x *DiscoverEC2) GetInstances() map[string]*DiscoverEC2Instance

func (*DiscoverEC2) GetRegion 

func (x *DiscoverEC2) GetRegion() string

func (*DiscoverEC2) GetSsmDocument 

func (x *DiscoverEC2) GetSsmDocument() string

func (*DiscoverEC2) ProtoMessage 

func (*DiscoverEC2) ProtoMessage()

func (*DiscoverEC2) ProtoReflect 

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

func (*DiscoverEC2) Reset 

func (x *DiscoverEC2) Reset()

func (*DiscoverEC2) String 

func (x *DiscoverEC2) String() string

type DiscoverEC2Instance 

type DiscoverEC2Instance struct {

	// InstanceID is the EC2 Instance ID that uniquely identifies the instance.
	InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Name is the instance Name.
	// Might be empty, if the instance doesn't have the Name tag.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// InvocationURL is the URL that points to the invocation.
	// Empty if there was an error before installing the
	InvocationUrl string `protobuf:"bytes,5,opt,name=invocation_url,json=invocationUrl,proto3" json:"invocation_url,omitempty"`
	// DiscoveryConfig is the discovery config name that originated this instance enrollment.
	DiscoveryConfig string `protobuf:"bytes,6,opt,name=discovery_config,json=discoveryConfig,proto3" json:"discovery_config,omitempty"`
	// DiscoveryGroup is the DiscoveryGroup name that originated this task.
	DiscoveryGroup string `protobuf:"bytes,7,opt,name=discovery_group,json=discoveryGroup,proto3" json:"discovery_group,omitempty"`
	// SyncTime is the timestamp when the error was produced.
	SyncTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=sync_time,json=syncTime,proto3" json:"sync_time,omitempty"`
	// contains filtered or unexported fields
}

DiscoverEC2Instance contains the result of enrolling an AWS EC2 Instance.

func (*DiscoverEC2Instance) Descriptor deprecated 

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

Deprecated: Use DiscoverEC2Instance.ProtoReflect.Descriptor instead.

func (*DiscoverEC2Instance) GetDiscoveryConfig 

func (x *DiscoverEC2Instance) GetDiscoveryConfig() string

func (*DiscoverEC2Instance) GetDiscoveryGroup 

func (x *DiscoverEC2Instance) GetDiscoveryGroup() string

func (*DiscoverEC2Instance) GetInstanceId 

func (x *DiscoverEC2Instance) GetInstanceId() string

func (*DiscoverEC2Instance) GetInvocationUrl 

func (x *DiscoverEC2Instance) GetInvocationUrl() string

func (*DiscoverEC2Instance) GetName 

func (x *DiscoverEC2Instance) GetName() string

func (*DiscoverEC2Instance) GetSyncTime 

func (x *DiscoverEC2Instance) GetSyncTime() *timestamppb.Timestamp

func (*DiscoverEC2Instance) ProtoMessage 

func (*DiscoverEC2Instance) ProtoMessage()

func (*DiscoverEC2Instance) ProtoReflect 

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

func (*DiscoverEC2Instance) Reset 

func (x *DiscoverEC2Instance) Reset()

func (*DiscoverEC2Instance) String 

func (x *DiscoverEC2Instance) String() string

type DiscoverEKS 

type DiscoverEKS struct {

	// Clusters maps a cluster name to the result of enrolling that cluster into teleport.
	Clusters map[string]*DiscoverEKSCluster `` /* 143-byte string literal not displayed */
	// AccountID is the AWS Account ID for the cluster.
	AccountId string `protobuf:"bytes,2,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// Region is the AWS Region where Teleport failed to enroll EKS Clusters.
	Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	// AppAutoDiscover indicates whether the Kubernetes agent should auto enroll HTTP services as Teleport Apps.
	AppAutoDiscover bool `protobuf:"varint,4,opt,name=app_auto_discover,json=appAutoDiscover,proto3" json:"app_auto_discover,omitempty"`
	// contains filtered or unexported fields
}

DiscoverEKS contains the clusters that failed to auto-enroll into the cluster.

func (*DiscoverEKS) Descriptor deprecated 

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

Deprecated: Use DiscoverEKS.ProtoReflect.Descriptor instead.

func (*DiscoverEKS) GetAccountId 

func (x *DiscoverEKS) GetAccountId() string

func (*DiscoverEKS) GetAppAutoDiscover 

func (x *DiscoverEKS) GetAppAutoDiscover() bool

func (*DiscoverEKS) GetClusters 

func (x *DiscoverEKS) GetClusters() map[string]*DiscoverEKSCluster

func (*DiscoverEKS) GetRegion 

func (x *DiscoverEKS) GetRegion() string

func (*DiscoverEKS) ProtoMessage 

func (*DiscoverEKS) ProtoMessage()

func (*DiscoverEKS) ProtoReflect 

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

func (*DiscoverEKS) Reset 

func (x *DiscoverEKS) Reset()

func (*DiscoverEKS) String 

func (x *DiscoverEKS) String() string

type DiscoverEKSCluster 

type DiscoverEKSCluster struct {

	// Name is the cluster Name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// DiscoveryConfig is the discovery config name that originated this cluster enrollment.
	DiscoveryConfig string `protobuf:"bytes,2,opt,name=discovery_config,json=discoveryConfig,proto3" json:"discovery_config,omitempty"`
	// DiscoveryGroup is the DiscoveryGroup name that originated this task.
	DiscoveryGroup string `protobuf:"bytes,3,opt,name=discovery_group,json=discoveryGroup,proto3" json:"discovery_group,omitempty"`
	// SyncTime is the timestamp when the error was produced.
	SyncTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=sync_time,json=syncTime,proto3" json:"sync_time,omitempty"`
	// contains filtered or unexported fields
}

DiscoverEKSCluster contains the result of enrolling an AWS EKS Cluster.

func (*DiscoverEKSCluster) Descriptor deprecated 

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

Deprecated: Use DiscoverEKSCluster.ProtoReflect.Descriptor instead.

func (*DiscoverEKSCluster) GetDiscoveryConfig 

func (x *DiscoverEKSCluster) GetDiscoveryConfig() string

func (*DiscoverEKSCluster) GetDiscoveryGroup 

func (x *DiscoverEKSCluster) GetDiscoveryGroup() string

func (*DiscoverEKSCluster) GetName 

func (x *DiscoverEKSCluster) GetName() string

func (*DiscoverEKSCluster) GetSyncTime 

func (x *DiscoverEKSCluster) GetSyncTime() *timestamppb.Timestamp

func (*DiscoverEKSCluster) ProtoMessage 

func (*DiscoverEKSCluster) ProtoMessage()

func (*DiscoverEKSCluster) ProtoReflect 

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

func (*DiscoverEKSCluster) Reset 

func (x *DiscoverEKSCluster) Reset()

func (*DiscoverEKSCluster) String 

func (x *DiscoverEKSCluster) String() string

type DiscoverRDS 

type DiscoverRDS struct {

	// Databases maps a database resource id to the result of enrolling that database into teleport.
	// For RDS Aurora Clusters, this is the DBClusterIdentifier.
	// For other RDS databases, this is the DBInstanceIdentifier.
	Databases map[string]*DiscoverRDSDatabase `` /* 145-byte string literal not displayed */
	// AccountID is the AWS Account ID for the database.
	AccountId string `protobuf:"bytes,2,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// Region is the AWS Region where Teleport failed to enroll RDS databases.
	Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	// contains filtered or unexported fields
}

DiscoverRDS contains the databases that failed to auto-enroll into teleport.

func (*DiscoverRDS) Descriptor deprecated 

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

Deprecated: Use DiscoverRDS.ProtoReflect.Descriptor instead.

func (*DiscoverRDS) GetAccountId 

func (x *DiscoverRDS) GetAccountId() string

func (*DiscoverRDS) GetDatabases 

func (x *DiscoverRDS) GetDatabases() map[string]*DiscoverRDSDatabase

func (*DiscoverRDS) GetRegion 

func (x *DiscoverRDS) GetRegion() string

func (*DiscoverRDS) ProtoMessage 

func (*DiscoverRDS) ProtoMessage()

func (*DiscoverRDS) ProtoReflect 

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

func (*DiscoverRDS) Reset 

func (x *DiscoverRDS) Reset()

func (*DiscoverRDS) String 

func (x *DiscoverRDS) String() string

type DiscoverRDSDatabase 

type DiscoverRDSDatabase struct {

	// Name is the database identifier.
	// For RDS Aurora Clusters, this is the DBClusterIdentifier.
	// For other RDS databases, this is the DBInstanceIdentifier.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// IsCluster indicates whether this database is a cluster or a single instance.
	IsCluster bool `protobuf:"varint,2,opt,name=is_cluster,json=isCluster,proto3" json:"is_cluster,omitempty"`
	// Engine indicates the engine name for this RDS.
	// Eg, aurora-postgresql, postgresql
	Engine string `protobuf:"bytes,3,opt,name=engine,proto3" json:"engine,omitempty"`
	// DiscoveryConfig is the discovery config name that originated this database enrollment.
	DiscoveryConfig string `protobuf:"bytes,4,opt,name=discovery_config,json=discoveryConfig,proto3" json:"discovery_config,omitempty"`
	// DiscoveryGroup is the DiscoveryGroup name that originated this task.
	DiscoveryGroup string `protobuf:"bytes,5,opt,name=discovery_group,json=discoveryGroup,proto3" json:"discovery_group,omitempty"`
	// SyncTime is the timestamp when the error was produced.
	SyncTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=sync_time,json=syncTime,proto3" json:"sync_time,omitempty"`
	// contains filtered or unexported fields
}

DiscoverRDSDatabase contains the result of enrolling an AWS RDS database.

func (*DiscoverRDSDatabase) Descriptor deprecated 

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

Deprecated: Use DiscoverRDSDatabase.ProtoReflect.Descriptor instead.

func (*DiscoverRDSDatabase) GetDiscoveryConfig 

func (x *DiscoverRDSDatabase) GetDiscoveryConfig() string

func (*DiscoverRDSDatabase) GetDiscoveryGroup 

func (x *DiscoverRDSDatabase) GetDiscoveryGroup() string

func (*DiscoverRDSDatabase) GetEngine 

func (x *DiscoverRDSDatabase) GetEngine() string

func (*DiscoverRDSDatabase) GetIsCluster 

func (x *DiscoverRDSDatabase) GetIsCluster() bool

func (*DiscoverRDSDatabase) GetName 

func (x *DiscoverRDSDatabase) GetName() string

func (*DiscoverRDSDatabase) GetSyncTime 

func (x *DiscoverRDSDatabase) GetSyncTime() *timestamppb.Timestamp

func (*DiscoverRDSDatabase) ProtoMessage 

func (*DiscoverRDSDatabase) ProtoMessage()

func (*DiscoverRDSDatabase) ProtoReflect 

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

func (*DiscoverRDSDatabase) Reset 

func (x *DiscoverRDSDatabase) Reset()

func (*DiscoverRDSDatabase) String 

func (x *DiscoverRDSDatabase) String() string

type GetUserTaskRequest 

type GetUserTaskRequest struct {

	// Name is the name of the UserTask to get.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

GetUserTaskRequest is a request to get a User Task by name.

func (*GetUserTaskRequest) Descriptor deprecated 

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

Deprecated: Use GetUserTaskRequest.ProtoReflect.Descriptor instead.

func (*GetUserTaskRequest) GetName 

func (x *GetUserTaskRequest) GetName() string

func (*GetUserTaskRequest) ProtoMessage 

func (*GetUserTaskRequest) ProtoMessage()

func (*GetUserTaskRequest) ProtoReflect 

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

func (*GetUserTaskRequest) Reset 

func (x *GetUserTaskRequest) Reset()

func (*GetUserTaskRequest) String 

func (x *GetUserTaskRequest) String() string

type ListUserTasksByIntegrationRequest 

type ListUserTasksByIntegrationRequest struct {

	// page_size is the maximum number of items to return.
	// The server may impose a different page size at its discretion.
	PageSize int64 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// page_token is the next_page_token value returned from a previous List request, if any.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// integration is the integration name that will be used to filter the returned list.
	Integration string `protobuf:"bytes,3,opt,name=integration,proto3" json:"integration,omitempty"`
	// contains filtered or unexported fields
}

ListUserTasksByIntegrationRequest is a request to get a list of User Tasks filtered by an Integration.

func (*ListUserTasksByIntegrationRequest) Descriptor deprecated 

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

Deprecated: Use ListUserTasksByIntegrationRequest.ProtoReflect.Descriptor instead.

func (*ListUserTasksByIntegrationRequest) GetIntegration 

func (x *ListUserTasksByIntegrationRequest) GetIntegration() string

func (*ListUserTasksByIntegrationRequest) GetPageSize 

func (x *ListUserTasksByIntegrationRequest) GetPageSize() int64

func (*ListUserTasksByIntegrationRequest) GetPageToken 

func (x *ListUserTasksByIntegrationRequest) GetPageToken() string

func (*ListUserTasksByIntegrationRequest) ProtoMessage 

func (*ListUserTasksByIntegrationRequest) ProtoMessage()

func (*ListUserTasksByIntegrationRequest) ProtoReflect 

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

func (*ListUserTasksByIntegrationRequest) Reset 

func (x *ListUserTasksByIntegrationRequest) Reset()

func (*ListUserTasksByIntegrationRequest) String 

func (x *ListUserTasksByIntegrationRequest) String() string

type ListUserTasksRequest 

type ListUserTasksRequest struct {

	// page_size is the maximum number of items to return.
	// The server may impose a different page size at its discretion.
	PageSize int64 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// page_token is the next_page_token value returned from a previous List request, if any.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

ListUserTasksRequest is a request to get a list of User Tasks.

func (*ListUserTasksRequest) Descriptor deprecated 

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

Deprecated: Use ListUserTasksRequest.ProtoReflect.Descriptor instead.

func (*ListUserTasksRequest) GetPageSize 

func (x *ListUserTasksRequest) GetPageSize() int64

func (*ListUserTasksRequest) GetPageToken 

func (x *ListUserTasksRequest) GetPageToken() string

func (*ListUserTasksRequest) ProtoMessage 

func (*ListUserTasksRequest) ProtoMessage()

func (*ListUserTasksRequest) ProtoReflect 

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

func (*ListUserTasksRequest) Reset 

func (x *ListUserTasksRequest) Reset()

func (*ListUserTasksRequest) String 

func (x *ListUserTasksRequest) String() string

type ListUserTasksResponse 

type ListUserTasksResponse struct {
	UserTasks []*UserTask `protobuf:"bytes,1,rep,name=user_tasks,json=userTasks,proto3" json:"user_tasks,omitempty"`
	// Token to retrieve the next page of results, or empty if there are no
	// more results in the list.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

ListUserTasksResponse is a response to ListUserTasks.

func (*ListUserTasksResponse) Descriptor deprecated 

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

Deprecated: Use ListUserTasksResponse.ProtoReflect.Descriptor instead.

func (*ListUserTasksResponse) GetNextPageToken 

func (x *ListUserTasksResponse) GetNextPageToken() string

func (*ListUserTasksResponse) GetUserTasks 

func (x *ListUserTasksResponse) GetUserTasks() []*UserTask

func (*ListUserTasksResponse) ProtoMessage 

func (*ListUserTasksResponse) ProtoMessage()

func (*ListUserTasksResponse) ProtoReflect 

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

func (*ListUserTasksResponse) Reset 

func (x *ListUserTasksResponse) Reset()

func (*ListUserTasksResponse) String 

func (x *ListUserTasksResponse) String() string

type UnimplementedUserTaskServiceServer 

type UnimplementedUserTaskServiceServer struct{}

UnimplementedUserTaskServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedUserTaskServiceServer) CreateUserTask 

func (UnimplementedUserTaskServiceServer) CreateUserTask(context.Context, *CreateUserTaskRequest) (*UserTask, error)

func (UnimplementedUserTaskServiceServer) DeleteUserTask 

func (UnimplementedUserTaskServiceServer) DeleteUserTask(context.Context, *DeleteUserTaskRequest) (*emptypb.Empty, error)

func (UnimplementedUserTaskServiceServer) GetUserTask 

func (UnimplementedUserTaskServiceServer) GetUserTask(context.Context, *GetUserTaskRequest) (*UserTask, error)

func (UnimplementedUserTaskServiceServer) ListUserTasks 

func (UnimplementedUserTaskServiceServer) ListUserTasks(context.Context, *ListUserTasksRequest) (*ListUserTasksResponse, error)

func (UnimplementedUserTaskServiceServer) ListUserTasksByIntegration 

func (UnimplementedUserTaskServiceServer) ListUserTasksByIntegration(context.Context, *ListUserTasksByIntegrationRequest) (*ListUserTasksResponse, error)

func (UnimplementedUserTaskServiceServer) UpdateUserTask 

func (UnimplementedUserTaskServiceServer) UpdateUserTask(context.Context, *UpdateUserTaskRequest) (*UserTask, error)

func (UnimplementedUserTaskServiceServer) UpsertUserTask 

func (UnimplementedUserTaskServiceServer) UpsertUserTask(context.Context, *UpsertUserTaskRequest) (*UserTask, error)

type UnsafeUserTaskServiceServer 

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

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

type UpdateUserTaskRequest 

type UpdateUserTaskRequest struct {
	UserTask *UserTask `protobuf:"bytes,1,opt,name=user_task,json=userTask,proto3" json:"user_task,omitempty"`
	// contains filtered or unexported fields
}

UpdateUserTaskRequest is a request to update an existing User Task.

func (*UpdateUserTaskRequest) Descriptor deprecated 

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

Deprecated: Use UpdateUserTaskRequest.ProtoReflect.Descriptor instead.

func (*UpdateUserTaskRequest) GetUserTask 

func (x *UpdateUserTaskRequest) GetUserTask() *UserTask

func (*UpdateUserTaskRequest) ProtoMessage 

func (*UpdateUserTaskRequest) ProtoMessage()

func (*UpdateUserTaskRequest) ProtoReflect 

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

func (*UpdateUserTaskRequest) Reset 

func (x *UpdateUserTaskRequest) Reset()

func (*UpdateUserTaskRequest) String 

func (x *UpdateUserTaskRequest) String() string

type UpsertUserTaskRequest 

type UpsertUserTaskRequest struct {
	UserTask *UserTask `protobuf:"bytes,1,opt,name=user_task,json=userTask,proto3" json:"user_task,omitempty"`
	// contains filtered or unexported fields
}

UpsertUserTaskRequest is a request to create or update a User Task.

func (*UpsertUserTaskRequest) Descriptor deprecated 

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

Deprecated: Use UpsertUserTaskRequest.ProtoReflect.Descriptor instead.

func (*UpsertUserTaskRequest) GetUserTask 

func (x *UpsertUserTaskRequest) GetUserTask() *UserTask

func (*UpsertUserTaskRequest) ProtoMessage 

func (*UpsertUserTaskRequest) ProtoMessage()

func (*UpsertUserTaskRequest) ProtoReflect 

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

func (*UpsertUserTaskRequest) Reset 

func (x *UpsertUserTaskRequest) Reset()

func (*UpsertUserTaskRequest) String 

func (x *UpsertUserTaskRequest) String() string

type UserTask 

type UserTask struct {

	// The kind of resource represented.
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	// Mandatory field for all resources. Not populated for this resource type.
	SubKind string `protobuf:"bytes,2,opt,name=sub_kind,json=subKind,proto3" json:"sub_kind,omitempty"`
	// The version of the resource being represented.
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// Common metadata that all resources share.
	Metadata *v1.Metadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// The configured properties of UserTask.
	Spec *UserTaskSpec `protobuf:"bytes,5,opt,name=spec,proto3" json:"spec,omitempty"`
	// The current status for this UserTask.
	Status *UserTaskStatus `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

UserTask is a resource that represents an action to be completed by the user. UserTasks are a unit of work for users to act upon issues related to other resources. As an example, when auto-enrolling EC2 instances using the Discovery Service a UserTask is created to let the user know that something failed on a set of instances. The user can then mark the task as resolved after following the recommendation/fixing steps.

func (*UserTask) Descriptor deprecated 

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

Deprecated: Use UserTask.ProtoReflect.Descriptor instead.

func (*UserTask) GetKind 

func (x *UserTask) GetKind() string

func (*UserTask) GetMetadata 

func (x *UserTask) GetMetadata() *v1.Metadata

func (*UserTask) GetSpec 

func (x *UserTask) GetSpec() *UserTaskSpec

func (*UserTask) GetStatus 

func (x *UserTask) GetStatus() *UserTaskStatus

func (*UserTask) GetSubKind 

func (x *UserTask) GetSubKind() string

func (*UserTask) GetVersion 

func (x *UserTask) GetVersion() string

func (*UserTask) ProtoMessage 

func (*UserTask) ProtoMessage()

func (*UserTask) ProtoReflect 

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

func (*UserTask) Reset 

func (x *UserTask) Reset()

func (*UserTask) String 

func (x *UserTask) String() string

type UserTaskServiceClient 

type UserTaskServiceClient interface {
	// CreateUserTask creates a User Task.
	CreateUserTask(ctx context.Context, in *CreateUserTaskRequest, opts ...grpc.CallOption) (*UserTask, error)
	// UpsertUserTask creates or updates User Task.
	UpsertUserTask(ctx context.Context, in *UpsertUserTaskRequest, opts ...grpc.CallOption) (*UserTask, error)
	// GetUserTask gets a UserTask by name.
	GetUserTask(ctx context.Context, in *GetUserTaskRequest, opts ...grpc.CallOption) (*UserTask, error)
	// ListUserTasks returns a list of UserTasks. It supports pagination and filters.
	ListUserTasks(ctx context.Context, in *ListUserTasksRequest, opts ...grpc.CallOption) (*ListUserTasksResponse, error)
	// ListUserTasksByIntegration returns a list of UserTasks filtered by an integration and other optional fields. It supports pagination.
	ListUserTasksByIntegration(ctx context.Context, in *ListUserTasksByIntegrationRequest, opts ...grpc.CallOption) (*ListUserTasksResponse, error)
	// UpdateUserTask updates an existing User Task.
	UpdateUserTask(ctx context.Context, in *UpdateUserTaskRequest, opts ...grpc.CallOption) (*UserTask, error)
	// DeleteUserTask deletes a User Task.
	DeleteUserTask(ctx context.Context, in *DeleteUserTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

UserTaskServiceClient is the client API for UserTaskService 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.

UserTaskService is a service that provides methods to manage User Tasks.

func NewUserTaskServiceClient 

func NewUserTaskServiceClient(cc grpc.ClientConnInterface) UserTaskServiceClient

type UserTaskServiceServer 

type UserTaskServiceServer interface {
	// CreateUserTask creates a User Task.
	CreateUserTask(context.Context, *CreateUserTaskRequest) (*UserTask, error)
	// UpsertUserTask creates or updates User Task.
	UpsertUserTask(context.Context, *UpsertUserTaskRequest) (*UserTask, error)
	// GetUserTask gets a UserTask by name.
	GetUserTask(context.Context, *GetUserTaskRequest) (*UserTask, error)
	// ListUserTasks returns a list of UserTasks. It supports pagination and filters.
	ListUserTasks(context.Context, *ListUserTasksRequest) (*ListUserTasksResponse, error)
	// ListUserTasksByIntegration returns a list of UserTasks filtered by an integration and other optional fields. It supports pagination.
	ListUserTasksByIntegration(context.Context, *ListUserTasksByIntegrationRequest) (*ListUserTasksResponse, error)
	// UpdateUserTask updates an existing User Task.
	UpdateUserTask(context.Context, *UpdateUserTaskRequest) (*UserTask, error)
	// DeleteUserTask deletes a User Task.
	DeleteUserTask(context.Context, *DeleteUserTaskRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

UserTaskServiceServer is the server API for UserTaskService service. All implementations must embed UnimplementedUserTaskServiceServer for forward compatibility.

UserTaskService is a service that provides methods to manage User Tasks.

type UserTaskSpec 

type UserTaskSpec struct {

	// Integration is the integration name that originated this task.
	Integration string `protobuf:"bytes,1,opt,name=integration,proto3" json:"integration,omitempty"`
	// TaskType indicates the type of task.
	// Examples: discover-ec2, discover-rds, discover-eks
	TaskType string `protobuf:"bytes,2,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	// IssueType is an identifier for the type of issue that happened.
	// Example for discover-ec2: SSM_AGENT_NOT_AVAILABLE
	IssueType string `protobuf:"bytes,3,opt,name=issue_type,json=issueType,proto3" json:"issue_type,omitempty"`
	// State indicates the task state.
	// When the task is created, it starts with OPEN.
	// Users can mark it as RESOLVED.
	// If the issue happens again (eg, new discover iteration faces the same error), it will move to OPEN again.
	State string `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	// DiscoverEC2 contains the AWS EC2 instances that failed to auto enroll into the cluster.
	// Present when TaskType is discover-ec2.
	DiscoverEc2 *DiscoverEC2 `protobuf:"bytes,5,opt,name=discover_ec2,json=discoverEc2,proto3" json:"discover_ec2,omitempty"`
	// DiscoverEKS contains the AWS EKS clusters that failed to auto enroll into the cluster.
	// Present when TaskType is discover-eks.
	DiscoverEks *DiscoverEKS `protobuf:"bytes,6,opt,name=discover_eks,json=discoverEks,proto3" json:"discover_eks,omitempty"`
	// DiscoverRDS contains the AWS RDS databases that failed to auto enroll into the cluster.
	// Present when TaskType is discover-rds.
	DiscoverRds *DiscoverRDS `protobuf:"bytes,7,opt,name=discover_rds,json=discoverRds,proto3" json:"discover_rds,omitempty"`
	// contains filtered or unexported fields
}

UserTaskSpec contains the properties of the UserTask.

func (*UserTaskSpec) Descriptor deprecated 

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

Deprecated: Use UserTaskSpec.ProtoReflect.Descriptor instead.

func (*UserTaskSpec) GetDiscoverEc2 

func (x *UserTaskSpec) GetDiscoverEc2() *DiscoverEC2

func (*UserTaskSpec) GetDiscoverEks 

func (x *UserTaskSpec) GetDiscoverEks() *DiscoverEKS

func (*UserTaskSpec) GetDiscoverRds 

func (x *UserTaskSpec) GetDiscoverRds() *DiscoverRDS

func (*UserTaskSpec) GetIntegration 

func (x *UserTaskSpec) GetIntegration() string

func (*UserTaskSpec) GetIssueType 

func (x *UserTaskSpec) GetIssueType() string

func (*UserTaskSpec) GetState 

func (x *UserTaskSpec) GetState() string

func (*UserTaskSpec) GetTaskType 

func (x *UserTaskSpec) GetTaskType() string

func (*UserTaskSpec) ProtoMessage 

func (*UserTaskSpec) ProtoMessage()

func (*UserTaskSpec) ProtoReflect 

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

func (*UserTaskSpec) Reset 

func (x *UserTaskSpec) Reset()

func (*UserTaskSpec) String 

func (x *UserTaskSpec) String() string

type UserTaskStatus 

type UserTaskStatus struct {

	// LastStateChange is the timestamp when the UserTask state was last modified.
	LastStateChange *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=last_state_change,json=lastStateChange,proto3" json:"last_state_change,omitempty"`
	// contains filtered or unexported fields
}

UserTaskStatus contains the current status for the UserTask.

func (*UserTaskStatus) Descriptor deprecated 

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

Deprecated: Use UserTaskStatus.ProtoReflect.Descriptor instead.

func (*UserTaskStatus) GetLastStateChange 

func (x *UserTaskStatus) GetLastStateChange() *timestamppb.Timestamp

func (*UserTaskStatus) ProtoMessage 

func (*UserTaskStatus) ProtoMessage()

func (*UserTaskStatus) ProtoReflect 

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

func (*UserTaskStatus) Reset 

func (x *UserTaskStatus) Reset()

func (*UserTaskStatus) String 

func (x *UserTaskStatus) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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