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

application

package
v0.4.7 Latest Latest
Warning

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

 Go to latest Published: Jun 7, 2018 License: Apache-2.0 Imports: 41 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
	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 added in v0.3.1 

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

func (*ApplicationQuery) MarshalTo added in v0.3.1 

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

func (*ApplicationQuery) ProtoMessage 

func (*ApplicationQuery) ProtoMessage()

func (*ApplicationQuery) Reset 

func (m *ApplicationQuery) Reset()

func (*ApplicationQuery) Size added in v0.3.1 

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

func (*ApplicationQuery) String 

func (m *ApplicationQuery) String() string

func (*ApplicationQuery) Unmarshal added in v0.3.1 

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

type ApplicationResourceEventsQuery added in v0.4.4 

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 added in v0.4.4 

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

func (*ApplicationResourceEventsQuery) GetAppName added in v0.4.4 

func (m *ApplicationResourceEventsQuery) GetAppName() string

func (*ApplicationResourceEventsQuery) GetResName added in v0.4.4 

func (m *ApplicationResourceEventsQuery) GetResName() string

func (*ApplicationResourceEventsQuery) GetResUid added in v0.4.4 

func (m *ApplicationResourceEventsQuery) GetResUid() string

func (*ApplicationResourceEventsQuery) Marshal added in v0.4.4 

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

func (*ApplicationResourceEventsQuery) MarshalTo added in v0.4.4 

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

func (*ApplicationResourceEventsQuery) ProtoMessage added in v0.4.4 

func (*ApplicationResourceEventsQuery) ProtoMessage()

func (*ApplicationResourceEventsQuery) Reset added in v0.4.4 

func (m *ApplicationResourceEventsQuery) Reset()

func (*ApplicationResourceEventsQuery) Size added in v0.4.4 

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

func (*ApplicationResourceEventsQuery) String added in v0.4.4 

func (m *ApplicationResourceEventsQuery) String() string

func (*ApplicationResourceEventsQuery) Unmarshal added in v0.4.4 

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 added in v0.3.1 

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

func (*ApplicationResponse) MarshalTo added in v0.3.1 

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

func (*ApplicationResponse) ProtoMessage 

func (*ApplicationResponse) ProtoMessage()

func (*ApplicationResponse) Reset 

func (m *ApplicationResponse) Reset()

func (*ApplicationResponse) Size added in v0.3.1 

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

func (*ApplicationResponse) String 

func (m *ApplicationResponse) String() string

func (*ApplicationResponse) Unmarshal added in v0.3.1 

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

type ApplicationRollbackRequest added in v0.3.1 

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 added in v0.3.1 

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

func (*ApplicationRollbackRequest) GetDryRun added in v0.3.1 

func (m *ApplicationRollbackRequest) GetDryRun() bool

func (*ApplicationRollbackRequest) GetID added in v0.3.1 

func (m *ApplicationRollbackRequest) GetID() int64

func (*ApplicationRollbackRequest) GetName added in v0.3.1 

func (m *ApplicationRollbackRequest) GetName() string

func (*ApplicationRollbackRequest) GetPrune added in v0.3.2 

func (m *ApplicationRollbackRequest) GetPrune() bool

func (*ApplicationRollbackRequest) Marshal added in v0.3.1 

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

func (*ApplicationRollbackRequest) MarshalTo added in v0.3.1 

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

func (*ApplicationRollbackRequest) ProtoMessage added in v0.3.1 

func (*ApplicationRollbackRequest) ProtoMessage()

func (*ApplicationRollbackRequest) Reset added in v0.3.1 

func (m *ApplicationRollbackRequest) Reset()

func (*ApplicationRollbackRequest) Size added in v0.3.1 

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

func (*ApplicationRollbackRequest) String added in v0.3.1 

func (m *ApplicationRollbackRequest) String() string

func (*ApplicationRollbackRequest) Unmarshal added in v0.3.1 

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 added in v0.3.0 

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

type ApplicationService_PodLogsServer added in v0.3.0 

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

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 ApplicationSpecRequest added in v0.3.3 

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 added in v0.3.3 

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

func (*ApplicationSpecRequest) GetAppName added in v0.3.3 

func (m *ApplicationSpecRequest) GetAppName() string

func (*ApplicationSpecRequest) GetSpec added in v0.3.3 

func (m *ApplicationSpecRequest) GetSpec() github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.ApplicationSpec

func (*ApplicationSpecRequest) Marshal added in v0.3.3 

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

func (*ApplicationSpecRequest) MarshalTo added in v0.3.3 

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

func (*ApplicationSpecRequest) ProtoMessage added in v0.3.3 

func (*ApplicationSpecRequest) ProtoMessage()

func (*ApplicationSpecRequest) Reset added in v0.3.3 

func (m *ApplicationSpecRequest) Reset()

func (*ApplicationSpecRequest) Size added in v0.3.3 

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

func (*ApplicationSpecRequest) String added in v0.3.3 

func (m *ApplicationSpecRequest) String() string

func (*ApplicationSpecRequest) Unmarshal added in v0.3.3 

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 added in v0.3.2 

func (m *ApplicationSyncRequest) GetPrune() bool

func (*ApplicationSyncRequest) GetRevision 

func (m *ApplicationSyncRequest) GetRevision() string

func (*ApplicationSyncRequest) Marshal added in v0.3.1 

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

func (*ApplicationSyncRequest) MarshalTo added in v0.3.1 

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

func (*ApplicationSyncRequest) ProtoMessage 

func (*ApplicationSyncRequest) ProtoMessage()

func (*ApplicationSyncRequest) Reset 

func (m *ApplicationSyncRequest) Reset()

func (*ApplicationSyncRequest) Size added in v0.3.1 

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

func (*ApplicationSyncRequest) String 

func (m *ApplicationSyncRequest) String() string

func (*ApplicationSyncRequest) Unmarshal added in v0.3.1 

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 added in v0.4.0 

func (m *DeleteApplicationRequest) GetCascade() bool

func (*DeleteApplicationRequest) GetName 

func (m *DeleteApplicationRequest) GetName() string

func (*DeleteApplicationRequest) Marshal added in v0.3.1 

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

func (*DeleteApplicationRequest) MarshalTo added in v0.3.1 

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

func (*DeleteApplicationRequest) ProtoMessage 

func (*DeleteApplicationRequest) ProtoMessage()

func (*DeleteApplicationRequest) Reset 

func (m *DeleteApplicationRequest) Reset()

func (*DeleteApplicationRequest) Size added in v0.3.1 

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

func (*DeleteApplicationRequest) String 

func (m *DeleteApplicationRequest) String() string

func (*DeleteApplicationRequest) Unmarshal added in v0.3.1 

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

type DeletePodQuery added in v0.3.0 

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 added in v0.3.0 

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

func (*DeletePodQuery) GetApplicationName added in v0.3.0 

func (m *DeletePodQuery) GetApplicationName() string

func (*DeletePodQuery) GetPodName added in v0.3.0 

func (m *DeletePodQuery) GetPodName() string

func (*DeletePodQuery) Marshal added in v0.3.1 

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

func (*DeletePodQuery) MarshalTo added in v0.3.1 

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

func (*DeletePodQuery) ProtoMessage added in v0.3.0 

func (*DeletePodQuery) ProtoMessage()

func (*DeletePodQuery) Reset added in v0.3.0 

func (m *DeletePodQuery) Reset()

func (*DeletePodQuery) Size added in v0.3.1 

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

func (*DeletePodQuery) String added in v0.3.0 

func (m *DeletePodQuery) String() string

func (*DeletePodQuery) Unmarshal added in v0.3.1 

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

type LogEntry added in v0.3.0 

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 added in v0.3.0 

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

func (*LogEntry) GetContent added in v0.3.0 

func (m *LogEntry) GetContent() string

func (*LogEntry) GetTimeStamp added in v0.3.0 

func (m *LogEntry) GetTimeStamp() k8s_io_apimachinery_pkg_apis_meta_v1.Time

func (*LogEntry) Marshal added in v0.3.1 

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

func (*LogEntry) MarshalTo added in v0.3.1 

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

func (*LogEntry) ProtoMessage added in v0.3.0 

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset added in v0.3.0 

func (m *LogEntry) Reset()

func (*LogEntry) Size added in v0.3.1 

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

func (*LogEntry) String added in v0.3.0 

func (m *LogEntry) String() string

func (*LogEntry) Unmarshal added in v0.3.1 

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

type ManifestQuery added in v0.4.1 

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 added in v0.4.1 

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

func (*ManifestQuery) GetAppName added in v0.4.1 

func (m *ManifestQuery) GetAppName() string

func (*ManifestQuery) GetRevision added in v0.4.1 

func (m *ManifestQuery) GetRevision() string

func (*ManifestQuery) Marshal added in v0.4.1 

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

func (*ManifestQuery) MarshalTo added in v0.4.1 

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

func (*ManifestQuery) ProtoMessage added in v0.4.1 

func (*ManifestQuery) ProtoMessage()

func (*ManifestQuery) Reset added in v0.4.1 

func (m *ManifestQuery) Reset()

func (*ManifestQuery) Size added in v0.4.1 

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

func (*ManifestQuery) String added in v0.4.1 

func (m *ManifestQuery) String() string

func (*ManifestQuery) Unmarshal added in v0.4.1 

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

type PodLogsQuery added in v0.3.0 

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 added in v0.3.0 

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

func (*PodLogsQuery) GetApplicationName added in v0.3.0 

func (m *PodLogsQuery) GetApplicationName() string

func (*PodLogsQuery) GetContainer added in v0.3.0 

func (m *PodLogsQuery) GetContainer() string

func (*PodLogsQuery) GetFollow added in v0.3.0 

func (m *PodLogsQuery) GetFollow() bool

func (*PodLogsQuery) GetPodName added in v0.3.0 

func (m *PodLogsQuery) GetPodName() string

func (*PodLogsQuery) GetSinceSeconds added in v0.3.0 

func (m *PodLogsQuery) GetSinceSeconds() int64

func (*PodLogsQuery) GetSinceTime added in v0.3.0 

func (m *PodLogsQuery) GetSinceTime() *k8s_io_apimachinery_pkg_apis_meta_v1.Time

func (*PodLogsQuery) GetTailLines added in v0.3.0 

func (m *PodLogsQuery) GetTailLines() int64

func (*PodLogsQuery) Marshal added in v0.3.1 

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

func (*PodLogsQuery) MarshalTo added in v0.3.1 

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

func (*PodLogsQuery) ProtoMessage added in v0.3.0 

func (*PodLogsQuery) ProtoMessage()

func (*PodLogsQuery) Reset added in v0.3.0 

func (m *PodLogsQuery) Reset()

func (*PodLogsQuery) Size added in v0.3.1 

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

func (*PodLogsQuery) String added in v0.3.0 

func (m *PodLogsQuery) String() string

func (*PodLogsQuery) Unmarshal added in v0.3.1 

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 

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

Delete removes an application and all associated resources

func (*Server) DeletePod added in v0.3.0 

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

func (*Server) Get 

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

Get returns an application by name

func (*Server) GetManifests added in v0.4.1 

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

GetManifests returns application manifests

func (*Server) List 

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

List returns list of applications

func (*Server) ListResourceEvents added in v0.4.4 

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

ListResourceEvents returns a list of event resources

func (*Server) PodLogs added in v0.3.0 

func (s *Server) PodLogs(q *PodLogsQuery, ws ApplicationService_PodLogsServer) error

func (*Server) Rollback added in v0.3.1 

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 added in v0.3.3 

func (s *Server) UpdateSpec(ctx context.Context, q *ApplicationSpecRequest) (*appv1.ApplicationSpec, error)

UpdateSpec updates an application spec

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.