application

package
v0.4.3 Latest Latest
Warning

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

 Go to latest Published: May 21, 2018 License: Apache-2.0 Imports: 39 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
	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 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)
	// 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)
	// 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) 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.