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

repository

package
v0.12.1 Latest Latest
Warning

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

 Go to latest Published: Apr 9, 2019 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Overview

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

type AppInfo struct {
	Type                 string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Path                 string   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AppInfo contains application type and app file path

func (*AppInfo) Descriptor added in v0.7.1 

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

func (*AppInfo) GetPath added in v0.7.1 

func (m *AppInfo) GetPath() string

func (*AppInfo) GetType added in v0.7.1 

func (m *AppInfo) GetType() string

func (*AppInfo) Marshal added in v0.7.1 

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

func (*AppInfo) MarshalTo added in v0.7.1 

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

func (*AppInfo) ProtoMessage added in v0.7.1 

func (*AppInfo) ProtoMessage()

func (*AppInfo) Reset added in v0.7.1 

func (m *AppInfo) Reset()

func (*AppInfo) Size added in v0.7.1 

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

func (*AppInfo) String added in v0.7.1 

func (m *AppInfo) String() string

func (*AppInfo) Unmarshal added in v0.7.1 

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

func (*AppInfo) XXX_DiscardUnknown added in v0.9.0 

func (m *AppInfo) XXX_DiscardUnknown()

func (*AppInfo) XXX_Marshal added in v0.9.0 

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

func (*AppInfo) XXX_Merge added in v0.9.0 

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

func (*AppInfo) XXX_Size added in v0.9.0 

func (m *AppInfo) XXX_Size() int

func (*AppInfo) XXX_Unmarshal added in v0.9.0 

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

type RepoAppDetailsQuery added in v0.7.1 

type RepoAppDetailsQuery 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"`
	Path                 string                          `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	Helm                 *repository.HelmAppDetailsQuery `protobuf:"bytes,4,opt,name=helm" json:"helm,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

RepoAppDetailsQuery contains query information for app details request

func (*RepoAppDetailsQuery) Descriptor added in v0.7.1 

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

func (*RepoAppDetailsQuery) GetHelm added in v0.12.0 

func (m *RepoAppDetailsQuery) GetHelm() *repository.HelmAppDetailsQuery

func (*RepoAppDetailsQuery) GetPath added in v0.7.1 

func (m *RepoAppDetailsQuery) GetPath() string

func (*RepoAppDetailsQuery) GetRepo added in v0.7.1 

func (m *RepoAppDetailsQuery) GetRepo() string

func (*RepoAppDetailsQuery) GetRevision added in v0.7.1 

func (m *RepoAppDetailsQuery) GetRevision() string

func (*RepoAppDetailsQuery) Marshal added in v0.7.1 

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

func (*RepoAppDetailsQuery) MarshalTo added in v0.7.1 

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

func (*RepoAppDetailsQuery) ProtoMessage added in v0.7.1 

func (*RepoAppDetailsQuery) ProtoMessage()

func (*RepoAppDetailsQuery) Reset added in v0.7.1 

func (m *RepoAppDetailsQuery) Reset()

func (*RepoAppDetailsQuery) Size added in v0.7.1 

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

func (*RepoAppDetailsQuery) String added in v0.7.1 

func (m *RepoAppDetailsQuery) String() string

func (*RepoAppDetailsQuery) Unmarshal added in v0.7.1 

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

func (*RepoAppDetailsQuery) XXX_DiscardUnknown added in v0.9.0 

func (m *RepoAppDetailsQuery) XXX_DiscardUnknown()

func (*RepoAppDetailsQuery) XXX_Marshal added in v0.9.0 

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

func (*RepoAppDetailsQuery) XXX_Merge added in v0.9.0 

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

func (*RepoAppDetailsQuery) XXX_Size added in v0.9.0 

func (m *RepoAppDetailsQuery) XXX_Size() int

func (*RepoAppDetailsQuery) XXX_Unmarshal added in v0.9.0 

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

type RepoAppsQuery added in v0.7.0 

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

RepoAppsQuery is a query for Repository apps

func (*RepoAppsQuery) Descriptor added in v0.7.0 

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

func (*RepoAppsQuery) GetRepo added in v0.7.0 

func (m *RepoAppsQuery) GetRepo() string

func (*RepoAppsQuery) GetRevision added in v0.7.0 

func (m *RepoAppsQuery) GetRevision() string

func (*RepoAppsQuery) Marshal added in v0.7.0 

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

func (*RepoAppsQuery) MarshalTo added in v0.7.0 

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

func (*RepoAppsQuery) ProtoMessage added in v0.7.0 

func (*RepoAppsQuery) ProtoMessage()

func (*RepoAppsQuery) Reset added in v0.7.0 

func (m *RepoAppsQuery) Reset()

func (*RepoAppsQuery) Size added in v0.7.0 

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

func (*RepoAppsQuery) String added in v0.7.0 

func (m *RepoAppsQuery) String() string

func (*RepoAppsQuery) Unmarshal added in v0.7.0 

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

func (*RepoAppsQuery) XXX_DiscardUnknown added in v0.9.0 

func (m *RepoAppsQuery) XXX_DiscardUnknown()

func (*RepoAppsQuery) XXX_Marshal added in v0.9.0 

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

func (*RepoAppsQuery) XXX_Merge added in v0.9.0 

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

func (*RepoAppsQuery) XXX_Size added in v0.9.0 

func (m *RepoAppsQuery) XXX_Size() int

func (*RepoAppsQuery) XXX_Unmarshal added in v0.9.0 

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

type RepoAppsResponse added in v0.7.0 

type RepoAppsResponse struct {
	Items                []*AppInfo `protobuf:"bytes,1,rep,name=items" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

RepoAppsResponse contains applications of specified repository

func (*RepoAppsResponse) Descriptor added in v0.7.0 

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

func (*RepoAppsResponse) GetItems added in v0.7.1 

func (m *RepoAppsResponse) GetItems() []*AppInfo

func (*RepoAppsResponse) Marshal added in v0.7.0 

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

func (*RepoAppsResponse) MarshalTo added in v0.7.0 

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

func (*RepoAppsResponse) ProtoMessage added in v0.7.0 

func (*RepoAppsResponse) ProtoMessage()

func (*RepoAppsResponse) Reset added in v0.7.0 

func (m *RepoAppsResponse) Reset()

func (*RepoAppsResponse) Size added in v0.7.0 

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

func (*RepoAppsResponse) String added in v0.7.0 

func (m *RepoAppsResponse) String() string

func (*RepoAppsResponse) Unmarshal added in v0.7.0 

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

func (*RepoAppsResponse) XXX_DiscardUnknown added in v0.9.0 

func (m *RepoAppsResponse) XXX_DiscardUnknown()

func (*RepoAppsResponse) XXX_Marshal added in v0.9.0 

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

func (*RepoAppsResponse) XXX_Merge added in v0.9.0 

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

func (*RepoAppsResponse) XXX_Size added in v0.9.0 

func (m *RepoAppsResponse) XXX_Size() int

func (*RepoAppsResponse) XXX_Unmarshal added in v0.9.0 

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

type RepoCreateRequest added in v0.5.0 

type RepoCreateRequest struct {
	Repo                 *v1alpha1.Repository `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	Upsert               bool                 `protobuf:"varint,2,opt,name=upsert,proto3" json:"upsert,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*RepoCreateRequest) Descriptor added in v0.5.0 

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

func (*RepoCreateRequest) GetRepo added in v0.5.0 

func (m *RepoCreateRequest) GetRepo() *v1alpha1.Repository

func (*RepoCreateRequest) GetUpsert added in v0.6.0 

func (m *RepoCreateRequest) GetUpsert() bool

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

func (*RepoCreateRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *RepoCreateRequest) XXX_DiscardUnknown()

func (*RepoCreateRequest) XXX_Marshal added in v0.9.0 

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

func (*RepoCreateRequest) XXX_Merge added in v0.9.0 

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

func (*RepoCreateRequest) XXX_Size added in v0.9.0 

func (m *RepoCreateRequest) XXX_Size() int

func (*RepoCreateRequest) XXX_Unmarshal added in v0.9.0 

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

type RepoQuery 

type RepoQuery struct {
	Repo                 string   `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*RepoQuery) XXX_DiscardUnknown added in v0.9.0 

func (m *RepoQuery) XXX_DiscardUnknown()

func (*RepoQuery) XXX_Marshal added in v0.9.0 

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

func (*RepoQuery) XXX_Merge added in v0.9.0 

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

func (*RepoQuery) XXX_Size added in v0.9.0 

func (m *RepoQuery) XXX_Size() int

func (*RepoQuery) XXX_Unmarshal added in v0.9.0 

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

type RepoResponse 

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

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

func (*RepoResponse) XXX_DiscardUnknown added in v0.9.0 

func (m *RepoResponse) XXX_DiscardUnknown()

func (*RepoResponse) XXX_Marshal added in v0.9.0 

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

func (*RepoResponse) XXX_Merge added in v0.9.0 

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

func (*RepoResponse) XXX_Size added in v0.9.0 

func (m *RepoResponse) XXX_Size() int

func (*RepoResponse) XXX_Unmarshal added in v0.9.0 

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

type RepoUpdateRequest 

type RepoUpdateRequest struct {
	Repo                 *v1alpha1.Repository `protobuf:"bytes,1,opt,name=repo" json:"repo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*RepoUpdateRequest) Descriptor 

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

func (*RepoUpdateRequest) GetRepo 

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

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

func (*RepoUpdateRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *RepoUpdateRequest) XXX_DiscardUnknown()

func (*RepoUpdateRequest) XXX_Marshal added in v0.9.0 

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

func (*RepoUpdateRequest) XXX_Merge added in v0.9.0 

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

func (*RepoUpdateRequest) XXX_Size added in v0.9.0 

func (m *RepoUpdateRequest) XXX_Size() int

func (*RepoUpdateRequest) XXX_Unmarshal added in v0.9.0 

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

type RepositoryServiceClient 

type RepositoryServiceClient interface {
	// List returns list of repos
	List(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*v1alpha1.RepositoryList, error)
	// ListApps returns list of apps in the repo
	ListApps(ctx context.Context, in *RepoAppsQuery, opts ...grpc.CallOption) (*RepoAppsResponse, error)
	// GetAppDetails returns application details by given path
	GetAppDetails(ctx context.Context, in *RepoAppDetailsQuery, opts ...grpc.CallOption) (*repository.RepoAppDetailsResponse, error)
	// Create creates a repo
	Create(ctx context.Context, in *RepoCreateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error)
	// Update updates a repo
	Update(ctx context.Context, in *RepoUpdateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error)
	// Delete deletes 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) (*v1alpha1.RepositoryList, error)
	// ListApps returns list of apps in the repo
	ListApps(context.Context, *RepoAppsQuery) (*RepoAppsResponse, error)
	// GetAppDetails returns application details by given path
	GetAppDetails(context.Context, *RepoAppDetailsQuery) (*repository.RepoAppDetailsResponse, error)
	// Create creates a repo
	Create(context.Context, *RepoCreateRequest) (*v1alpha1.Repository, error)
	// Update updates a repo
	Update(context.Context, *RepoUpdateRequest) (*v1alpha1.Repository, error)
	// Delete deletes 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,
	cache *cache.Cache,
) *Server

NewServer returns a new instance of the Repository service

func (*Server) Create 

func (s *Server) Create(ctx context.Context, q *RepoCreateRequest) (*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) GetAppDetails added in v0.7.1 

func (s *Server) GetAppDetails(ctx context.Context, q *RepoAppDetailsQuery) (*repository.RepoAppDetailsResponse, error)

func (*Server) List 

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

List returns list of repositories

func (*Server) ListApps added in v0.7.0 

func (s *Server) ListApps(ctx context.Context, q *RepoAppsQuery) (*RepoAppsResponse, error)

ListApps returns list of apps in the repo

func (*Server) Update 

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

Update updates a repository

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.