Help us shape the future of Go! Take the 2026 Go Developer Survey

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

Delete removes an application and all associated resources

func (*Server) Get

Get returns a application by name

func (*Server) List

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL