application

package
v0.9.2 Latest Latest
Warning

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

 Go to latest Published: Sep 28, 2018 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Overview

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

type ApplicationCreateRequest struct {
	Application          v1alpha1.Application `protobuf:"bytes,1,req,name=application" json:"application"`
	Upsert               *bool                `protobuf:"varint,2,opt,name=upsert" json:"upsert,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ApplicationCreateRequest) Descriptor added in v0.5.0 

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

func (*ApplicationCreateRequest) GetApplication added in v0.5.0 

func (m *ApplicationCreateRequest) GetApplication() v1alpha1.Application

func (*ApplicationCreateRequest) GetUpsert added in v0.5.0 

func (m *ApplicationCreateRequest) GetUpsert() bool

func (*ApplicationCreateRequest) Marshal added in v0.5.0 

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

func (*ApplicationCreateRequest) MarshalTo added in v0.5.0 

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

func (*ApplicationCreateRequest) ProtoMessage added in v0.5.0 

func (*ApplicationCreateRequest) ProtoMessage()

func (*ApplicationCreateRequest) Reset added in v0.5.0 

func (m *ApplicationCreateRequest) Reset()

func (*ApplicationCreateRequest) Size added in v0.5.0 

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

func (*ApplicationCreateRequest) String added in v0.5.0 

func (m *ApplicationCreateRequest) String() string

func (*ApplicationCreateRequest) Unmarshal added in v0.5.0 

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

func (*ApplicationCreateRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *ApplicationCreateRequest) XXX_DiscardUnknown()

func (*ApplicationCreateRequest) XXX_Marshal added in v0.9.0 

func (m *ApplicationCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplicationCreateRequest) XXX_Merge added in v0.9.0 

func (dst *ApplicationCreateRequest) XXX_Merge(src proto.Message)

func (*ApplicationCreateRequest) XXX_Size added in v0.9.0 

func (m *ApplicationCreateRequest) XXX_Size() int

func (*ApplicationCreateRequest) XXX_Unmarshal added in v0.9.0 

func (m *ApplicationCreateRequest) XXX_Unmarshal(b []byte) error

type ApplicationDeleteRequest added in v0.5.0 

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

func (*ApplicationDeleteRequest) Descriptor added in v0.5.0 

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

func (*ApplicationDeleteRequest) GetCascade added in v0.5.0 

func (m *ApplicationDeleteRequest) GetCascade() bool

func (*ApplicationDeleteRequest) GetName added in v0.5.0 

func (m *ApplicationDeleteRequest) GetName() string

func (*ApplicationDeleteRequest) Marshal added in v0.5.0 

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

func (*ApplicationDeleteRequest) MarshalTo added in v0.5.0 

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

func (*ApplicationDeleteRequest) ProtoMessage added in v0.5.0 

func (*ApplicationDeleteRequest) ProtoMessage()

func (*ApplicationDeleteRequest) Reset added in v0.5.0 

func (m *ApplicationDeleteRequest) Reset()

func (*ApplicationDeleteRequest) Size added in v0.5.0 

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

func (*ApplicationDeleteRequest) String added in v0.5.0 

func (m *ApplicationDeleteRequest) String() string

func (*ApplicationDeleteRequest) Unmarshal added in v0.5.0 

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

func (*ApplicationDeleteRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *ApplicationDeleteRequest) XXX_DiscardUnknown()

func (*ApplicationDeleteRequest) XXX_Marshal added in v0.9.0 

func (m *ApplicationDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplicationDeleteRequest) XXX_Merge added in v0.9.0 

func (dst *ApplicationDeleteRequest) XXX_Merge(src proto.Message)

func (*ApplicationDeleteRequest) XXX_Size added in v0.9.0 

func (m *ApplicationDeleteRequest) XXX_Size() int

func (*ApplicationDeleteRequest) XXX_Unmarshal added in v0.9.0 

func (m *ApplicationDeleteRequest) XXX_Unmarshal(b []byte) error

type ApplicationDeleteResourceRequest added in v0.8.0 

type ApplicationDeleteResourceRequest struct {
	Name                 *string  `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	ResourceName         string   `protobuf:"bytes,2,req,name=resourceName" json:"resourceName"`
	APIVersion           string   `protobuf:"bytes,3,req,name=apiVersion" json:"apiVersion"`
	Kind                 string   `protobuf:"bytes,4,req,name=kind" json:"kind"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ApplicationDeleteResourceRequest) Descriptor added in v0.8.0 

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

func (*ApplicationDeleteResourceRequest) GetAPIVersion added in v0.8.0 

func (m *ApplicationDeleteResourceRequest) GetAPIVersion() string

func (*ApplicationDeleteResourceRequest) GetKind added in v0.8.0 

func (m *ApplicationDeleteResourceRequest) GetKind() string

func (*ApplicationDeleteResourceRequest) GetName added in v0.8.0 

func (m *ApplicationDeleteResourceRequest) GetName() string

func (*ApplicationDeleteResourceRequest) GetResourceName added in v0.8.0 

func (m *ApplicationDeleteResourceRequest) GetResourceName() string

func (*ApplicationDeleteResourceRequest) Marshal added in v0.8.0 

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

func (*ApplicationDeleteResourceRequest) MarshalTo added in v0.8.0 

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

func (*ApplicationDeleteResourceRequest) ProtoMessage added in v0.8.0 

func (*ApplicationDeleteResourceRequest) ProtoMessage()

func (*ApplicationDeleteResourceRequest) Reset added in v0.8.0 

func (m *ApplicationDeleteResourceRequest) Reset()

func (*ApplicationDeleteResourceRequest) Size added in v0.8.0 

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

func (*ApplicationDeleteResourceRequest) String added in v0.8.0 

func (m *ApplicationDeleteResourceRequest) String() string

func (*ApplicationDeleteResourceRequest) Unmarshal added in v0.8.0 

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

func (*ApplicationDeleteResourceRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *ApplicationDeleteResourceRequest) XXX_DiscardUnknown()

func (*ApplicationDeleteResourceRequest) XXX_Marshal added in v0.9.0 

func (m *ApplicationDeleteResourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplicationDeleteResourceRequest) XXX_Merge added in v0.9.0 

func (dst *ApplicationDeleteResourceRequest) XXX_Merge(src proto.Message)

func (*ApplicationDeleteResourceRequest) XXX_Size added in v0.9.0 

func (m *ApplicationDeleteResourceRequest) XXX_Size() int

func (*ApplicationDeleteResourceRequest) XXX_Unmarshal added in v0.9.0 

func (m *ApplicationDeleteResourceRequest) XXX_Unmarshal(b []byte) error

type ApplicationManifestQuery added in v0.5.0 

type ApplicationManifestQuery struct {
	Name                 *string  `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Revision             string   `protobuf:"bytes,2,opt,name=revision" json:"revision"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ManifestQuery is a query for manifest resources

func (*ApplicationManifestQuery) Descriptor added in v0.5.0 

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

func (*ApplicationManifestQuery) GetName added in v0.5.0 

func (m *ApplicationManifestQuery) GetName() string

func (*ApplicationManifestQuery) GetRevision added in v0.5.0 

func (m *ApplicationManifestQuery) GetRevision() string

func (*ApplicationManifestQuery) Marshal added in v0.5.0 

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

func (*ApplicationManifestQuery) MarshalTo added in v0.5.0 

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

func (*ApplicationManifestQuery) ProtoMessage added in v0.5.0 

func (*ApplicationManifestQuery) ProtoMessage()

func (*ApplicationManifestQuery) Reset added in v0.5.0 

func (m *ApplicationManifestQuery) Reset()

func (*ApplicationManifestQuery) Size added in v0.5.0 

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

func (*ApplicationManifestQuery) String added in v0.5.0 

func (m *ApplicationManifestQuery) String() string

func (*ApplicationManifestQuery) Unmarshal added in v0.5.0 

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

func (*ApplicationManifestQuery) XXX_DiscardUnknown added in v0.9.0 

func (m *ApplicationManifestQuery) XXX_DiscardUnknown()

func (*ApplicationManifestQuery) XXX_Marshal added in v0.9.0 

func (m *ApplicationManifestQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplicationManifestQuery) XXX_Merge added in v0.9.0 

func (dst *ApplicationManifestQuery) XXX_Merge(src proto.Message)

func (*ApplicationManifestQuery) XXX_Size added in v0.9.0 

func (m *ApplicationManifestQuery) XXX_Size() int

func (*ApplicationManifestQuery) XXX_Unmarshal added in v0.9.0 

func (m *ApplicationManifestQuery) XXX_Unmarshal(b []byte) error

type ApplicationPodLogsQuery added in v0.5.0 

type ApplicationPodLogsQuery struct {
	Name                 *string  `protobuf:"bytes,1,req,name=name" json:"name,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            *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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ApplicationPodLogsQuery) Descriptor added in v0.5.0 

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

func (*ApplicationPodLogsQuery) GetContainer added in v0.5.0 

func (m *ApplicationPodLogsQuery) GetContainer() string

func (*ApplicationPodLogsQuery) GetFollow added in v0.5.0 

func (m *ApplicationPodLogsQuery) GetFollow() bool

func (*ApplicationPodLogsQuery) GetName added in v0.5.0 

func (m *ApplicationPodLogsQuery) GetName() string

func (*ApplicationPodLogsQuery) GetPodName added in v0.5.0 

func (m *ApplicationPodLogsQuery) GetPodName() string

func (*ApplicationPodLogsQuery) GetSinceSeconds added in v0.5.0 

func (m *ApplicationPodLogsQuery) GetSinceSeconds() int64

func (*ApplicationPodLogsQuery) GetSinceTime added in v0.5.0 

func (m *ApplicationPodLogsQuery) GetSinceTime() *v1.Time

func (*ApplicationPodLogsQuery) GetTailLines added in v0.5.0 

func (m *ApplicationPodLogsQuery) GetTailLines() int64

func (*ApplicationPodLogsQuery) Marshal added in v0.5.0 

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

func (*ApplicationPodLogsQuery) MarshalTo added in v0.5.0 

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

func (*ApplicationPodLogsQuery) ProtoMessage added in v0.5.0 

func (*ApplicationPodLogsQuery) ProtoMessage()

func (*ApplicationPodLogsQuery) Reset added in v0.5.0 

func (m *ApplicationPodLogsQuery) Reset()

func (*ApplicationPodLogsQuery) Size added in v0.5.0 

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

func (*ApplicationPodLogsQuery) String added in v0.5.0 

func (m *ApplicationPodLogsQuery) String() string

func (*ApplicationPodLogsQuery) Unmarshal added in v0.5.0 

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

func (*ApplicationPodLogsQuery) XXX_DiscardUnknown added in v0.9.0 

func (m *ApplicationPodLogsQuery) XXX_DiscardUnknown()

func (*ApplicationPodLogsQuery) XXX_Marshal added in v0.9.0 

func (m *ApplicationPodLogsQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplicationPodLogsQuery) XXX_Merge added in v0.9.0 

func (dst *ApplicationPodLogsQuery) XXX_Merge(src proto.Message)

func (*ApplicationPodLogsQuery) XXX_Size added in v0.9.0 

func (m *ApplicationPodLogsQuery) XXX_Size() int

func (*ApplicationPodLogsQuery) XXX_Unmarshal added in v0.9.0 

func (m *ApplicationPodLogsQuery) XXX_Unmarshal(b []byte) error

type ApplicationQuery 

type ApplicationQuery struct {
	Name                 *string  `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Refresh              bool     `protobuf:"varint,2,opt,name=refresh" json:"refresh"`
	Projects             []string `protobuf:"bytes,3,rep,name=project" json:"project,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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) GetProjects added in v0.6.0 

func (m *ApplicationQuery) GetProjects() []string

func (*ApplicationQuery) GetRefresh added in v0.5.3 

func (m *ApplicationQuery) GetRefresh() bool

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

func (*ApplicationQuery) XXX_DiscardUnknown added in v0.9.0 

func (m *ApplicationQuery) XXX_DiscardUnknown()

func (*ApplicationQuery) XXX_Marshal added in v0.9.0 

func (m *ApplicationQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplicationQuery) XXX_Merge added in v0.9.0 

func (dst *ApplicationQuery) XXX_Merge(src proto.Message)

func (*ApplicationQuery) XXX_Size added in v0.9.0 

func (m *ApplicationQuery) XXX_Size() int

func (*ApplicationQuery) XXX_Unmarshal added in v0.9.0 

func (m *ApplicationQuery) XXX_Unmarshal(b []byte) error

type ApplicationResourceEventsQuery added in v0.4.4 

type ApplicationResourceEventsQuery struct {
	Name                 *string  `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	ResourceName         string   `protobuf:"bytes,2,req,name=resourceName" json:"resourceName"`
	ResourceUID          string   `protobuf:"bytes,3,req,name=resourceUID" json:"resourceUID"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ApplicationEventsQuery is a query for application resource events

func (*ApplicationResourceEventsQuery) Descriptor added in v0.4.4 

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

func (*ApplicationResourceEventsQuery) GetName added in v0.5.0 

func (m *ApplicationResourceEventsQuery) GetName() string

func (*ApplicationResourceEventsQuery) GetResourceName added in v0.5.0 

func (m *ApplicationResourceEventsQuery) GetResourceName() string

func (*ApplicationResourceEventsQuery) GetResourceUID added in v0.5.0 

func (m *ApplicationResourceEventsQuery) GetResourceUID() 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

func (*ApplicationResourceEventsQuery) XXX_DiscardUnknown added in v0.9.0 

func (m *ApplicationResourceEventsQuery) XXX_DiscardUnknown()

func (*ApplicationResourceEventsQuery) XXX_Marshal added in v0.9.0 

func (m *ApplicationResourceEventsQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplicationResourceEventsQuery) XXX_Merge added in v0.9.0 

func (dst *ApplicationResourceEventsQuery) XXX_Merge(src proto.Message)

func (*ApplicationResourceEventsQuery) XXX_Size added in v0.9.0 

func (m *ApplicationResourceEventsQuery) XXX_Size() int

func (*ApplicationResourceEventsQuery) XXX_Unmarshal added in v0.9.0 

func (m *ApplicationResourceEventsQuery) XXX_Unmarshal(b []byte) error

type ApplicationResponse 

type ApplicationResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*ApplicationResponse) XXX_DiscardUnknown added in v0.9.0 

func (m *ApplicationResponse) XXX_DiscardUnknown()

func (*ApplicationResponse) XXX_Marshal added in v0.9.0 

func (m *ApplicationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplicationResponse) XXX_Merge added in v0.9.0 

func (dst *ApplicationResponse) XXX_Merge(src proto.Message)

func (*ApplicationResponse) XXX_Size added in v0.9.0 

func (m *ApplicationResponse) XXX_Size() int

func (*ApplicationResponse) XXX_Unmarshal added in v0.9.0 

func (m *ApplicationResponse) XXX_Unmarshal(b []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,opt,name=dryRun" json:"dryRun"`
	Prune                bool     `protobuf:"varint,4,opt,name=prune" json:"prune"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*ApplicationRollbackRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *ApplicationRollbackRequest) XXX_DiscardUnknown()

func (*ApplicationRollbackRequest) XXX_Marshal added in v0.9.0 

func (m *ApplicationRollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplicationRollbackRequest) XXX_Merge added in v0.9.0 

func (dst *ApplicationRollbackRequest) XXX_Merge(src proto.Message)

func (*ApplicationRollbackRequest) XXX_Size added in v0.9.0 

func (m *ApplicationRollbackRequest) XXX_Size() int

func (*ApplicationRollbackRequest) XXX_Unmarshal added in v0.9.0 

func (m *ApplicationRollbackRequest) XXX_Unmarshal(b []byte) error

type ApplicationServiceClient 

type ApplicationServiceClient interface {
	// List returns list of applications
	List(ctx context.Context, in *ApplicationQuery, opts ...grpc.CallOption) (*v1alpha1.ApplicationList, error)
	// ListResourceEvents returns a list of event resources
	ListResourceEvents(ctx context.Context, in *ApplicationResourceEventsQuery, opts ...grpc.CallOption) (*v11.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 *ApplicationCreateRequest, opts ...grpc.CallOption) (*v1alpha1.Application, error)
	// Get returns an application by name
	Get(ctx context.Context, in *ApplicationQuery, opts ...grpc.CallOption) (*v1alpha1.Application, error)
	// GetManifests returns application manifests
	GetManifests(ctx context.Context, in *ApplicationManifestQuery, opts ...grpc.CallOption) (*repository.ManifestResponse, error)
	// Update updates an application
	Update(ctx context.Context, in *ApplicationUpdateRequest, opts ...grpc.CallOption) (*v1alpha1.Application, error)
	// UpdateSpec updates an application spec
	UpdateSpec(ctx context.Context, in *ApplicationUpdateSpecRequest, opts ...grpc.CallOption) (*v1alpha1.ApplicationSpec, error)
	// Delete deletes an application
	Delete(ctx context.Context, in *ApplicationDeleteRequest, opts ...grpc.CallOption) (*ApplicationResponse, error)
	// Sync syncs an application to its target state
	Sync(ctx context.Context, in *ApplicationSyncRequest, opts ...grpc.CallOption) (*v1alpha1.Application, error)
	// Rollback syncs an application to its target state
	Rollback(ctx context.Context, in *ApplicationRollbackRequest, opts ...grpc.CallOption) (*v1alpha1.Application, error)
	// TerminateOperation terminates the currently running operation
	TerminateOperation(ctx context.Context, in *OperationTerminateRequest, opts ...grpc.CallOption) (*OperationTerminateResponse, error)
	// DeleteResource deletes a single application resource
	DeleteResource(ctx context.Context, in *ApplicationDeleteResourceRequest, opts ...grpc.CallOption) (*ApplicationResponse, error)
	// PodLogs returns stream of log entries for the specified pod. Pod
	PodLogs(ctx context.Context, in *ApplicationPodLogsQuery, 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) (*v1alpha1.ApplicationList, error)
	// ListResourceEvents returns a list of event resources
	ListResourceEvents(context.Context, *ApplicationResourceEventsQuery) (*v11.EventList, error)
	// Watch returns stream of application change events.
	Watch(*ApplicationQuery, ApplicationService_WatchServer) error
	// Create creates an application
	Create(context.Context, *ApplicationCreateRequest) (*v1alpha1.Application, error)
	// Get returns an application by name
	Get(context.Context, *ApplicationQuery) (*v1alpha1.Application, error)
	// GetManifests returns application manifests
	GetManifests(context.Context, *ApplicationManifestQuery) (*repository.ManifestResponse, error)
	// Update updates an application
	Update(context.Context, *ApplicationUpdateRequest) (*v1alpha1.Application, error)
	// UpdateSpec updates an application spec
	UpdateSpec(context.Context, *ApplicationUpdateSpecRequest) (*v1alpha1.ApplicationSpec, error)
	// Delete deletes an application
	Delete(context.Context, *ApplicationDeleteRequest) (*ApplicationResponse, error)
	// Sync syncs an application to its target state
	Sync(context.Context, *ApplicationSyncRequest) (*v1alpha1.Application, error)
	// Rollback syncs an application to its target state
	Rollback(context.Context, *ApplicationRollbackRequest) (*v1alpha1.Application, error)
	// TerminateOperation terminates the currently running operation
	TerminateOperation(context.Context, *OperationTerminateRequest) (*OperationTerminateResponse, error)
	// DeleteResource deletes a single application resource
	DeleteResource(context.Context, *ApplicationDeleteResourceRequest) (*ApplicationResponse, error)
	// PodLogs returns stream of log entries for the specified pod. Pod
	PodLogs(*ApplicationPodLogsQuery, ApplicationService_PodLogsServer) error
}

func NewServer 

func NewServer(
	namespace string,
	kubeclientset kubernetes.Interface,
	appclientset appclientset.Interface,
	repoClientset reposerver.Clientset,
	kubectl kube.Kubectl,
	db db.ArgoDB,
	enf *rbac.Enforcer,
	projectLock *util.KeyLock,
) 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() (*v1alpha1.ApplicationWatchEvent, error)
	grpc.ClientStream
}

type ApplicationService_WatchServer 

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

type ApplicationSyncRequest 

type ApplicationSyncRequest struct {
	Name                 *string                `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Revision             string                 `protobuf:"bytes,2,opt,name=revision" json:"revision"`
	DryRun               bool                   `protobuf:"varint,3,opt,name=dryRun" json:"dryRun"`
	Prune                bool                   `protobuf:"varint,4,opt,name=prune" json:"prune"`
	Strategy             *v1alpha1.SyncStrategy `protobuf:"bytes,5,opt,name=strategy" json:"strategy,omitempty"`
	Parameter            *ParameterOverrides    `protobuf:"bytes,6,opt,name=parameter" json:"parameter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `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) GetParameter added in v0.9.0 

func (m *ApplicationSyncRequest) GetParameter() *ParameterOverrides

func (*ApplicationSyncRequest) GetPrune added in v0.3.2 

func (m *ApplicationSyncRequest) GetPrune() bool

func (*ApplicationSyncRequest) GetRevision 

func (m *ApplicationSyncRequest) GetRevision() string

func (*ApplicationSyncRequest) GetStrategy added in v0.6.0 

func (m *ApplicationSyncRequest) GetStrategy() *v1alpha1.SyncStrategy

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

func (*ApplicationSyncRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *ApplicationSyncRequest) XXX_DiscardUnknown()

func (*ApplicationSyncRequest) XXX_Marshal added in v0.9.0 

func (m *ApplicationSyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplicationSyncRequest) XXX_Merge added in v0.9.0 

func (dst *ApplicationSyncRequest) XXX_Merge(src proto.Message)

func (*ApplicationSyncRequest) XXX_Size added in v0.9.0 

func (m *ApplicationSyncRequest) XXX_Size() int

func (*ApplicationSyncRequest) XXX_Unmarshal added in v0.9.0 

func (m *ApplicationSyncRequest) XXX_Unmarshal(b []byte) error

type ApplicationUpdateRequest added in v0.5.0 

type ApplicationUpdateRequest struct {
	Application          *v1alpha1.Application `protobuf:"bytes,1,req,name=application" json:"application,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ApplicationUpdateRequest) Descriptor added in v0.5.0 

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

func (*ApplicationUpdateRequest) GetApplication added in v0.5.0 

func (m *ApplicationUpdateRequest) GetApplication() *v1alpha1.Application

func (*ApplicationUpdateRequest) Marshal added in v0.5.0 

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

func (*ApplicationUpdateRequest) MarshalTo added in v0.5.0 

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

func (*ApplicationUpdateRequest) ProtoMessage added in v0.5.0 

func (*ApplicationUpdateRequest) ProtoMessage()

func (*ApplicationUpdateRequest) Reset added in v0.5.0 

func (m *ApplicationUpdateRequest) Reset()

func (*ApplicationUpdateRequest) Size added in v0.5.0 

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

func (*ApplicationUpdateRequest) String added in v0.5.0 

func (m *ApplicationUpdateRequest) String() string

func (*ApplicationUpdateRequest) Unmarshal added in v0.5.0 

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

func (*ApplicationUpdateRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *ApplicationUpdateRequest) XXX_DiscardUnknown()

func (*ApplicationUpdateRequest) XXX_Marshal added in v0.9.0 

func (m *ApplicationUpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplicationUpdateRequest) XXX_Merge added in v0.9.0 

func (dst *ApplicationUpdateRequest) XXX_Merge(src proto.Message)

func (*ApplicationUpdateRequest) XXX_Size added in v0.9.0 

func (m *ApplicationUpdateRequest) XXX_Size() int

func (*ApplicationUpdateRequest) XXX_Unmarshal added in v0.9.0 

func (m *ApplicationUpdateRequest) XXX_Unmarshal(b []byte) error

type ApplicationUpdateSpecRequest added in v0.5.0 

type ApplicationUpdateSpecRequest struct {
	Name                 *string                  `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Spec                 v1alpha1.ApplicationSpec `protobuf:"bytes,2,req,name=spec" json:"spec"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

ApplicationUpdateSpecRequest is a request to update application spec

func (*ApplicationUpdateSpecRequest) Descriptor added in v0.5.0 

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

func (*ApplicationUpdateSpecRequest) GetName added in v0.5.0 

func (m *ApplicationUpdateSpecRequest) GetName() string

func (*ApplicationUpdateSpecRequest) GetSpec added in v0.5.0 

func (m *ApplicationUpdateSpecRequest) GetSpec() v1alpha1.ApplicationSpec

func (*ApplicationUpdateSpecRequest) Marshal added in v0.5.0 

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

func (*ApplicationUpdateSpecRequest) MarshalTo added in v0.5.0 

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

func (*ApplicationUpdateSpecRequest) ProtoMessage added in v0.5.0 

func (*ApplicationUpdateSpecRequest) ProtoMessage()

func (*ApplicationUpdateSpecRequest) Reset added in v0.5.0 

func (m *ApplicationUpdateSpecRequest) Reset()

func (*ApplicationUpdateSpecRequest) Size added in v0.5.0 

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

func (*ApplicationUpdateSpecRequest) String added in v0.5.0 

func (m *ApplicationUpdateSpecRequest) String() string

func (*ApplicationUpdateSpecRequest) Unmarshal added in v0.5.0 

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

func (*ApplicationUpdateSpecRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *ApplicationUpdateSpecRequest) XXX_DiscardUnknown()

func (*ApplicationUpdateSpecRequest) XXX_Marshal added in v0.9.0 

func (m *ApplicationUpdateSpecRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ApplicationUpdateSpecRequest) XXX_Merge added in v0.9.0 

func (dst *ApplicationUpdateSpecRequest) XXX_Merge(src proto.Message)

func (*ApplicationUpdateSpecRequest) XXX_Size added in v0.9.0 

func (m *ApplicationUpdateSpecRequest) XXX_Size() int

func (*ApplicationUpdateSpecRequest) XXX_Unmarshal added in v0.9.0 

func (m *ApplicationUpdateSpecRequest) XXX_Unmarshal(b []byte) error

type LogEntry added in v0.3.0 

type LogEntry struct {
	Content              string   `protobuf:"bytes,1,req,name=content" json:"content"`
	TimeStamp            v1.Time  `protobuf:"bytes,2,req,name=timeStamp" json:"timeStamp"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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() 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

func (*LogEntry) XXX_DiscardUnknown added in v0.9.0 

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal added in v0.9.0 

func (m *LogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogEntry) XXX_Merge added in v0.9.0 

func (dst *LogEntry) XXX_Merge(src proto.Message)

func (*LogEntry) XXX_Size added in v0.9.0 

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal added in v0.9.0 

func (m *LogEntry) XXX_Unmarshal(b []byte) error

type OperationTerminateRequest added in v0.6.0 

type OperationTerminateRequest struct {
	Name                 *string  `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OperationTerminateRequest) Descriptor added in v0.6.0 

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

func (*OperationTerminateRequest) GetName added in v0.6.0 

func (m *OperationTerminateRequest) GetName() string

func (*OperationTerminateRequest) Marshal added in v0.6.0 

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

func (*OperationTerminateRequest) MarshalTo added in v0.6.0 

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

func (*OperationTerminateRequest) ProtoMessage added in v0.6.0 

func (*OperationTerminateRequest) ProtoMessage()

func (*OperationTerminateRequest) Reset added in v0.6.0 

func (m *OperationTerminateRequest) Reset()

func (*OperationTerminateRequest) Size added in v0.6.0 

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

func (*OperationTerminateRequest) String added in v0.6.0 

func (m *OperationTerminateRequest) String() string

func (*OperationTerminateRequest) Unmarshal added in v0.6.0 

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

func (*OperationTerminateRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *OperationTerminateRequest) XXX_DiscardUnknown()

func (*OperationTerminateRequest) XXX_Marshal added in v0.9.0 

func (m *OperationTerminateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperationTerminateRequest) XXX_Merge added in v0.9.0 

func (dst *OperationTerminateRequest) XXX_Merge(src proto.Message)

func (*OperationTerminateRequest) XXX_Size added in v0.9.0 

func (m *OperationTerminateRequest) XXX_Size() int

func (*OperationTerminateRequest) XXX_Unmarshal added in v0.9.0 

func (m *OperationTerminateRequest) XXX_Unmarshal(b []byte) error

type OperationTerminateResponse added in v0.6.0 

type OperationTerminateResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OperationTerminateResponse) Descriptor added in v0.6.0 

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

func (*OperationTerminateResponse) Marshal added in v0.6.0 

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

func (*OperationTerminateResponse) MarshalTo added in v0.6.0 

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

func (*OperationTerminateResponse) ProtoMessage added in v0.6.0 

func (*OperationTerminateResponse) ProtoMessage()

func (*OperationTerminateResponse) Reset added in v0.6.0 

func (m *OperationTerminateResponse) Reset()

func (*OperationTerminateResponse) Size added in v0.6.0 

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

func (*OperationTerminateResponse) String added in v0.6.0 

func (m *OperationTerminateResponse) String() string

func (*OperationTerminateResponse) Unmarshal added in v0.6.0 

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

func (*OperationTerminateResponse) XXX_DiscardUnknown added in v0.9.0 

func (m *OperationTerminateResponse) XXX_DiscardUnknown()

func (*OperationTerminateResponse) XXX_Marshal added in v0.9.0 

func (m *OperationTerminateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperationTerminateResponse) XXX_Merge added in v0.9.0 

func (dst *OperationTerminateResponse) XXX_Merge(src proto.Message)

func (*OperationTerminateResponse) XXX_Size added in v0.9.0 

func (m *OperationTerminateResponse) XXX_Size() int

func (*OperationTerminateResponse) XXX_Unmarshal added in v0.9.0 

func (m *OperationTerminateResponse) XXX_Unmarshal(b []byte) error

type Parameter added in v0.9.0 

type Parameter struct {
	Name                 string   `protobuf:"bytes,1,req,name=name" json:"name"`
	Value                string   `protobuf:"bytes,2,opt,name=value" json:"value"`
	Component            string   `protobuf:"bytes,3,opt,name=component" json:"component"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Parameter) Descriptor added in v0.9.0 

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

func (*Parameter) GetComponent added in v0.9.0 

func (m *Parameter) GetComponent() string

func (*Parameter) GetName added in v0.9.0 

func (m *Parameter) GetName() string

func (*Parameter) GetValue added in v0.9.0 

func (m *Parameter) GetValue() string

func (*Parameter) Marshal added in v0.9.0 

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

func (*Parameter) MarshalTo added in v0.9.0 

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

func (*Parameter) ProtoMessage added in v0.9.0 

func (*Parameter) ProtoMessage()

func (*Parameter) Reset added in v0.9.0 

func (m *Parameter) Reset()

func (*Parameter) Size added in v0.9.0 

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

func (*Parameter) String added in v0.9.0 

func (m *Parameter) String() string

func (*Parameter) Unmarshal added in v0.9.0 

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

func (*Parameter) XXX_DiscardUnknown added in v0.9.0 

func (m *Parameter) XXX_DiscardUnknown()

func (*Parameter) XXX_Marshal added in v0.9.0 

func (m *Parameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Parameter) XXX_Merge added in v0.9.0 

func (dst *Parameter) XXX_Merge(src proto.Message)

func (*Parameter) XXX_Size added in v0.9.0 

func (m *Parameter) XXX_Size() int

func (*Parameter) XXX_Unmarshal added in v0.9.0 

func (m *Parameter) XXX_Unmarshal(b []byte) error

type ParameterOverrides added in v0.9.0 

type ParameterOverrides struct {
	Overrides            []*Parameter `protobuf:"bytes,1,rep,name=overrides" json:"overrides,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

ParameterOverrides is a wrapper on a list of parameters. If omitted, the application's overrides in the spec will be used. If set, will use the supplied list of overrides

func (*ParameterOverrides) Descriptor added in v0.9.0 

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

func (*ParameterOverrides) GetOverrides added in v0.9.0 

func (m *ParameterOverrides) GetOverrides() []*Parameter

func (*ParameterOverrides) Marshal added in v0.9.0 

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

func (*ParameterOverrides) MarshalTo added in v0.9.0 

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

func (*ParameterOverrides) ProtoMessage added in v0.9.0 

func (*ParameterOverrides) ProtoMessage()

func (*ParameterOverrides) Reset added in v0.9.0 

func (m *ParameterOverrides) Reset()

func (*ParameterOverrides) Size added in v0.9.0 

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

func (*ParameterOverrides) String added in v0.9.0 

func (m *ParameterOverrides) String() string

func (*ParameterOverrides) Unmarshal added in v0.9.0 

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

func (*ParameterOverrides) XXX_DiscardUnknown added in v0.9.0 

func (m *ParameterOverrides) XXX_DiscardUnknown()

func (*ParameterOverrides) XXX_Marshal added in v0.9.0 

func (m *ParameterOverrides) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ParameterOverrides) XXX_Merge added in v0.9.0 

func (dst *ParameterOverrides) XXX_Merge(src proto.Message)

func (*ParameterOverrides) XXX_Size added in v0.9.0 

func (m *ParameterOverrides) XXX_Size() int

func (*ParameterOverrides) XXX_Unmarshal added in v0.9.0 

func (m *ParameterOverrides) XXX_Unmarshal(b []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, q *ApplicationCreateRequest) (*appv1.Application, error)

Create creates an application

func (*Server) Delete 

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

Delete removes an application and all associated resources

func (*Server) DeleteResource added in v0.8.0 

func (s *Server) DeleteResource(ctx context.Context, q *ApplicationDeleteResourceRequest) (*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 *ApplicationManifestQuery) (*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 *ApplicationPodLogsQuery, 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) TerminateOperation added in v0.6.0 

func (s *Server) TerminateOperation(ctx context.Context, termOpReq *OperationTerminateRequest) (*OperationTerminateResponse, error)

func (*Server) Update 

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

Update updates an application

func (*Server) UpdateSpec added in v0.3.3 

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

UpdateSpec updates an application spec and filters out any invalid parameter overrides

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.