Documentation

Overview

    Package application is a generated protocol buffer package.
    
    Application Service
    
    Application Service API performs CRUD actions against application resources
    
    It is generated from these files:
    	server/application/application.proto
    
    It has these top-level messages:
    	ApplicationQuery
    	ApplicationResourceEventsQuery
    	ManifestQuery
    	ApplicationResponse
    	DeleteApplicationRequest
    	ApplicationSyncRequest
    	ApplicationSpecRequest
    	ApplicationRollbackRequest
    	DeletePodQuery
    	PodLogsQuery
    	LogEntry
    

    Package application is a reverse proxy.

    It translates gRPC into RESTful JSON APIs.

    Index

    Constants

    This section is empty.

    Variables

    View Source
    var (
    	ErrInvalidLengthApplication = fmt.Errorf("proto: negative length found during unmarshaling")
    	ErrIntOverflowApplication   = fmt.Errorf("proto: integer overflow")
    )

    Functions

    func RegisterApplicationServiceHandler

    func RegisterApplicationServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

      RegisterApplicationServiceHandler registers the http handlers for service ApplicationService to "mux". The handlers forward requests to the grpc endpoint over "conn".

      func RegisterApplicationServiceHandlerClient

      func RegisterApplicationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ApplicationServiceClient) error

        RegisterApplicationServiceHandler registers the http handlers for service ApplicationService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ApplicationServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ApplicationServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ApplicationServiceClient" to call the correct interceptors.

        func RegisterApplicationServiceHandlerFromEndpoint

        func RegisterApplicationServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

          RegisterApplicationServiceHandlerFromEndpoint is same as RegisterApplicationServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

          func RegisterApplicationServiceServer

          func RegisterApplicationServiceServer(s *grpc.Server, srv ApplicationServiceServer)

          Types

          type ApplicationQuery

          type ApplicationQuery struct {
          	Name             *string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
          	XXX_unrecognized []byte  `json:"-"`
          }

            ApplicationQuery is a query for application resources

            func (*ApplicationQuery) Descriptor

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

            func (*ApplicationQuery) GetName

            func (m *ApplicationQuery) GetName() string

            func (*ApplicationQuery) Marshal

            func (m *ApplicationQuery) Marshal() (dAtA []byte, err error)

            func (*ApplicationQuery) MarshalTo

            func (m *ApplicationQuery) MarshalTo(dAtA []byte) (int, error)

            func (*ApplicationQuery) ProtoMessage

            func (*ApplicationQuery) ProtoMessage()

            func (*ApplicationQuery) Reset

            func (m *ApplicationQuery) Reset()

            func (*ApplicationQuery) Size

            func (m *ApplicationQuery) Size() (n int)

            func (*ApplicationQuery) String

            func (m *ApplicationQuery) String() string

            func (*ApplicationQuery) Unmarshal

            func (m *ApplicationQuery) Unmarshal(dAtA []byte) error

            type ApplicationResourceEventsQuery

            type ApplicationResourceEventsQuery struct {
            	AppName          *string `protobuf:"bytes,1,req,name=appName" json:"appName,omitempty"`
            	ResName          *string `protobuf:"bytes,2,req,name=resName" json:"resName,omitempty"`
            	ResUid           *string `protobuf:"bytes,3,req,name=resUid" json:"resUid,omitempty"`
            	XXX_unrecognized []byte  `json:"-"`
            }

              ApplicationEventsQuery is a query for application resource events

              func (*ApplicationResourceEventsQuery) Descriptor

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

              func (*ApplicationResourceEventsQuery) GetAppName

              func (m *ApplicationResourceEventsQuery) GetAppName() string

              func (*ApplicationResourceEventsQuery) GetResName

              func (m *ApplicationResourceEventsQuery) GetResName() string

              func (*ApplicationResourceEventsQuery) GetResUid

              func (m *ApplicationResourceEventsQuery) GetResUid() string

              func (*ApplicationResourceEventsQuery) Marshal

              func (m *ApplicationResourceEventsQuery) Marshal() (dAtA []byte, err error)

              func (*ApplicationResourceEventsQuery) MarshalTo

              func (m *ApplicationResourceEventsQuery) MarshalTo(dAtA []byte) (int, error)

              func (*ApplicationResourceEventsQuery) ProtoMessage

              func (*ApplicationResourceEventsQuery) ProtoMessage()

              func (*ApplicationResourceEventsQuery) Reset

              func (m *ApplicationResourceEventsQuery) Reset()

              func (*ApplicationResourceEventsQuery) Size

              func (m *ApplicationResourceEventsQuery) Size() (n int)

              func (*ApplicationResourceEventsQuery) String

              func (*ApplicationResourceEventsQuery) Unmarshal

              func (m *ApplicationResourceEventsQuery) Unmarshal(dAtA []byte) error

              type ApplicationResponse

              type ApplicationResponse struct {
              	XXX_unrecognized []byte `json:"-"`
              }

              func (*ApplicationResponse) Descriptor

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

              func (*ApplicationResponse) Marshal

              func (m *ApplicationResponse) Marshal() (dAtA []byte, err error)

              func (*ApplicationResponse) MarshalTo

              func (m *ApplicationResponse) MarshalTo(dAtA []byte) (int, error)

              func (*ApplicationResponse) ProtoMessage

              func (*ApplicationResponse) ProtoMessage()

              func (*ApplicationResponse) Reset

              func (m *ApplicationResponse) Reset()

              func (*ApplicationResponse) Size

              func (m *ApplicationResponse) Size() (n int)

              func (*ApplicationResponse) String

              func (m *ApplicationResponse) String() string

              func (*ApplicationResponse) Unmarshal

              func (m *ApplicationResponse) Unmarshal(dAtA []byte) error

              type ApplicationRollbackRequest

              type ApplicationRollbackRequest struct {
              	Name             *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
              	ID               int64   `protobuf:"varint,2,req,name=id" json:"id"`
              	DryRun           bool    `protobuf:"varint,3,req,name=dryRun" json:"dryRun"`
              	Prune            bool    `protobuf:"varint,4,req,name=prune" json:"prune"`
              	XXX_unrecognized []byte  `json:"-"`
              }

              func (*ApplicationRollbackRequest) Descriptor

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

              func (*ApplicationRollbackRequest) GetDryRun

              func (m *ApplicationRollbackRequest) GetDryRun() bool

              func (*ApplicationRollbackRequest) GetID

              func (m *ApplicationRollbackRequest) GetID() int64

              func (*ApplicationRollbackRequest) GetName

              func (m *ApplicationRollbackRequest) GetName() string

              func (*ApplicationRollbackRequest) GetPrune

              func (m *ApplicationRollbackRequest) GetPrune() bool

              func (*ApplicationRollbackRequest) Marshal

              func (m *ApplicationRollbackRequest) Marshal() (dAtA []byte, err error)

              func (*ApplicationRollbackRequest) MarshalTo

              func (m *ApplicationRollbackRequest) MarshalTo(dAtA []byte) (int, error)

              func (*ApplicationRollbackRequest) ProtoMessage

              func (*ApplicationRollbackRequest) ProtoMessage()

              func (*ApplicationRollbackRequest) Reset

              func (m *ApplicationRollbackRequest) Reset()

              func (*ApplicationRollbackRequest) Size

              func (m *ApplicationRollbackRequest) Size() (n int)

              func (*ApplicationRollbackRequest) String

              func (m *ApplicationRollbackRequest) String() string

              func (*ApplicationRollbackRequest) Unmarshal

              func (m *ApplicationRollbackRequest) Unmarshal(dAtA []byte) error

              type ApplicationServiceClient

              type ApplicationServiceClient interface {
              	// List returns list of applications
              	List(ctx context.Context, in *ApplicationQuery, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.ApplicationList, error)
              	// ListResourceEvents returns a list of event resources
              	ListResourceEvents(ctx context.Context, in *ApplicationResourceEventsQuery, opts ...grpc.CallOption) (*k8s_io_api_core_v1.EventList, error)
              	// Watch returns stream of application change events.
              	Watch(ctx context.Context, in *ApplicationQuery, opts ...grpc.CallOption) (ApplicationService_WatchClient, error)
              	// Create creates an application
              	Create(ctx context.Context, in *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Application, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Application, error)
              	// Get returns an application by name
              	Get(ctx context.Context, in *ApplicationQuery, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Application, error)
              	// GetManifests returns application manifests
              	GetManifests(ctx context.Context, in *ManifestQuery, opts ...grpc.CallOption) (*repository.ManifestResponse, error)
              	// Update updates an application
              	Update(ctx context.Context, in *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Application, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Application, error)
              	// Update updates an application spec
              	UpdateSpec(ctx context.Context, in *ApplicationSpecRequest, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.ApplicationSpec, error)
              	// Delete deletes an application
              	Delete(ctx context.Context, in *DeleteApplicationRequest, opts ...grpc.CallOption) (*ApplicationResponse, error)
              	// Sync syncs an application to its target state
              	Sync(ctx context.Context, in *ApplicationSyncRequest, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Application, error)
              	// Sync syncs an application to its target state
              	Rollback(ctx context.Context, in *ApplicationRollbackRequest, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Application, error)
              	// PodLogs returns stream of log entries for the specified pod. Pod
              	DeletePod(ctx context.Context, in *DeletePodQuery, opts ...grpc.CallOption) (*ApplicationResponse, error)
              	// PodLogs returns stream of log entries for the specified pod. Pod
              	PodLogs(ctx context.Context, in *PodLogsQuery, opts ...grpc.CallOption) (ApplicationService_PodLogsClient, error)
              }

              func NewApplicationServiceClient

              func NewApplicationServiceClient(cc *grpc.ClientConn) ApplicationServiceClient

              type ApplicationServiceServer

              type ApplicationServiceServer interface {
              	// List returns list of applications
              	List(context.Context, *ApplicationQuery) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.ApplicationList, error)
              	// ListResourceEvents returns a list of event resources
              	ListResourceEvents(context.Context, *ApplicationResourceEventsQuery) (*k8s_io_api_core_v1.EventList, error)
              	// Watch returns stream of application change events.
              	Watch(*ApplicationQuery, ApplicationService_WatchServer) error
              	// Create creates an application
              	Create(context.Context, *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Application) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Application, error)
              	// Get returns an application by name
              	Get(context.Context, *ApplicationQuery) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Application, error)
              	// GetManifests returns application manifests
              	GetManifests(context.Context, *ManifestQuery) (*repository.ManifestResponse, error)
              	// Update updates an application
              	Update(context.Context, *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Application) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Application, error)
              	// Update updates an application spec
              	UpdateSpec(context.Context, *ApplicationSpecRequest) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.ApplicationSpec, error)
              	// Delete deletes an application
              	Delete(context.Context, *DeleteApplicationRequest) (*ApplicationResponse, error)
              	// Sync syncs an application to its target state
              	Sync(context.Context, *ApplicationSyncRequest) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Application, error)
              	// Sync syncs an application to its target state
              	Rollback(context.Context, *ApplicationRollbackRequest) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Application, error)
              	// PodLogs returns stream of log entries for the specified pod. Pod
              	DeletePod(context.Context, *DeletePodQuery) (*ApplicationResponse, error)
              	// PodLogs returns stream of log entries for the specified pod. Pod
              	PodLogs(*PodLogsQuery, ApplicationService_PodLogsServer) error
              }

              func NewServer

              func NewServer(
              	namespace string,
              	kubeclientset kubernetes.Interface,
              	appclientset appclientset.Interface,
              	repoClientset reposerver.Clientset,
              	db db.ArgoDB,
              ) ApplicationServiceServer

                NewServer returns a new instance of the Application service

                type ApplicationService_PodLogsClient

                type ApplicationService_PodLogsClient interface {
                	Recv() (*LogEntry, error)
                	grpc.ClientStream
                }

                type ApplicationService_PodLogsServer

                type ApplicationService_PodLogsServer interface {
                	Send(*LogEntry) error
                	grpc.ServerStream
                }

                type ApplicationSpecRequest

                type ApplicationSpecRequest struct {
                	AppName          *string                                                                   `protobuf:"bytes,1,req,name=appName" json:"appName,omitempty"`
                	Spec             github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.ApplicationSpec `protobuf:"bytes,2,req,name=spec" json:"spec"`
                	XXX_unrecognized []byte                                                                    `json:"-"`
                }

                  ApplicationSpecRequest is a request to update application spec

                  func (*ApplicationSpecRequest) Descriptor

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

                  func (*ApplicationSpecRequest) GetAppName

                  func (m *ApplicationSpecRequest) GetAppName() string

                  func (*ApplicationSpecRequest) Marshal

                  func (m *ApplicationSpecRequest) Marshal() (dAtA []byte, err error)

                  func (*ApplicationSpecRequest) MarshalTo

                  func (m *ApplicationSpecRequest) MarshalTo(dAtA []byte) (int, error)

                  func (*ApplicationSpecRequest) ProtoMessage

                  func (*ApplicationSpecRequest) ProtoMessage()

                  func (*ApplicationSpecRequest) Reset

                  func (m *ApplicationSpecRequest) Reset()

                  func (*ApplicationSpecRequest) Size

                  func (m *ApplicationSpecRequest) Size() (n int)

                  func (*ApplicationSpecRequest) String

                  func (m *ApplicationSpecRequest) String() string

                  func (*ApplicationSpecRequest) Unmarshal

                  func (m *ApplicationSpecRequest) Unmarshal(dAtA []byte) error

                  type ApplicationSyncRequest

                  type ApplicationSyncRequest struct {
                  	Name             *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
                  	Revision         string  `protobuf:"bytes,2,req,name=revision" json:"revision"`
                  	DryRun           bool    `protobuf:"varint,3,req,name=dryRun" json:"dryRun"`
                  	Prune            bool    `protobuf:"varint,4,req,name=prune" json:"prune"`
                  	XXX_unrecognized []byte  `json:"-"`
                  }

                    ApplicationSyncRequest is a request to apply the config state to live state

                    func (*ApplicationSyncRequest) Descriptor

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

                    func (*ApplicationSyncRequest) GetDryRun

                    func (m *ApplicationSyncRequest) GetDryRun() bool

                    func (*ApplicationSyncRequest) GetName

                    func (m *ApplicationSyncRequest) GetName() string

                    func (*ApplicationSyncRequest) GetPrune

                    func (m *ApplicationSyncRequest) GetPrune() bool

                    func (*ApplicationSyncRequest) GetRevision

                    func (m *ApplicationSyncRequest) GetRevision() string

                    func (*ApplicationSyncRequest) Marshal

                    func (m *ApplicationSyncRequest) Marshal() (dAtA []byte, err error)

                    func (*ApplicationSyncRequest) MarshalTo

                    func (m *ApplicationSyncRequest) MarshalTo(dAtA []byte) (int, error)

                    func (*ApplicationSyncRequest) ProtoMessage

                    func (*ApplicationSyncRequest) ProtoMessage()

                    func (*ApplicationSyncRequest) Reset

                    func (m *ApplicationSyncRequest) Reset()

                    func (*ApplicationSyncRequest) Size

                    func (m *ApplicationSyncRequest) Size() (n int)

                    func (*ApplicationSyncRequest) String

                    func (m *ApplicationSyncRequest) String() string

                    func (*ApplicationSyncRequest) Unmarshal

                    func (m *ApplicationSyncRequest) Unmarshal(dAtA []byte) error

                    type DeleteApplicationRequest

                    type DeleteApplicationRequest struct {
                    	Name             *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
                    	Cascade          *bool   `protobuf:"varint,2,opt,name=cascade" json:"cascade,omitempty"`
                    	XXX_unrecognized []byte  `json:"-"`
                    }

                    func (*DeleteApplicationRequest) Descriptor

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

                    func (*DeleteApplicationRequest) GetCascade

                    func (m *DeleteApplicationRequest) GetCascade() bool

                    func (*DeleteApplicationRequest) GetName

                    func (m *DeleteApplicationRequest) GetName() string

                    func (*DeleteApplicationRequest) Marshal

                    func (m *DeleteApplicationRequest) Marshal() (dAtA []byte, err error)

                    func (*DeleteApplicationRequest) MarshalTo

                    func (m *DeleteApplicationRequest) MarshalTo(dAtA []byte) (int, error)

                    func (*DeleteApplicationRequest) ProtoMessage

                    func (*DeleteApplicationRequest) ProtoMessage()

                    func (*DeleteApplicationRequest) Reset

                    func (m *DeleteApplicationRequest) Reset()

                    func (*DeleteApplicationRequest) Size

                    func (m *DeleteApplicationRequest) Size() (n int)

                    func (*DeleteApplicationRequest) String

                    func (m *DeleteApplicationRequest) String() string

                    func (*DeleteApplicationRequest) Unmarshal

                    func (m *DeleteApplicationRequest) Unmarshal(dAtA []byte) error

                    type DeletePodQuery

                    type DeletePodQuery struct {
                    	ApplicationName  *string `protobuf:"bytes,1,req,name=applicationName" json:"applicationName,omitempty"`
                    	PodName          *string `protobuf:"bytes,2,req,name=podName" json:"podName,omitempty"`
                    	XXX_unrecognized []byte  `json:"-"`
                    }

                    func (*DeletePodQuery) Descriptor

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

                    func (*DeletePodQuery) GetApplicationName

                    func (m *DeletePodQuery) GetApplicationName() string

                    func (*DeletePodQuery) GetPodName

                    func (m *DeletePodQuery) GetPodName() string

                    func (*DeletePodQuery) Marshal

                    func (m *DeletePodQuery) Marshal() (dAtA []byte, err error)

                    func (*DeletePodQuery) MarshalTo

                    func (m *DeletePodQuery) MarshalTo(dAtA []byte) (int, error)

                    func (*DeletePodQuery) ProtoMessage

                    func (*DeletePodQuery) ProtoMessage()

                    func (*DeletePodQuery) Reset

                    func (m *DeletePodQuery) Reset()

                    func (*DeletePodQuery) Size

                    func (m *DeletePodQuery) Size() (n int)

                    func (*DeletePodQuery) String

                    func (m *DeletePodQuery) String() string

                    func (*DeletePodQuery) Unmarshal

                    func (m *DeletePodQuery) Unmarshal(dAtA []byte) error

                    type LogEntry

                    type LogEntry struct {
                    	Content          string                                    `protobuf:"bytes,1,req,name=content" json:"content"`
                    	TimeStamp        k8s_io_apimachinery_pkg_apis_meta_v1.Time `protobuf:"bytes,2,req,name=timeStamp" json:"timeStamp"`
                    	XXX_unrecognized []byte                                    `json:"-"`
                    }

                    func (*LogEntry) Descriptor

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

                    func (*LogEntry) GetContent

                    func (m *LogEntry) GetContent() string

                    func (*LogEntry) GetTimeStamp

                    func (*LogEntry) Marshal

                    func (m *LogEntry) Marshal() (dAtA []byte, err error)

                    func (*LogEntry) MarshalTo

                    func (m *LogEntry) MarshalTo(dAtA []byte) (int, error)

                    func (*LogEntry) ProtoMessage

                    func (*LogEntry) ProtoMessage()

                    func (*LogEntry) Reset

                    func (m *LogEntry) Reset()

                    func (*LogEntry) Size

                    func (m *LogEntry) Size() (n int)

                    func (*LogEntry) String

                    func (m *LogEntry) String() string

                    func (*LogEntry) Unmarshal

                    func (m *LogEntry) Unmarshal(dAtA []byte) error

                    type ManifestQuery

                    type ManifestQuery struct {
                    	AppName          *string `protobuf:"bytes,1,req,name=appName" json:"appName,omitempty"`
                    	Revision         *string `protobuf:"bytes,2,opt,name=revision" json:"revision,omitempty"`
                    	XXX_unrecognized []byte  `json:"-"`
                    }

                      ManifestQuery is a query for manifest resources

                      func (*ManifestQuery) Descriptor

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

                      func (*ManifestQuery) GetAppName

                      func (m *ManifestQuery) GetAppName() string

                      func (*ManifestQuery) GetRevision

                      func (m *ManifestQuery) GetRevision() string

                      func (*ManifestQuery) Marshal

                      func (m *ManifestQuery) Marshal() (dAtA []byte, err error)

                      func (*ManifestQuery) MarshalTo

                      func (m *ManifestQuery) MarshalTo(dAtA []byte) (int, error)

                      func (*ManifestQuery) ProtoMessage

                      func (*ManifestQuery) ProtoMessage()

                      func (*ManifestQuery) Reset

                      func (m *ManifestQuery) Reset()

                      func (*ManifestQuery) Size

                      func (m *ManifestQuery) Size() (n int)

                      func (*ManifestQuery) String

                      func (m *ManifestQuery) String() string

                      func (*ManifestQuery) Unmarshal

                      func (m *ManifestQuery) Unmarshal(dAtA []byte) error

                      type PodLogsQuery

                      type PodLogsQuery struct {
                      	ApplicationName  *string                                    `protobuf:"bytes,1,req,name=applicationName" json:"applicationName,omitempty"`
                      	PodName          *string                                    `protobuf:"bytes,2,req,name=podName" json:"podName,omitempty"`
                      	Container        string                                     `protobuf:"bytes,3,req,name=container" json:"container"`
                      	SinceSeconds     int64                                      `protobuf:"varint,4,req,name=sinceSeconds" json:"sinceSeconds"`
                      	SinceTime        *k8s_io_apimachinery_pkg_apis_meta_v1.Time `protobuf:"bytes,5,opt,name=sinceTime" json:"sinceTime,omitempty"`
                      	TailLines        int64                                      `protobuf:"varint,6,req,name=tailLines" json:"tailLines"`
                      	Follow           bool                                       `protobuf:"varint,7,req,name=follow" json:"follow"`
                      	XXX_unrecognized []byte                                     `json:"-"`
                      }

                      func (*PodLogsQuery) Descriptor

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

                      func (*PodLogsQuery) GetApplicationName

                      func (m *PodLogsQuery) GetApplicationName() string

                      func (*PodLogsQuery) GetContainer

                      func (m *PodLogsQuery) GetContainer() string

                      func (*PodLogsQuery) GetFollow

                      func (m *PodLogsQuery) GetFollow() bool

                      func (*PodLogsQuery) GetPodName

                      func (m *PodLogsQuery) GetPodName() string

                      func (*PodLogsQuery) GetSinceSeconds

                      func (m *PodLogsQuery) GetSinceSeconds() int64

                      func (*PodLogsQuery) GetSinceTime

                      func (*PodLogsQuery) GetTailLines

                      func (m *PodLogsQuery) GetTailLines() int64

                      func (*PodLogsQuery) Marshal

                      func (m *PodLogsQuery) Marshal() (dAtA []byte, err error)

                      func (*PodLogsQuery) MarshalTo

                      func (m *PodLogsQuery) MarshalTo(dAtA []byte) (int, error)

                      func (*PodLogsQuery) ProtoMessage

                      func (*PodLogsQuery) ProtoMessage()

                      func (*PodLogsQuery) Reset

                      func (m *PodLogsQuery) Reset()

                      func (*PodLogsQuery) Size

                      func (m *PodLogsQuery) Size() (n int)

                      func (*PodLogsQuery) String

                      func (m *PodLogsQuery) String() string

                      func (*PodLogsQuery) Unmarshal

                      func (m *PodLogsQuery) Unmarshal(dAtA []byte) error

                      type SSEMarshaler

                      type SSEMarshaler struct {
                      }

                      func (*SSEMarshaler) ContentType

                      func (m *SSEMarshaler) ContentType() string

                      func (*SSEMarshaler) Marshal

                      func (m *SSEMarshaler) Marshal(v interface{}) ([]byte, error)

                      func (*SSEMarshaler) NewDecoder

                      func (m *SSEMarshaler) NewDecoder(r io.Reader) runtime.Decoder

                      func (*SSEMarshaler) NewEncoder

                      func (m *SSEMarshaler) NewEncoder(w io.Writer) runtime.Encoder

                      func (*SSEMarshaler) Unmarshal

                      func (m *SSEMarshaler) Unmarshal(data []byte, v interface{}) error

                      type Server

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

                        Server provides a Application service

                        func (*Server) Create

                        func (s *Server) Create(ctx context.Context, a *appv1.Application) (*appv1.Application, error)

                          Create creates an application

                          func (*Server) Delete

                            Delete removes an application and all associated resources

                            func (*Server) DeletePod

                            func (s *Server) DeletePod(ctx context.Context, q *DeletePodQuery) (*ApplicationResponse, error)

                            func (*Server) Get

                              Get returns an application by name

                              func (*Server) GetManifests

                              func (s *Server) GetManifests(ctx context.Context, q *ManifestQuery) (*repository.ManifestResponse, error)

                                GetManifests returns application manifests

                                func (*Server) List

                                  List returns list of applications

                                  func (*Server) ListResourceEvents

                                  func (s *Server) ListResourceEvents(ctx context.Context, q *ApplicationResourceEventsQuery) (*v1.EventList, error)

                                    ListResourceEvents returns a list of event resources

                                    func (*Server) PodLogs

                                    func (*Server) Rollback

                                    func (s *Server) Rollback(ctx context.Context, rollbackReq *ApplicationRollbackRequest) (*appv1.Application, error)

                                    func (*Server) Sync

                                    func (s *Server) Sync(ctx context.Context, syncReq *ApplicationSyncRequest) (*appv1.Application, error)

                                      Sync syncs an application to its target state

                                      func (*Server) Update

                                      func (s *Server) Update(ctx context.Context, a *appv1.Application) (*appv1.Application, error)

                                        Update updates an application

                                        func (*Server) UpdateSpec

                                          UpdateSpec updates an application spec

                                          func (*Server) Watch