repository

package
v2.14.0-rc3 Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2024 License: Apache-2.0 Imports: 19 Imported by: 20

Documentation

Overview

Package repository is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

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

Functions

func RegisterRepositoryServiceHandler 

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

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

func RegisterRepositoryServiceHandlerClient 

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

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

func RegisterRepositoryServiceHandlerFromEndpoint 

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

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

func RegisterRepositoryServiceHandlerServer 

func RegisterRepositoryServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RepositoryServiceServer) error

RegisterRepositoryServiceHandlerServer registers the http handlers for service RepositoryService to "mux". UnaryRPC :call RepositoryServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterRepositoryServiceHandlerFromEndpoint instead.

func RegisterRepositoryServiceServer 

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

Types

type AppInfo 

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

AppInfo contains application type and app file path

func (*AppInfo) Descriptor 

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

func (*AppInfo) GetPath 

func (m *AppInfo) GetPath() string

func (*AppInfo) GetType 

func (m *AppInfo) GetType() string

func (*AppInfo) Marshal 

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

func (*AppInfo) MarshalTo 

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

func (*AppInfo) MarshalToSizedBuffer 

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

func (*AppInfo) ProtoMessage 

func (*AppInfo) ProtoMessage()

func (*AppInfo) Reset 

func (m *AppInfo) Reset()

func (*AppInfo) Size 

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

func (*AppInfo) String 

func (m *AppInfo) String() string

func (*AppInfo) Unmarshal 

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

func (*AppInfo) XXX_DiscardUnknown 

func (m *AppInfo) XXX_DiscardUnknown()

func (*AppInfo) XXX_Marshal 

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

func (*AppInfo) XXX_Merge 

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

func (*AppInfo) XXX_Size 

func (m *AppInfo) XXX_Size() int

func (*AppInfo) XXX_Unmarshal 

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

type RepoAccessQuery 

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

RepoAccessQuery is a query for checking access to a repo

func (*RepoAccessQuery) Descriptor 

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

func (*RepoAccessQuery) GetEnableOci 

func (m *RepoAccessQuery) GetEnableOci() bool

func (*RepoAccessQuery) GetForceHttpBasicAuth added in v2.6.0 

func (m *RepoAccessQuery) GetForceHttpBasicAuth() bool

func (*RepoAccessQuery) GetGcpServiceAccountKey added in v2.6.0 

func (m *RepoAccessQuery) GetGcpServiceAccountKey() string

func (*RepoAccessQuery) GetGithubAppEnterpriseBaseUrl 

func (m *RepoAccessQuery) GetGithubAppEnterpriseBaseUrl() string

func (*RepoAccessQuery) GetGithubAppID 

func (m *RepoAccessQuery) GetGithubAppID() int64

func (*RepoAccessQuery) GetGithubAppInstallationID 

func (m *RepoAccessQuery) GetGithubAppInstallationID() int64

func (*RepoAccessQuery) GetGithubAppPrivateKey 

func (m *RepoAccessQuery) GetGithubAppPrivateKey() string

func (*RepoAccessQuery) GetInsecure 

func (m *RepoAccessQuery) GetInsecure() bool

func (*RepoAccessQuery) GetName 

func (m *RepoAccessQuery) GetName() string

func (*RepoAccessQuery) GetPassword 

func (m *RepoAccessQuery) GetPassword() string

func (*RepoAccessQuery) GetProject added in v2.2.0 

func (m *RepoAccessQuery) GetProject() string

func (*RepoAccessQuery) GetProxy added in v2.1.0 

func (m *RepoAccessQuery) GetProxy() string

func (*RepoAccessQuery) GetRepo 

func (m *RepoAccessQuery) GetRepo() string

func (*RepoAccessQuery) GetSshPrivateKey 

func (m *RepoAccessQuery) GetSshPrivateKey() string

func (*RepoAccessQuery) GetTlsClientCertData 

func (m *RepoAccessQuery) GetTlsClientCertData() string

func (*RepoAccessQuery) GetTlsClientCertKey 

func (m *RepoAccessQuery) GetTlsClientCertKey() string

func (*RepoAccessQuery) GetType 

func (m *RepoAccessQuery) GetType() string

func (*RepoAccessQuery) GetUsername 

func (m *RepoAccessQuery) GetUsername() string

func (*RepoAccessQuery) Marshal 

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

func (*RepoAccessQuery) MarshalTo 

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

func (*RepoAccessQuery) MarshalToSizedBuffer 

func (m *RepoAccessQuery) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RepoAccessQuery) ProtoMessage 

func (*RepoAccessQuery) ProtoMessage()

func (*RepoAccessQuery) Reset 

func (m *RepoAccessQuery) Reset()

func (*RepoAccessQuery) Size 

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

func (*RepoAccessQuery) String 

func (m *RepoAccessQuery) String() string

func (*RepoAccessQuery) Unmarshal 

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

func (*RepoAccessQuery) XXX_DiscardUnknown 

func (m *RepoAccessQuery) XXX_DiscardUnknown()

func (*RepoAccessQuery) XXX_Marshal 

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

func (*RepoAccessQuery) XXX_Merge 

func (m *RepoAccessQuery) XXX_Merge(src proto.Message)

func (*RepoAccessQuery) XXX_Size 

func (m *RepoAccessQuery) XXX_Size() int

func (*RepoAccessQuery) XXX_Unmarshal 

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

type RepoAppDetailsQuery 

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:"-"`
}

RepoAppDetailsQuery contains query information for app details request

func (*RepoAppDetailsQuery) Descriptor 

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

func (*RepoAppDetailsQuery) GetAppName 

func (m *RepoAppDetailsQuery) GetAppName() string

func (*RepoAppDetailsQuery) GetAppProject added in v2.1.11 

func (m *RepoAppDetailsQuery) GetAppProject() string

func (*RepoAppDetailsQuery) GetSource 

func (m *RepoAppDetailsQuery) GetSource() *v1alpha1.ApplicationSource

func (*RepoAppDetailsQuery) GetSourceIndex added in v2.12.0 

func (m *RepoAppDetailsQuery) GetSourceIndex() int32

func (*RepoAppDetailsQuery) GetVersionId added in v2.12.0 

func (m *RepoAppDetailsQuery) GetVersionId() int32

func (*RepoAppDetailsQuery) Marshal 

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

func (*RepoAppDetailsQuery) MarshalTo 

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

func (*RepoAppDetailsQuery) MarshalToSizedBuffer 

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

func (*RepoAppDetailsQuery) ProtoMessage 

func (*RepoAppDetailsQuery) ProtoMessage()

func (*RepoAppDetailsQuery) Reset 

func (m *RepoAppDetailsQuery) Reset()

func (*RepoAppDetailsQuery) Size 

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

func (*RepoAppDetailsQuery) String 

func (m *RepoAppDetailsQuery) String() string

func (*RepoAppDetailsQuery) Unmarshal 

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

func (*RepoAppDetailsQuery) XXX_DiscardUnknown 

func (m *RepoAppDetailsQuery) XXX_DiscardUnknown()

func (*RepoAppDetailsQuery) XXX_Marshal 

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

func (*RepoAppDetailsQuery) XXX_Merge 

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

func (*RepoAppDetailsQuery) XXX_Size 

func (m *RepoAppDetailsQuery) XXX_Size() int

func (*RepoAppDetailsQuery) XXX_Unmarshal 

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

type RepoAppsQuery 

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:"-"`
}

RepoAppsQuery is a query for Repository apps

func (*RepoAppsQuery) Descriptor 

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

func (*RepoAppsQuery) GetAppName added in v2.1.11 

func (m *RepoAppsQuery) GetAppName() string

func (*RepoAppsQuery) GetAppProject added in v2.1.11 

func (m *RepoAppsQuery) GetAppProject() string

func (*RepoAppsQuery) GetRepo 

func (m *RepoAppsQuery) GetRepo() string

func (*RepoAppsQuery) GetRevision 

func (m *RepoAppsQuery) GetRevision() string

func (*RepoAppsQuery) Marshal 

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

func (*RepoAppsQuery) MarshalTo 

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

func (*RepoAppsQuery) MarshalToSizedBuffer 

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

func (*RepoAppsQuery) ProtoMessage 

func (*RepoAppsQuery) ProtoMessage()

func (*RepoAppsQuery) Reset 

func (m *RepoAppsQuery) Reset()

func (*RepoAppsQuery) Size 

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

func (*RepoAppsQuery) String 

func (m *RepoAppsQuery) String() string

func (*RepoAppsQuery) Unmarshal 

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

func (*RepoAppsQuery) XXX_DiscardUnknown 

func (m *RepoAppsQuery) XXX_DiscardUnknown()

func (*RepoAppsQuery) XXX_Marshal 

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

func (*RepoAppsQuery) XXX_Merge 

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

func (*RepoAppsQuery) XXX_Size 

func (m *RepoAppsQuery) XXX_Size() int

func (*RepoAppsQuery) XXX_Unmarshal 

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

type RepoAppsResponse 

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:"-"`
}

RepoAppsResponse contains applications of specified repository

func (*RepoAppsResponse) Descriptor 

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

func (*RepoAppsResponse) GetItems 

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

func (*RepoAppsResponse) Marshal 

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

func (*RepoAppsResponse) MarshalTo 

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

func (*RepoAppsResponse) MarshalToSizedBuffer 

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

func (*RepoAppsResponse) ProtoMessage 

func (*RepoAppsResponse) ProtoMessage()

func (*RepoAppsResponse) Reset 

func (m *RepoAppsResponse) Reset()

func (*RepoAppsResponse) Size 

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

func (*RepoAppsResponse) String 

func (m *RepoAppsResponse) String() string

func (*RepoAppsResponse) Unmarshal 

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

func (*RepoAppsResponse) XXX_DiscardUnknown 

func (m *RepoAppsResponse) XXX_DiscardUnknown()

func (*RepoAppsResponse) XXX_Marshal 

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

func (*RepoAppsResponse) XXX_Merge 

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

func (*RepoAppsResponse) XXX_Size 

func (m *RepoAppsResponse) XXX_Size() int

func (*RepoAppsResponse) XXX_Unmarshal 

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

type RepoCreateRequest 

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:"-"`
}

RepoCreateRequest is a request for creating repository config

func (*RepoCreateRequest) Descriptor 

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

func (*RepoCreateRequest) GetCredsOnly 

func (m *RepoCreateRequest) GetCredsOnly() bool

func (*RepoCreateRequest) GetRepo 

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

func (*RepoCreateRequest) GetUpsert 

func (m *RepoCreateRequest) GetUpsert() bool

func (*RepoCreateRequest) Marshal 

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

func (*RepoCreateRequest) MarshalTo 

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

func (*RepoCreateRequest) MarshalToSizedBuffer 

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

func (*RepoCreateRequest) ProtoMessage 

func (*RepoCreateRequest) ProtoMessage()

func (*RepoCreateRequest) Reset 

func (m *RepoCreateRequest) Reset()

func (*RepoCreateRequest) Size 

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

func (*RepoCreateRequest) String 

func (m *RepoCreateRequest) String() string

func (*RepoCreateRequest) Unmarshal 

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

func (*RepoCreateRequest) XXX_DiscardUnknown 

func (m *RepoCreateRequest) XXX_DiscardUnknown()

func (*RepoCreateRequest) XXX_Marshal 

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

func (*RepoCreateRequest) XXX_Merge 

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

func (*RepoCreateRequest) XXX_Size 

func (m *RepoCreateRequest) XXX_Size() int

func (*RepoCreateRequest) XXX_Unmarshal 

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

type RepoQuery 

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:"-"`
}

RepoQuery is a query for Repository resources

func (*RepoQuery) Descriptor 

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

func (*RepoQuery) GetAppProject added in v2.12.0 

func (m *RepoQuery) GetAppProject() string

func (*RepoQuery) GetForceRefresh 

func (m *RepoQuery) GetForceRefresh() bool

func (*RepoQuery) GetRepo 

func (m *RepoQuery) GetRepo() string

func (*RepoQuery) Marshal 

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

func (*RepoQuery) MarshalTo 

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

func (*RepoQuery) MarshalToSizedBuffer 

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

func (*RepoQuery) ProtoMessage 

func (*RepoQuery) ProtoMessage()

func (*RepoQuery) Reset 

func (m *RepoQuery) Reset()

func (*RepoQuery) Size 

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

func (*RepoQuery) String 

func (m *RepoQuery) String() string

func (*RepoQuery) Unmarshal 

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

func (*RepoQuery) XXX_DiscardUnknown 

func (m *RepoQuery) XXX_DiscardUnknown()

func (*RepoQuery) XXX_Marshal 

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

func (*RepoQuery) XXX_Merge 

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

func (*RepoQuery) XXX_Size 

func (m *RepoQuery) XXX_Size() int

func (*RepoQuery) XXX_Unmarshal 

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

type RepoResponse 

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

func (*RepoResponse) Descriptor 

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

func (*RepoResponse) Marshal 

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

func (*RepoResponse) MarshalTo 

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

func (*RepoResponse) MarshalToSizedBuffer 

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

func (*RepoResponse) ProtoMessage 

func (*RepoResponse) ProtoMessage()

func (*RepoResponse) Reset 

func (m *RepoResponse) Reset()

func (*RepoResponse) Size 

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

func (*RepoResponse) String 

func (m *RepoResponse) String() string

func (*RepoResponse) Unmarshal 

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

func (*RepoResponse) XXX_DiscardUnknown 

func (m *RepoResponse) XXX_DiscardUnknown()

func (*RepoResponse) XXX_Marshal 

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

func (*RepoResponse) XXX_Merge 

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

func (*RepoResponse) XXX_Size 

func (m *RepoResponse) XXX_Size() int

func (*RepoResponse) XXX_Unmarshal 

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

type RepoUpdateRequest 

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 (*RepoUpdateRequest) Descriptor 

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

func (*RepoUpdateRequest) GetRepo 

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

func (*RepoUpdateRequest) Marshal 

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

func (*RepoUpdateRequest) MarshalTo 

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

func (*RepoUpdateRequest) MarshalToSizedBuffer 

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

func (*RepoUpdateRequest) ProtoMessage 

func (*RepoUpdateRequest) ProtoMessage()

func (*RepoUpdateRequest) Reset 

func (m *RepoUpdateRequest) Reset()

func (*RepoUpdateRequest) Size 

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

func (*RepoUpdateRequest) String 

func (m *RepoUpdateRequest) String() string

func (*RepoUpdateRequest) Unmarshal 

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

func (*RepoUpdateRequest) XXX_DiscardUnknown 

func (m *RepoUpdateRequest) XXX_DiscardUnknown()

func (*RepoUpdateRequest) XXX_Marshal 

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

func (*RepoUpdateRequest) XXX_Merge 

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

func (*RepoUpdateRequest) XXX_Size 

func (m *RepoUpdateRequest) XXX_Size() int

func (*RepoUpdateRequest) XXX_Unmarshal 

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

type RepositoryServiceClient 

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)
	// 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)
}

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.

func NewRepositoryServiceClient 

func NewRepositoryServiceClient(cc *grpc.ClientConn) RepositoryServiceClient

type RepositoryServiceServer 

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)
	// 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)
}

RepositoryServiceServer is the server API for RepositoryService service.

type UnimplementedRepositoryServiceServer 

type UnimplementedRepositoryServiceServer struct {
}

UnimplementedRepositoryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRepositoryServiceServer) Create 

func (*UnimplementedRepositoryServiceServer) Create(ctx context.Context, req *RepoCreateRequest) (*v1alpha1.Repository, error)

func (*UnimplementedRepositoryServiceServer) CreateRepository 

func (*UnimplementedRepositoryServiceServer) CreateRepository(ctx context.Context, req *RepoCreateRequest) (*v1alpha1.Repository, error)

func (*UnimplementedRepositoryServiceServer) CreateWriteRepository 

func (*UnimplementedRepositoryServiceServer) CreateWriteRepository(ctx context.Context, req *RepoCreateRequest) (*v1alpha1.Repository, error)

func (*UnimplementedRepositoryServiceServer) Delete 

func (*UnimplementedRepositoryServiceServer) Delete(ctx context.Context, req *RepoQuery) (*RepoResponse, error)

func (*UnimplementedRepositoryServiceServer) DeleteRepository 

func (*UnimplementedRepositoryServiceServer) DeleteRepository(ctx context.Context, req *RepoQuery) (*RepoResponse, error)

func (*UnimplementedRepositoryServiceServer) DeleteWriteRepository 

func (*UnimplementedRepositoryServiceServer) DeleteWriteRepository(ctx context.Context, req *RepoQuery) (*RepoResponse, error)

func (*UnimplementedRepositoryServiceServer) Get 

func (*UnimplementedRepositoryServiceServer) Get(ctx context.Context, req *RepoQuery) (*v1alpha1.Repository, error)

func (*UnimplementedRepositoryServiceServer) GetAppDetails 

func (*UnimplementedRepositoryServiceServer) GetAppDetails(ctx context.Context, req *RepoAppDetailsQuery) (*apiclient.RepoAppDetailsResponse, error)

func (*UnimplementedRepositoryServiceServer) GetHelmCharts 

func (*UnimplementedRepositoryServiceServer) GetHelmCharts(ctx context.Context, req *RepoQuery) (*apiclient.HelmChartsResponse, error)

func (*UnimplementedRepositoryServiceServer) GetWrite 

func (*UnimplementedRepositoryServiceServer) GetWrite(ctx context.Context, req *RepoQuery) (*v1alpha1.Repository, error)

func (*UnimplementedRepositoryServiceServer) List 

func (*UnimplementedRepositoryServiceServer) List(ctx context.Context, req *RepoQuery) (*v1alpha1.RepositoryList, error)

func (*UnimplementedRepositoryServiceServer) ListApps 

func (*UnimplementedRepositoryServiceServer) ListApps(ctx context.Context, req *RepoAppsQuery) (*RepoAppsResponse, error)

func (*UnimplementedRepositoryServiceServer) ListRefs 

func (*UnimplementedRepositoryServiceServer) ListRefs(ctx context.Context, req *RepoQuery) (*apiclient.Refs, error)

func (*UnimplementedRepositoryServiceServer) ListRepositories 

func (*UnimplementedRepositoryServiceServer) ListRepositories(ctx context.Context, req *RepoQuery) (*v1alpha1.RepositoryList, error)

func (*UnimplementedRepositoryServiceServer) ListWriteRepositories 

func (*UnimplementedRepositoryServiceServer) ListWriteRepositories(ctx context.Context, req *RepoQuery) (*v1alpha1.RepositoryList, error)

func (*UnimplementedRepositoryServiceServer) Update 

func (*UnimplementedRepositoryServiceServer) Update(ctx context.Context, req *RepoUpdateRequest) (*v1alpha1.Repository, error)

func (*UnimplementedRepositoryServiceServer) UpdateRepository 

func (*UnimplementedRepositoryServiceServer) UpdateRepository(ctx context.Context, req *RepoUpdateRequest) (*v1alpha1.Repository, error)

func (*UnimplementedRepositoryServiceServer) UpdateWriteRepository 

func (*UnimplementedRepositoryServiceServer) UpdateWriteRepository(ctx context.Context, req *RepoUpdateRequest) (*v1alpha1.Repository, error)

func (*UnimplementedRepositoryServiceServer) ValidateAccess 

func (*UnimplementedRepositoryServiceServer) ValidateAccess(ctx context.Context, req *RepoAccessQuery) (*RepoResponse, error)

func (*UnimplementedRepositoryServiceServer) ValidateWriteAccess 

func (*UnimplementedRepositoryServiceServer) ValidateWriteAccess(ctx context.Context, req *RepoAccessQuery) (*RepoResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.