application

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Mar 29, 2018 License: Apache-2.0 Imports: 33 Imported by: 0

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
ApplicationResponse
DeleteApplicationRequest
ApplicationSyncRequest
ApplicationSyncResult
ResourceDetails

Package application is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

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"`
}

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

func (*ApplicationQuery) ProtoMessage()

func (*ApplicationQuery) Reset 

func (m *ApplicationQuery) Reset()

func (*ApplicationQuery) String 

func (m *ApplicationQuery) String() string

type ApplicationResponse 

type ApplicationResponse struct {
}

func (*ApplicationResponse) Descriptor 

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

func (*ApplicationResponse) ProtoMessage 

func (*ApplicationResponse) ProtoMessage()

func (*ApplicationResponse) Reset 

func (m *ApplicationResponse) Reset()

func (*ApplicationResponse) String 

func (m *ApplicationResponse) String() string

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)
	// 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)
	// 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)
	// Delete deletes an application
	Delete(ctx context.Context, in *DeleteApplicationRequest, opts ...grpc.CallOption) (*ApplicationResponse, error)
	// ListPods returns pods in an application
	ListPods(ctx context.Context, in *ApplicationQuery, opts ...grpc.CallOption) (*k8s_io_api_core_v1.PodList, error)
	// Sync syncs an application to its target state
	Sync(ctx context.Context, in *ApplicationSyncRequest, opts ...grpc.CallOption) (*ApplicationSyncResult, 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)
	// 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)
	// 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)
	// Delete deletes an application
	Delete(context.Context, *DeleteApplicationRequest) (*ApplicationResponse, error)
	// ListPods returns pods in an application
	ListPods(context.Context, *ApplicationQuery) (*k8s_io_api_core_v1.PodList, error)
	// Sync syncs an application to its target state
	Sync(context.Context, *ApplicationSyncRequest) (*ApplicationSyncResult, error)
}

func NewServer 

func NewServer(
	namespace string,
	kubeclientset kubernetes.Interface,
	appclientset appclientset.Interface,
	repoClientset reposerver.Clientset,
	repoService apirepository.RepositoryServiceServer,
	clusterService cluster.ClusterServiceServer) ApplicationServiceServer

NewServer returns a new instance of the Application service

type ApplicationService_WatchClient 

type ApplicationService_WatchClient interface {
	Recv() (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.ApplicationWatchEvent, error)
	grpc.ClientStream
}

type ApplicationService_WatchServer 

type ApplicationService_WatchServer interface {
	Send(*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.ApplicationWatchEvent) error
	grpc.ServerStream
}

type ApplicationSyncRequest 

type ApplicationSyncRequest struct {
	Name     string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Revision string `protobuf:"bytes,2,opt,name=revision" json:"revision,omitempty"`
	DryRun   bool   `protobuf:"varint,3,opt,name=dryRun" json:"dryRun,omitempty"`
}

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

func (m *ApplicationSyncRequest) GetRevision() string

func (*ApplicationSyncRequest) ProtoMessage 

func (*ApplicationSyncRequest) ProtoMessage()

func (*ApplicationSyncRequest) Reset 

func (m *ApplicationSyncRequest) Reset()

func (*ApplicationSyncRequest) String 

func (m *ApplicationSyncRequest) String() string

type ApplicationSyncResult 

type ApplicationSyncResult struct {
	Message   string             `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
	Resources []*ResourceDetails `protobuf:"bytes,2,rep,name=resources" json:"resources,omitempty"`
}

ApplicationSyncResult is a result of a sync requeswt

func (*ApplicationSyncResult) Descriptor 

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

func (*ApplicationSyncResult) GetMessage 

func (m *ApplicationSyncResult) GetMessage() string

func (*ApplicationSyncResult) GetResources 

func (m *ApplicationSyncResult) GetResources() []*ResourceDetails

func (*ApplicationSyncResult) ProtoMessage 

func (*ApplicationSyncResult) ProtoMessage()

func (*ApplicationSyncResult) Reset 

func (m *ApplicationSyncResult) Reset()

func (*ApplicationSyncResult) String 

func (m *ApplicationSyncResult) String() string

type DeleteApplicationRequest 

type DeleteApplicationRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Namespace string `protobuf:"bytes,2,opt,name=namespace" json:"namespace,omitempty"`
	Server    string `protobuf:"bytes,3,opt,name=server" json:"server,omitempty"`
}

func (*DeleteApplicationRequest) Descriptor 

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

func (*DeleteApplicationRequest) GetName 

func (m *DeleteApplicationRequest) GetName() string

func (*DeleteApplicationRequest) GetNamespace 

func (m *DeleteApplicationRequest) GetNamespace() string

func (*DeleteApplicationRequest) GetServer 

func (m *DeleteApplicationRequest) GetServer() string

func (*DeleteApplicationRequest) ProtoMessage 

func (*DeleteApplicationRequest) ProtoMessage()

func (*DeleteApplicationRequest) Reset 

func (m *DeleteApplicationRequest) Reset()

func (*DeleteApplicationRequest) String 

func (m *DeleteApplicationRequest) String() string

type ResourceDetails 

type ResourceDetails struct {
	Name      string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Kind      string `protobuf:"bytes,2,opt,name=kind" json:"kind,omitempty"`
	Namespace string `protobuf:"bytes,3,opt,name=namespace" json:"namespace,omitempty"`
	Message   string `protobuf:"bytes,4,opt,name=message" json:"message,omitempty"`
}

func (*ResourceDetails) Descriptor 

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

func (*ResourceDetails) GetKind 

func (m *ResourceDetails) GetKind() string

func (*ResourceDetails) GetMessage 

func (m *ResourceDetails) GetMessage() string

func (*ResourceDetails) GetName 

func (m *ResourceDetails) GetName() string

func (*ResourceDetails) GetNamespace 

func (m *ResourceDetails) GetNamespace() string

func (*ResourceDetails) ProtoMessage 

func (*ResourceDetails) ProtoMessage()

func (*ResourceDetails) Reset 

func (m *ResourceDetails) Reset()

func (*ResourceDetails) String 

func (m *ResourceDetails) String() string

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 a application

func (*Server) Delete 

func (s *Server) Delete(ctx context.Context, q *DeleteApplicationRequest) (*ApplicationResponse, error)

Delete removes an application and all associated resources

func (*Server) Get 

func (s *Server) Get(ctx context.Context, q *ApplicationQuery) (*appv1.Application, error)

Get returns a application by name

func (*Server) List 

func (s *Server) List(ctx context.Context, q *ApplicationQuery) (*appv1.ApplicationList, error)

List returns list of applications

func (*Server) ListPods 

func (s *Server) ListPods(ctx context.Context, q *ApplicationQuery) (*apiv1.PodList, error)

ListPods returns pods in a application

func (*Server) Sync 

func (s *Server) Sync(ctx context.Context, syncReq *ApplicationSyncRequest) (*ApplicationSyncResult, 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 a application

func (*Server) Watch 

func (s *Server) Watch(q *ApplicationQuery, ws ApplicationService_WatchServer) error

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.