server

Documentation

Index

• Variables
• func DescribeEvents(el *corev1.EventList) []*pb.PodEvent
• func SortedResourceNames(list corev1.ResourceList) []corev1.ResourceName
• type RuntimeServer
  • func CreaterRuntimeServer(conf option.Config, store store.Storer, clientset kubernetes.Interface, ...) *RuntimeServer
  • func (r *RuntimeServer) AddThirdPartyEndpoint(ctx context.Context, re *pb.AddThirdPartyEndpointsReq) (*pb.Empty, error)
  • func (r *RuntimeServer) DelThirdPartyEndpoint(ctx context.Context, re *pb.DelThirdPartyEndpointsReq) (*pb.Empty, error)
  • func (r *RuntimeServer) GetAppPods(ctx context.Context, re *pb.ServiceRequest) (*pb.ServiceAppPodList, error)
  • func (r *RuntimeServer) GetAppStatus(ctx context.Context, re *pb.ServicesRequest) (*pb.StatusMessage, error)
  • func (r *RuntimeServer) GetAppVolumeStatus(ctx context.Context, re *pb.ServiceRequest) (*pb.ServiceVolumeStatusMessage, error)
  • func (r *RuntimeServer) GetDeployInfo(ctx context.Context, re *pb.ServiceRequest) (*pb.DeployInfo, error)
  • func (r *RuntimeServer) GetPodDetail(ctx context.Context, req *pb.GetPodDetailReq) (podDetail *pb.PodDetail, err error)
  • func (r *RuntimeServer) GetStorageClasses(ctx context.Context, re *pb.Empty) (*pb.StorageClasses, error)
  • func (r *RuntimeServer) GetTenantResource(ctx context.Context, re *pb.TenantRequest) (*pb.TenantResource, error)
  • func (r *RuntimeServer) ListThirdPartyEndpoints(ctx context.Context, re *pb.ServiceRequest) (*pb.ThirdPartyEndpoints, error)
  • func (r *RuntimeServer) Start(errchan chan error)
  • func (r *RuntimeServer) UpdThirdPartyEndpoint(ctx context.Context, re *pb.UpdThirdPartyEndpointsReq) (*pb.Empty, error)
• type SortableResourceNames
  • func (list SortableResourceNames) Len() int
  • func (list SortableResourceNames) Less(i, j int) bool
  • func (list SortableResourceNames) Swap(i, j int)

Variables

var (
	// ErrAppServiceNotFound app service not found error, happens when haven't find any matched data when looking up with a service id
	ErrAppServiceNotFound = errors.New("app service not found")
	// ErrPodNotFound pod not found error, happens when haven't find any matched data when looking up with a pod name
	ErrPodNotFound = errors.New("pod not found")
)

Functions

func DescribeEvents

func DescribeEvents(el *corev1.EventList) []*pb.PodEvent

DescribeEvents -

func SortedResourceNames

func SortedResourceNames(list corev1.ResourceList) []corev1.ResourceName

SortedResourceNames returns the sorted resource names of a resource list.

Types

type RuntimeServer

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

RuntimeServer app runtime grpc server

func CreaterRuntimeServer

func CreaterRuntimeServer(conf option.Config,
	store store.Storer,
	clientset kubernetes.Interface,
	updateCh *channels.RingChannel) *RuntimeServer

CreaterRuntimeServer create a runtime grpc server

func (*RuntimeServer) AddThirdPartyEndpoint

func (r *RuntimeServer) AddThirdPartyEndpoint(ctx context.Context, re *pb.AddThirdPartyEndpointsReq) (*pb.Empty, error)

AddThirdPartyEndpoint creates a create event.

func (*RuntimeServer) DelThirdPartyEndpoint

func (r *RuntimeServer) DelThirdPartyEndpoint(ctx context.Context, re *pb.DelThirdPartyEndpointsReq) (*pb.Empty, error)

DelThirdPartyEndpoint creates a delete event.

func (*RuntimeServer) GetAppPods

func (r *RuntimeServer) GetAppPods(ctx context.Context, re *pb.ServiceRequest) (*pb.ServiceAppPodList, error)

GetAppPods get app pod list

func (*RuntimeServer) GetAppStatus

func (r *RuntimeServer) GetAppStatus(ctx context.Context, re *pb.ServicesRequest) (*pb.StatusMessage, error)

GetAppStatus get app service status

func (*RuntimeServer) GetAppVolumeStatus

func (r *RuntimeServer) GetAppVolumeStatus(ctx context.Context, re *pb.ServiceRequest) (*pb.ServiceVolumeStatusMessage, error)

GetAppVolumeStatus get app volume status

func (*RuntimeServer) GetDeployInfo

func (r *RuntimeServer) GetDeployInfo(ctx context.Context, re *pb.ServiceRequest) (*pb.DeployInfo, error)

GetDeployInfo get deploy info

func (*RuntimeServer) GetPodDetail

func (r *RuntimeServer) GetPodDetail(ctx context.Context, req *pb.GetPodDetailReq) (podDetail *pb.PodDetail, err error)

GetPodDetail returns detail information of the pod based on pod name.

func (*RuntimeServer) GetStorageClasses

func (r *RuntimeServer) GetStorageClasses(ctx context.Context, re *pb.Empty) (*pb.StorageClasses, error)

GetStorageClasses get storageclass list

func (*RuntimeServer) GetTenantResource

func (r *RuntimeServer) GetTenantResource(ctx context.Context, re *pb.TenantRequest) (*pb.TenantResource, error)

GetTenantResource get tenant resource if TenantId is "" will return the sum of the all tenant

func (*RuntimeServer) ListThirdPartyEndpoints

func (r *RuntimeServer) ListThirdPartyEndpoints(ctx context.Context, re *pb.ServiceRequest) (*pb.ThirdPartyEndpoints, error)

ListThirdPartyEndpoints returns a collection of third-part endpoints.

func (*RuntimeServer) Start

func (r *RuntimeServer) Start(errchan chan error)

Start start runtime server

func (*RuntimeServer) UpdThirdPartyEndpoint

func (r *RuntimeServer) UpdThirdPartyEndpoint(ctx context.Context, re *pb.UpdThirdPartyEndpointsReq) (*pb.Empty, error)

UpdThirdPartyEndpoint creates a update event.

type SortableResourceNames

type SortableResourceNames []corev1.ResourceName

SortableResourceNames -

func (SortableResourceNames) Len

func (list SortableResourceNames) Len() int

func (SortableResourceNames) Less

func (list SortableResourceNames) Less(i, j int) bool

func (SortableResourceNames) Swap

func (list SortableResourceNames) Swap(i, j int)