graph

package
v0.0.0-...-76bc989 Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2024 License: Apache-2.0 Imports: 56 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrUnauthenticated     = NewError("KUBETAIL_UNAUTHENTICATED", "Authentication required")
	ErrForbidden           = NewError("KUBETAIL_FORBIDDEN", "Access forbidden")
	ErrWatchError          = NewError("KUBETAIL_WATCH_ERROR", "Watch error")
	ErrInternalServerError = NewError("INTERNAL_SERVER_ERROR", "Internal server error")
)

custom errors

Functions

func GetGVR 

func GetGVR(obj runtime.Object) (schema.GroupVersionResource, error)

GetGVR

func IsNilPtr 

func IsNilPtr(val interface{}) bool

func NewError 

func NewError(code string, message string) *gqlerror.Error

Initialize custom GraphQL errors

func NewExecutableSchema 

func NewExecutableSchema(cfg Config) graphql.ExecutableSchema

NewExecutableSchema creates an ExecutableSchema from the ResolverRoot interface.

func NewGrpcError 

func NewGrpcError(conn *grpc.ClientConn, err error) *gqlerror.Error

New GRPC error

func NewHandler 

func NewHandler(r *Resolver, options *HandlerOptions) *handler.Server

func NewWatchError 

func NewWatchError(status *metav1.Status) *gqlerror.Error

New Watch API error

func NullIfValidationFailedDirective 

func NullIfValidationFailedDirective(ctx context.Context, obj interface{}, next graphql.Resolver) (interface{}, error)

Returns nil if there are errors in the context

func ValidateDirective 

func ValidateDirective(ctx context.Context, obj interface{}, next graphql.Resolver, rule string, message *string) (interface{}, error)

Types

type AppsV1DaemonSetsWatchEventResolver 

type AppsV1DaemonSetsWatchEventResolver interface {
	Object(ctx context.Context, obj *watch.Event) (*v12.DaemonSet, error)
}

type AppsV1DeploymentsWatchEventResolver 

type AppsV1DeploymentsWatchEventResolver interface {
	Object(ctx context.Context, obj *watch.Event) (*v12.Deployment, error)
}

type AppsV1ReplicaSetsWatchEventResolver 

type AppsV1ReplicaSetsWatchEventResolver interface {
	Object(ctx context.Context, obj *watch.Event) (*v12.ReplicaSet, error)
}

type AppsV1StatefulSetsWatchEventResolver 

type AppsV1StatefulSetsWatchEventResolver interface {
	Object(ctx context.Context, obj *watch.Event) (*v12.StatefulSet, error)
}

type BatchV1CronJobsWatchEventResolver 

type BatchV1CronJobsWatchEventResolver interface {
	Object(ctx context.Context, obj *watch.Event) (*v13.CronJob, error)
}

type BatchV1JobsWatchEventResolver 

type BatchV1JobsWatchEventResolver interface {
	Object(ctx context.Context, obj *watch.Event) (*v13.Job, error)
}

type ComplexityRoot 

type ComplexityRoot struct {
	AppsV1DaemonSet struct {
		APIVersion func(childComplexity int) int
		Kind       func(childComplexity int) int
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
		Status     func(childComplexity int) int
		UID        func(childComplexity int) int
	}

	AppsV1DaemonSetCondition struct {
		LastTransitionTime func(childComplexity int) int
		Message            func(childComplexity int) int
		Reason             func(childComplexity int) int
		Status             func(childComplexity int) int
		Type               func(childComplexity int) int
	}

	AppsV1DaemonSetList struct {
		APIVersion func(childComplexity int) int
		Items      func(childComplexity int) int
		Kind       func(childComplexity int) int
		ListMeta   func(childComplexity int) int
	}

	AppsV1DaemonSetSpec struct {
		Selector func(childComplexity int) int
	}

	AppsV1DaemonSetStatus struct {
		Conditions             func(childComplexity int) int
		CurrentNumberScheduled func(childComplexity int) int
		DesiredNumberScheduled func(childComplexity int) int
		NumberAvailable        func(childComplexity int) int
		NumberMisscheduled     func(childComplexity int) int
		NumberReady            func(childComplexity int) int
		NumberUnavailable      func(childComplexity int) int
		ObservedGeneration     func(childComplexity int) int
		UpdatedNumberScheduled func(childComplexity int) int
	}

	AppsV1DaemonSetsWatchEvent struct {
		Object func(childComplexity int) int
		Type   func(childComplexity int) int
	}

	AppsV1Deployment struct {
		APIVersion func(childComplexity int) int
		Kind       func(childComplexity int) int
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
		Status     func(childComplexity int) int
		UID        func(childComplexity int) int
	}

	AppsV1DeploymentList struct {
		APIVersion func(childComplexity int) int
		Items      func(childComplexity int) int
		Kind       func(childComplexity int) int
		ListMeta   func(childComplexity int) int
	}

	AppsV1DeploymentSpec struct {
		Paused   func(childComplexity int) int
		Replicas func(childComplexity int) int
		Selector func(childComplexity int) int
	}

	AppsV1DeploymentStatus struct {
		Replicas func(childComplexity int) int
	}

	AppsV1DeploymentsWatchEvent struct {
		Object func(childComplexity int) int
		Type   func(childComplexity int) int
	}

	AppsV1ReplicaSet struct {
		APIVersion func(childComplexity int) int
		Kind       func(childComplexity int) int
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
		Status     func(childComplexity int) int
		UID        func(childComplexity int) int
	}

	AppsV1ReplicaSetList struct {
		APIVersion func(childComplexity int) int
		Items      func(childComplexity int) int
		Kind       func(childComplexity int) int
		ListMeta   func(childComplexity int) int
	}

	AppsV1ReplicaSetSpec struct {
		Replicas func(childComplexity int) int
		Selector func(childComplexity int) int
	}

	AppsV1ReplicaSetStatus struct {
		Replicas func(childComplexity int) int
	}

	AppsV1ReplicaSetsWatchEvent struct {
		Object func(childComplexity int) int
		Type   func(childComplexity int) int
	}

	AppsV1StatefulSet struct {
		APIVersion func(childComplexity int) int
		Kind       func(childComplexity int) int
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
		UID        func(childComplexity int) int
	}

	AppsV1StatefulSetList struct {
		APIVersion func(childComplexity int) int
		Items      func(childComplexity int) int
		Kind       func(childComplexity int) int
		ListMeta   func(childComplexity int) int
	}

	AppsV1StatefulSetSpec struct {
		Replicas func(childComplexity int) int
		Selector func(childComplexity int) int
	}

	AppsV1StatefulSetsWatchEvent struct {
		Object func(childComplexity int) int
		Type   func(childComplexity int) int
	}

	BatchV1CronJob struct {
		APIVersion func(childComplexity int) int
		Kind       func(childComplexity int) int
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
		Status     func(childComplexity int) int
		UID        func(childComplexity int) int
	}

	BatchV1CronJobList struct {
		APIVersion func(childComplexity int) int
		Items      func(childComplexity int) int
		Kind       func(childComplexity int) int
		ListMeta   func(childComplexity int) int
	}

	BatchV1CronJobSpec struct {
		FailedJobsHistoryLimit     func(childComplexity int) int
		JobTemplate                func(childComplexity int) int
		Schedule                   func(childComplexity int) int
		SuccessfulJobsHistoryLimit func(childComplexity int) int
		Suspend                    func(childComplexity int) int
		TimeZone                   func(childComplexity int) int
	}

	BatchV1CronJobStatus struct {
		Active             func(childComplexity int) int
		LastScheduleTime   func(childComplexity int) int
		LastSuccessfulTime func(childComplexity int) int
	}

	BatchV1CronJobsWatchEvent struct {
		Object func(childComplexity int) int
		Type   func(childComplexity int) int
	}

	BatchV1Job struct {
		APIVersion func(childComplexity int) int
		Kind       func(childComplexity int) int
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
		Status     func(childComplexity int) int
		UID        func(childComplexity int) int
	}

	BatchV1JobCondition struct {
		LastProbeTime      func(childComplexity int) int
		LastTransitionTime func(childComplexity int) int
		Message            func(childComplexity int) int
		Reason             func(childComplexity int) int
		Status             func(childComplexity int) int
		Type               func(childComplexity int) int
	}

	BatchV1JobList struct {
		APIVersion func(childComplexity int) int
		Items      func(childComplexity int) int
		Kind       func(childComplexity int) int
		ListMeta   func(childComplexity int) int
	}

	BatchV1JobSpec struct {
		BackoffLimit            func(childComplexity int) int
		Completions             func(childComplexity int) int
		ManualSelector          func(childComplexity int) int
		Parallelism             func(childComplexity int) int
		Selector                func(childComplexity int) int
		Suspend                 func(childComplexity int) int
		TTLSecondsAfterFinished func(childComplexity int) int
	}

	BatchV1JobStatus struct {
		Active           func(childComplexity int) int
		CompletedIndexes func(childComplexity int) int
		CompletionTime   func(childComplexity int) int
		Conditions       func(childComplexity int) int
		Failed           func(childComplexity int) int
		Ready            func(childComplexity int) int
		StartTime        func(childComplexity int) int
		Succeeded        func(childComplexity int) int
	}

	BatchV1JobTemplateSpec struct {
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
	}

	BatchV1JobsWatchEvent struct {
		Object func(childComplexity int) int
		Type   func(childComplexity int) int
	}

	CoreV1Container struct {
		Image func(childComplexity int) int
		Name  func(childComplexity int) int
	}

	CoreV1ContainerState struct {
		Running    func(childComplexity int) int
		Terminated func(childComplexity int) int
		Waiting    func(childComplexity int) int
	}

	CoreV1ContainerStateRunning struct {
		StartedAt func(childComplexity int) int
	}

	CoreV1ContainerStateTerminated struct {
		ContainerID func(childComplexity int) int
		ExitCode    func(childComplexity int) int
		Message     func(childComplexity int) int
		Reason      func(childComplexity int) int
		Signal      func(childComplexity int) int
	}

	CoreV1ContainerStateWaiting struct {
		Message func(childComplexity int) int
		Reason  func(childComplexity int) int
	}

	CoreV1ContainerStatus struct {
		ContainerID          func(childComplexity int) int
		Image                func(childComplexity int) int
		ImageID              func(childComplexity int) int
		LastTerminationState func(childComplexity int) int
		Name                 func(childComplexity int) int
		Ready                func(childComplexity int) int
		RestartCount         func(childComplexity int) int
		Started              func(childComplexity int) int
		State                func(childComplexity int) int
	}

	CoreV1Namespace struct {
		APIVersion func(childComplexity int) int
		Kind       func(childComplexity int) int
		ObjectMeta func(childComplexity int) int
		UID        func(childComplexity int) int
	}

	CoreV1NamespaceList struct {
		APIVersion func(childComplexity int) int
		Items      func(childComplexity int) int
		Kind       func(childComplexity int) int
		ListMeta   func(childComplexity int) int
	}

	CoreV1NamespacesWatchEvent struct {
		Object func(childComplexity int) int
		Type   func(childComplexity int) int
	}

	CoreV1Node struct {
		APIVersion func(childComplexity int) int
		Kind       func(childComplexity int) int
		ObjectMeta func(childComplexity int) int
		UID        func(childComplexity int) int
	}

	CoreV1NodeList struct {
		APIVersion func(childComplexity int) int
		Items      func(childComplexity int) int
		Kind       func(childComplexity int) int
		ListMeta   func(childComplexity int) int
	}

	CoreV1NodesWatchEvent struct {
		Object func(childComplexity int) int
		Type   func(childComplexity int) int
	}

	CoreV1ObjectReference struct {
		APIVersion      func(childComplexity int) int
		FieldPath       func(childComplexity int) int
		Kind            func(childComplexity int) int
		Name            func(childComplexity int) int
		Namespace       func(childComplexity int) int
		ResourceVersion func(childComplexity int) int
		UID             func(childComplexity int) int
	}

	CoreV1Pod struct {
		APIVersion func(childComplexity int) int
		Kind       func(childComplexity int) int
		ObjectMeta func(childComplexity int) int
		Spec       func(childComplexity int) int
		Status     func(childComplexity int) int
		UID        func(childComplexity int) int
	}

	CoreV1PodList struct {
		APIVersion func(childComplexity int) int
		Items      func(childComplexity int) int
		Kind       func(childComplexity int) int
		ListMeta   func(childComplexity int) int
	}

	CoreV1PodSpec struct {
		Containers        func(childComplexity int) int
		Hostname          func(childComplexity int) int
		NodeName          func(childComplexity int) int
		PriorityClassName func(childComplexity int) int
	}

	CoreV1PodStatus struct {
		ContainerStatuses func(childComplexity int) int
		Message           func(childComplexity int) int
		Phase             func(childComplexity int) int
		Reason            func(childComplexity int) int
	}

	CoreV1PodsWatchEvent struct {
		Object func(childComplexity int) int
		Type   func(childComplexity int) int
	}

	HealthCheckResponse struct {
		Message   func(childComplexity int) int
		Status    func(childComplexity int) int
		Timestamp func(childComplexity int) int
	}

	LogMetadata struct {
		FileInfo func(childComplexity int) int
		Id       func(childComplexity int) int
		Spec     func(childComplexity int) int
	}

	LogMetadataFileInfo struct {
		LastModifiedAt func(childComplexity int) int
		Size           func(childComplexity int) int
	}

	LogMetadataList struct {
		Items func(childComplexity int) int
	}

	LogMetadataSpec struct {
		ContainerId   func(childComplexity int) int
		ContainerName func(childComplexity int) int
		Namespace     func(childComplexity int) int
		NodeName      func(childComplexity int) int
		PodName       func(childComplexity int) int
	}

	LogMetadataWatchEvent struct {
		Object func(childComplexity int) int
		Type   func(childComplexity int) int
	}

	LogRecord struct {
		Message   func(childComplexity int) int
		Timestamp func(childComplexity int) int
	}

	MetaV1LabelSelector struct {
		MatchExpressions func(childComplexity int) int
		MatchLabels      func(childComplexity int) int
	}

	MetaV1LabelSelectorRequirement struct {
		Key      func(childComplexity int) int
		Operator func(childComplexity int) int
		Values   func(childComplexity int) int
	}

	MetaV1ListMeta struct {
		Continue           func(childComplexity int) int
		RemainingItemCount func(childComplexity int) int
		ResourceVersion    func(childComplexity int) int
	}

	MetaV1ObjectMeta struct {
		Annotations       func(childComplexity int) int
		CreationTimestamp func(childComplexity int) int
		DeletionTimestamp func(childComplexity int) int
		Labels            func(childComplexity int) int
		Name              func(childComplexity int) int
		Namespace         func(childComplexity int) int
		OwnerReferences   func(childComplexity int) int
		ResourceVersion   func(childComplexity int) int
		UID               func(childComplexity int) int
	}

	MetaV1OwnerReference struct {
		APIVersion func(childComplexity int) int
		Controller func(childComplexity int) int
		Kind       func(childComplexity int) int
		Name       func(childComplexity int) int
		UID        func(childComplexity int) int
	}

	PageInfo struct {
		EndCursor       func(childComplexity int) int
		HasNextPage     func(childComplexity int) int
		HasPreviousPage func(childComplexity int) int
		StartCursor     func(childComplexity int) int
	}

	PodLogQueryResponse struct {
		PageInfo func(childComplexity int) int
		Results  func(childComplexity int) int
	}

	Query struct {
		AppsV1DaemonSetsGet    func(childComplexity int, name string, namespace *string, options *v1.GetOptions) int
		AppsV1DaemonSetsList   func(childComplexity int, namespace *string, options *v1.ListOptions) int
		AppsV1DeploymentsGet   func(childComplexity int, name string, namespace *string, options *v1.GetOptions) int
		AppsV1DeploymentsList  func(childComplexity int, namespace *string, options *v1.ListOptions) int
		AppsV1ReplicaSetsGet   func(childComplexity int, name string, namespace *string, options *v1.GetOptions) int
		AppsV1ReplicaSetsList  func(childComplexity int, namespace *string, options *v1.ListOptions) int
		AppsV1StatefulSetsGet  func(childComplexity int, name string, namespace *string, options *v1.GetOptions) int
		AppsV1StatefulSetsList func(childComplexity int, namespace *string, options *v1.ListOptions) int
		BatchV1CronJobsGet     func(childComplexity int, name string, namespace *string, options *v1.GetOptions) int
		BatchV1CronJobsList    func(childComplexity int, namespace *string, options *v1.ListOptions) int
		BatchV1JobsGet         func(childComplexity int, name string, namespace *string, options *v1.GetOptions) int
		BatchV1JobsList        func(childComplexity int, namespace *string, options *v1.ListOptions) int
		CoreV1NamespacesList   func(childComplexity int, options *v1.ListOptions) int
		CoreV1NodesList        func(childComplexity int, options *v1.ListOptions) int
		CoreV1PodsGet          func(childComplexity int, namespace *string, name string, options *v1.GetOptions) int
		CoreV1PodsGetLogs      func(childComplexity int, namespace *string, name string, options *v11.PodLogOptions) int
		CoreV1PodsList         func(childComplexity int, namespace *string, options *v1.ListOptions) int
		LivezGet               func(childComplexity int) int
		LogMetadataList        func(childComplexity int, namespace *string) int
		PodLogHead             func(childComplexity int, namespace *string, name string, container *string, after *string, since *string, first *int) int
		PodLogTail             func(childComplexity int, namespace *string, name string, container *string, before *string, last *int) int
		ReadyzGet              func(childComplexity int) int
	}

	Subscription struct {
		AppsV1DaemonSetsWatch   func(childComplexity int, namespace *string, options *v1.ListOptions) int
		AppsV1DeploymentsWatch  func(childComplexity int, namespace *string, options *v1.ListOptions) int
		AppsV1ReplicaSetsWatch  func(childComplexity int, namespace *string, options *v1.ListOptions) int
		AppsV1StatefulSetsWatch func(childComplexity int, namespace *string, options *v1.ListOptions) int
		BatchV1CronJobsWatch    func(childComplexity int, namespace *string, options *v1.ListOptions) int
		BatchV1JobsWatch        func(childComplexity int, namespace *string, options *v1.ListOptions) int
		CoreV1NamespacesWatch   func(childComplexity int, options *v1.ListOptions) int
		CoreV1NodesWatch        func(childComplexity int, options *v1.ListOptions) int
		CoreV1PodLogTail        func(childComplexity int, namespace *string, name string, options *v11.PodLogOptions) int
		CoreV1PodsWatch         func(childComplexity int, namespace *string, options *v1.ListOptions) int
		LivezWatch              func(childComplexity int) int
		LogMetadataWatch        func(childComplexity int, namespace *string) int
		PodLogFollow            func(childComplexity int, namespace *string, name string, container *string, after *string, since *string) int
		ReadyzWatch             func(childComplexity int) int
	}
}

type Config 

type Config struct {
	Schema     *ast.Schema
	Resolvers  ResolverRoot
	Directives DirectiveRoot
	Complexity ComplexityRoot
}

type CoreV1NamespacesWatchEventResolver 

type CoreV1NamespacesWatchEventResolver interface {
	Object(ctx context.Context, obj *watch.Event) (*v11.Namespace, error)
}

type CoreV1NodesWatchEventResolver 

type CoreV1NodesWatchEventResolver interface {
	Object(ctx context.Context, obj *watch.Event) (*v11.Node, error)
}

type CoreV1PodsWatchEventResolver 

type CoreV1PodsWatchEventResolver interface {
	Object(ctx context.Context, obj *watch.Event) (*v11.Pod, error)
}

type DirectiveRoot 

type DirectiveRoot struct {
	NullIfValidationFailed func(ctx context.Context, obj interface{}, next graphql.Resolver) (res interface{}, err error)
	Validate               func(ctx context.Context, obj interface{}, next graphql.Resolver, rule string, message *string) (res interface{}, err error)
}

type FetchResponse 

type FetchResponse struct {
	Namespace string
	Result    *unstructured.UnstructuredList
	Error     error
}

Represents response from fetchListResource()

type FollowArgs 

type FollowArgs struct {
	After string
	Since string
}

type HandlerOptions 

type HandlerOptions struct {
	WSInitFunc transport.WebsocketInitFunc
}

func NewDefaultHandlerOptions 

func NewDefaultHandlerOptions() *HandlerOptions

type HeadArgs 

type HeadArgs struct {
	After string
	Since string
	First uint
}

Log API args

type HeadSince 

type HeadSince int8

Head enums 

const (
	HeadSinceUnset HeadSince = iota
	HeadSinceBeginning
	HeadSinceTime
)

type QueryResolver 

type QueryResolver interface {
	AppsV1DaemonSetsGet(ctx context.Context, name string, namespace *string, options *v1.GetOptions) (*v12.DaemonSet, error)
	AppsV1DaemonSetsList(ctx context.Context, namespace *string, options *v1.ListOptions) (*v12.DaemonSetList, error)
	AppsV1DeploymentsGet(ctx context.Context, name string, namespace *string, options *v1.GetOptions) (*v12.Deployment, error)
	AppsV1DeploymentsList(ctx context.Context, namespace *string, options *v1.ListOptions) (*v12.DeploymentList, error)
	AppsV1ReplicaSetsGet(ctx context.Context, name string, namespace *string, options *v1.GetOptions) (*v12.ReplicaSet, error)
	AppsV1ReplicaSetsList(ctx context.Context, namespace *string, options *v1.ListOptions) (*v12.ReplicaSetList, error)
	AppsV1StatefulSetsGet(ctx context.Context, name string, namespace *string, options *v1.GetOptions) (*v12.StatefulSet, error)
	AppsV1StatefulSetsList(ctx context.Context, namespace *string, options *v1.ListOptions) (*v12.StatefulSetList, error)
	BatchV1CronJobsGet(ctx context.Context, name string, namespace *string, options *v1.GetOptions) (*v13.CronJob, error)
	BatchV1CronJobsList(ctx context.Context, namespace *string, options *v1.ListOptions) (*v13.CronJobList, error)
	BatchV1JobsGet(ctx context.Context, name string, namespace *string, options *v1.GetOptions) (*v13.Job, error)
	BatchV1JobsList(ctx context.Context, namespace *string, options *v1.ListOptions) (*v13.JobList, error)
	CoreV1NamespacesList(ctx context.Context, options *v1.ListOptions) (*v11.NamespaceList, error)
	CoreV1NodesList(ctx context.Context, options *v1.ListOptions) (*v11.NodeList, error)
	CoreV1PodsGet(ctx context.Context, namespace *string, name string, options *v1.GetOptions) (*v11.Pod, error)
	CoreV1PodsList(ctx context.Context, namespace *string, options *v1.ListOptions) (*v11.PodList, error)
	CoreV1PodsGetLogs(ctx context.Context, namespace *string, name string, options *v11.PodLogOptions) ([]model.LogRecord, error)
	LogMetadataList(ctx context.Context, namespace *string) (*agentpb.LogMetadataList, error)
	PodLogHead(ctx context.Context, namespace *string, name string, container *string, after *string, since *string, first *int) (*model.PodLogQueryResponse, error)
	PodLogTail(ctx context.Context, namespace *string, name string, container *string, before *string, last *int) (*model.PodLogQueryResponse, error)
	LivezGet(ctx context.Context) (model.HealthCheckResponse, error)
	ReadyzGet(ctx context.Context) (model.HealthCheckResponse, error)
}

type Resolver 

type Resolver struct {
	TestClientset     *fake.Clientset
	TestDynamicClient *dynamicFake.FakeDynamicClient
	// contains filtered or unexported fields
}

func NewResolver 

func NewResolver(cfg *rest.Config, grpcDispatcher *grpcdispatcher.Dispatcher, allowedNamespaces []string) (*Resolver, error)

func (*Resolver) AppsV1DaemonSetsWatchEvent 

func (r *Resolver) AppsV1DaemonSetsWatchEvent() AppsV1DaemonSetsWatchEventResolver

AppsV1DaemonSetsWatchEvent returns AppsV1DaemonSetsWatchEventResolver implementation.

func (*Resolver) AppsV1DeploymentsWatchEvent 

func (r *Resolver) AppsV1DeploymentsWatchEvent() AppsV1DeploymentsWatchEventResolver

AppsV1DeploymentsWatchEvent returns AppsV1DeploymentsWatchEventResolver implementation.

func (*Resolver) AppsV1ReplicaSetsWatchEvent 

func (r *Resolver) AppsV1ReplicaSetsWatchEvent() AppsV1ReplicaSetsWatchEventResolver

AppsV1ReplicaSetsWatchEvent returns AppsV1ReplicaSetsWatchEventResolver implementation.

func (*Resolver) AppsV1StatefulSetsWatchEvent 

func (r *Resolver) AppsV1StatefulSetsWatchEvent() AppsV1StatefulSetsWatchEventResolver

AppsV1StatefulSetsWatchEvent returns AppsV1StatefulSetsWatchEventResolver implementation.

func (*Resolver) BatchV1CronJobsWatchEvent 

func (r *Resolver) BatchV1CronJobsWatchEvent() BatchV1CronJobsWatchEventResolver

BatchV1CronJobsWatchEvent returns BatchV1CronJobsWatchEventResolver implementation.

func (*Resolver) BatchV1JobsWatchEvent 

func (r *Resolver) BatchV1JobsWatchEvent() BatchV1JobsWatchEventResolver

BatchV1JobsWatchEvent returns BatchV1JobsWatchEventResolver implementation.

func (*Resolver) CoreV1NamespacesWatchEvent 

func (r *Resolver) CoreV1NamespacesWatchEvent() CoreV1NamespacesWatchEventResolver

CoreV1NamespacesWatchEvent returns CoreV1NamespacesWatchEventResolver implementation.

func (*Resolver) CoreV1NodesWatchEvent 

func (r *Resolver) CoreV1NodesWatchEvent() CoreV1NodesWatchEventResolver

CoreV1NodesWatchEvent returns CoreV1NodesWatchEventResolver implementation.

func (*Resolver) CoreV1PodsWatchEvent 

func (r *Resolver) CoreV1PodsWatchEvent() CoreV1PodsWatchEventResolver

CoreV1PodsWatchEvent returns CoreV1PodsWatchEventResolver implementation.

func (*Resolver) K8SClientset 

func (r *Resolver) K8SClientset(ctx context.Context) kubernetes.Interface

func (*Resolver) K8SDynamicClient 

func (r *Resolver) K8SDynamicClient(ctx context.Context) dynamic.Interface

func (*Resolver) Query 

func (r *Resolver) Query() QueryResolver

Query returns QueryResolver implementation.

func (*Resolver) Subscription 

func (r *Resolver) Subscription() SubscriptionResolver

Subscription returns SubscriptionResolver implementation.

func (*Resolver) ToNamespace 

func (r *Resolver) ToNamespace(namespace *string) (string, error)

func (*Resolver) ToNamespaces 

func (r *Resolver) ToNamespaces(namespace *string) ([]string, error)

type ResolverRoot 

type ResolverRoot interface {
	AppsV1DaemonSetsWatchEvent() AppsV1DaemonSetsWatchEventResolver
	AppsV1DeploymentsWatchEvent() AppsV1DeploymentsWatchEventResolver
	AppsV1ReplicaSetsWatchEvent() AppsV1ReplicaSetsWatchEventResolver
	AppsV1StatefulSetsWatchEvent() AppsV1StatefulSetsWatchEventResolver
	BatchV1CronJobsWatchEvent() BatchV1CronJobsWatchEventResolver
	BatchV1JobsWatchEvent() BatchV1JobsWatchEventResolver
	CoreV1NamespacesWatchEvent() CoreV1NamespacesWatchEventResolver
	CoreV1NodesWatchEvent() CoreV1NodesWatchEventResolver
	CoreV1PodsWatchEvent() CoreV1PodsWatchEventResolver
	Query() QueryResolver
	Subscription() SubscriptionResolver
}

type SubscriptionResolver 

type SubscriptionResolver interface {
	AppsV1DaemonSetsWatch(ctx context.Context, namespace *string, options *v1.ListOptions) (<-chan *watch.Event, error)
	AppsV1DeploymentsWatch(ctx context.Context, namespace *string, options *v1.ListOptions) (<-chan *watch.Event, error)
	AppsV1ReplicaSetsWatch(ctx context.Context, namespace *string, options *v1.ListOptions) (<-chan *watch.Event, error)
	AppsV1StatefulSetsWatch(ctx context.Context, namespace *string, options *v1.ListOptions) (<-chan *watch.Event, error)
	BatchV1CronJobsWatch(ctx context.Context, namespace *string, options *v1.ListOptions) (<-chan *watch.Event, error)
	BatchV1JobsWatch(ctx context.Context, namespace *string, options *v1.ListOptions) (<-chan *watch.Event, error)
	CoreV1NamespacesWatch(ctx context.Context, options *v1.ListOptions) (<-chan *watch.Event, error)
	CoreV1NodesWatch(ctx context.Context, options *v1.ListOptions) (<-chan *watch.Event, error)
	CoreV1PodsWatch(ctx context.Context, namespace *string, options *v1.ListOptions) (<-chan *watch.Event, error)
	CoreV1PodLogTail(ctx context.Context, namespace *string, name string, options *v11.PodLogOptions) (<-chan *model.LogRecord, error)
	LogMetadataWatch(ctx context.Context, namespace *string) (<-chan *agentpb.LogMetadataWatchEvent, error)
	PodLogFollow(ctx context.Context, namespace *string, name string, container *string, after *string, since *string) (<-chan *model.LogRecord, error)
	LivezWatch(ctx context.Context) (<-chan model.HealthCheckResponse, error)
	ReadyzWatch(ctx context.Context) (<-chan model.HealthCheckResponse, error)
}

type TailArgs 

type TailArgs struct {
	Before string
	Last   uint
}

type TailCursor 

type TailCursor struct {
	TailLines int64     `json:"tail_lines"`
	Time      time.Time `json:"time"`
	FirstTS   time.Time `json:"first_ts"`
}

Tail cursor

type TailUntil 

type TailUntil int8

Tail enums 

const (
	TailUntilUnset TailUntil = iota
	TailUntilNow
	TailUntilTime
)

Source Files

View all Source files

Directories

Path Synopsis

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.