repository

package
v0.11.2 Latest Latest
Warning

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

 Go to latest Published: Feb 19, 2019 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Overview

Package repository is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	DefaultRepoStatusCacheExpiration = 1 * time.Hour
)

Variables

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

Functions

func RegisterRepositoryServiceHandler 

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

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

func RegisterRepositoryServiceHandlerClient 

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

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

func RegisterRepositoryServiceHandlerFromEndpoint 

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

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

func RegisterRepositoryServiceServer 

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

Types

type AppInfo added in v0.7.1 

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

AppInfo contains application type and app file path

func (*AppInfo) Descriptor added in v0.7.1 

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

func (*AppInfo) GetPath added in v0.7.1 

func (m *AppInfo) GetPath() string

func (*AppInfo) GetType added in v0.7.1 

func (m *AppInfo) GetType() string

func (*AppInfo) Marshal added in v0.7.1 

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

func (*AppInfo) MarshalTo added in v0.7.1 

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

func (*AppInfo) ProtoMessage added in v0.7.1 

func (*AppInfo) ProtoMessage()

func (*AppInfo) Reset added in v0.7.1 

func (m *AppInfo) Reset()

func (*AppInfo) Size added in v0.7.1 

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

func (*AppInfo) String added in v0.7.1 

func (m *AppInfo) String() string

func (*AppInfo) Unmarshal added in v0.7.1 

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

func (*AppInfo) XXX_DiscardUnknown added in v0.9.0 

func (m *AppInfo) XXX_DiscardUnknown()

func (*AppInfo) XXX_Marshal added in v0.9.0 

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

func (*AppInfo) XXX_Merge added in v0.9.0 

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

func (*AppInfo) XXX_Size added in v0.9.0 

func (m *AppInfo) XXX_Size() int

func (*AppInfo) XXX_Unmarshal added in v0.9.0 

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

type HelmAppSpec added in v0.7.0 

type HelmAppSpec struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Path                 string   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	ValueFiles           []string `protobuf:"bytes,3,rep,name=valueFiles" json:"valueFiles,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

HelmAppSpec contains helm app name and path in source repo

func (*HelmAppSpec) Descriptor added in v0.7.0 

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

func (*HelmAppSpec) GetName added in v0.7.0 

func (m *HelmAppSpec) GetName() string

func (*HelmAppSpec) GetPath added in v0.7.0 

func (m *HelmAppSpec) GetPath() string

func (*HelmAppSpec) GetValueFiles added in v0.7.1 

func (m *HelmAppSpec) GetValueFiles() []string

func (*HelmAppSpec) Marshal added in v0.7.0 

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

func (*HelmAppSpec) MarshalTo added in v0.7.0 

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

func (*HelmAppSpec) ProtoMessage added in v0.7.0 

func (*HelmAppSpec) ProtoMessage()

func (*HelmAppSpec) Reset added in v0.7.0 

func (m *HelmAppSpec) Reset()

func (*HelmAppSpec) Size added in v0.7.0 

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

func (*HelmAppSpec) String added in v0.7.0 

func (m *HelmAppSpec) String() string

func (*HelmAppSpec) Unmarshal added in v0.7.0 

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

func (*HelmAppSpec) XXX_DiscardUnknown added in v0.9.0 

func (m *HelmAppSpec) XXX_DiscardUnknown()

func (*HelmAppSpec) XXX_Marshal added in v0.9.0 

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

func (*HelmAppSpec) XXX_Merge added in v0.9.0 

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

func (*HelmAppSpec) XXX_Size added in v0.9.0 

func (m *HelmAppSpec) XXX_Size() int

func (*HelmAppSpec) XXX_Unmarshal added in v0.9.0 

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

type KsonnetAppSpec added in v0.4.4 

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

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

func (*KsonnetAppSpec) Descriptor added in v0.4.4 

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

func (*KsonnetAppSpec) GetEnvironments added in v0.4.4 

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

func (*KsonnetAppSpec) GetName added in v0.4.4 

func (m *KsonnetAppSpec) GetName() string

func (*KsonnetAppSpec) GetPath added in v0.5.0 

func (m *KsonnetAppSpec) GetPath() string

func (*KsonnetAppSpec) Marshal added in v0.4.4 

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

func (*KsonnetAppSpec) MarshalTo added in v0.4.4 

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

func (*KsonnetAppSpec) ProtoMessage added in v0.4.4 

func (*KsonnetAppSpec) ProtoMessage()

func (*KsonnetAppSpec) Reset added in v0.4.4 

func (m *KsonnetAppSpec) Reset()

func (*KsonnetAppSpec) Size added in v0.4.4 

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

func (*KsonnetAppSpec) String added in v0.4.4 

func (m *KsonnetAppSpec) String() string

func (*KsonnetAppSpec) Unmarshal added in v0.4.4 

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

func (*KsonnetAppSpec) XXX_DiscardUnknown added in v0.9.0 

func (m *KsonnetAppSpec) XXX_DiscardUnknown()

func (*KsonnetAppSpec) XXX_Marshal added in v0.9.0 

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

func (*KsonnetAppSpec) XXX_Merge added in v0.9.0 

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

func (*KsonnetAppSpec) XXX_Size added in v0.9.0 

func (m *KsonnetAppSpec) XXX_Size() int

func (*KsonnetAppSpec) XXX_Unmarshal added in v0.9.0 

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

type KsonnetEnvironment added in v0.4.4 

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

func (*KsonnetEnvironment) Descriptor added in v0.4.4 

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

func (*KsonnetEnvironment) GetDestination added in v0.4.4 

func (m *KsonnetEnvironment) GetDestination() *KsonnetEnvironmentDestination

func (*KsonnetEnvironment) GetK8SVersion added in v0.4.4 

func (m *KsonnetEnvironment) GetK8SVersion() string

func (*KsonnetEnvironment) GetName added in v0.4.4 

func (m *KsonnetEnvironment) GetName() string

func (*KsonnetEnvironment) GetPath added in v0.4.4 

func (m *KsonnetEnvironment) GetPath() string

func (*KsonnetEnvironment) Marshal added in v0.4.4 

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

func (*KsonnetEnvironment) MarshalTo added in v0.4.4 

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

func (*KsonnetEnvironment) ProtoMessage added in v0.4.4 

func (*KsonnetEnvironment) ProtoMessage()

func (*KsonnetEnvironment) Reset added in v0.4.4 

func (m *KsonnetEnvironment) Reset()

func (*KsonnetEnvironment) Size added in v0.4.4 

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

func (*KsonnetEnvironment) String added in v0.4.4 

func (m *KsonnetEnvironment) String() string

func (*KsonnetEnvironment) Unmarshal added in v0.4.4 

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

func (*KsonnetEnvironment) XXX_DiscardUnknown added in v0.9.0 

func (m *KsonnetEnvironment) XXX_DiscardUnknown()

func (*KsonnetEnvironment) XXX_Marshal added in v0.9.0 

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

func (*KsonnetEnvironment) XXX_Merge added in v0.9.0 

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

func (*KsonnetEnvironment) XXX_Size added in v0.9.0 

func (m *KsonnetEnvironment) XXX_Size() int

func (*KsonnetEnvironment) XXX_Unmarshal added in v0.9.0 

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

type KsonnetEnvironmentDestination added in v0.4.4 

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

func (*KsonnetEnvironmentDestination) Descriptor added in v0.4.4 

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

func (*KsonnetEnvironmentDestination) GetNamespace added in v0.4.4 

func (m *KsonnetEnvironmentDestination) GetNamespace() string

func (*KsonnetEnvironmentDestination) GetServer added in v0.4.4 

func (m *KsonnetEnvironmentDestination) GetServer() string

func (*KsonnetEnvironmentDestination) Marshal added in v0.4.4 

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

func (*KsonnetEnvironmentDestination) MarshalTo added in v0.4.4 

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

func (*KsonnetEnvironmentDestination) ProtoMessage added in v0.4.4 

func (*KsonnetEnvironmentDestination) ProtoMessage()

func (*KsonnetEnvironmentDestination) Reset added in v0.4.4 

func (m *KsonnetEnvironmentDestination) Reset()

func (*KsonnetEnvironmentDestination) Size added in v0.4.4 

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

func (*KsonnetEnvironmentDestination) String added in v0.4.4 

func (m *KsonnetEnvironmentDestination) String() string

func (*KsonnetEnvironmentDestination) Unmarshal added in v0.4.4 

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

func (*KsonnetEnvironmentDestination) XXX_DiscardUnknown added in v0.9.0 

func (m *KsonnetEnvironmentDestination) XXX_DiscardUnknown()

func (*KsonnetEnvironmentDestination) XXX_Marshal added in v0.9.0 

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

func (*KsonnetEnvironmentDestination) XXX_Merge added in v0.9.0 

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

func (*KsonnetEnvironmentDestination) XXX_Size added in v0.9.0 

func (m *KsonnetEnvironmentDestination) XXX_Size() int

func (*KsonnetEnvironmentDestination) XXX_Unmarshal added in v0.9.0 

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

type KustomizeAppSpec added in v0.8.0 

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

KustomizeAppSpec contains kustomize app name and path in source repo

func (*KustomizeAppSpec) Descriptor added in v0.8.0 

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

func (*KustomizeAppSpec) GetPath added in v0.8.0 

func (m *KustomizeAppSpec) GetPath() string

func (*KustomizeAppSpec) Marshal added in v0.8.0 

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

func (*KustomizeAppSpec) MarshalTo added in v0.8.0 

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

func (*KustomizeAppSpec) ProtoMessage added in v0.8.0 

func (*KustomizeAppSpec) ProtoMessage()

func (*KustomizeAppSpec) Reset added in v0.8.0 

func (m *KustomizeAppSpec) Reset()

func (*KustomizeAppSpec) Size added in v0.8.0 

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

func (*KustomizeAppSpec) String added in v0.8.0 

func (m *KustomizeAppSpec) String() string

func (*KustomizeAppSpec) Unmarshal added in v0.8.0 

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

func (*KustomizeAppSpec) XXX_DiscardUnknown added in v0.9.0 

func (m *KustomizeAppSpec) XXX_DiscardUnknown()

func (*KustomizeAppSpec) XXX_Marshal added in v0.9.0 

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

func (*KustomizeAppSpec) XXX_Merge added in v0.9.0 

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

func (*KustomizeAppSpec) XXX_Size added in v0.9.0 

func (m *KustomizeAppSpec) XXX_Size() int

func (*KustomizeAppSpec) XXX_Unmarshal added in v0.9.0 

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

type RepoAppDetailsQuery added in v0.7.1 

type RepoAppDetailsQuery struct {
	Repo                 string   `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	Revision             string   `protobuf:"bytes,2,opt,name=revision,proto3" json:"revision,omitempty"`
	Path                 string   `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RepoAppDetailsQuery contains query information for app details request

func (*RepoAppDetailsQuery) Descriptor added in v0.7.1 

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

func (*RepoAppDetailsQuery) GetPath added in v0.7.1 

func (m *RepoAppDetailsQuery) GetPath() string

func (*RepoAppDetailsQuery) GetRepo added in v0.7.1 

func (m *RepoAppDetailsQuery) GetRepo() string

func (*RepoAppDetailsQuery) GetRevision added in v0.7.1 

func (m *RepoAppDetailsQuery) GetRevision() string

func (*RepoAppDetailsQuery) Marshal added in v0.7.1 

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

func (*RepoAppDetailsQuery) MarshalTo added in v0.7.1 

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

func (*RepoAppDetailsQuery) ProtoMessage added in v0.7.1 

func (*RepoAppDetailsQuery) ProtoMessage()

func (*RepoAppDetailsQuery) Reset added in v0.7.1 

func (m *RepoAppDetailsQuery) Reset()

func (*RepoAppDetailsQuery) Size added in v0.7.1 

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

func (*RepoAppDetailsQuery) String added in v0.7.1 

func (m *RepoAppDetailsQuery) String() string

func (*RepoAppDetailsQuery) Unmarshal added in v0.7.1 

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

func (*RepoAppDetailsQuery) XXX_DiscardUnknown added in v0.9.0 

func (m *RepoAppDetailsQuery) XXX_DiscardUnknown()

func (*RepoAppDetailsQuery) XXX_Marshal added in v0.9.0 

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

func (*RepoAppDetailsQuery) XXX_Merge added in v0.9.0 

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

func (*RepoAppDetailsQuery) XXX_Size added in v0.9.0 

func (m *RepoAppDetailsQuery) XXX_Size() int

func (*RepoAppDetailsQuery) XXX_Unmarshal added in v0.9.0 

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

type RepoAppDetailsResponse added in v0.7.1 

type RepoAppDetailsResponse struct {
	Type                 string            `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Ksonnet              *KsonnetAppSpec   `protobuf:"bytes,2,opt,name=ksonnet" json:"ksonnet,omitempty"`
	Helm                 *HelmAppSpec      `protobuf:"bytes,3,opt,name=helm" json:"helm,omitempty"`
	Kustomize            *KustomizeAppSpec `protobuf:"bytes,4,opt,name=kustomize" json:"kustomize,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

RepoAppDetailsResponse application details

func (*RepoAppDetailsResponse) Descriptor added in v0.7.1 

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

func (*RepoAppDetailsResponse) GetHelm added in v0.7.1 

func (m *RepoAppDetailsResponse) GetHelm() *HelmAppSpec

func (*RepoAppDetailsResponse) GetKsonnet added in v0.7.1 

func (m *RepoAppDetailsResponse) GetKsonnet() *KsonnetAppSpec

func (*RepoAppDetailsResponse) GetKustomize added in v0.8.0 

func (m *RepoAppDetailsResponse) GetKustomize() *KustomizeAppSpec

func (*RepoAppDetailsResponse) GetType added in v0.7.1 

func (m *RepoAppDetailsResponse) GetType() string

func (*RepoAppDetailsResponse) Marshal added in v0.7.1 

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

func (*RepoAppDetailsResponse) MarshalTo added in v0.7.1 

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

func (*RepoAppDetailsResponse) ProtoMessage added in v0.7.1 

func (*RepoAppDetailsResponse) ProtoMessage()

func (*RepoAppDetailsResponse) Reset added in v0.7.1 

func (m *RepoAppDetailsResponse) Reset()

func (*RepoAppDetailsResponse) Size added in v0.7.1 

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

func (*RepoAppDetailsResponse) String added in v0.7.1 

func (m *RepoAppDetailsResponse) String() string

func (*RepoAppDetailsResponse) Unmarshal added in v0.7.1 

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

func (*RepoAppDetailsResponse) XXX_DiscardUnknown added in v0.9.0 

func (m *RepoAppDetailsResponse) XXX_DiscardUnknown()

func (*RepoAppDetailsResponse) XXX_Marshal added in v0.9.0 

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

func (*RepoAppDetailsResponse) XXX_Merge added in v0.9.0 

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

func (*RepoAppDetailsResponse) XXX_Size added in v0.9.0 

func (m *RepoAppDetailsResponse) XXX_Size() int

func (*RepoAppDetailsResponse) XXX_Unmarshal added in v0.9.0 

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

type RepoAppsQuery added in v0.7.0 

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

RepoAppsQuery is a query for Repository apps

func (*RepoAppsQuery) Descriptor added in v0.7.0 

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

func (*RepoAppsQuery) GetRepo added in v0.7.0 

func (m *RepoAppsQuery) GetRepo() string

func (*RepoAppsQuery) GetRevision added in v0.7.0 

func (m *RepoAppsQuery) GetRevision() string

func (*RepoAppsQuery) Marshal added in v0.7.0 

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

func (*RepoAppsQuery) MarshalTo added in v0.7.0 

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

func (*RepoAppsQuery) ProtoMessage added in v0.7.0 

func (*RepoAppsQuery) ProtoMessage()

func (*RepoAppsQuery) Reset added in v0.7.0 

func (m *RepoAppsQuery) Reset()

func (*RepoAppsQuery) Size added in v0.7.0 

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

func (*RepoAppsQuery) String added in v0.7.0 

func (m *RepoAppsQuery) String() string

func (*RepoAppsQuery) Unmarshal added in v0.7.0 

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

func (*RepoAppsQuery) XXX_DiscardUnknown added in v0.9.0 

func (m *RepoAppsQuery) XXX_DiscardUnknown()

func (*RepoAppsQuery) XXX_Marshal added in v0.9.0 

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

func (*RepoAppsQuery) XXX_Merge added in v0.9.0 

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

func (*RepoAppsQuery) XXX_Size added in v0.9.0 

func (m *RepoAppsQuery) XXX_Size() int

func (*RepoAppsQuery) XXX_Unmarshal added in v0.9.0 

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

type RepoAppsResponse added in v0.7.0 

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

RepoAppsResponse contains applications of specified repository

func (*RepoAppsResponse) Descriptor added in v0.7.0 

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

func (*RepoAppsResponse) GetItems added in v0.7.1 

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

func (*RepoAppsResponse) Marshal added in v0.7.0 

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

func (*RepoAppsResponse) MarshalTo added in v0.7.0 

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

func (*RepoAppsResponse) ProtoMessage added in v0.7.0 

func (*RepoAppsResponse) ProtoMessage()

func (*RepoAppsResponse) Reset added in v0.7.0 

func (m *RepoAppsResponse) Reset()

func (*RepoAppsResponse) Size added in v0.7.0 

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

func (*RepoAppsResponse) String added in v0.7.0 

func (m *RepoAppsResponse) String() string

func (*RepoAppsResponse) Unmarshal added in v0.7.0 

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

func (*RepoAppsResponse) XXX_DiscardUnknown added in v0.9.0 

func (m *RepoAppsResponse) XXX_DiscardUnknown()

func (*RepoAppsResponse) XXX_Marshal added in v0.9.0 

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

func (*RepoAppsResponse) XXX_Merge added in v0.9.0 

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

func (*RepoAppsResponse) XXX_Size added in v0.9.0 

func (m *RepoAppsResponse) XXX_Size() int

func (*RepoAppsResponse) XXX_Unmarshal added in v0.9.0 

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

type RepoCreateRequest added in v0.5.0 

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

func (*RepoCreateRequest) Descriptor added in v0.5.0 

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

func (*RepoCreateRequest) GetRepo added in v0.5.0 

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

func (*RepoCreateRequest) GetUpsert added in v0.6.0 

func (m *RepoCreateRequest) GetUpsert() bool

func (*RepoCreateRequest) Marshal added in v0.5.0 

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

func (*RepoCreateRequest) MarshalTo added in v0.5.0 

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

func (*RepoCreateRequest) ProtoMessage added in v0.5.0 

func (*RepoCreateRequest) ProtoMessage()

func (*RepoCreateRequest) Reset added in v0.5.0 

func (m *RepoCreateRequest) Reset()

func (*RepoCreateRequest) Size added in v0.5.0 

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

func (*RepoCreateRequest) String added in v0.5.0 

func (m *RepoCreateRequest) String() string

func (*RepoCreateRequest) Unmarshal added in v0.5.0 

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

func (*RepoCreateRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *RepoCreateRequest) XXX_DiscardUnknown()

func (*RepoCreateRequest) XXX_Marshal added in v0.9.0 

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

func (*RepoCreateRequest) XXX_Merge added in v0.9.0 

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

func (*RepoCreateRequest) XXX_Size added in v0.9.0 

func (m *RepoCreateRequest) XXX_Size() int

func (*RepoCreateRequest) XXX_Unmarshal added in v0.9.0 

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

type RepoQuery 

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

RepoQuery is a query for Repository resources

func (*RepoQuery) Descriptor 

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

func (*RepoQuery) GetRepo 

func (m *RepoQuery) GetRepo() string

func (*RepoQuery) Marshal added in v0.3.1 

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

func (*RepoQuery) MarshalTo added in v0.3.1 

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

func (*RepoQuery) ProtoMessage 

func (*RepoQuery) ProtoMessage()

func (*RepoQuery) Reset 

func (m *RepoQuery) Reset()

func (*RepoQuery) Size added in v0.3.1 

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

func (*RepoQuery) String 

func (m *RepoQuery) String() string

func (*RepoQuery) Unmarshal added in v0.3.1 

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

func (*RepoQuery) XXX_DiscardUnknown added in v0.9.0 

func (m *RepoQuery) XXX_DiscardUnknown()

func (*RepoQuery) XXX_Marshal added in v0.9.0 

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

func (*RepoQuery) XXX_Merge added in v0.9.0 

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

func (*RepoQuery) XXX_Size added in v0.9.0 

func (m *RepoQuery) XXX_Size() int

func (*RepoQuery) XXX_Unmarshal added in v0.9.0 

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

type RepoResponse 

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

func (*RepoResponse) Descriptor 

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

func (*RepoResponse) Marshal added in v0.3.1 

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

func (*RepoResponse) MarshalTo added in v0.3.1 

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

func (*RepoResponse) ProtoMessage 

func (*RepoResponse) ProtoMessage()

func (*RepoResponse) Reset 

func (m *RepoResponse) Reset()

func (*RepoResponse) Size added in v0.3.1 

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

func (*RepoResponse) String 

func (m *RepoResponse) String() string

func (*RepoResponse) Unmarshal added in v0.3.1 

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

func (*RepoResponse) XXX_DiscardUnknown added in v0.9.0 

func (m *RepoResponse) XXX_DiscardUnknown()

func (*RepoResponse) XXX_Marshal added in v0.9.0 

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

func (*RepoResponse) XXX_Merge added in v0.9.0 

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

func (*RepoResponse) XXX_Size added in v0.9.0 

func (m *RepoResponse) XXX_Size() int

func (*RepoResponse) XXX_Unmarshal added in v0.9.0 

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

type RepoUpdateRequest 

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

func (*RepoUpdateRequest) Descriptor 

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

func (*RepoUpdateRequest) GetRepo 

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

func (*RepoUpdateRequest) Marshal added in v0.3.1 

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

func (*RepoUpdateRequest) MarshalTo added in v0.3.1 

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

func (*RepoUpdateRequest) ProtoMessage 

func (*RepoUpdateRequest) ProtoMessage()

func (*RepoUpdateRequest) Reset 

func (m *RepoUpdateRequest) Reset()

func (*RepoUpdateRequest) Size added in v0.3.1 

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

func (*RepoUpdateRequest) String 

func (m *RepoUpdateRequest) String() string

func (*RepoUpdateRequest) Unmarshal added in v0.3.1 

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

func (*RepoUpdateRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *RepoUpdateRequest) XXX_DiscardUnknown()

func (*RepoUpdateRequest) XXX_Marshal added in v0.9.0 

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

func (*RepoUpdateRequest) XXX_Merge added in v0.9.0 

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

func (*RepoUpdateRequest) XXX_Size added in v0.9.0 

func (m *RepoUpdateRequest) XXX_Size() int

func (*RepoUpdateRequest) XXX_Unmarshal added in v0.9.0 

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

type RepositoryServiceClient 

type RepositoryServiceClient interface {
	// List returns list of repos
	List(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*v1alpha1.RepositoryList, error)
	// ListApps returns list of apps in the repo
	ListApps(ctx context.Context, in *RepoAppsQuery, opts ...grpc.CallOption) (*RepoAppsResponse, error)
	// GetAppDetails returns application details by given path
	GetAppDetails(ctx context.Context, in *RepoAppDetailsQuery, opts ...grpc.CallOption) (*RepoAppDetailsResponse, error)
	// Create creates a repo
	Create(ctx context.Context, in *RepoCreateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error)
	// Update updates a repo
	Update(ctx context.Context, in *RepoUpdateRequest, opts ...grpc.CallOption) (*v1alpha1.Repository, error)
	// Delete deletes a repo
	Delete(ctx context.Context, in *RepoQuery, opts ...grpc.CallOption) (*RepoResponse, error)
}

func NewRepositoryServiceClient 

func NewRepositoryServiceClient(cc *grpc.ClientConn) RepositoryServiceClient

type RepositoryServiceServer 

type RepositoryServiceServer interface {
	// List returns list of repos
	List(context.Context, *RepoQuery) (*v1alpha1.RepositoryList, error)
	// ListApps returns list of apps in the repo
	ListApps(context.Context, *RepoAppsQuery) (*RepoAppsResponse, error)
	// GetAppDetails returns application details by given path
	GetAppDetails(context.Context, *RepoAppDetailsQuery) (*RepoAppDetailsResponse, error)
	// Create creates a repo
	Create(context.Context, *RepoCreateRequest) (*v1alpha1.Repository, error)
	// Update updates a repo
	Update(context.Context, *RepoUpdateRequest) (*v1alpha1.Repository, error)
	// Delete deletes a repo
	Delete(context.Context, *RepoQuery) (*RepoResponse, error)
}

type Server 

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

Server provides a Repository service

func NewServer 

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

NewServer returns a new instance of the Repository service

func (*Server) Create 

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

Create creates a repository

func (*Server) Delete 

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

Delete updates a repository

func (*Server) GetAppDetails added in v0.7.1 

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

func (*Server) List 

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

List returns list of repositories

func (*Server) ListApps added in v0.7.0 

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

ListKsonnetApps returns list of Ksonnet apps in the repo

func (*Server) Update 

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

Update updates a repository

Source Files

View all Source files

Jump to

Keyboard shortcuts

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