repository

package
v0.5.3 Latest Latest
Warning

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

Go to latest
Published: Jun 20, 2018 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Overview

Package repository is a generated protocol buffer package.

Repository Service

Repository Service API performs CRUD actions against repository resources

It is generated from these files:
	server/repository/repository.proto

It has these top-level messages:
	RepoKsonnetQuery
	RepoKsonnetResponse
	KsonnetAppSpec
	KsonnetEnvironment
	KsonnetEnvironmentDestination
	RepoQuery
	RepoResponse
	RepoCreateRequest
	RepoUpdateRequest

Package repository is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthRepository = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRepository   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterRepositoryServiceHandler

func RegisterRepositoryServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterRepositoryServiceHandler registers the http handlers for service RepositoryService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterRepositoryServiceHandlerClient

func RegisterRepositoryServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RepositoryServiceClient) error

RegisterRepositoryServiceHandler registers the http handlers for service RepositoryService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RepositoryServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RepositoryServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RepositoryServiceClient" to call the correct interceptors.

func RegisterRepositoryServiceHandlerFromEndpoint

func RegisterRepositoryServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterRepositoryServiceHandlerFromEndpoint is same as RegisterRepositoryServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterRepositoryServiceServer

func RegisterRepositoryServiceServer(s *grpc.Server, srv RepositoryServiceServer)

Types

type KsonnetAppSpec added in v0.4.4

type KsonnetAppSpec struct {
	Name         string                         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Path         string                         `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Environments map[string]*KsonnetEnvironment `` /* 151-byte string literal not displayed */
}

KsonnetAppSpec contains Ksonnet app response This roughly reflects: ksonnet/ksonnet/metadata/app/schema.go

func (*KsonnetAppSpec) Descriptor added in v0.4.4

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

func (*KsonnetAppSpec) GetEnvironments added in v0.4.4

func (m *KsonnetAppSpec) GetEnvironments() map[string]*KsonnetEnvironment

func (*KsonnetAppSpec) GetName added in v0.4.4

func (m *KsonnetAppSpec) GetName() string

func (*KsonnetAppSpec) GetPath added in v0.5.0

func (m *KsonnetAppSpec) GetPath() string

func (*KsonnetAppSpec) Marshal added in v0.4.4

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

func (*KsonnetAppSpec) MarshalTo added in v0.4.4

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

func (*KsonnetAppSpec) ProtoMessage added in v0.4.4

func (*KsonnetAppSpec) ProtoMessage()

func (*KsonnetAppSpec) Reset added in v0.4.4

func (m *KsonnetAppSpec) Reset()

func (*KsonnetAppSpec) Size added in v0.4.4

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

func (*KsonnetAppSpec) String added in v0.4.4

func (m *KsonnetAppSpec) String() string

func (*KsonnetAppSpec) Unmarshal added in v0.4.4

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

type KsonnetEnvironment added in v0.4.4

type KsonnetEnvironment struct {
	// Name is the user defined name of an environment
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// KubernetesVersion is the kubernetes version the targetted cluster is running on.
	K8SVersion string `protobuf:"bytes,2,opt,name=k8sVersion,proto3" json:"k8sVersion,omitempty"`
	// Path is the relative project path containing metadata for this environment.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// Destination stores the cluster address that this environment points to.
	Destination *KsonnetEnvironmentDestination `protobuf:"bytes,4,opt,name=destination" json:"destination,omitempty"`
}

func (*KsonnetEnvironment) Descriptor added in v0.4.4

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

func (*KsonnetEnvironment) GetDestination added in v0.4.4

func (*KsonnetEnvironment) GetK8SVersion added in v0.4.4

func (m *KsonnetEnvironment) GetK8SVersion() string

func (*KsonnetEnvironment) GetName added in v0.4.4

func (m *KsonnetEnvironment) GetName() string

func (*KsonnetEnvironment) GetPath added in v0.4.4

func (m *KsonnetEnvironment) GetPath() string

func (*KsonnetEnvironment) Marshal added in v0.4.4

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

func (*KsonnetEnvironment) MarshalTo added in v0.4.4

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

func (*KsonnetEnvironment) ProtoMessage added in v0.4.4

func (*KsonnetEnvironment) ProtoMessage()

func (*KsonnetEnvironment) Reset added in v0.4.4

func (m *KsonnetEnvironment) Reset()

func (*KsonnetEnvironment) Size added in v0.4.4

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

func (*KsonnetEnvironment) String added in v0.4.4

func (m *KsonnetEnvironment) String() string

func (*KsonnetEnvironment) Unmarshal added in v0.4.4

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

type KsonnetEnvironmentDestination added in v0.4.4

type KsonnetEnvironmentDestination struct {
	// Server is the Kubernetes server that the cluster is running on.
	Server string `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	// Namespace is the namespace of the Kubernetes server that targets should be deployed to
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

func (*KsonnetEnvironmentDestination) Descriptor added in v0.4.4

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

func (*KsonnetEnvironmentDestination) GetNamespace added in v0.4.4

func (m *KsonnetEnvironmentDestination) GetNamespace() string

func (*KsonnetEnvironmentDestination) GetServer added in v0.4.4

func (m *KsonnetEnvironmentDestination) GetServer() string

func (*KsonnetEnvironmentDestination) Marshal added in v0.4.4

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

func (*KsonnetEnvironmentDestination) MarshalTo added in v0.4.4

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

func (*KsonnetEnvironmentDestination) ProtoMessage added in v0.4.4

func (*KsonnetEnvironmentDestination) ProtoMessage()

func (*KsonnetEnvironmentDestination) Reset added in v0.4.4

func (m *KsonnetEnvironmentDestination) Reset()

func (*KsonnetEnvironmentDestination) Size added in v0.4.4

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

func (*KsonnetEnvironmentDestination) String added in v0.4.4

func (*KsonnetEnvironmentDestination) Unmarshal added in v0.4.4

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

type RepoCreateRequest added in v0.5.0

type RepoCreateRequest struct {
	Repo *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
}

func (*RepoCreateRequest) Descriptor added in v0.5.0

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

func (*RepoCreateRequest) GetRepo added in v0.5.0

func (*RepoCreateRequest) Marshal added in v0.5.0

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

func (*RepoCreateRequest) MarshalTo added in v0.5.0

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

func (*RepoCreateRequest) ProtoMessage added in v0.5.0

func (*RepoCreateRequest) ProtoMessage()

func (*RepoCreateRequest) Reset added in v0.5.0

func (m *RepoCreateRequest) Reset()

func (*RepoCreateRequest) Size added in v0.5.0

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

func (*RepoCreateRequest) String added in v0.5.0

func (m *RepoCreateRequest) String() string

func (*RepoCreateRequest) Unmarshal added in v0.5.0

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

type RepoKsonnetQuery added in v0.4.4

type RepoKsonnetQuery struct {
	Repo     string `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	Revision string `protobuf:"bytes,2,opt,name=revision,proto3" json:"revision,omitempty"`
}

RepoKsonnetQuery is a query for Repository contents matching a particular path

func (*RepoKsonnetQuery) Descriptor added in v0.4.4

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

func (*RepoKsonnetQuery) GetRepo added in v0.4.4

func (m *RepoKsonnetQuery) GetRepo() string

func (*RepoKsonnetQuery) GetRevision added in v0.4.4

func (m *RepoKsonnetQuery) GetRevision() string

func (*RepoKsonnetQuery) Marshal added in v0.4.4

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

func (*RepoKsonnetQuery) MarshalTo added in v0.4.4

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

func (*RepoKsonnetQuery) ProtoMessage added in v0.4.4

func (*RepoKsonnetQuery) ProtoMessage()

func (*RepoKsonnetQuery) Reset added in v0.4.4

func (m *RepoKsonnetQuery) Reset()

func (*RepoKsonnetQuery) Size added in v0.4.4

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

func (*RepoKsonnetQuery) String added in v0.4.4

func (m *RepoKsonnetQuery) String() string

func (*RepoKsonnetQuery) Unmarshal added in v0.4.4

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

type RepoKsonnetResponse added in v0.4.4

type RepoKsonnetResponse struct {
	Items []*KsonnetAppSpec `protobuf:"bytes,1,rep,name=items" json:"items,omitempty"`
}

RepoKsonnetResponse is a response for Repository contents matching a particular path

func (*RepoKsonnetResponse) Descriptor added in v0.4.4

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

func (*RepoKsonnetResponse) GetItems added in v0.5.0

func (m *RepoKsonnetResponse) GetItems() []*KsonnetAppSpec

func (*RepoKsonnetResponse) Marshal added in v0.4.4

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

func (*RepoKsonnetResponse) MarshalTo added in v0.4.4

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

func (*RepoKsonnetResponse) ProtoMessage added in v0.4.4

func (*RepoKsonnetResponse) ProtoMessage()

func (*RepoKsonnetResponse) Reset added in v0.4.4

func (m *RepoKsonnetResponse) Reset()

func (*RepoKsonnetResponse) Size added in v0.4.4

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

func (*RepoKsonnetResponse) String added in v0.4.4

func (m *RepoKsonnetResponse) String() string

func (*RepoKsonnetResponse) Unmarshal added in v0.4.4

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

type RepoQuery

type RepoQuery struct {
	Repo string `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
}

RepoQuery is a query for Repository resources

func (*RepoQuery) Descriptor

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

func (*RepoQuery) GetRepo

func (m *RepoQuery) GetRepo() string

func (*RepoQuery) Marshal added in v0.3.1

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

func (*RepoQuery) MarshalTo added in v0.3.1

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

func (*RepoQuery) ProtoMessage

func (*RepoQuery) ProtoMessage()

func (*RepoQuery) Reset

func (m *RepoQuery) Reset()

func (*RepoQuery) Size added in v0.3.1

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

func (*RepoQuery) String

func (m *RepoQuery) String() string

func (*RepoQuery) Unmarshal added in v0.3.1

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

type RepoResponse

type RepoResponse struct {
}

func (*RepoResponse) Descriptor

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

func (*RepoResponse) Marshal added in v0.3.1

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

func (*RepoResponse) MarshalTo added in v0.3.1

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

func (*RepoResponse) ProtoMessage

func (*RepoResponse) ProtoMessage()

func (*RepoResponse) Reset

func (m *RepoResponse) Reset()

func (*RepoResponse) Size added in v0.3.1

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

func (*RepoResponse) String

func (m *RepoResponse) String() string

func (*RepoResponse) Unmarshal added in v0.3.1

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

type RepoUpdateRequest

type RepoUpdateRequest struct {
	Repo *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
}

func (*RepoUpdateRequest) Descriptor

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

func (*RepoUpdateRequest) Marshal added in v0.3.1

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

func (*RepoUpdateRequest) MarshalTo added in v0.3.1

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

func (*RepoUpdateRequest) ProtoMessage

func (*RepoUpdateRequest) ProtoMessage()

func (*RepoUpdateRequest) Reset

func (m *RepoUpdateRequest) Reset()

func (*RepoUpdateRequest) Size added in v0.3.1

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

func (*RepoUpdateRequest) String

func (m *RepoUpdateRequest) String() string

func (*RepoUpdateRequest) Unmarshal added in v0.3.1

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

type RepositoryServiceClient

type RepositoryServiceClient interface {
	// List returns list of repos
	List(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.RepositoryList, error)
	// ListKsonnetApps returns list of Ksonnet apps in the repo
	ListKsonnetApps(ctx context.Context, in *RepoKsonnetQuery, opts ...grpc.CallOption) (*RepoKsonnetResponse, error)
	// Create creates a repo
	Create(ctx context.Context, in *RepoCreateRequest, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository, error)
	// Get returns a repo by name
	Get(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository, error)
	// Update updates a repo
	Update(ctx context.Context, in *RepoUpdateRequest, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository, error)
	// Delete updates a repo
	Delete(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*RepoResponse, error)
}

func NewRepositoryServiceClient

func NewRepositoryServiceClient(cc *grpc.ClientConn) RepositoryServiceClient

type RepositoryServiceServer

type RepositoryServiceServer interface {
	// List returns list of repos
	List(context.Context, *RepoQuery) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.RepositoryList, error)
	// ListKsonnetApps returns list of Ksonnet apps in the repo
	ListKsonnetApps(context.Context, *RepoKsonnetQuery) (*RepoKsonnetResponse, error)
	// Create creates a repo
	Create(context.Context, *RepoCreateRequest) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository, error)
	// Get returns a repo by name
	Get(context.Context, *RepoQuery) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository, error)
	// Update updates a repo
	Update(context.Context, *RepoUpdateRequest) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository, error)
	// Delete updates a repo
	Delete(context.Context, *RepoQuery) (*RepoResponse, error)
}

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server provides a Repository service

func NewServer

func NewServer(
	repoClientset reposerver.Clientset,
	db db.ArgoDB,
	enf *rbac.Enforcer,
) *Server

NewServer returns a new instance of the Repository service

func (*Server) Create

Create creates a repository

func (*Server) Delete

func (s *Server) Delete(ctx context.Context, q *RepoQuery) (*RepoResponse, error)

Delete updates a repository

func (*Server) Get

func (s *Server) Get(ctx context.Context, q *RepoQuery) (*appsv1.Repository, error)

Get returns a repository by URL

func (*Server) List

func (s *Server) List(ctx context.Context, q *RepoQuery) (*appsv1.RepositoryList, error)

List returns list of repositories

func (*Server) ListKsonnetApps added in v0.4.4

func (s *Server) ListKsonnetApps(ctx context.Context, q *RepoKsonnetQuery) (*RepoKsonnetResponse, error)

ListKsonnetApps returns list of Ksonnet apps in the repo

func (*Server) Update

Update updates a repository

Directories

Path Synopsis
Code generated by mockery v1.0.0
Code generated by mockery v1.0.0

Jump to

Keyboard shortcuts

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