repository

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: May 17, 2018 License: Apache-2.0 Imports: 18 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:
	RepoQuery
	RepoResponse
	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 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 {
	Url  string                                                                `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Repo *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository `protobuf:"bytes,2,opt,name=repo" json:"repo,omitempty"`
}

func (*RepoUpdateRequest) Descriptor 

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

func (*RepoUpdateRequest) GetRepo 

func (m *RepoUpdateRequest) GetRepo() *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository

func (*RepoUpdateRequest) GetUrl 

func (m *RepoUpdateRequest) GetUrl() string

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)
	// Create creates a repo
	Create(ctx context.Context, in *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository, 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 *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository, error)
	// Update updates a repo (special handler intended to be used only by the gRPC gateway)
	UpdateREST(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)
	// Create creates a repo
	Create(context.Context, *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository) (*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, *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Repository, error)
	// Update updates a repo (special handler intended to be used only by the gRPC gateway)
	UpdateREST(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(db db.ArgoDB) *Server

NewServer returns a new instance of the Repository service

func (*Server) Create 

func (s *Server) Create(ctx context.Context, r *appsv1.Repository) (*appsv1.Repository, error)

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

func (s *Server) Update(ctx context.Context, r *appsv1.Repository) (*appsv1.Repository, error)

Update updates a repository

func (*Server) UpdateREST 

func (s *Server) UpdateREST(ctx context.Context, r *RepoUpdateRequest) (*appsv1.Repository, error)

UpdateREST updates a repository (from a REST request)

Source Files

View all Source files

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
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.