project

package
v1.0.0-rc2 Latest Latest
Warning

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

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

Documentation

Overview

Package project is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// JWTTokenSubFormat format of the JWT token subject that Argo CD vends out.
	JWTTokenSubFormat = "proj:%s:%s"
)

Variables

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

Functions

func RegisterProjectServiceHandler 

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

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

func RegisterProjectServiceHandlerClient 

func RegisterProjectServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ProjectServiceClient) error

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

func RegisterProjectServiceHandlerFromEndpoint 

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

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

func RegisterProjectServiceServer 

func RegisterProjectServiceServer(s *grpc.Server, srv ProjectServiceServer)

Types

type EmptyResponse 

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

func (*EmptyResponse) Descriptor 

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

func (*EmptyResponse) Marshal 

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

func (*EmptyResponse) MarshalTo 

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

func (*EmptyResponse) ProtoMessage 

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) Reset 

func (m *EmptyResponse) Reset()

func (*EmptyResponse) Size 

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

func (*EmptyResponse) String 

func (m *EmptyResponse) String() string

func (*EmptyResponse) Unmarshal 

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

func (*EmptyResponse) XXX_DiscardUnknown 

func (m *EmptyResponse) XXX_DiscardUnknown()

func (*EmptyResponse) XXX_Marshal 

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

func (*EmptyResponse) XXX_Merge 

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

func (*EmptyResponse) XXX_Size 

func (m *EmptyResponse) XXX_Size() int

func (*EmptyResponse) XXX_Unmarshal 

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

type ProjectCreateRequest 

type ProjectCreateRequest struct {
	Project              *v1alpha1.AppProject `protobuf:"bytes,1,opt,name=project" json:"project,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

ProjectCreateRequest defines project creation parameters.

func (*ProjectCreateRequest) Descriptor 

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

func (*ProjectCreateRequest) GetProject 

func (m *ProjectCreateRequest) GetProject() *v1alpha1.AppProject

func (*ProjectCreateRequest) Marshal 

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

func (*ProjectCreateRequest) MarshalTo 

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

func (*ProjectCreateRequest) ProtoMessage 

func (*ProjectCreateRequest) ProtoMessage()

func (*ProjectCreateRequest) Reset 

func (m *ProjectCreateRequest) Reset()

func (*ProjectCreateRequest) Size 

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

func (*ProjectCreateRequest) String 

func (m *ProjectCreateRequest) String() string

func (*ProjectCreateRequest) Unmarshal 

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

func (*ProjectCreateRequest) XXX_DiscardUnknown 

func (m *ProjectCreateRequest) XXX_DiscardUnknown()

func (*ProjectCreateRequest) XXX_Marshal 

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

func (*ProjectCreateRequest) XXX_Merge 

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

func (*ProjectCreateRequest) XXX_Size 

func (m *ProjectCreateRequest) XXX_Size() int

func (*ProjectCreateRequest) XXX_Unmarshal 

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

type ProjectQuery 

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

ProjectQuery is a query for Project resources

func (*ProjectQuery) Descriptor 

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

func (*ProjectQuery) GetName 

func (m *ProjectQuery) GetName() string

func (*ProjectQuery) Marshal 

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

func (*ProjectQuery) MarshalTo 

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

func (*ProjectQuery) ProtoMessage 

func (*ProjectQuery) ProtoMessage()

func (*ProjectQuery) Reset 

func (m *ProjectQuery) Reset()

func (*ProjectQuery) Size 

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

func (*ProjectQuery) String 

func (m *ProjectQuery) String() string

func (*ProjectQuery) Unmarshal 

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

func (*ProjectQuery) XXX_DiscardUnknown 

func (m *ProjectQuery) XXX_DiscardUnknown()

func (*ProjectQuery) XXX_Marshal 

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

func (*ProjectQuery) XXX_Merge 

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

func (*ProjectQuery) XXX_Size 

func (m *ProjectQuery) XXX_Size() int

func (*ProjectQuery) XXX_Unmarshal 

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

type ProjectServiceClient 

type ProjectServiceClient interface {
	// Create a new project token.
	CreateToken(ctx context.Context, in *ProjectTokenCreateRequest, opts ...grpc.CallOption) (*ProjectTokenResponse, error)
	// Delete a new project token.
	DeleteToken(ctx context.Context, in *ProjectTokenDeleteRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	// Create a new project.
	Create(ctx context.Context, in *ProjectCreateRequest, opts ...grpc.CallOption) (*v1alpha1.AppProject, error)
	// List returns list of projects
	List(ctx context.Context, in *ProjectQuery, opts ...grpc.CallOption) (*v1alpha1.AppProjectList, error)
	// Get returns a project by name
	Get(ctx context.Context, in *ProjectQuery, opts ...grpc.CallOption) (*v1alpha1.AppProject, error)
	// Update updates a project
	Update(ctx context.Context, in *ProjectUpdateRequest, opts ...grpc.CallOption) (*v1alpha1.AppProject, error)
	// Delete deletes a project
	Delete(ctx context.Context, in *ProjectQuery, opts ...grpc.CallOption) (*EmptyResponse, error)
	// ListEvents returns a list of project events
	ListEvents(ctx context.Context, in *ProjectQuery, opts ...grpc.CallOption) (*v1.EventList, error)
}

func NewProjectServiceClient 

func NewProjectServiceClient(cc *grpc.ClientConn) ProjectServiceClient

type ProjectServiceServer 

type ProjectServiceServer interface {
	// Create a new project token.
	CreateToken(context.Context, *ProjectTokenCreateRequest) (*ProjectTokenResponse, error)
	// Delete a new project token.
	DeleteToken(context.Context, *ProjectTokenDeleteRequest) (*EmptyResponse, error)
	// Create a new project.
	Create(context.Context, *ProjectCreateRequest) (*v1alpha1.AppProject, error)
	// List returns list of projects
	List(context.Context, *ProjectQuery) (*v1alpha1.AppProjectList, error)
	// Get returns a project by name
	Get(context.Context, *ProjectQuery) (*v1alpha1.AppProject, error)
	// Update updates a project
	Update(context.Context, *ProjectUpdateRequest) (*v1alpha1.AppProject, error)
	// Delete deletes a project
	Delete(context.Context, *ProjectQuery) (*EmptyResponse, error)
	// ListEvents returns a list of project events
	ListEvents(context.Context, *ProjectQuery) (*v1.EventList, error)
}

type ProjectTokenCreateRequest 

type ProjectTokenCreateRequest struct {
	Project     string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Role        string `protobuf:"bytes,3,opt,name=role,proto3" json:"role,omitempty"`
	// expiresIn represents a duration in seconds
	ExpiresIn            int64    `protobuf:"varint,4,opt,name=expiresIn,proto3" json:"expiresIn,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ProjectTokenCreateRequest defines project token creation parameters.

func (*ProjectTokenCreateRequest) Descriptor 

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

func (*ProjectTokenCreateRequest) GetDescription 

func (m *ProjectTokenCreateRequest) GetDescription() string

func (*ProjectTokenCreateRequest) GetExpiresIn 

func (m *ProjectTokenCreateRequest) GetExpiresIn() int64

func (*ProjectTokenCreateRequest) GetProject 

func (m *ProjectTokenCreateRequest) GetProject() string

func (*ProjectTokenCreateRequest) GetRole 

func (m *ProjectTokenCreateRequest) GetRole() string

func (*ProjectTokenCreateRequest) Marshal 

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

func (*ProjectTokenCreateRequest) MarshalTo 

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

func (*ProjectTokenCreateRequest) ProtoMessage 

func (*ProjectTokenCreateRequest) ProtoMessage()

func (*ProjectTokenCreateRequest) Reset 

func (m *ProjectTokenCreateRequest) Reset()

func (*ProjectTokenCreateRequest) Size 

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

func (*ProjectTokenCreateRequest) String 

func (m *ProjectTokenCreateRequest) String() string

func (*ProjectTokenCreateRequest) Unmarshal 

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

func (*ProjectTokenCreateRequest) XXX_DiscardUnknown 

func (m *ProjectTokenCreateRequest) XXX_DiscardUnknown()

func (*ProjectTokenCreateRequest) XXX_Marshal 

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

func (*ProjectTokenCreateRequest) XXX_Merge 

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

func (*ProjectTokenCreateRequest) XXX_Size 

func (m *ProjectTokenCreateRequest) XXX_Size() int

func (*ProjectTokenCreateRequest) XXX_Unmarshal 

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

type ProjectTokenDeleteRequest 

type ProjectTokenDeleteRequest struct {
	Project              string   `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Role                 string   `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
	Iat                  int64    `protobuf:"varint,3,opt,name=iat,proto3" json:"iat,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ProjectTokenCreateRequest defines project token deletion parameters.

func (*ProjectTokenDeleteRequest) Descriptor 

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

func (*ProjectTokenDeleteRequest) GetIat 

func (m *ProjectTokenDeleteRequest) GetIat() int64

func (*ProjectTokenDeleteRequest) GetProject 

func (m *ProjectTokenDeleteRequest) GetProject() string

func (*ProjectTokenDeleteRequest) GetRole 

func (m *ProjectTokenDeleteRequest) GetRole() string

func (*ProjectTokenDeleteRequest) Marshal 

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

func (*ProjectTokenDeleteRequest) MarshalTo 

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

func (*ProjectTokenDeleteRequest) ProtoMessage 

func (*ProjectTokenDeleteRequest) ProtoMessage()

func (*ProjectTokenDeleteRequest) Reset 

func (m *ProjectTokenDeleteRequest) Reset()

func (*ProjectTokenDeleteRequest) Size 

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

func (*ProjectTokenDeleteRequest) String 

func (m *ProjectTokenDeleteRequest) String() string

func (*ProjectTokenDeleteRequest) Unmarshal 

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

func (*ProjectTokenDeleteRequest) XXX_DiscardUnknown 

func (m *ProjectTokenDeleteRequest) XXX_DiscardUnknown()

func (*ProjectTokenDeleteRequest) XXX_Marshal 

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

func (*ProjectTokenDeleteRequest) XXX_Merge 

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

func (*ProjectTokenDeleteRequest) XXX_Size 

func (m *ProjectTokenDeleteRequest) XXX_Size() int

func (*ProjectTokenDeleteRequest) XXX_Unmarshal 

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

type ProjectTokenResponse 

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

ProjectTokenResponse wraps the created token or returns an empty string if deleted.

func (*ProjectTokenResponse) Descriptor 

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

func (*ProjectTokenResponse) GetToken 

func (m *ProjectTokenResponse) GetToken() string

func (*ProjectTokenResponse) Marshal 

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

func (*ProjectTokenResponse) MarshalTo 

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

func (*ProjectTokenResponse) ProtoMessage 

func (*ProjectTokenResponse) ProtoMessage()

func (*ProjectTokenResponse) Reset 

func (m *ProjectTokenResponse) Reset()

func (*ProjectTokenResponse) Size 

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

func (*ProjectTokenResponse) String 

func (m *ProjectTokenResponse) String() string

func (*ProjectTokenResponse) Unmarshal 

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

func (*ProjectTokenResponse) XXX_DiscardUnknown 

func (m *ProjectTokenResponse) XXX_DiscardUnknown()

func (*ProjectTokenResponse) XXX_Marshal 

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

func (*ProjectTokenResponse) XXX_Merge 

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

func (*ProjectTokenResponse) XXX_Size 

func (m *ProjectTokenResponse) XXX_Size() int

func (*ProjectTokenResponse) XXX_Unmarshal 

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

type ProjectUpdateRequest 

type ProjectUpdateRequest struct {
	Project              *v1alpha1.AppProject `protobuf:"bytes,1,opt,name=project" json:"project,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ProjectUpdateRequest) Descriptor 

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

func (*ProjectUpdateRequest) GetProject 

func (m *ProjectUpdateRequest) GetProject() *v1alpha1.AppProject

func (*ProjectUpdateRequest) Marshal 

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

func (*ProjectUpdateRequest) MarshalTo 

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

func (*ProjectUpdateRequest) ProtoMessage 

func (*ProjectUpdateRequest) ProtoMessage()

func (*ProjectUpdateRequest) Reset 

func (m *ProjectUpdateRequest) Reset()

func (*ProjectUpdateRequest) Size 

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

func (*ProjectUpdateRequest) String 

func (m *ProjectUpdateRequest) String() string

func (*ProjectUpdateRequest) Unmarshal 

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

func (*ProjectUpdateRequest) XXX_DiscardUnknown 

func (m *ProjectUpdateRequest) XXX_DiscardUnknown()

func (*ProjectUpdateRequest) XXX_Marshal 

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

func (*ProjectUpdateRequest) XXX_Merge 

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

func (*ProjectUpdateRequest) XXX_Size 

func (m *ProjectUpdateRequest) XXX_Size() int

func (*ProjectUpdateRequest) XXX_Unmarshal 

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

type Server 

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

Server provides a Project service

func NewServer 

func NewServer(ns string, kubeclientset kubernetes.Interface, appclientset appclientset.Interface, enf *rbac.Enforcer, projectLock *util.KeyLock, sessionMgr *session.SessionManager) *Server

NewServer returns a new instance of the Project service

func (*Server) Create 

func (s *Server) Create(ctx context.Context, q *ProjectCreateRequest) (*v1alpha1.AppProject, error)

Create a new project.

func (*Server) CreateToken 

func (s *Server) CreateToken(ctx context.Context, q *ProjectTokenCreateRequest) (*ProjectTokenResponse, error)

CreateToken creates a new token to access a project

func (*Server) Delete 

func (s *Server) Delete(ctx context.Context, q *ProjectQuery) (*EmptyResponse, error)

Delete deletes a project

func (*Server) DeleteToken 

func (s *Server) DeleteToken(ctx context.Context, q *ProjectTokenDeleteRequest) (*EmptyResponse, error)

DeleteToken deletes a token in a project

func (*Server) Get 

func (s *Server) Get(ctx context.Context, q *ProjectQuery) (*v1alpha1.AppProject, error)

Get returns a project by name

func (*Server) List 

func (s *Server) List(ctx context.Context, q *ProjectQuery) (*v1alpha1.AppProjectList, error)

List returns list of projects

func (*Server) ListEvents 

func (s *Server) ListEvents(ctx context.Context, q *ProjectQuery) (*v1.EventList, error)

func (*Server) Update 

func (s *Server) Update(ctx context.Context, q *ProjectUpdateRequest) (*v1alpha1.AppProject, error)

Update updates a project

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.