mirror of
https://github.com/hanzoai/cd.git
synced 2026-10-30 14:56:45 +00:00
repository.proto and 11 sibling hand-written .proto files referenced generated.proto's application/v1alpha1 types under the pre-fork package path (github.com.argoproj.argo_cd.v3...); protoc silently kept compiling because generated.proto still carried that same stale package too. Point both at the real, mechanically-derived path (github.com.hanzoai.cd.pkg.apis.application.v1alpha1, no v3 segment) and regenerate everything protoc/go-to-protobuf own: generated.proto/pb.go, every pkg/apiclient and reposerver/cmpserver/commitserver *.pb.go, assets/swagger.json, and the CRD manifests. That regeneration surfaced a second, unrelated bug: hack/gen-crd-spec stamped app.kubernetes.io/part-of: cd on the CRDs, but util/settings.isSettingsObject (and the ConfigMap informer built on it) only ever recognizes part-of=hanzocd. The same wrong "cd" value was baked into cmd/cd/commands/admin/settings.go's setSettingsMeta and the shared test/testdata.go fixtures ~30 files import — util/settings' own test suite was panicking on an empty slice because its fixture was invisible to the informer it was supposedly seeding. Fixed the label everywhere it's produced or asserted in the settings path; left the ~90 unrelated part-of:"cd" literals in other packages' local test fixtures alone since they never touch this selector. Also dropped 25 "TODO: Remove deprecated <dead upstream issue link>" comments that duplicated the real explanation already sitting one line away (a proper `Deprecated:` godoc, a cobra Deprecated field, or a nolint:staticcheck marker) — kept the explanation, dropped the link, per the standing rule for these citations. And repointed the two Grafana dashboards' job selector from argocd-server-metrics, a Service the manifests never create, to hanzocd-server-metrics, the one they do.
4451 lines
125 KiB
Go
Generated
4451 lines
125 KiB
Go
Generated
// Code generated by protoc-gen-gogo. DO NOT EDIT.
|
|
// source: server/repository/repository.proto
|
|
|
|
// Repository Service
|
|
//
|
|
// Repository Service API performs CRUD actions against repository resources
|
|
|
|
package repository
|
|
|
|
import (
|
|
context "context"
|
|
fmt "fmt"
|
|
proto "github.com/gogo/protobuf/proto"
|
|
v1alpha1 "github.com/hanzoai/cd/pkg/apis/application/v1alpha1"
|
|
apiclient "github.com/hanzoai/cd/reposerver/apiclient"
|
|
_ "google.golang.org/genproto/googleapis/api/annotations"
|
|
grpc "google.golang.org/grpc"
|
|
codes "google.golang.org/grpc/codes"
|
|
status "google.golang.org/grpc/status"
|
|
io "io"
|
|
math "math"
|
|
math_bits "math/bits"
|
|
)
|
|
|
|
// Reference imports to suppress errors if they are not otherwise used.
|
|
var _ = proto.Marshal
|
|
var _ = fmt.Errorf
|
|
var _ = math.Inf
|
|
|
|
// This is a compile-time assertion to ensure that this generated file
|
|
// is compatible with the proto package it is being compiled against.
|
|
// A compilation error at this line likely means your copy of the
|
|
// proto package needs to be updated.
|
|
const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
|
|
|
|
// RepoAppsQuery is a query for Repository apps
|
|
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"`
|
|
AppName string `protobuf:"bytes,3,opt,name=appName,proto3" json:"appName,omitempty"`
|
|
AppProject string `protobuf:"bytes,4,opt,name=appProject,proto3" json:"appProject,omitempty"`
|
|
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
|
XXX_unrecognized []byte `json:"-"`
|
|
XXX_sizecache int32 `json:"-"`
|
|
}
|
|
|
|
func (m *RepoAppsQuery) Reset() { *m = RepoAppsQuery{} }
|
|
func (m *RepoAppsQuery) String() string { return proto.CompactTextString(m) }
|
|
func (*RepoAppsQuery) ProtoMessage() {}
|
|
func (*RepoAppsQuery) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_8d38260443475705, []int{0}
|
|
}
|
|
func (m *RepoAppsQuery) XXX_Unmarshal(b []byte) error {
|
|
return m.Unmarshal(b)
|
|
}
|
|
func (m *RepoAppsQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
if deterministic {
|
|
return xxx_messageInfo_RepoAppsQuery.Marshal(b, m, deterministic)
|
|
} else {
|
|
b = b[:cap(b)]
|
|
n, err := m.MarshalToSizedBuffer(b)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return b[:n], nil
|
|
}
|
|
}
|
|
func (m *RepoAppsQuery) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_RepoAppsQuery.Merge(m, src)
|
|
}
|
|
func (m *RepoAppsQuery) XXX_Size() int {
|
|
return m.Size()
|
|
}
|
|
func (m *RepoAppsQuery) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_RepoAppsQuery.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_RepoAppsQuery proto.InternalMessageInfo
|
|
|
|
func (m *RepoAppsQuery) GetRepo() string {
|
|
if m != nil {
|
|
return m.Repo
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAppsQuery) GetRevision() string {
|
|
if m != nil {
|
|
return m.Revision
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAppsQuery) GetAppName() string {
|
|
if m != nil {
|
|
return m.AppName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAppsQuery) GetAppProject() string {
|
|
if m != nil {
|
|
return m.AppProject
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// AppInfo contains application type and app file path
|
|
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:"-"`
|
|
}
|
|
|
|
func (m *AppInfo) Reset() { *m = AppInfo{} }
|
|
func (m *AppInfo) String() string { return proto.CompactTextString(m) }
|
|
func (*AppInfo) ProtoMessage() {}
|
|
func (*AppInfo) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_8d38260443475705, []int{1}
|
|
}
|
|
func (m *AppInfo) XXX_Unmarshal(b []byte) error {
|
|
return m.Unmarshal(b)
|
|
}
|
|
func (m *AppInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
if deterministic {
|
|
return xxx_messageInfo_AppInfo.Marshal(b, m, deterministic)
|
|
} else {
|
|
b = b[:cap(b)]
|
|
n, err := m.MarshalToSizedBuffer(b)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return b[:n], nil
|
|
}
|
|
}
|
|
func (m *AppInfo) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_AppInfo.Merge(m, src)
|
|
}
|
|
func (m *AppInfo) XXX_Size() int {
|
|
return m.Size()
|
|
}
|
|
func (m *AppInfo) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_AppInfo.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_AppInfo proto.InternalMessageInfo
|
|
|
|
func (m *AppInfo) GetType() string {
|
|
if m != nil {
|
|
return m.Type
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *AppInfo) GetPath() string {
|
|
if m != nil {
|
|
return m.Path
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// RepoAppDetailsQuery contains query information for app details request
|
|
type RepoAppDetailsQuery struct {
|
|
Source *v1alpha1.ApplicationSource `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
|
|
AppName string `protobuf:"bytes,2,opt,name=appName,proto3" json:"appName,omitempty"`
|
|
AppProject string `protobuf:"bytes,3,opt,name=appProject,proto3" json:"appProject,omitempty"`
|
|
// source index (for multi source apps)
|
|
SourceIndex int32 `protobuf:"varint,4,opt,name=sourceIndex,proto3" json:"sourceIndex,omitempty"`
|
|
// versionId from historical data (for multi source apps)
|
|
VersionId int32 `protobuf:"varint,5,opt,name=versionId,proto3" json:"versionId,omitempty"`
|
|
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
|
XXX_unrecognized []byte `json:"-"`
|
|
XXX_sizecache int32 `json:"-"`
|
|
}
|
|
|
|
func (m *RepoAppDetailsQuery) Reset() { *m = RepoAppDetailsQuery{} }
|
|
func (m *RepoAppDetailsQuery) String() string { return proto.CompactTextString(m) }
|
|
func (*RepoAppDetailsQuery) ProtoMessage() {}
|
|
func (*RepoAppDetailsQuery) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_8d38260443475705, []int{2}
|
|
}
|
|
func (m *RepoAppDetailsQuery) XXX_Unmarshal(b []byte) error {
|
|
return m.Unmarshal(b)
|
|
}
|
|
func (m *RepoAppDetailsQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
if deterministic {
|
|
return xxx_messageInfo_RepoAppDetailsQuery.Marshal(b, m, deterministic)
|
|
} else {
|
|
b = b[:cap(b)]
|
|
n, err := m.MarshalToSizedBuffer(b)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return b[:n], nil
|
|
}
|
|
}
|
|
func (m *RepoAppDetailsQuery) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_RepoAppDetailsQuery.Merge(m, src)
|
|
}
|
|
func (m *RepoAppDetailsQuery) XXX_Size() int {
|
|
return m.Size()
|
|
}
|
|
func (m *RepoAppDetailsQuery) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_RepoAppDetailsQuery.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_RepoAppDetailsQuery proto.InternalMessageInfo
|
|
|
|
func (m *RepoAppDetailsQuery) GetSource() *v1alpha1.ApplicationSource {
|
|
if m != nil {
|
|
return m.Source
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *RepoAppDetailsQuery) GetAppName() string {
|
|
if m != nil {
|
|
return m.AppName
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAppDetailsQuery) GetAppProject() string {
|
|
if m != nil {
|
|
return m.AppProject
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAppDetailsQuery) GetSourceIndex() int32 {
|
|
if m != nil {
|
|
return m.SourceIndex
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (m *RepoAppDetailsQuery) GetVersionId() int32 {
|
|
if m != nil {
|
|
return m.VersionId
|
|
}
|
|
return 0
|
|
}
|
|
|
|
// RepoAppsResponse contains applications of specified repository
|
|
type RepoAppsResponse struct {
|
|
Items []*AppInfo `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
|
|
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
|
XXX_unrecognized []byte `json:"-"`
|
|
XXX_sizecache int32 `json:"-"`
|
|
}
|
|
|
|
func (m *RepoAppsResponse) Reset() { *m = RepoAppsResponse{} }
|
|
func (m *RepoAppsResponse) String() string { return proto.CompactTextString(m) }
|
|
func (*RepoAppsResponse) ProtoMessage() {}
|
|
func (*RepoAppsResponse) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_8d38260443475705, []int{3}
|
|
}
|
|
func (m *RepoAppsResponse) XXX_Unmarshal(b []byte) error {
|
|
return m.Unmarshal(b)
|
|
}
|
|
func (m *RepoAppsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
if deterministic {
|
|
return xxx_messageInfo_RepoAppsResponse.Marshal(b, m, deterministic)
|
|
} else {
|
|
b = b[:cap(b)]
|
|
n, err := m.MarshalToSizedBuffer(b)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return b[:n], nil
|
|
}
|
|
}
|
|
func (m *RepoAppsResponse) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_RepoAppsResponse.Merge(m, src)
|
|
}
|
|
func (m *RepoAppsResponse) XXX_Size() int {
|
|
return m.Size()
|
|
}
|
|
func (m *RepoAppsResponse) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_RepoAppsResponse.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_RepoAppsResponse proto.InternalMessageInfo
|
|
|
|
func (m *RepoAppsResponse) GetItems() []*AppInfo {
|
|
if m != nil {
|
|
return m.Items
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// RepoQuery is a query for Repository resources
|
|
type RepoQuery struct {
|
|
// Repo URL for query
|
|
Repo string `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
|
|
// Whether to force a cache refresh on repo's connection state
|
|
ForceRefresh bool `protobuf:"varint,2,opt,name=forceRefresh,proto3" json:"forceRefresh,omitempty"`
|
|
// App project for query
|
|
AppProject string `protobuf:"bytes,3,opt,name=appProject,proto3" json:"appProject,omitempty"`
|
|
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
|
XXX_unrecognized []byte `json:"-"`
|
|
XXX_sizecache int32 `json:"-"`
|
|
}
|
|
|
|
func (m *RepoQuery) Reset() { *m = RepoQuery{} }
|
|
func (m *RepoQuery) String() string { return proto.CompactTextString(m) }
|
|
func (*RepoQuery) ProtoMessage() {}
|
|
func (*RepoQuery) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_8d38260443475705, []int{4}
|
|
}
|
|
func (m *RepoQuery) XXX_Unmarshal(b []byte) error {
|
|
return m.Unmarshal(b)
|
|
}
|
|
func (m *RepoQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
if deterministic {
|
|
return xxx_messageInfo_RepoQuery.Marshal(b, m, deterministic)
|
|
} else {
|
|
b = b[:cap(b)]
|
|
n, err := m.MarshalToSizedBuffer(b)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return b[:n], nil
|
|
}
|
|
}
|
|
func (m *RepoQuery) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_RepoQuery.Merge(m, src)
|
|
}
|
|
func (m *RepoQuery) XXX_Size() int {
|
|
return m.Size()
|
|
}
|
|
func (m *RepoQuery) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_RepoQuery.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_RepoQuery proto.InternalMessageInfo
|
|
|
|
func (m *RepoQuery) GetRepo() string {
|
|
if m != nil {
|
|
return m.Repo
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoQuery) GetForceRefresh() bool {
|
|
if m != nil {
|
|
return m.ForceRefresh
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (m *RepoQuery) GetAppProject() string {
|
|
if m != nil {
|
|
return m.AppProject
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// RepoAccessQuery is a query for checking access to a repo
|
|
type RepoAccessQuery struct {
|
|
// The URL to the repo
|
|
Repo string `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
|
|
// Username for accessing repo
|
|
Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
|
|
// Password for accessing repo
|
|
Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
|
|
// Private key data for accessing SSH repository
|
|
SshPrivateKey string `protobuf:"bytes,4,opt,name=sshPrivateKey,proto3" json:"sshPrivateKey,omitempty"`
|
|
// Whether to skip certificate or host key validation
|
|
Insecure bool `protobuf:"varint,5,opt,name=insecure,proto3" json:"insecure,omitempty"`
|
|
// TLS client cert data for accessing HTTPS repository
|
|
TlsClientCertData string `protobuf:"bytes,6,opt,name=tlsClientCertData,proto3" json:"tlsClientCertData,omitempty"`
|
|
// TLS client cert key for accessing HTTPS repository
|
|
TlsClientCertKey string `protobuf:"bytes,7,opt,name=tlsClientCertKey,proto3" json:"tlsClientCertKey,omitempty"`
|
|
// The type of the repo
|
|
Type string `protobuf:"bytes,9,opt,name=type,proto3" json:"type,omitempty"`
|
|
// The name of the repo
|
|
Name string `protobuf:"bytes,10,opt,name=name,proto3" json:"name,omitempty"`
|
|
// Whether helm-oci support should be enabled for this repo
|
|
EnableOci bool `protobuf:"varint,11,opt,name=enableOci,proto3" json:"enableOci,omitempty"`
|
|
// Github App Private Key PEM data
|
|
GithubAppPrivateKey string `protobuf:"bytes,12,opt,name=githubAppPrivateKey,proto3" json:"githubAppPrivateKey,omitempty"`
|
|
// Github App ID of the app used to access the repo
|
|
GithubAppID int64 `protobuf:"varint,13,opt,name=githubAppID,proto3" json:"githubAppID,omitempty"`
|
|
// Github App Installation ID of the installed GitHub App
|
|
GithubAppInstallationID int64 `protobuf:"varint,14,opt,name=githubAppInstallationID,proto3" json:"githubAppInstallationID,omitempty"`
|
|
// Github App Enterprise base url if empty will default to https://api.github.com
|
|
GithubAppEnterpriseBaseUrl string `protobuf:"bytes,15,opt,name=githubAppEnterpriseBaseUrl,proto3" json:"githubAppEnterpriseBaseUrl,omitempty"`
|
|
// HTTP/HTTPS proxy to access the repository
|
|
Proxy string `protobuf:"bytes,16,opt,name=proxy,proto3" json:"proxy,omitempty"`
|
|
// Reference between project and repository that allow you automatically to be added as item inside SourceRepos project entity
|
|
Project string `protobuf:"bytes,17,opt,name=project,proto3" json:"project,omitempty"`
|
|
// Google Cloud Platform service account key
|
|
GcpServiceAccountKey string `protobuf:"bytes,18,opt,name=gcpServiceAccountKey,proto3" json:"gcpServiceAccountKey,omitempty"`
|
|
// Whether to force HTTP basic auth
|
|
ForceHttpBasicAuth bool `protobuf:"varint,19,opt,name=forceHttpBasicAuth,proto3" json:"forceHttpBasicAuth,omitempty"`
|
|
// Whether to use azure workload identity for authentication
|
|
UseAzureWorkloadIdentity bool `protobuf:"varint,20,opt,name=useAzureWorkloadIdentity,proto3" json:"useAzureWorkloadIdentity,omitempty"`
|
|
// BearerToken contains the bearer token used for Git auth at the repo server
|
|
BearerToken string `protobuf:"bytes,21,opt,name=bearerToken,proto3" json:"bearerToken,omitempty"`
|
|
// Whether https should be disabled for an OCI repo
|
|
InsecureOciForceHttp bool `protobuf:"varint,22,opt,name=insecureOciForceHttp,proto3" json:"insecureOciForceHttp,omitempty"`
|
|
// Azure Service Principal Client ID
|
|
AzureServicePrincipalClientId string `protobuf:"bytes,23,opt,name=azureServicePrincipalClientId,proto3" json:"azureServicePrincipalClientId,omitempty"`
|
|
// Azure Service Principal Client Secret
|
|
AzureServicePrincipalClientSecret string `protobuf:"bytes,24,opt,name=azureServicePrincipalClientSecret,proto3" json:"azureServicePrincipalClientSecret,omitempty"`
|
|
// Azure Service Principal Tenant ID
|
|
AzureServicePrincipalTenantId string `protobuf:"bytes,25,opt,name=azureServicePrincipalTenantId,proto3" json:"azureServicePrincipalTenantId,omitempty"`
|
|
// Azure Active Directory Endpoint
|
|
AzureActiveDirectoryEndpoint string `protobuf:"bytes,26,opt,name=azureActiveDirectoryEndpoint,proto3" json:"azureActiveDirectoryEndpoint,omitempty"`
|
|
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
|
XXX_unrecognized []byte `json:"-"`
|
|
XXX_sizecache int32 `json:"-"`
|
|
}
|
|
|
|
func (m *RepoAccessQuery) Reset() { *m = RepoAccessQuery{} }
|
|
func (m *RepoAccessQuery) String() string { return proto.CompactTextString(m) }
|
|
func (*RepoAccessQuery) ProtoMessage() {}
|
|
func (*RepoAccessQuery) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_8d38260443475705, []int{5}
|
|
}
|
|
func (m *RepoAccessQuery) XXX_Unmarshal(b []byte) error {
|
|
return m.Unmarshal(b)
|
|
}
|
|
func (m *RepoAccessQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
if deterministic {
|
|
return xxx_messageInfo_RepoAccessQuery.Marshal(b, m, deterministic)
|
|
} else {
|
|
b = b[:cap(b)]
|
|
n, err := m.MarshalToSizedBuffer(b)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return b[:n], nil
|
|
}
|
|
}
|
|
func (m *RepoAccessQuery) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_RepoAccessQuery.Merge(m, src)
|
|
}
|
|
func (m *RepoAccessQuery) XXX_Size() int {
|
|
return m.Size()
|
|
}
|
|
func (m *RepoAccessQuery) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_RepoAccessQuery.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_RepoAccessQuery proto.InternalMessageInfo
|
|
|
|
func (m *RepoAccessQuery) GetRepo() string {
|
|
if m != nil {
|
|
return m.Repo
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetUsername() string {
|
|
if m != nil {
|
|
return m.Username
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetPassword() string {
|
|
if m != nil {
|
|
return m.Password
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetSshPrivateKey() string {
|
|
if m != nil {
|
|
return m.SshPrivateKey
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetInsecure() bool {
|
|
if m != nil {
|
|
return m.Insecure
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetTlsClientCertData() string {
|
|
if m != nil {
|
|
return m.TlsClientCertData
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetTlsClientCertKey() string {
|
|
if m != nil {
|
|
return m.TlsClientCertKey
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetType() string {
|
|
if m != nil {
|
|
return m.Type
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetName() string {
|
|
if m != nil {
|
|
return m.Name
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetEnableOci() bool {
|
|
if m != nil {
|
|
return m.EnableOci
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetGithubAppPrivateKey() string {
|
|
if m != nil {
|
|
return m.GithubAppPrivateKey
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetGithubAppID() int64 {
|
|
if m != nil {
|
|
return m.GithubAppID
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetGithubAppInstallationID() int64 {
|
|
if m != nil {
|
|
return m.GithubAppInstallationID
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetGithubAppEnterpriseBaseUrl() string {
|
|
if m != nil {
|
|
return m.GithubAppEnterpriseBaseUrl
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetProxy() string {
|
|
if m != nil {
|
|
return m.Proxy
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetProject() string {
|
|
if m != nil {
|
|
return m.Project
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetGcpServiceAccountKey() string {
|
|
if m != nil {
|
|
return m.GcpServiceAccountKey
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetForceHttpBasicAuth() bool {
|
|
if m != nil {
|
|
return m.ForceHttpBasicAuth
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetUseAzureWorkloadIdentity() bool {
|
|
if m != nil {
|
|
return m.UseAzureWorkloadIdentity
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetBearerToken() string {
|
|
if m != nil {
|
|
return m.BearerToken
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetInsecureOciForceHttp() bool {
|
|
if m != nil {
|
|
return m.InsecureOciForceHttp
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetAzureServicePrincipalClientId() string {
|
|
if m != nil {
|
|
return m.AzureServicePrincipalClientId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetAzureServicePrincipalClientSecret() string {
|
|
if m != nil {
|
|
return m.AzureServicePrincipalClientSecret
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetAzureServicePrincipalTenantId() string {
|
|
if m != nil {
|
|
return m.AzureServicePrincipalTenantId
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *RepoAccessQuery) GetAzureActiveDirectoryEndpoint() string {
|
|
if m != nil {
|
|
return m.AzureActiveDirectoryEndpoint
|
|
}
|
|
return ""
|
|
}
|
|
|
|
type RepoResponse struct {
|
|
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
|
XXX_unrecognized []byte `json:"-"`
|
|
XXX_sizecache int32 `json:"-"`
|
|
}
|
|
|
|
func (m *RepoResponse) Reset() { *m = RepoResponse{} }
|
|
func (m *RepoResponse) String() string { return proto.CompactTextString(m) }
|
|
func (*RepoResponse) ProtoMessage() {}
|
|
func (*RepoResponse) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_8d38260443475705, []int{6}
|
|
}
|
|
func (m *RepoResponse) XXX_Unmarshal(b []byte) error {
|
|
return m.Unmarshal(b)
|
|
}
|
|
func (m *RepoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
if deterministic {
|
|
return xxx_messageInfo_RepoResponse.Marshal(b, m, deterministic)
|
|
} else {
|
|
b = b[:cap(b)]
|
|
n, err := m.MarshalToSizedBuffer(b)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return b[:n], nil
|
|
}
|
|
}
|
|
func (m *RepoResponse) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_RepoResponse.Merge(m, src)
|
|
}
|
|
func (m *RepoResponse) XXX_Size() int {
|
|
return m.Size()
|
|
}
|
|
func (m *RepoResponse) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_RepoResponse.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_RepoResponse proto.InternalMessageInfo
|
|
|
|
// RepoCreateRequest is a request for creating repository config
|
|
type RepoCreateRequest struct {
|
|
// Repository definition
|
|
Repo *v1alpha1.Repository `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
|
|
// Whether to create in upsert mode
|
|
Upsert bool `protobuf:"varint,2,opt,name=upsert,proto3" json:"upsert,omitempty"`
|
|
// Whether to operate on credential set instead of repository
|
|
CredsOnly bool `protobuf:"varint,3,opt,name=credsOnly,proto3" json:"credsOnly,omitempty"`
|
|
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
|
XXX_unrecognized []byte `json:"-"`
|
|
XXX_sizecache int32 `json:"-"`
|
|
}
|
|
|
|
func (m *RepoCreateRequest) Reset() { *m = RepoCreateRequest{} }
|
|
func (m *RepoCreateRequest) String() string { return proto.CompactTextString(m) }
|
|
func (*RepoCreateRequest) ProtoMessage() {}
|
|
func (*RepoCreateRequest) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_8d38260443475705, []int{7}
|
|
}
|
|
func (m *RepoCreateRequest) XXX_Unmarshal(b []byte) error {
|
|
return m.Unmarshal(b)
|
|
}
|
|
func (m *RepoCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
if deterministic {
|
|
return xxx_messageInfo_RepoCreateRequest.Marshal(b, m, deterministic)
|
|
} else {
|
|
b = b[:cap(b)]
|
|
n, err := m.MarshalToSizedBuffer(b)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return b[:n], nil
|
|
}
|
|
}
|
|
func (m *RepoCreateRequest) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_RepoCreateRequest.Merge(m, src)
|
|
}
|
|
func (m *RepoCreateRequest) XXX_Size() int {
|
|
return m.Size()
|
|
}
|
|
func (m *RepoCreateRequest) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_RepoCreateRequest.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_RepoCreateRequest proto.InternalMessageInfo
|
|
|
|
func (m *RepoCreateRequest) GetRepo() *v1alpha1.Repository {
|
|
if m != nil {
|
|
return m.Repo
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (m *RepoCreateRequest) GetUpsert() bool {
|
|
if m != nil {
|
|
return m.Upsert
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (m *RepoCreateRequest) GetCredsOnly() bool {
|
|
if m != nil {
|
|
return m.CredsOnly
|
|
}
|
|
return false
|
|
}
|
|
|
|
type RepoUpdateRequest struct {
|
|
Repo *v1alpha1.Repository `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
|
|
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
|
XXX_unrecognized []byte `json:"-"`
|
|
XXX_sizecache int32 `json:"-"`
|
|
}
|
|
|
|
func (m *RepoUpdateRequest) Reset() { *m = RepoUpdateRequest{} }
|
|
func (m *RepoUpdateRequest) String() string { return proto.CompactTextString(m) }
|
|
func (*RepoUpdateRequest) ProtoMessage() {}
|
|
func (*RepoUpdateRequest) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_8d38260443475705, []int{8}
|
|
}
|
|
func (m *RepoUpdateRequest) XXX_Unmarshal(b []byte) error {
|
|
return m.Unmarshal(b)
|
|
}
|
|
func (m *RepoUpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
if deterministic {
|
|
return xxx_messageInfo_RepoUpdateRequest.Marshal(b, m, deterministic)
|
|
} else {
|
|
b = b[:cap(b)]
|
|
n, err := m.MarshalToSizedBuffer(b)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return b[:n], nil
|
|
}
|
|
}
|
|
func (m *RepoUpdateRequest) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_RepoUpdateRequest.Merge(m, src)
|
|
}
|
|
func (m *RepoUpdateRequest) XXX_Size() int {
|
|
return m.Size()
|
|
}
|
|
func (m *RepoUpdateRequest) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_RepoUpdateRequest.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_RepoUpdateRequest proto.InternalMessageInfo
|
|
|
|
func (m *RepoUpdateRequest) GetRepo() *v1alpha1.Repository {
|
|
if m != nil {
|
|
return m.Repo
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func init() {
|
|
proto.RegisterType((*RepoAppsQuery)(nil), "repository.RepoAppsQuery")
|
|
proto.RegisterType((*AppInfo)(nil), "repository.AppInfo")
|
|
proto.RegisterType((*RepoAppDetailsQuery)(nil), "repository.RepoAppDetailsQuery")
|
|
proto.RegisterType((*RepoAppsResponse)(nil), "repository.RepoAppsResponse")
|
|
proto.RegisterType((*RepoQuery)(nil), "repository.RepoQuery")
|
|
proto.RegisterType((*RepoAccessQuery)(nil), "repository.RepoAccessQuery")
|
|
proto.RegisterType((*RepoResponse)(nil), "repository.RepoResponse")
|
|
proto.RegisterType((*RepoCreateRequest)(nil), "repository.RepoCreateRequest")
|
|
proto.RegisterType((*RepoUpdateRequest)(nil), "repository.RepoUpdateRequest")
|
|
}
|
|
|
|
func init() {
|
|
proto.RegisterFile("server/repository/repository.proto", fileDescriptor_8d38260443475705)
|
|
}
|
|
|
|
var fileDescriptor_8d38260443475705 = []byte{
|
|
// 1445 bytes of a gzipped FileDescriptorProto
|
|
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x58, 0xdf, 0x6e, 0x1b, 0xc5,
|
|
0x17, 0xd6, 0x26, 0x4d, 0x9a, 0x4c, 0x9a, 0xd6, 0x9d, 0x34, 0xed, 0xd6, 0x4d, 0x9d, 0x74, 0xd5,
|
|
0xdf, 0x4f, 0x21, 0x6a, 0xd7, 0x4d, 0x40, 0x02, 0x55, 0x05, 0xe4, 0xc4, 0xfd, 0x63, 0x51, 0x91,
|
|
0xb2, 0x69, 0xa9, 0x40, 0x02, 0x31, 0xd9, 0x3d, 0xb1, 0x87, 0x6c, 0x76, 0x87, 0x99, 0xb1, 0x5b,
|
|
0x17, 0x15, 0xa4, 0x5e, 0x15, 0x21, 0x6e, 0xe8, 0x05, 0x57, 0xf4, 0x9e, 0x37, 0x41, 0xe2, 0x06,
|
|
0xc4, 0x0b, 0xa0, 0x8a, 0x7b, 0x5e, 0x01, 0xcd, 0xcc, 0x7a, 0xbd, 0x76, 0xbc, 0x36, 0x25, 0x0d,
|
|
0x77, 0x3b, 0xe7, 0x9c, 0xfd, 0xbe, 0xef, 0x9c, 0x39, 0x7b, 0x66, 0x6c, 0xe4, 0x08, 0xe0, 0x2d,
|
|
0xe0, 0x65, 0x0e, 0x2c, 0x16, 0x54, 0xc6, 0xbc, 0x9d, 0x79, 0x74, 0x19, 0x8f, 0x65, 0x8c, 0x51,
|
|
0xd7, 0x52, 0x5c, 0xa8, 0xc7, 0x71, 0x3d, 0x84, 0x32, 0x61, 0xb4, 0x4c, 0xa2, 0x28, 0x96, 0x44,
|
|
0xd2, 0x38, 0x12, 0x26, 0xb2, 0xb8, 0x51, 0xa7, 0xb2, 0xd1, 0xdc, 0x76, 0xfd, 0x78, 0xaf, 0xdc,
|
|
0x20, 0xd1, 0xa3, 0x98, 0xd0, 0xb2, 0x1f, 0x94, 0xd9, 0x6e, 0x5d, 0xbd, 0x20, 0xca, 0x84, 0xb1,
|
|
0x90, 0xfa, 0xfa, 0x95, 0x72, 0x6b, 0x95, 0x84, 0xac, 0x41, 0x56, 0xcb, 0x75, 0x88, 0x80, 0x13,
|
|
0x09, 0x41, 0x02, 0x72, 0x6d, 0x30, 0x88, 0x16, 0x31, 0x52, 0xac, 0xd3, 0x46, 0xb3, 0x1e, 0xb0,
|
|
0xb8, 0xc2, 0x98, 0xf8, 0xa0, 0x09, 0xbc, 0x8d, 0x31, 0x3a, 0xa2, 0x82, 0x6c, 0x6b, 0xc9, 0x5a,
|
|
0x9e, 0xf6, 0xf4, 0x33, 0x2e, 0xa2, 0x29, 0x0e, 0x2d, 0x2a, 0x68, 0x1c, 0xd9, 0x63, 0xda, 0x9e,
|
|
0xae, 0xb1, 0x8d, 0x8e, 0x12, 0xc6, 0xde, 0x27, 0x7b, 0x60, 0x8f, 0x6b, 0x57, 0x67, 0x89, 0x4b,
|
|
0x08, 0x11, 0xc6, 0xee, 0xf0, 0xf8, 0x73, 0xf0, 0xa5, 0x7d, 0x44, 0x3b, 0x33, 0x16, 0x67, 0x15,
|
|
0x1d, 0xad, 0x30, 0x56, 0x8b, 0x76, 0x62, 0x45, 0x2a, 0xdb, 0x0c, 0x3a, 0xa4, 0xea, 0x59, 0xd9,
|
|
0x18, 0x91, 0x8d, 0x84, 0x50, 0x3f, 0x3b, 0x7f, 0x59, 0x68, 0x2e, 0x91, 0x5b, 0x05, 0x49, 0x68,
|
|
0x98, 0x88, 0xfe, 0x14, 0x4d, 0x8a, 0xb8, 0xc9, 0x7d, 0x83, 0x30, 0xb3, 0x76, 0xc3, 0xed, 0x16,
|
|
0xc5, 0x4d, 0x8a, 0xe2, 0xfa, 0x81, 0xcb, 0x76, 0xeb, 0xae, 0xaa, 0xac, 0x9b, 0xa9, 0xac, 0xdb,
|
|
0xa9, 0xac, 0x5b, 0xe9, 0x1a, 0xb7, 0x34, 0x9a, 0x97, 0xa0, 0x66, 0x93, 0x1c, 0x1b, 0x96, 0xe4,
|
|
0x78, 0x7f, 0x92, 0x78, 0x09, 0xcd, 0x18, 0x8c, 0x5a, 0x14, 0xc0, 0x43, 0x5d, 0x85, 0x09, 0x2f,
|
|
0x6b, 0xc2, 0x0b, 0x68, 0xba, 0x05, 0x5c, 0xd5, 0xb2, 0x16, 0xd8, 0x13, 0xda, 0xdf, 0x35, 0x38,
|
|
0x6f, 0xa3, 0x42, 0x67, 0x7f, 0x3c, 0x10, 0x2c, 0x8e, 0x04, 0xe0, 0xd7, 0xd0, 0x04, 0x95, 0xb0,
|
|
0x27, 0x6c, 0x6b, 0x69, 0x7c, 0x79, 0x66, 0x6d, 0xce, 0xcd, 0xec, 0x6a, 0x52, 0x51, 0xcf, 0x44,
|
|
0x38, 0x3e, 0x9a, 0x56, 0xaf, 0xe7, 0x6f, 0xad, 0x83, 0x8e, 0xed, 0xc4, 0x2a, 0x55, 0xd8, 0xe1,
|
|
0x20, 0x4c, 0xb5, 0xa7, 0xbc, 0x1e, 0xdb, 0xa8, 0x1c, 0x9d, 0xdf, 0xa6, 0xd0, 0x09, 0x2d, 0xd2,
|
|
0xf7, 0x41, 0x0c, 0x6f, 0xa3, 0xa6, 0x00, 0x1e, 0x75, 0xcb, 0x98, 0xae, 0x95, 0x8f, 0x11, 0x21,
|
|
0x1e, 0xc4, 0x3c, 0x48, 0x18, 0xd2, 0x35, 0xbe, 0x88, 0x66, 0x85, 0x68, 0xdc, 0xe1, 0xb4, 0x45,
|
|
0x24, 0xbc, 0x07, 0xed, 0xa4, 0x97, 0x7a, 0x8d, 0x0a, 0x81, 0x46, 0x02, 0xfc, 0x26, 0x07, 0x5d,
|
|
0xc6, 0x29, 0x2f, 0x5d, 0xe3, 0x4b, 0xe8, 0xa4, 0x0c, 0xc5, 0x46, 0x48, 0x21, 0x92, 0x1b, 0xc0,
|
|
0x65, 0x95, 0x48, 0x62, 0x4f, 0x6a, 0x94, 0xfd, 0x0e, 0xbc, 0x82, 0x0a, 0x3d, 0x46, 0x45, 0x79,
|
|
0x54, 0x07, 0xef, 0xb3, 0xa7, 0x9d, 0x3b, 0xdd, 0xdb, 0xb9, 0x3a, 0x47, 0x64, 0x6c, 0x3a, 0xbf,
|
|
0x05, 0x34, 0x0d, 0x11, 0xd9, 0x0e, 0x61, 0xd3, 0xa7, 0xf6, 0x8c, 0x96, 0xd7, 0x35, 0xe0, 0x2b,
|
|
0x68, 0xce, 0x34, 0x6c, 0x45, 0x55, 0x35, 0xcd, 0xf3, 0x98, 0x06, 0x18, 0xe4, 0x52, 0x7d, 0x95,
|
|
0x9a, 0x6b, 0x55, 0x7b, 0x76, 0xc9, 0x5a, 0x1e, 0xf7, 0xb2, 0x26, 0xfc, 0x16, 0x3a, 0xd3, 0x5d,
|
|
0x46, 0x42, 0x92, 0x30, 0xd4, 0xad, 0x5d, 0xab, 0xda, 0xc7, 0x75, 0x74, 0x9e, 0x1b, 0xbf, 0x83,
|
|
0x8a, 0xa9, 0xeb, 0x7a, 0x24, 0x81, 0x33, 0x4e, 0x05, 0xac, 0x13, 0x01, 0xf7, 0x78, 0x68, 0x9f,
|
|
0xd0, 0xa2, 0x86, 0x44, 0xe0, 0x53, 0x68, 0x82, 0xf1, 0xf8, 0x61, 0xdb, 0x2e, 0xe8, 0x50, 0xb3,
|
|
0x50, 0xdf, 0x10, 0x4b, 0x5a, 0xe8, 0xa4, 0xf9, 0x86, 0x92, 0x25, 0x5e, 0x43, 0xa7, 0xea, 0x3e,
|
|
0xdb, 0x02, 0xde, 0xa2, 0x3e, 0x54, 0x7c, 0x3f, 0x6e, 0x46, 0xba, 0xe6, 0x58, 0x87, 0x0d, 0xf4,
|
|
0x61, 0x17, 0x61, 0xdd, 0xa3, 0xb7, 0xa4, 0x64, 0xeb, 0x44, 0x50, 0xbf, 0xd2, 0x94, 0x0d, 0x7b,
|
|
0x4e, 0x17, 0x76, 0x80, 0x07, 0x5f, 0x45, 0x76, 0x53, 0x40, 0xe5, 0x51, 0x93, 0xc3, 0xfd, 0x98,
|
|
0xef, 0x86, 0x31, 0x09, 0x6a, 0x01, 0x44, 0x92, 0xca, 0xb6, 0x7d, 0x4a, 0xbf, 0x95, 0xeb, 0x57,
|
|
0xb5, 0xde, 0x06, 0xc2, 0x81, 0xdf, 0x8d, 0x77, 0x21, 0xb2, 0xe7, 0xb5, 0xac, 0xac, 0x49, 0x65,
|
|
0xd0, 0xe9, 0xb5, 0x4d, 0x9f, 0xde, 0xe8, 0xd0, 0xdb, 0xa7, 0x35, 0xf2, 0x40, 0x1f, 0xae, 0xa2,
|
|
0xf3, 0x44, 0xd1, 0x25, 0xb9, 0xdd, 0xe1, 0x34, 0xf2, 0x29, 0x23, 0xa1, 0xe9, 0xaf, 0x5a, 0x60,
|
|
0x9f, 0xd1, 0x3c, 0xc3, 0x83, 0xf0, 0x6d, 0x74, 0x61, 0x48, 0xc0, 0x16, 0xf8, 0x1c, 0xa4, 0x6d,
|
|
0x6b, 0xa4, 0xd1, 0x81, 0xb9, 0x9a, 0xee, 0x42, 0x44, 0xb4, 0xa6, 0xb3, 0x43, 0x34, 0x75, 0x82,
|
|
0xf0, 0x3a, 0x5a, 0xd0, 0x01, 0x15, 0x5f, 0xd2, 0x16, 0x54, 0x29, 0x07, 0x5f, 0xcd, 0xa6, 0xeb,
|
|
0x51, 0xc0, 0x62, 0x1a, 0x49, 0xbb, 0xa8, 0x41, 0x86, 0xc6, 0x38, 0xc7, 0xd1, 0x31, 0x35, 0x52,
|
|
0x3a, 0x33, 0xcf, 0x79, 0x6e, 0xa1, 0x93, 0xca, 0xb0, 0xc1, 0x81, 0x48, 0xf0, 0xe0, 0x8b, 0x26,
|
|
0x08, 0x89, 0xb7, 0x32, 0x53, 0x66, 0x66, 0xed, 0xdd, 0x7f, 0x35, 0xf5, 0xbd, 0x74, 0x78, 0x26,
|
|
0x63, 0xea, 0x34, 0x9a, 0x6c, 0x32, 0x01, 0x5c, 0x26, 0xc3, 0x30, 0x59, 0xa9, 0x4f, 0xd8, 0xe7,
|
|
0x10, 0x88, 0xcd, 0x28, 0x6c, 0xeb, 0x19, 0x35, 0xe5, 0x75, 0x0d, 0x4e, 0xc3, 0xe8, 0xbb, 0xc7,
|
|
0x82, 0x43, 0xd6, 0xb7, 0xf6, 0xcb, 0xbc, 0xa1, 0x32, 0xc6, 0x64, 0x17, 0xf0, 0xd7, 0xe8, 0xc8,
|
|
0x6d, 0x2a, 0x24, 0x9e, 0xcf, 0x9e, 0x06, 0xe9, 0xec, 0x2f, 0x6e, 0x1c, 0x90, 0x5b, 0x61, 0x3b,
|
|
0xe7, 0x9e, 0xfc, 0xfe, 0xe7, 0xb3, 0x31, 0x8c, 0x0b, 0xe5, 0xd6, 0x6a, 0xf7, 0x2a, 0x41, 0x41,
|
|
0x3c, 0x1d, 0xb3, 0xf0, 0x57, 0x68, 0xfc, 0x26, 0xe4, 0xf2, 0x1f, 0x34, 0x77, 0x67, 0x51, 0x73,
|
|
0x9f, 0xc5, 0x67, 0xfa, 0xb9, 0xcb, 0x5f, 0xaa, 0xd5, 0x63, 0xfc, 0x8d, 0x85, 0xa6, 0x6e, 0x82,
|
|
0xbc, 0xcf, 0xa9, 0x84, 0x43, 0x53, 0xf1, 0x3f, 0xad, 0x62, 0x11, 0x9f, 0x57, 0x2a, 0x1e, 0x28,
|
|
0xaa, 0xcb, 0x83, 0xb4, 0x3c, 0xb5, 0x50, 0x41, 0x55, 0xcc, 0xcb, 0xf8, 0x0e, 0x75, 0x67, 0xec,
|
|
0xbc, 0x9d, 0xc1, 0xcf, 0x2c, 0x34, 0xaf, 0x42, 0x74, 0x5d, 0xfe, 0x33, 0x3d, 0x25, 0xad, 0xc7,
|
|
0xc6, 0xa7, 0x07, 0xd7, 0x09, 0x7f, 0x84, 0xa6, 0x4c, 0x7d, 0x76, 0x72, 0x75, 0x14, 0x7a, 0xcd,
|
|
0x3b, 0xc2, 0xb9, 0xa8, 0x41, 0x4b, 0x78, 0x21, 0xa7, 0x05, 0xca, 0x5c, 0xc1, 0x7d, 0x86, 0x66,
|
|
0x14, 0xf4, 0xe6, 0x46, 0xed, 0x2e, 0xa9, 0xbf, 0x04, 0xfa, 0xb2, 0x46, 0x77, 0xf0, 0x52, 0x1e,
|
|
0x7a, 0xec, 0xd3, 0xcb, 0x52, 0x41, 0x52, 0x23, 0x5e, 0xdd, 0xc9, 0xf0, 0xd9, 0x7e, 0xf8, 0xf4,
|
|
0x26, 0x5d, 0x5c, 0x18, 0xe4, 0x4a, 0x07, 0xda, 0xc8, 0x64, 0x88, 0x82, 0xff, 0xce, 0x42, 0xb3,
|
|
0x37, 0x41, 0x76, 0xef, 0xbb, 0x78, 0x71, 0x00, 0x6a, 0xf6, 0x2e, 0x5c, 0x74, 0xf2, 0x03, 0x52,
|
|
0xf2, 0x37, 0x35, 0xf9, 0xaa, 0x73, 0x69, 0x3f, 0xb9, 0xb9, 0x9a, 0x6a, 0x8c, 0x7b, 0xde, 0x6d,
|
|
0x2d, 0x23, 0x30, 0x6f, 0x5f, 0xb5, 0x56, 0x30, 0xd7, 0x72, 0x6e, 0x41, 0xb8, 0xb7, 0xd1, 0x20,
|
|
0x5c, 0xe6, 0x96, 0xb7, 0x94, 0x35, 0x77, 0xc3, 0x53, 0x01, 0x2b, 0x5a, 0xc0, 0x45, 0xec, 0xe4,
|
|
0x65, 0xdf, 0x80, 0x70, 0xcf, 0x37, 0x14, 0xdf, 0x5a, 0x68, 0xd2, 0x8c, 0x7d, 0x7c, 0xbe, 0x9f,
|
|
0xad, 0xe7, 0x38, 0x38, 0xf8, 0xe7, 0x7d, 0xc1, 0xb4, 0xad, 0xb3, 0xef, 0x33, 0xba, 0xaa, 0x47,
|
|
0xaf, 0x1a, 0x73, 0xdf, 0x5b, 0xa8, 0xd0, 0x61, 0xed, 0xbc, 0x77, 0xe8, 0xba, 0x4a, 0xc3, 0x75,
|
|
0xe1, 0x1f, 0x2d, 0x34, 0x6f, 0x28, 0x7b, 0x3f, 0xf3, 0xc3, 0x57, 0x96, 0xb4, 0xb1, 0x93, 0xf3,
|
|
0xa1, 0x27, 0xfa, 0x7e, 0xb0, 0xd0, 0xa4, 0x39, 0x19, 0xf7, 0x0b, 0xea, 0x39, 0x31, 0x0f, 0x2e,
|
|
0xe8, 0xb2, 0xe9, 0xac, 0x62, 0xce, 0x77, 0xa5, 0xd9, 0x1f, 0x77, 0xb7, 0xf3, 0xb9, 0x85, 0x0a,
|
|
0x1d, 0x05, 0xf9, 0x45, 0x7b, 0xc5, 0x1a, 0x57, 0xfe, 0xb9, 0x46, 0xfc, 0x93, 0x85, 0xe6, 0x0d,
|
|
0xfd, 0xc8, 0xad, 0x7d, 0xc5, 0x2a, 0xaf, 0x68, 0x95, 0x2b, 0x45, 0x67, 0xd8, 0x59, 0xd7, 0xa3,
|
|
0xf5, 0x13, 0x34, 0x59, 0x85, 0x10, 0xf2, 0xcf, 0x5f, 0xbb, 0xdf, 0x9c, 0x0e, 0x04, 0xc7, 0x1c,
|
|
0xef, 0x2b, 0x79, 0xc7, 0xbb, 0xda, 0xab, 0x00, 0x15, 0x0c, 0x7c, 0xa6, 0x08, 0x2f, 0x4d, 0xb4,
|
|
0x38, 0x82, 0x08, 0xc7, 0x68, 0xde, 0xb0, 0xf4, 0xd7, 0xfb, 0xa5, 0xa9, 0x92, 0xcb, 0xc2, 0xca,
|
|
0x88, 0xcb, 0xc2, 0x03, 0x74, 0xfc, 0x43, 0x12, 0x52, 0xb5, 0x77, 0xe6, 0x17, 0x34, 0x3e, 0xb7,
|
|
0x6f, 0x84, 0x77, 0x7f, 0x59, 0x0f, 0xe1, 0x73, 0x35, 0xdf, 0xb2, 0x93, 0x7b, 0x82, 0xb5, 0x12,
|
|
0x9a, 0x64, 0xbb, 0x9e, 0x58, 0x68, 0xae, 0xc3, 0xac, 0x93, 0x3d, 0x18, 0xfd, 0x1b, 0x9a, 0xde,
|
|
0x75, 0xfe, 0x3f, 0x34, 0xdd, 0x3e, 0x11, 0xeb, 0xd7, 0x7e, 0x7e, 0x51, 0xb2, 0x7e, 0x7d, 0x51,
|
|
0xb2, 0xfe, 0x78, 0x51, 0xb2, 0x3e, 0x76, 0x87, 0xfe, 0x23, 0xe6, 0xeb, 0xdf, 0x2a, 0x99, 0x3f,
|
|
0xb1, 0xb6, 0x27, 0xf5, 0xbf, 0x58, 0xaf, 0xff, 0x1d, 0x00, 0x00, 0xff, 0xff, 0xcc, 0x67, 0xbe,
|
|
0xb2, 0x98, 0x13, 0x00, 0x00,
|
|
}
|
|
|
|
// Reference imports to suppress errors if they are not otherwise used.
|
|
var _ context.Context
|
|
var _ grpc.ClientConn
|
|
|
|
// This is a compile-time assertion to ensure that this generated file
|
|
// is compatible with the grpc package it is being compiled against.
|
|
const _ = grpc.SupportPackageIsVersion4
|
|
|
|
// RepositoryServiceClient is the client API for RepositoryService service.
|
|
//
|
|
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
|
|
type RepositoryServiceClient interface {
|
|
// List returns list of repos or repository credentials
|
|
List(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*v1alpha1.RepositoryList, error)
|
|
// Get returns a repository or its credentials
|
|
Get(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*v1alpha1.Repository, error)
|
|
// GetWrite returns a repository or its write credentials
|
|
GetWrite(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*v1alpha1.Repository, error)
|
|
// ListRepositories gets a list of all configured repositories
|
|
ListRepositories(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*v1alpha1.RepositoryList, error)
|
|
// ListWriteRepositories gets a list of all configured write repositories
|
|
ListWriteRepositories(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*v1alpha1.RepositoryList, error)
|
|
ListRefs(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*apiclient.Refs, error)
|
|
ListOCITags(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*apiclient.Refs, 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) (*apiclient.RepoAppDetailsResponse, error)
|
|
// GetHelmCharts returns list of helm charts in the specified repository
|
|
GetHelmCharts(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*apiclient.HelmChartsResponse, error)
|
|
// Create creates a repo or a repo credential set
|
|
Create(ctx context.Context, in *RepoCreateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error)
|
|
// CreateRepository creates a new repository configuration
|
|
CreateRepository(ctx context.Context, in *RepoCreateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error)
|
|
// CreateWriteRepository creates a new write repository configuration
|
|
CreateWriteRepository(ctx context.Context, in *RepoCreateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error)
|
|
// Update updates a repo or repo credential set
|
|
Update(ctx context.Context, in *RepoUpdateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error)
|
|
// UpdateRepository updates a repository configuration
|
|
UpdateRepository(ctx context.Context, in *RepoUpdateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error)
|
|
// UpdateWriteRepository updates a write repository configuration
|
|
UpdateWriteRepository(ctx context.Context, in *RepoUpdateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error)
|
|
// Delete deletes a repository from the configuration
|
|
Delete(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*RepoResponse, error)
|
|
// DeleteRepository deletes a repository from the configuration
|
|
DeleteRepository(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*RepoResponse, error)
|
|
// DeleteWriteRepository deletes a write repository from the configuration
|
|
DeleteWriteRepository(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*RepoResponse, error)
|
|
// ValidateAccess validates access to a repository with given parameters
|
|
ValidateAccess(ctx context.Context, in *RepoAccessQuery, opts ...grpc.CallOption) (*RepoResponse, error)
|
|
// ValidateWriteAccess validates write access to a repository with given parameters
|
|
ValidateWriteAccess(ctx context.Context, in *RepoAccessQuery, opts ...grpc.CallOption) (*RepoResponse, error)
|
|
}
|
|
|
|
type repositoryServiceClient struct {
|
|
cc *grpc.ClientConn
|
|
}
|
|
|
|
func NewRepositoryServiceClient(cc *grpc.ClientConn) RepositoryServiceClient {
|
|
return &repositoryServiceClient{cc}
|
|
}
|
|
|
|
// Deprecated: Do not use.
|
|
func (c *repositoryServiceClient) List(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*v1alpha1.RepositoryList, error) {
|
|
out := new(v1alpha1.RepositoryList)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/List", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) Get(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*v1alpha1.Repository, error) {
|
|
out := new(v1alpha1.Repository)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/Get", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) GetWrite(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*v1alpha1.Repository, error) {
|
|
out := new(v1alpha1.Repository)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/GetWrite", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) ListRepositories(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*v1alpha1.RepositoryList, error) {
|
|
out := new(v1alpha1.RepositoryList)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/ListRepositories", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) ListWriteRepositories(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*v1alpha1.RepositoryList, error) {
|
|
out := new(v1alpha1.RepositoryList)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/ListWriteRepositories", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) ListRefs(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*apiclient.Refs, error) {
|
|
out := new(apiclient.Refs)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/ListRefs", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) ListOCITags(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*apiclient.Refs, error) {
|
|
out := new(apiclient.Refs)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/ListOCITags", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) ListApps(ctx context.Context, in *RepoAppsQuery, opts ...grpc.CallOption) (*RepoAppsResponse, error) {
|
|
out := new(RepoAppsResponse)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/ListApps", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) GetAppDetails(ctx context.Context, in *RepoAppDetailsQuery, opts ...grpc.CallOption) (*apiclient.RepoAppDetailsResponse, error) {
|
|
out := new(apiclient.RepoAppDetailsResponse)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/GetAppDetails", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) GetHelmCharts(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*apiclient.HelmChartsResponse, error) {
|
|
out := new(apiclient.HelmChartsResponse)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/GetHelmCharts", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
// Deprecated: Do not use.
|
|
func (c *repositoryServiceClient) Create(ctx context.Context, in *RepoCreateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error) {
|
|
out := new(v1alpha1.Repository)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/Create", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) CreateRepository(ctx context.Context, in *RepoCreateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error) {
|
|
out := new(v1alpha1.Repository)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/CreateRepository", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) CreateWriteRepository(ctx context.Context, in *RepoCreateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error) {
|
|
out := new(v1alpha1.Repository)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/CreateWriteRepository", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
// Deprecated: Do not use.
|
|
func (c *repositoryServiceClient) Update(ctx context.Context, in *RepoUpdateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error) {
|
|
out := new(v1alpha1.Repository)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/Update", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) UpdateRepository(ctx context.Context, in *RepoUpdateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error) {
|
|
out := new(v1alpha1.Repository)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/UpdateRepository", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) UpdateWriteRepository(ctx context.Context, in *RepoUpdateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error) {
|
|
out := new(v1alpha1.Repository)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/UpdateWriteRepository", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
// Deprecated: Do not use.
|
|
func (c *repositoryServiceClient) Delete(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*RepoResponse, error) {
|
|
out := new(RepoResponse)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/Delete", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) DeleteRepository(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*RepoResponse, error) {
|
|
out := new(RepoResponse)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/DeleteRepository", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) DeleteWriteRepository(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*RepoResponse, error) {
|
|
out := new(RepoResponse)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/DeleteWriteRepository", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) ValidateAccess(ctx context.Context, in *RepoAccessQuery, opts ...grpc.CallOption) (*RepoResponse, error) {
|
|
out := new(RepoResponse)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/ValidateAccess", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (c *repositoryServiceClient) ValidateWriteAccess(ctx context.Context, in *RepoAccessQuery, opts ...grpc.CallOption) (*RepoResponse, error) {
|
|
out := new(RepoResponse)
|
|
err := c.cc.Invoke(ctx, "/repository.RepositoryService/ValidateWriteAccess", in, out, opts...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
// RepositoryServiceServer is the server API for RepositoryService service.
|
|
type RepositoryServiceServer interface {
|
|
// List returns list of repos or repository credentials
|
|
List(context.Context, *RepoQuery) (*v1alpha1.RepositoryList, error)
|
|
// Get returns a repository or its credentials
|
|
Get(context.Context, *RepoQuery) (*v1alpha1.Repository, error)
|
|
// GetWrite returns a repository or its write credentials
|
|
GetWrite(context.Context, *RepoQuery) (*v1alpha1.Repository, error)
|
|
// ListRepositories gets a list of all configured repositories
|
|
ListRepositories(context.Context, *RepoQuery) (*v1alpha1.RepositoryList, error)
|
|
// ListWriteRepositories gets a list of all configured write repositories
|
|
ListWriteRepositories(context.Context, *RepoQuery) (*v1alpha1.RepositoryList, error)
|
|
ListRefs(context.Context, *RepoQuery) (*apiclient.Refs, error)
|
|
ListOCITags(context.Context, *RepoQuery) (*apiclient.Refs, 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) (*apiclient.RepoAppDetailsResponse, error)
|
|
// GetHelmCharts returns list of helm charts in the specified repository
|
|
GetHelmCharts(context.Context, *RepoQuery) (*apiclient.HelmChartsResponse, error)
|
|
// Create creates a repo or a repo credential set
|
|
Create(context.Context, *RepoCreateRequest) (*v1alpha1.Repository, error)
|
|
// CreateRepository creates a new repository configuration
|
|
CreateRepository(context.Context, *RepoCreateRequest) (*v1alpha1.Repository, error)
|
|
// CreateWriteRepository creates a new write repository configuration
|
|
CreateWriteRepository(context.Context, *RepoCreateRequest) (*v1alpha1.Repository, error)
|
|
// Update updates a repo or repo credential set
|
|
Update(context.Context, *RepoUpdateRequest) (*v1alpha1.Repository, error)
|
|
// UpdateRepository updates a repository configuration
|
|
UpdateRepository(context.Context, *RepoUpdateRequest) (*v1alpha1.Repository, error)
|
|
// UpdateWriteRepository updates a write repository configuration
|
|
UpdateWriteRepository(context.Context, *RepoUpdateRequest) (*v1alpha1.Repository, error)
|
|
// Delete deletes a repository from the configuration
|
|
Delete(context.Context, *RepoQuery) (*RepoResponse, error)
|
|
// DeleteRepository deletes a repository from the configuration
|
|
DeleteRepository(context.Context, *RepoQuery) (*RepoResponse, error)
|
|
// DeleteWriteRepository deletes a write repository from the configuration
|
|
DeleteWriteRepository(context.Context, *RepoQuery) (*RepoResponse, error)
|
|
// ValidateAccess validates access to a repository with given parameters
|
|
ValidateAccess(context.Context, *RepoAccessQuery) (*RepoResponse, error)
|
|
// ValidateWriteAccess validates write access to a repository with given parameters
|
|
ValidateWriteAccess(context.Context, *RepoAccessQuery) (*RepoResponse, error)
|
|
}
|
|
|
|
// UnimplementedRepositoryServiceServer can be embedded to have forward compatible implementations.
|
|
type UnimplementedRepositoryServiceServer struct {
|
|
}
|
|
|
|
func (*UnimplementedRepositoryServiceServer) List(ctx context.Context, req *RepoQuery) (*v1alpha1.RepositoryList, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method List not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) Get(ctx context.Context, req *RepoQuery) (*v1alpha1.Repository, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method Get not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) GetWrite(ctx context.Context, req *RepoQuery) (*v1alpha1.Repository, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetWrite not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) ListRepositories(ctx context.Context, req *RepoQuery) (*v1alpha1.RepositoryList, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListRepositories not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) ListWriteRepositories(ctx context.Context, req *RepoQuery) (*v1alpha1.RepositoryList, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListWriteRepositories not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) ListRefs(ctx context.Context, req *RepoQuery) (*apiclient.Refs, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListRefs not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) ListOCITags(ctx context.Context, req *RepoQuery) (*apiclient.Refs, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListOCITags not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) ListApps(ctx context.Context, req *RepoAppsQuery) (*RepoAppsResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ListApps not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) GetAppDetails(ctx context.Context, req *RepoAppDetailsQuery) (*apiclient.RepoAppDetailsResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetAppDetails not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) GetHelmCharts(ctx context.Context, req *RepoQuery) (*apiclient.HelmChartsResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method GetHelmCharts not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) Create(ctx context.Context, req *RepoCreateRequest) (*v1alpha1.Repository, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method Create not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) CreateRepository(ctx context.Context, req *RepoCreateRequest) (*v1alpha1.Repository, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method CreateRepository not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) CreateWriteRepository(ctx context.Context, req *RepoCreateRequest) (*v1alpha1.Repository, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method CreateWriteRepository not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) Update(ctx context.Context, req *RepoUpdateRequest) (*v1alpha1.Repository, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method Update not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) UpdateRepository(ctx context.Context, req *RepoUpdateRequest) (*v1alpha1.Repository, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method UpdateRepository not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) UpdateWriteRepository(ctx context.Context, req *RepoUpdateRequest) (*v1alpha1.Repository, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method UpdateWriteRepository not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) Delete(ctx context.Context, req *RepoQuery) (*RepoResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method Delete not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) DeleteRepository(ctx context.Context, req *RepoQuery) (*RepoResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method DeleteRepository not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) DeleteWriteRepository(ctx context.Context, req *RepoQuery) (*RepoResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method DeleteWriteRepository not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) ValidateAccess(ctx context.Context, req *RepoAccessQuery) (*RepoResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ValidateAccess not implemented")
|
|
}
|
|
func (*UnimplementedRepositoryServiceServer) ValidateWriteAccess(ctx context.Context, req *RepoAccessQuery) (*RepoResponse, error) {
|
|
return nil, status.Errorf(codes.Unimplemented, "method ValidateWriteAccess not implemented")
|
|
}
|
|
|
|
func RegisterRepositoryServiceServer(s *grpc.Server, srv RepositoryServiceServer) {
|
|
s.RegisterService(&_RepositoryService_serviceDesc, srv)
|
|
}
|
|
|
|
func _RepositoryService_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).List(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/List",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).List(ctx, req.(*RepoQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).Get(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/Get",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).Get(ctx, req.(*RepoQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_GetWrite_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).GetWrite(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/GetWrite",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).GetWrite(ctx, req.(*RepoQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_ListRepositories_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).ListRepositories(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/ListRepositories",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).ListRepositories(ctx, req.(*RepoQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_ListWriteRepositories_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).ListWriteRepositories(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/ListWriteRepositories",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).ListWriteRepositories(ctx, req.(*RepoQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_ListRefs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).ListRefs(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/ListRefs",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).ListRefs(ctx, req.(*RepoQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_ListOCITags_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).ListOCITags(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/ListOCITags",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).ListOCITags(ctx, req.(*RepoQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_ListApps_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoAppsQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).ListApps(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/ListApps",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).ListApps(ctx, req.(*RepoAppsQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_GetAppDetails_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoAppDetailsQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).GetAppDetails(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/GetAppDetails",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).GetAppDetails(ctx, req.(*RepoAppDetailsQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_GetHelmCharts_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).GetHelmCharts(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/GetHelmCharts",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).GetHelmCharts(ctx, req.(*RepoQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoCreateRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).Create(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/Create",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).Create(ctx, req.(*RepoCreateRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_CreateRepository_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoCreateRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).CreateRepository(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/CreateRepository",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).CreateRepository(ctx, req.(*RepoCreateRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_CreateWriteRepository_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoCreateRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).CreateWriteRepository(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/CreateWriteRepository",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).CreateWriteRepository(ctx, req.(*RepoCreateRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_Update_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoUpdateRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).Update(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/Update",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).Update(ctx, req.(*RepoUpdateRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_UpdateRepository_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoUpdateRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).UpdateRepository(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/UpdateRepository",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).UpdateRepository(ctx, req.(*RepoUpdateRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_UpdateWriteRepository_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoUpdateRequest)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).UpdateWriteRepository(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/UpdateWriteRepository",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).UpdateWriteRepository(ctx, req.(*RepoUpdateRequest))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_Delete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).Delete(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/Delete",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).Delete(ctx, req.(*RepoQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_DeleteRepository_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).DeleteRepository(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/DeleteRepository",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).DeleteRepository(ctx, req.(*RepoQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_DeleteWriteRepository_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).DeleteWriteRepository(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/DeleteWriteRepository",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).DeleteWriteRepository(ctx, req.(*RepoQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_ValidateAccess_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoAccessQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).ValidateAccess(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/ValidateAccess",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).ValidateAccess(ctx, req.(*RepoAccessQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
func _RepositoryService_ValidateWriteAccess_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
in := new(RepoAccessQuery)
|
|
if err := dec(in); err != nil {
|
|
return nil, err
|
|
}
|
|
if interceptor == nil {
|
|
return srv.(RepositoryServiceServer).ValidateWriteAccess(ctx, in)
|
|
}
|
|
info := &grpc.UnaryServerInfo{
|
|
Server: srv,
|
|
FullMethod: "/repository.RepositoryService/ValidateWriteAccess",
|
|
}
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
return srv.(RepositoryServiceServer).ValidateWriteAccess(ctx, req.(*RepoAccessQuery))
|
|
}
|
|
return interceptor(ctx, in, info, handler)
|
|
}
|
|
|
|
var _RepositoryService_serviceDesc = grpc.ServiceDesc{
|
|
ServiceName: "repository.RepositoryService",
|
|
HandlerType: (*RepositoryServiceServer)(nil),
|
|
Methods: []grpc.MethodDesc{
|
|
{
|
|
MethodName: "List",
|
|
Handler: _RepositoryService_List_Handler,
|
|
},
|
|
{
|
|
MethodName: "Get",
|
|
Handler: _RepositoryService_Get_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetWrite",
|
|
Handler: _RepositoryService_GetWrite_Handler,
|
|
},
|
|
{
|
|
MethodName: "ListRepositories",
|
|
Handler: _RepositoryService_ListRepositories_Handler,
|
|
},
|
|
{
|
|
MethodName: "ListWriteRepositories",
|
|
Handler: _RepositoryService_ListWriteRepositories_Handler,
|
|
},
|
|
{
|
|
MethodName: "ListRefs",
|
|
Handler: _RepositoryService_ListRefs_Handler,
|
|
},
|
|
{
|
|
MethodName: "ListOCITags",
|
|
Handler: _RepositoryService_ListOCITags_Handler,
|
|
},
|
|
{
|
|
MethodName: "ListApps",
|
|
Handler: _RepositoryService_ListApps_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetAppDetails",
|
|
Handler: _RepositoryService_GetAppDetails_Handler,
|
|
},
|
|
{
|
|
MethodName: "GetHelmCharts",
|
|
Handler: _RepositoryService_GetHelmCharts_Handler,
|
|
},
|
|
{
|
|
MethodName: "Create",
|
|
Handler: _RepositoryService_Create_Handler,
|
|
},
|
|
{
|
|
MethodName: "CreateRepository",
|
|
Handler: _RepositoryService_CreateRepository_Handler,
|
|
},
|
|
{
|
|
MethodName: "CreateWriteRepository",
|
|
Handler: _RepositoryService_CreateWriteRepository_Handler,
|
|
},
|
|
{
|
|
MethodName: "Update",
|
|
Handler: _RepositoryService_Update_Handler,
|
|
},
|
|
{
|
|
MethodName: "UpdateRepository",
|
|
Handler: _RepositoryService_UpdateRepository_Handler,
|
|
},
|
|
{
|
|
MethodName: "UpdateWriteRepository",
|
|
Handler: _RepositoryService_UpdateWriteRepository_Handler,
|
|
},
|
|
{
|
|
MethodName: "Delete",
|
|
Handler: _RepositoryService_Delete_Handler,
|
|
},
|
|
{
|
|
MethodName: "DeleteRepository",
|
|
Handler: _RepositoryService_DeleteRepository_Handler,
|
|
},
|
|
{
|
|
MethodName: "DeleteWriteRepository",
|
|
Handler: _RepositoryService_DeleteWriteRepository_Handler,
|
|
},
|
|
{
|
|
MethodName: "ValidateAccess",
|
|
Handler: _RepositoryService_ValidateAccess_Handler,
|
|
},
|
|
{
|
|
MethodName: "ValidateWriteAccess",
|
|
Handler: _RepositoryService_ValidateWriteAccess_Handler,
|
|
},
|
|
},
|
|
Streams: []grpc.StreamDesc{},
|
|
Metadata: "server/repository/repository.proto",
|
|
}
|
|
|
|
func (m *RepoAppsQuery) Marshal() (dAtA []byte, err error) {
|
|
size := m.Size()
|
|
dAtA = make([]byte, size)
|
|
n, err := m.MarshalToSizedBuffer(dAtA[:size])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return dAtA[:n], nil
|
|
}
|
|
|
|
func (m *RepoAppsQuery) MarshalTo(dAtA []byte) (int, error) {
|
|
size := m.Size()
|
|
return m.MarshalToSizedBuffer(dAtA[:size])
|
|
}
|
|
|
|
func (m *RepoAppsQuery) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|
i := len(dAtA)
|
|
_ = i
|
|
var l int
|
|
_ = l
|
|
if m.XXX_unrecognized != nil {
|
|
i -= len(m.XXX_unrecognized)
|
|
copy(dAtA[i:], m.XXX_unrecognized)
|
|
}
|
|
if len(m.AppProject) > 0 {
|
|
i -= len(m.AppProject)
|
|
copy(dAtA[i:], m.AppProject)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.AppProject)))
|
|
i--
|
|
dAtA[i] = 0x22
|
|
}
|
|
if len(m.AppName) > 0 {
|
|
i -= len(m.AppName)
|
|
copy(dAtA[i:], m.AppName)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.AppName)))
|
|
i--
|
|
dAtA[i] = 0x1a
|
|
}
|
|
if len(m.Revision) > 0 {
|
|
i -= len(m.Revision)
|
|
copy(dAtA[i:], m.Revision)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.Revision)))
|
|
i--
|
|
dAtA[i] = 0x12
|
|
}
|
|
if len(m.Repo) > 0 {
|
|
i -= len(m.Repo)
|
|
copy(dAtA[i:], m.Repo)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.Repo)))
|
|
i--
|
|
dAtA[i] = 0xa
|
|
}
|
|
return len(dAtA) - i, nil
|
|
}
|
|
|
|
func (m *AppInfo) Marshal() (dAtA []byte, err error) {
|
|
size := m.Size()
|
|
dAtA = make([]byte, size)
|
|
n, err := m.MarshalToSizedBuffer(dAtA[:size])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return dAtA[:n], nil
|
|
}
|
|
|
|
func (m *AppInfo) MarshalTo(dAtA []byte) (int, error) {
|
|
size := m.Size()
|
|
return m.MarshalToSizedBuffer(dAtA[:size])
|
|
}
|
|
|
|
func (m *AppInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|
i := len(dAtA)
|
|
_ = i
|
|
var l int
|
|
_ = l
|
|
if m.XXX_unrecognized != nil {
|
|
i -= len(m.XXX_unrecognized)
|
|
copy(dAtA[i:], m.XXX_unrecognized)
|
|
}
|
|
if len(m.Path) > 0 {
|
|
i -= len(m.Path)
|
|
copy(dAtA[i:], m.Path)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.Path)))
|
|
i--
|
|
dAtA[i] = 0x12
|
|
}
|
|
if len(m.Type) > 0 {
|
|
i -= len(m.Type)
|
|
copy(dAtA[i:], m.Type)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.Type)))
|
|
i--
|
|
dAtA[i] = 0xa
|
|
}
|
|
return len(dAtA) - i, nil
|
|
}
|
|
|
|
func (m *RepoAppDetailsQuery) Marshal() (dAtA []byte, err error) {
|
|
size := m.Size()
|
|
dAtA = make([]byte, size)
|
|
n, err := m.MarshalToSizedBuffer(dAtA[:size])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return dAtA[:n], nil
|
|
}
|
|
|
|
func (m *RepoAppDetailsQuery) MarshalTo(dAtA []byte) (int, error) {
|
|
size := m.Size()
|
|
return m.MarshalToSizedBuffer(dAtA[:size])
|
|
}
|
|
|
|
func (m *RepoAppDetailsQuery) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|
i := len(dAtA)
|
|
_ = i
|
|
var l int
|
|
_ = l
|
|
if m.XXX_unrecognized != nil {
|
|
i -= len(m.XXX_unrecognized)
|
|
copy(dAtA[i:], m.XXX_unrecognized)
|
|
}
|
|
if m.VersionId != 0 {
|
|
i = encodeVarintRepository(dAtA, i, uint64(m.VersionId))
|
|
i--
|
|
dAtA[i] = 0x28
|
|
}
|
|
if m.SourceIndex != 0 {
|
|
i = encodeVarintRepository(dAtA, i, uint64(m.SourceIndex))
|
|
i--
|
|
dAtA[i] = 0x20
|
|
}
|
|
if len(m.AppProject) > 0 {
|
|
i -= len(m.AppProject)
|
|
copy(dAtA[i:], m.AppProject)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.AppProject)))
|
|
i--
|
|
dAtA[i] = 0x1a
|
|
}
|
|
if len(m.AppName) > 0 {
|
|
i -= len(m.AppName)
|
|
copy(dAtA[i:], m.AppName)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.AppName)))
|
|
i--
|
|
dAtA[i] = 0x12
|
|
}
|
|
if m.Source != nil {
|
|
{
|
|
size, err := m.Source.MarshalToSizedBuffer(dAtA[:i])
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
i -= size
|
|
i = encodeVarintRepository(dAtA, i, uint64(size))
|
|
}
|
|
i--
|
|
dAtA[i] = 0xa
|
|
}
|
|
return len(dAtA) - i, nil
|
|
}
|
|
|
|
func (m *RepoAppsResponse) Marshal() (dAtA []byte, err error) {
|
|
size := m.Size()
|
|
dAtA = make([]byte, size)
|
|
n, err := m.MarshalToSizedBuffer(dAtA[:size])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return dAtA[:n], nil
|
|
}
|
|
|
|
func (m *RepoAppsResponse) MarshalTo(dAtA []byte) (int, error) {
|
|
size := m.Size()
|
|
return m.MarshalToSizedBuffer(dAtA[:size])
|
|
}
|
|
|
|
func (m *RepoAppsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|
i := len(dAtA)
|
|
_ = i
|
|
var l int
|
|
_ = l
|
|
if m.XXX_unrecognized != nil {
|
|
i -= len(m.XXX_unrecognized)
|
|
copy(dAtA[i:], m.XXX_unrecognized)
|
|
}
|
|
if len(m.Items) > 0 {
|
|
for iNdEx := len(m.Items) - 1; iNdEx >= 0; iNdEx-- {
|
|
{
|
|
size, err := m.Items[iNdEx].MarshalToSizedBuffer(dAtA[:i])
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
i -= size
|
|
i = encodeVarintRepository(dAtA, i, uint64(size))
|
|
}
|
|
i--
|
|
dAtA[i] = 0xa
|
|
}
|
|
}
|
|
return len(dAtA) - i, nil
|
|
}
|
|
|
|
func (m *RepoQuery) Marshal() (dAtA []byte, err error) {
|
|
size := m.Size()
|
|
dAtA = make([]byte, size)
|
|
n, err := m.MarshalToSizedBuffer(dAtA[:size])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return dAtA[:n], nil
|
|
}
|
|
|
|
func (m *RepoQuery) MarshalTo(dAtA []byte) (int, error) {
|
|
size := m.Size()
|
|
return m.MarshalToSizedBuffer(dAtA[:size])
|
|
}
|
|
|
|
func (m *RepoQuery) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|
i := len(dAtA)
|
|
_ = i
|
|
var l int
|
|
_ = l
|
|
if m.XXX_unrecognized != nil {
|
|
i -= len(m.XXX_unrecognized)
|
|
copy(dAtA[i:], m.XXX_unrecognized)
|
|
}
|
|
if len(m.AppProject) > 0 {
|
|
i -= len(m.AppProject)
|
|
copy(dAtA[i:], m.AppProject)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.AppProject)))
|
|
i--
|
|
dAtA[i] = 0x1a
|
|
}
|
|
if m.ForceRefresh {
|
|
i--
|
|
if m.ForceRefresh {
|
|
dAtA[i] = 1
|
|
} else {
|
|
dAtA[i] = 0
|
|
}
|
|
i--
|
|
dAtA[i] = 0x10
|
|
}
|
|
if len(m.Repo) > 0 {
|
|
i -= len(m.Repo)
|
|
copy(dAtA[i:], m.Repo)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.Repo)))
|
|
i--
|
|
dAtA[i] = 0xa
|
|
}
|
|
return len(dAtA) - i, nil
|
|
}
|
|
|
|
func (m *RepoAccessQuery) Marshal() (dAtA []byte, err error) {
|
|
size := m.Size()
|
|
dAtA = make([]byte, size)
|
|
n, err := m.MarshalToSizedBuffer(dAtA[:size])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return dAtA[:n], nil
|
|
}
|
|
|
|
func (m *RepoAccessQuery) MarshalTo(dAtA []byte) (int, error) {
|
|
size := m.Size()
|
|
return m.MarshalToSizedBuffer(dAtA[:size])
|
|
}
|
|
|
|
func (m *RepoAccessQuery) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|
i := len(dAtA)
|
|
_ = i
|
|
var l int
|
|
_ = l
|
|
if m.XXX_unrecognized != nil {
|
|
i -= len(m.XXX_unrecognized)
|
|
copy(dAtA[i:], m.XXX_unrecognized)
|
|
}
|
|
if len(m.AzureActiveDirectoryEndpoint) > 0 {
|
|
i -= len(m.AzureActiveDirectoryEndpoint)
|
|
copy(dAtA[i:], m.AzureActiveDirectoryEndpoint)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.AzureActiveDirectoryEndpoint)))
|
|
i--
|
|
dAtA[i] = 0x1
|
|
i--
|
|
dAtA[i] = 0xd2
|
|
}
|
|
if len(m.AzureServicePrincipalTenantId) > 0 {
|
|
i -= len(m.AzureServicePrincipalTenantId)
|
|
copy(dAtA[i:], m.AzureServicePrincipalTenantId)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.AzureServicePrincipalTenantId)))
|
|
i--
|
|
dAtA[i] = 0x1
|
|
i--
|
|
dAtA[i] = 0xca
|
|
}
|
|
if len(m.AzureServicePrincipalClientSecret) > 0 {
|
|
i -= len(m.AzureServicePrincipalClientSecret)
|
|
copy(dAtA[i:], m.AzureServicePrincipalClientSecret)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.AzureServicePrincipalClientSecret)))
|
|
i--
|
|
dAtA[i] = 0x1
|
|
i--
|
|
dAtA[i] = 0xc2
|
|
}
|
|
if len(m.AzureServicePrincipalClientId) > 0 {
|
|
i -= len(m.AzureServicePrincipalClientId)
|
|
copy(dAtA[i:], m.AzureServicePrincipalClientId)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.AzureServicePrincipalClientId)))
|
|
i--
|
|
dAtA[i] = 0x1
|
|
i--
|
|
dAtA[i] = 0xba
|
|
}
|
|
if m.InsecureOciForceHttp {
|
|
i--
|
|
if m.InsecureOciForceHttp {
|
|
dAtA[i] = 1
|
|
} else {
|
|
dAtA[i] = 0
|
|
}
|
|
i--
|
|
dAtA[i] = 0x1
|
|
i--
|
|
dAtA[i] = 0xb0
|
|
}
|
|
if len(m.BearerToken) > 0 {
|
|
i -= len(m.BearerToken)
|
|
copy(dAtA[i:], m.BearerToken)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.BearerToken)))
|
|
i--
|
|
dAtA[i] = 0x1
|
|
i--
|
|
dAtA[i] = 0xaa
|
|
}
|
|
if m.UseAzureWorkloadIdentity {
|
|
i--
|
|
if m.UseAzureWorkloadIdentity {
|
|
dAtA[i] = 1
|
|
} else {
|
|
dAtA[i] = 0
|
|
}
|
|
i--
|
|
dAtA[i] = 0x1
|
|
i--
|
|
dAtA[i] = 0xa0
|
|
}
|
|
if m.ForceHttpBasicAuth {
|
|
i--
|
|
if m.ForceHttpBasicAuth {
|
|
dAtA[i] = 1
|
|
} else {
|
|
dAtA[i] = 0
|
|
}
|
|
i--
|
|
dAtA[i] = 0x1
|
|
i--
|
|
dAtA[i] = 0x98
|
|
}
|
|
if len(m.GcpServiceAccountKey) > 0 {
|
|
i -= len(m.GcpServiceAccountKey)
|
|
copy(dAtA[i:], m.GcpServiceAccountKey)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.GcpServiceAccountKey)))
|
|
i--
|
|
dAtA[i] = 0x1
|
|
i--
|
|
dAtA[i] = 0x92
|
|
}
|
|
if len(m.Project) > 0 {
|
|
i -= len(m.Project)
|
|
copy(dAtA[i:], m.Project)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.Project)))
|
|
i--
|
|
dAtA[i] = 0x1
|
|
i--
|
|
dAtA[i] = 0x8a
|
|
}
|
|
if len(m.Proxy) > 0 {
|
|
i -= len(m.Proxy)
|
|
copy(dAtA[i:], m.Proxy)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.Proxy)))
|
|
i--
|
|
dAtA[i] = 0x1
|
|
i--
|
|
dAtA[i] = 0x82
|
|
}
|
|
if len(m.GithubAppEnterpriseBaseUrl) > 0 {
|
|
i -= len(m.GithubAppEnterpriseBaseUrl)
|
|
copy(dAtA[i:], m.GithubAppEnterpriseBaseUrl)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.GithubAppEnterpriseBaseUrl)))
|
|
i--
|
|
dAtA[i] = 0x7a
|
|
}
|
|
if m.GithubAppInstallationID != 0 {
|
|
i = encodeVarintRepository(dAtA, i, uint64(m.GithubAppInstallationID))
|
|
i--
|
|
dAtA[i] = 0x70
|
|
}
|
|
if m.GithubAppID != 0 {
|
|
i = encodeVarintRepository(dAtA, i, uint64(m.GithubAppID))
|
|
i--
|
|
dAtA[i] = 0x68
|
|
}
|
|
if len(m.GithubAppPrivateKey) > 0 {
|
|
i -= len(m.GithubAppPrivateKey)
|
|
copy(dAtA[i:], m.GithubAppPrivateKey)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.GithubAppPrivateKey)))
|
|
i--
|
|
dAtA[i] = 0x62
|
|
}
|
|
if m.EnableOci {
|
|
i--
|
|
if m.EnableOci {
|
|
dAtA[i] = 1
|
|
} else {
|
|
dAtA[i] = 0
|
|
}
|
|
i--
|
|
dAtA[i] = 0x58
|
|
}
|
|
if len(m.Name) > 0 {
|
|
i -= len(m.Name)
|
|
copy(dAtA[i:], m.Name)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.Name)))
|
|
i--
|
|
dAtA[i] = 0x52
|
|
}
|
|
if len(m.Type) > 0 {
|
|
i -= len(m.Type)
|
|
copy(dAtA[i:], m.Type)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.Type)))
|
|
i--
|
|
dAtA[i] = 0x4a
|
|
}
|
|
if len(m.TlsClientCertKey) > 0 {
|
|
i -= len(m.TlsClientCertKey)
|
|
copy(dAtA[i:], m.TlsClientCertKey)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.TlsClientCertKey)))
|
|
i--
|
|
dAtA[i] = 0x3a
|
|
}
|
|
if len(m.TlsClientCertData) > 0 {
|
|
i -= len(m.TlsClientCertData)
|
|
copy(dAtA[i:], m.TlsClientCertData)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.TlsClientCertData)))
|
|
i--
|
|
dAtA[i] = 0x32
|
|
}
|
|
if m.Insecure {
|
|
i--
|
|
if m.Insecure {
|
|
dAtA[i] = 1
|
|
} else {
|
|
dAtA[i] = 0
|
|
}
|
|
i--
|
|
dAtA[i] = 0x28
|
|
}
|
|
if len(m.SshPrivateKey) > 0 {
|
|
i -= len(m.SshPrivateKey)
|
|
copy(dAtA[i:], m.SshPrivateKey)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.SshPrivateKey)))
|
|
i--
|
|
dAtA[i] = 0x22
|
|
}
|
|
if len(m.Password) > 0 {
|
|
i -= len(m.Password)
|
|
copy(dAtA[i:], m.Password)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.Password)))
|
|
i--
|
|
dAtA[i] = 0x1a
|
|
}
|
|
if len(m.Username) > 0 {
|
|
i -= len(m.Username)
|
|
copy(dAtA[i:], m.Username)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.Username)))
|
|
i--
|
|
dAtA[i] = 0x12
|
|
}
|
|
if len(m.Repo) > 0 {
|
|
i -= len(m.Repo)
|
|
copy(dAtA[i:], m.Repo)
|
|
i = encodeVarintRepository(dAtA, i, uint64(len(m.Repo)))
|
|
i--
|
|
dAtA[i] = 0xa
|
|
}
|
|
return len(dAtA) - i, nil
|
|
}
|
|
|
|
func (m *RepoResponse) Marshal() (dAtA []byte, err error) {
|
|
size := m.Size()
|
|
dAtA = make([]byte, size)
|
|
n, err := m.MarshalToSizedBuffer(dAtA[:size])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return dAtA[:n], nil
|
|
}
|
|
|
|
func (m *RepoResponse) MarshalTo(dAtA []byte) (int, error) {
|
|
size := m.Size()
|
|
return m.MarshalToSizedBuffer(dAtA[:size])
|
|
}
|
|
|
|
func (m *RepoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|
i := len(dAtA)
|
|
_ = i
|
|
var l int
|
|
_ = l
|
|
if m.XXX_unrecognized != nil {
|
|
i -= len(m.XXX_unrecognized)
|
|
copy(dAtA[i:], m.XXX_unrecognized)
|
|
}
|
|
return len(dAtA) - i, nil
|
|
}
|
|
|
|
func (m *RepoCreateRequest) Marshal() (dAtA []byte, err error) {
|
|
size := m.Size()
|
|
dAtA = make([]byte, size)
|
|
n, err := m.MarshalToSizedBuffer(dAtA[:size])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return dAtA[:n], nil
|
|
}
|
|
|
|
func (m *RepoCreateRequest) MarshalTo(dAtA []byte) (int, error) {
|
|
size := m.Size()
|
|
return m.MarshalToSizedBuffer(dAtA[:size])
|
|
}
|
|
|
|
func (m *RepoCreateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|
i := len(dAtA)
|
|
_ = i
|
|
var l int
|
|
_ = l
|
|
if m.XXX_unrecognized != nil {
|
|
i -= len(m.XXX_unrecognized)
|
|
copy(dAtA[i:], m.XXX_unrecognized)
|
|
}
|
|
if m.CredsOnly {
|
|
i--
|
|
if m.CredsOnly {
|
|
dAtA[i] = 1
|
|
} else {
|
|
dAtA[i] = 0
|
|
}
|
|
i--
|
|
dAtA[i] = 0x18
|
|
}
|
|
if m.Upsert {
|
|
i--
|
|
if m.Upsert {
|
|
dAtA[i] = 1
|
|
} else {
|
|
dAtA[i] = 0
|
|
}
|
|
i--
|
|
dAtA[i] = 0x10
|
|
}
|
|
if m.Repo != nil {
|
|
{
|
|
size, err := m.Repo.MarshalToSizedBuffer(dAtA[:i])
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
i -= size
|
|
i = encodeVarintRepository(dAtA, i, uint64(size))
|
|
}
|
|
i--
|
|
dAtA[i] = 0xa
|
|
}
|
|
return len(dAtA) - i, nil
|
|
}
|
|
|
|
func (m *RepoUpdateRequest) Marshal() (dAtA []byte, err error) {
|
|
size := m.Size()
|
|
dAtA = make([]byte, size)
|
|
n, err := m.MarshalToSizedBuffer(dAtA[:size])
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return dAtA[:n], nil
|
|
}
|
|
|
|
func (m *RepoUpdateRequest) MarshalTo(dAtA []byte) (int, error) {
|
|
size := m.Size()
|
|
return m.MarshalToSizedBuffer(dAtA[:size])
|
|
}
|
|
|
|
func (m *RepoUpdateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
|
|
i := len(dAtA)
|
|
_ = i
|
|
var l int
|
|
_ = l
|
|
if m.XXX_unrecognized != nil {
|
|
i -= len(m.XXX_unrecognized)
|
|
copy(dAtA[i:], m.XXX_unrecognized)
|
|
}
|
|
if m.Repo != nil {
|
|
{
|
|
size, err := m.Repo.MarshalToSizedBuffer(dAtA[:i])
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
i -= size
|
|
i = encodeVarintRepository(dAtA, i, uint64(size))
|
|
}
|
|
i--
|
|
dAtA[i] = 0xa
|
|
}
|
|
return len(dAtA) - i, nil
|
|
}
|
|
|
|
func encodeVarintRepository(dAtA []byte, offset int, v uint64) int {
|
|
offset -= sovRepository(v)
|
|
base := offset
|
|
for v >= 1<<7 {
|
|
dAtA[offset] = uint8(v&0x7f | 0x80)
|
|
v >>= 7
|
|
offset++
|
|
}
|
|
dAtA[offset] = uint8(v)
|
|
return base
|
|
}
|
|
func (m *RepoAppsQuery) Size() (n int) {
|
|
if m == nil {
|
|
return 0
|
|
}
|
|
var l int
|
|
_ = l
|
|
l = len(m.Repo)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.Revision)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.AppName)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.AppProject)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
if m.XXX_unrecognized != nil {
|
|
n += len(m.XXX_unrecognized)
|
|
}
|
|
return n
|
|
}
|
|
|
|
func (m *AppInfo) Size() (n int) {
|
|
if m == nil {
|
|
return 0
|
|
}
|
|
var l int
|
|
_ = l
|
|
l = len(m.Type)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.Path)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
if m.XXX_unrecognized != nil {
|
|
n += len(m.XXX_unrecognized)
|
|
}
|
|
return n
|
|
}
|
|
|
|
func (m *RepoAppDetailsQuery) Size() (n int) {
|
|
if m == nil {
|
|
return 0
|
|
}
|
|
var l int
|
|
_ = l
|
|
if m.Source != nil {
|
|
l = m.Source.Size()
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.AppName)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.AppProject)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
if m.SourceIndex != 0 {
|
|
n += 1 + sovRepository(uint64(m.SourceIndex))
|
|
}
|
|
if m.VersionId != 0 {
|
|
n += 1 + sovRepository(uint64(m.VersionId))
|
|
}
|
|
if m.XXX_unrecognized != nil {
|
|
n += len(m.XXX_unrecognized)
|
|
}
|
|
return n
|
|
}
|
|
|
|
func (m *RepoAppsResponse) Size() (n int) {
|
|
if m == nil {
|
|
return 0
|
|
}
|
|
var l int
|
|
_ = l
|
|
if len(m.Items) > 0 {
|
|
for _, e := range m.Items {
|
|
l = e.Size()
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
}
|
|
if m.XXX_unrecognized != nil {
|
|
n += len(m.XXX_unrecognized)
|
|
}
|
|
return n
|
|
}
|
|
|
|
func (m *RepoQuery) Size() (n int) {
|
|
if m == nil {
|
|
return 0
|
|
}
|
|
var l int
|
|
_ = l
|
|
l = len(m.Repo)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
if m.ForceRefresh {
|
|
n += 2
|
|
}
|
|
l = len(m.AppProject)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
if m.XXX_unrecognized != nil {
|
|
n += len(m.XXX_unrecognized)
|
|
}
|
|
return n
|
|
}
|
|
|
|
func (m *RepoAccessQuery) Size() (n int) {
|
|
if m == nil {
|
|
return 0
|
|
}
|
|
var l int
|
|
_ = l
|
|
l = len(m.Repo)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.Username)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.Password)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.SshPrivateKey)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
if m.Insecure {
|
|
n += 2
|
|
}
|
|
l = len(m.TlsClientCertData)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.TlsClientCertKey)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.Type)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.Name)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
if m.EnableOci {
|
|
n += 2
|
|
}
|
|
l = len(m.GithubAppPrivateKey)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
if m.GithubAppID != 0 {
|
|
n += 1 + sovRepository(uint64(m.GithubAppID))
|
|
}
|
|
if m.GithubAppInstallationID != 0 {
|
|
n += 1 + sovRepository(uint64(m.GithubAppInstallationID))
|
|
}
|
|
l = len(m.GithubAppEnterpriseBaseUrl)
|
|
if l > 0 {
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.Proxy)
|
|
if l > 0 {
|
|
n += 2 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.Project)
|
|
if l > 0 {
|
|
n += 2 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.GcpServiceAccountKey)
|
|
if l > 0 {
|
|
n += 2 + l + sovRepository(uint64(l))
|
|
}
|
|
if m.ForceHttpBasicAuth {
|
|
n += 3
|
|
}
|
|
if m.UseAzureWorkloadIdentity {
|
|
n += 3
|
|
}
|
|
l = len(m.BearerToken)
|
|
if l > 0 {
|
|
n += 2 + l + sovRepository(uint64(l))
|
|
}
|
|
if m.InsecureOciForceHttp {
|
|
n += 3
|
|
}
|
|
l = len(m.AzureServicePrincipalClientId)
|
|
if l > 0 {
|
|
n += 2 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.AzureServicePrincipalClientSecret)
|
|
if l > 0 {
|
|
n += 2 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.AzureServicePrincipalTenantId)
|
|
if l > 0 {
|
|
n += 2 + l + sovRepository(uint64(l))
|
|
}
|
|
l = len(m.AzureActiveDirectoryEndpoint)
|
|
if l > 0 {
|
|
n += 2 + l + sovRepository(uint64(l))
|
|
}
|
|
if m.XXX_unrecognized != nil {
|
|
n += len(m.XXX_unrecognized)
|
|
}
|
|
return n
|
|
}
|
|
|
|
func (m *RepoResponse) Size() (n int) {
|
|
if m == nil {
|
|
return 0
|
|
}
|
|
var l int
|
|
_ = l
|
|
if m.XXX_unrecognized != nil {
|
|
n += len(m.XXX_unrecognized)
|
|
}
|
|
return n
|
|
}
|
|
|
|
func (m *RepoCreateRequest) Size() (n int) {
|
|
if m == nil {
|
|
return 0
|
|
}
|
|
var l int
|
|
_ = l
|
|
if m.Repo != nil {
|
|
l = m.Repo.Size()
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
if m.Upsert {
|
|
n += 2
|
|
}
|
|
if m.CredsOnly {
|
|
n += 2
|
|
}
|
|
if m.XXX_unrecognized != nil {
|
|
n += len(m.XXX_unrecognized)
|
|
}
|
|
return n
|
|
}
|
|
|
|
func (m *RepoUpdateRequest) Size() (n int) {
|
|
if m == nil {
|
|
return 0
|
|
}
|
|
var l int
|
|
_ = l
|
|
if m.Repo != nil {
|
|
l = m.Repo.Size()
|
|
n += 1 + l + sovRepository(uint64(l))
|
|
}
|
|
if m.XXX_unrecognized != nil {
|
|
n += len(m.XXX_unrecognized)
|
|
}
|
|
return n
|
|
}
|
|
|
|
func sovRepository(x uint64) (n int) {
|
|
return (math_bits.Len64(x|1) + 6) / 7
|
|
}
|
|
func sozRepository(x uint64) (n int) {
|
|
return sovRepository(uint64((x << 1) ^ uint64((int64(x) >> 63))))
|
|
}
|
|
func (m *RepoAppsQuery) Unmarshal(dAtA []byte) error {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
for iNdEx < l {
|
|
preIndex := iNdEx
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
fieldNum := int32(wire >> 3)
|
|
wireType := int(wire & 0x7)
|
|
if wireType == 4 {
|
|
return fmt.Errorf("proto: RepoAppsQuery: wiretype end group for non-group")
|
|
}
|
|
if fieldNum <= 0 {
|
|
return fmt.Errorf("proto: RepoAppsQuery: illegal tag %d (wire type %d)", fieldNum, wire)
|
|
}
|
|
switch fieldNum {
|
|
case 1:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Repo", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Repo = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 2:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Revision", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Revision = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 3:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field AppName", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.AppName = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 4:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field AppProject", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.AppProject = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
default:
|
|
iNdEx = preIndex
|
|
skippy, err := skipRepository(dAtA[iNdEx:])
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if (skippy < 0) || (iNdEx+skippy) < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if (iNdEx + skippy) > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
|
|
iNdEx += skippy
|
|
}
|
|
}
|
|
|
|
if iNdEx > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
return nil
|
|
}
|
|
func (m *AppInfo) Unmarshal(dAtA []byte) error {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
for iNdEx < l {
|
|
preIndex := iNdEx
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
fieldNum := int32(wire >> 3)
|
|
wireType := int(wire & 0x7)
|
|
if wireType == 4 {
|
|
return fmt.Errorf("proto: AppInfo: wiretype end group for non-group")
|
|
}
|
|
if fieldNum <= 0 {
|
|
return fmt.Errorf("proto: AppInfo: illegal tag %d (wire type %d)", fieldNum, wire)
|
|
}
|
|
switch fieldNum {
|
|
case 1:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Type = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 2:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Path", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Path = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
default:
|
|
iNdEx = preIndex
|
|
skippy, err := skipRepository(dAtA[iNdEx:])
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if (skippy < 0) || (iNdEx+skippy) < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if (iNdEx + skippy) > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
|
|
iNdEx += skippy
|
|
}
|
|
}
|
|
|
|
if iNdEx > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
return nil
|
|
}
|
|
func (m *RepoAppDetailsQuery) Unmarshal(dAtA []byte) error {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
for iNdEx < l {
|
|
preIndex := iNdEx
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
fieldNum := int32(wire >> 3)
|
|
wireType := int(wire & 0x7)
|
|
if wireType == 4 {
|
|
return fmt.Errorf("proto: RepoAppDetailsQuery: wiretype end group for non-group")
|
|
}
|
|
if fieldNum <= 0 {
|
|
return fmt.Errorf("proto: RepoAppDetailsQuery: illegal tag %d (wire type %d)", fieldNum, wire)
|
|
}
|
|
switch fieldNum {
|
|
case 1:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Source", wireType)
|
|
}
|
|
var msglen int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
msglen |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if msglen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + msglen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
if m.Source == nil {
|
|
m.Source = &v1alpha1.ApplicationSource{}
|
|
}
|
|
if err := m.Source.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
|
return err
|
|
}
|
|
iNdEx = postIndex
|
|
case 2:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field AppName", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.AppName = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 3:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field AppProject", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.AppProject = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 4:
|
|
if wireType != 0 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field SourceIndex", wireType)
|
|
}
|
|
m.SourceIndex = 0
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
m.SourceIndex |= int32(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
case 5:
|
|
if wireType != 0 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field VersionId", wireType)
|
|
}
|
|
m.VersionId = 0
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
m.VersionId |= int32(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
default:
|
|
iNdEx = preIndex
|
|
skippy, err := skipRepository(dAtA[iNdEx:])
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if (skippy < 0) || (iNdEx+skippy) < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if (iNdEx + skippy) > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
|
|
iNdEx += skippy
|
|
}
|
|
}
|
|
|
|
if iNdEx > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
return nil
|
|
}
|
|
func (m *RepoAppsResponse) Unmarshal(dAtA []byte) error {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
for iNdEx < l {
|
|
preIndex := iNdEx
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
fieldNum := int32(wire >> 3)
|
|
wireType := int(wire & 0x7)
|
|
if wireType == 4 {
|
|
return fmt.Errorf("proto: RepoAppsResponse: wiretype end group for non-group")
|
|
}
|
|
if fieldNum <= 0 {
|
|
return fmt.Errorf("proto: RepoAppsResponse: illegal tag %d (wire type %d)", fieldNum, wire)
|
|
}
|
|
switch fieldNum {
|
|
case 1:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Items", wireType)
|
|
}
|
|
var msglen int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
msglen |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if msglen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + msglen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Items = append(m.Items, &AppInfo{})
|
|
if err := m.Items[len(m.Items)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
|
return err
|
|
}
|
|
iNdEx = postIndex
|
|
default:
|
|
iNdEx = preIndex
|
|
skippy, err := skipRepository(dAtA[iNdEx:])
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if (skippy < 0) || (iNdEx+skippy) < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if (iNdEx + skippy) > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
|
|
iNdEx += skippy
|
|
}
|
|
}
|
|
|
|
if iNdEx > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
return nil
|
|
}
|
|
func (m *RepoQuery) Unmarshal(dAtA []byte) error {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
for iNdEx < l {
|
|
preIndex := iNdEx
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
fieldNum := int32(wire >> 3)
|
|
wireType := int(wire & 0x7)
|
|
if wireType == 4 {
|
|
return fmt.Errorf("proto: RepoQuery: wiretype end group for non-group")
|
|
}
|
|
if fieldNum <= 0 {
|
|
return fmt.Errorf("proto: RepoQuery: illegal tag %d (wire type %d)", fieldNum, wire)
|
|
}
|
|
switch fieldNum {
|
|
case 1:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Repo", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Repo = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 2:
|
|
if wireType != 0 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field ForceRefresh", wireType)
|
|
}
|
|
var v int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
v |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
m.ForceRefresh = bool(v != 0)
|
|
case 3:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field AppProject", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.AppProject = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
default:
|
|
iNdEx = preIndex
|
|
skippy, err := skipRepository(dAtA[iNdEx:])
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if (skippy < 0) || (iNdEx+skippy) < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if (iNdEx + skippy) > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
|
|
iNdEx += skippy
|
|
}
|
|
}
|
|
|
|
if iNdEx > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
return nil
|
|
}
|
|
func (m *RepoAccessQuery) Unmarshal(dAtA []byte) error {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
for iNdEx < l {
|
|
preIndex := iNdEx
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
fieldNum := int32(wire >> 3)
|
|
wireType := int(wire & 0x7)
|
|
if wireType == 4 {
|
|
return fmt.Errorf("proto: RepoAccessQuery: wiretype end group for non-group")
|
|
}
|
|
if fieldNum <= 0 {
|
|
return fmt.Errorf("proto: RepoAccessQuery: illegal tag %d (wire type %d)", fieldNum, wire)
|
|
}
|
|
switch fieldNum {
|
|
case 1:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Repo", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Repo = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 2:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Username", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Username = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 3:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Password", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Password = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 4:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field SshPrivateKey", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.SshPrivateKey = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 5:
|
|
if wireType != 0 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Insecure", wireType)
|
|
}
|
|
var v int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
v |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
m.Insecure = bool(v != 0)
|
|
case 6:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field TlsClientCertData", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.TlsClientCertData = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 7:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field TlsClientCertKey", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.TlsClientCertKey = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 9:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Type = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 10:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Name = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 11:
|
|
if wireType != 0 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field EnableOci", wireType)
|
|
}
|
|
var v int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
v |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
m.EnableOci = bool(v != 0)
|
|
case 12:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field GithubAppPrivateKey", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.GithubAppPrivateKey = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 13:
|
|
if wireType != 0 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field GithubAppID", wireType)
|
|
}
|
|
m.GithubAppID = 0
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
m.GithubAppID |= int64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
case 14:
|
|
if wireType != 0 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field GithubAppInstallationID", wireType)
|
|
}
|
|
m.GithubAppInstallationID = 0
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
m.GithubAppInstallationID |= int64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
case 15:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field GithubAppEnterpriseBaseUrl", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.GithubAppEnterpriseBaseUrl = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 16:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Proxy", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Proxy = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 17:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Project", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.Project = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 18:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field GcpServiceAccountKey", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.GcpServiceAccountKey = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 19:
|
|
if wireType != 0 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field ForceHttpBasicAuth", wireType)
|
|
}
|
|
var v int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
v |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
m.ForceHttpBasicAuth = bool(v != 0)
|
|
case 20:
|
|
if wireType != 0 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field UseAzureWorkloadIdentity", wireType)
|
|
}
|
|
var v int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
v |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
m.UseAzureWorkloadIdentity = bool(v != 0)
|
|
case 21:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field BearerToken", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.BearerToken = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 22:
|
|
if wireType != 0 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field InsecureOciForceHttp", wireType)
|
|
}
|
|
var v int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
v |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
m.InsecureOciForceHttp = bool(v != 0)
|
|
case 23:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field AzureServicePrincipalClientId", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.AzureServicePrincipalClientId = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 24:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field AzureServicePrincipalClientSecret", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.AzureServicePrincipalClientSecret = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 25:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field AzureServicePrincipalTenantId", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.AzureServicePrincipalTenantId = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
case 26:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field AzureActiveDirectoryEndpoint", wireType)
|
|
}
|
|
var stringLen uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
stringLen |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
intStringLen := int(stringLen)
|
|
if intStringLen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + intStringLen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.AzureActiveDirectoryEndpoint = string(dAtA[iNdEx:postIndex])
|
|
iNdEx = postIndex
|
|
default:
|
|
iNdEx = preIndex
|
|
skippy, err := skipRepository(dAtA[iNdEx:])
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if (skippy < 0) || (iNdEx+skippy) < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if (iNdEx + skippy) > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
|
|
iNdEx += skippy
|
|
}
|
|
}
|
|
|
|
if iNdEx > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
return nil
|
|
}
|
|
func (m *RepoResponse) Unmarshal(dAtA []byte) error {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
for iNdEx < l {
|
|
preIndex := iNdEx
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
fieldNum := int32(wire >> 3)
|
|
wireType := int(wire & 0x7)
|
|
if wireType == 4 {
|
|
return fmt.Errorf("proto: RepoResponse: wiretype end group for non-group")
|
|
}
|
|
if fieldNum <= 0 {
|
|
return fmt.Errorf("proto: RepoResponse: illegal tag %d (wire type %d)", fieldNum, wire)
|
|
}
|
|
switch fieldNum {
|
|
default:
|
|
iNdEx = preIndex
|
|
skippy, err := skipRepository(dAtA[iNdEx:])
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if (skippy < 0) || (iNdEx+skippy) < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if (iNdEx + skippy) > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
|
|
iNdEx += skippy
|
|
}
|
|
}
|
|
|
|
if iNdEx > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
return nil
|
|
}
|
|
func (m *RepoCreateRequest) Unmarshal(dAtA []byte) error {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
for iNdEx < l {
|
|
preIndex := iNdEx
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
fieldNum := int32(wire >> 3)
|
|
wireType := int(wire & 0x7)
|
|
if wireType == 4 {
|
|
return fmt.Errorf("proto: RepoCreateRequest: wiretype end group for non-group")
|
|
}
|
|
if fieldNum <= 0 {
|
|
return fmt.Errorf("proto: RepoCreateRequest: illegal tag %d (wire type %d)", fieldNum, wire)
|
|
}
|
|
switch fieldNum {
|
|
case 1:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Repo", wireType)
|
|
}
|
|
var msglen int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
msglen |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if msglen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + msglen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
if m.Repo == nil {
|
|
m.Repo = &v1alpha1.Repository{}
|
|
}
|
|
if err := m.Repo.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
|
return err
|
|
}
|
|
iNdEx = postIndex
|
|
case 2:
|
|
if wireType != 0 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Upsert", wireType)
|
|
}
|
|
var v int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
v |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
m.Upsert = bool(v != 0)
|
|
case 3:
|
|
if wireType != 0 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field CredsOnly", wireType)
|
|
}
|
|
var v int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
v |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
m.CredsOnly = bool(v != 0)
|
|
default:
|
|
iNdEx = preIndex
|
|
skippy, err := skipRepository(dAtA[iNdEx:])
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if (skippy < 0) || (iNdEx+skippy) < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if (iNdEx + skippy) > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
|
|
iNdEx += skippy
|
|
}
|
|
}
|
|
|
|
if iNdEx > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
return nil
|
|
}
|
|
func (m *RepoUpdateRequest) Unmarshal(dAtA []byte) error {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
for iNdEx < l {
|
|
preIndex := iNdEx
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= uint64(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
fieldNum := int32(wire >> 3)
|
|
wireType := int(wire & 0x7)
|
|
if wireType == 4 {
|
|
return fmt.Errorf("proto: RepoUpdateRequest: wiretype end group for non-group")
|
|
}
|
|
if fieldNum <= 0 {
|
|
return fmt.Errorf("proto: RepoUpdateRequest: illegal tag %d (wire type %d)", fieldNum, wire)
|
|
}
|
|
switch fieldNum {
|
|
case 1:
|
|
if wireType != 2 {
|
|
return fmt.Errorf("proto: wrong wireType = %d for field Repo", wireType)
|
|
}
|
|
var msglen int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
msglen |= int(b&0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if msglen < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
postIndex := iNdEx + msglen
|
|
if postIndex < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if postIndex > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
if m.Repo == nil {
|
|
m.Repo = &v1alpha1.Repository{}
|
|
}
|
|
if err := m.Repo.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
|
|
return err
|
|
}
|
|
iNdEx = postIndex
|
|
default:
|
|
iNdEx = preIndex
|
|
skippy, err := skipRepository(dAtA[iNdEx:])
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if (skippy < 0) || (iNdEx+skippy) < 0 {
|
|
return ErrInvalidLengthRepository
|
|
}
|
|
if (iNdEx + skippy) > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
|
|
iNdEx += skippy
|
|
}
|
|
}
|
|
|
|
if iNdEx > l {
|
|
return io.ErrUnexpectedEOF
|
|
}
|
|
return nil
|
|
}
|
|
func skipRepository(dAtA []byte) (n int, err error) {
|
|
l := len(dAtA)
|
|
iNdEx := 0
|
|
depth := 0
|
|
for iNdEx < l {
|
|
var wire uint64
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return 0, ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return 0, io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
wire |= (uint64(b) & 0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
wireType := int(wire & 0x7)
|
|
switch wireType {
|
|
case 0:
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return 0, ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return 0, io.ErrUnexpectedEOF
|
|
}
|
|
iNdEx++
|
|
if dAtA[iNdEx-1] < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
case 1:
|
|
iNdEx += 8
|
|
case 2:
|
|
var length int
|
|
for shift := uint(0); ; shift += 7 {
|
|
if shift >= 64 {
|
|
return 0, ErrIntOverflowRepository
|
|
}
|
|
if iNdEx >= l {
|
|
return 0, io.ErrUnexpectedEOF
|
|
}
|
|
b := dAtA[iNdEx]
|
|
iNdEx++
|
|
length |= (int(b) & 0x7F) << shift
|
|
if b < 0x80 {
|
|
break
|
|
}
|
|
}
|
|
if length < 0 {
|
|
return 0, ErrInvalidLengthRepository
|
|
}
|
|
iNdEx += length
|
|
case 3:
|
|
depth++
|
|
case 4:
|
|
if depth == 0 {
|
|
return 0, ErrUnexpectedEndOfGroupRepository
|
|
}
|
|
depth--
|
|
case 5:
|
|
iNdEx += 4
|
|
default:
|
|
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
|
|
}
|
|
if iNdEx < 0 {
|
|
return 0, ErrInvalidLengthRepository
|
|
}
|
|
if depth == 0 {
|
|
return iNdEx, nil
|
|
}
|
|
}
|
|
return 0, io.ErrUnexpectedEOF
|
|
}
|
|
|
|
var (
|
|
ErrInvalidLengthRepository = fmt.Errorf("proto: negative length found during unmarshaling")
|
|
ErrIntOverflowRepository = fmt.Errorf("proto: integer overflow")
|
|
ErrUnexpectedEndOfGroupRepository = fmt.Errorf("proto: unexpected end of group")
|
|
)
|