rpcv3

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Aug 9, 2022 License: Apache-2.0 Imports: 22 Imported by: 2

Documentation

Overview

Package rpcv3 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package rpcv3 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package rpcv3 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package rpcv3 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package rpcv3 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package rpcv3 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_rpc_system_idp_proto protoreflect.FileDescriptor
View Source 
var File_proto_rpc_system_metro_proto protoreflect.FileDescriptor
View Source 
var File_proto_rpc_system_oidc_provider_proto protoreflect.FileDescriptor
View Source 
var File_proto_rpc_system_organization_proto protoreflect.FileDescriptor
View Source 
var File_proto_rpc_system_partner_proto protoreflect.FileDescriptor
View Source 
var File_proto_rpc_system_project_proto protoreflect.FileDescriptor
View Source 
var Idp_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.rpc.v3.Idp",
	HandlerType: (*IdpServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateIdp",
			Handler:    _Idp_CreateIdp_Handler,
		},
		{
			MethodName: "GetIdp",
			Handler:    _Idp_GetIdp_Handler,
		},
		{
			MethodName: "ListIdps",
			Handler:    _Idp_ListIdps_Handler,
		},
		{
			MethodName: "UpdateIdp",
			Handler:    _Idp_UpdateIdp_Handler,
		},
		{
			MethodName: "DeleteIdp",
			Handler:    _Idp_DeleteIdp_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/system/idp.proto",
}

Idp_ServiceDesc is the grpc.ServiceDesc for Idp service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Location_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.rpc.v3.Location",
	HandlerType: (*LocationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateLocation",
			Handler:    _Location_CreateLocation_Handler,
		},
		{
			MethodName: "GetLocations",
			Handler:    _Location_GetLocations_Handler,
		},
		{
			MethodName: "GetLocation",
			Handler:    _Location_GetLocation_Handler,
		},
		{
			MethodName: "UpdateLocation",
			Handler:    _Location_UpdateLocation_Handler,
		},
		{
			MethodName: "DeleteLocation",
			Handler:    _Location_DeleteLocation_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/system/metro.proto",
}

Location_ServiceDesc is the grpc.ServiceDesc for Location service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var OIDCProvider_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.rpc.v3.OIDCProvider",
	HandlerType: (*OIDCProviderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateOIDCProvider",
			Handler:    _OIDCProvider_CreateOIDCProvider_Handler,
		},
		{
			MethodName: "GetOIDCProvider",
			Handler:    _OIDCProvider_GetOIDCProvider_Handler,
		},
		{
			MethodName: "ListOIDCProvider",
			Handler:    _OIDCProvider_ListOIDCProvider_Handler,
		},
		{
			MethodName: "UpdateOIDCProvider",
			Handler:    _OIDCProvider_UpdateOIDCProvider_Handler,
		},
		{
			MethodName: "DeleteOIDCProvider",
			Handler:    _OIDCProvider_DeleteOIDCProvider_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/system/oidc_provider.proto",
}

OIDCProvider_ServiceDesc is the grpc.ServiceDesc for OIDCProvider service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Organization_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.rpc.v3.Organization",
	HandlerType: (*OrganizationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateOrganization",
			Handler:    _Organization_CreateOrganization_Handler,
		},
		{
			MethodName: "GetOrganizations",
			Handler:    _Organization_GetOrganizations_Handler,
		},
		{
			MethodName: "GetOrganization",
			Handler:    _Organization_GetOrganization_Handler,
		},
		{
			MethodName: "UpdateOrganization",
			Handler:    _Organization_UpdateOrganization_Handler,
		},
		{
			MethodName: "DeleteOrganization",
			Handler:    _Organization_DeleteOrganization_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/system/organization.proto",
}

Organization_ServiceDesc is the grpc.ServiceDesc for Organization service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Partner_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.rpc.v3.Partner",
	HandlerType: (*PartnerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreatePartner",
			Handler:    _Partner_CreatePartner_Handler,
		},
		{
			MethodName: "GetPartner",
			Handler:    _Partner_GetPartner_Handler,
		},
		{
			MethodName: "GetInitPartner",
			Handler:    _Partner_GetInitPartner_Handler,
		},
		{
			MethodName: "UpdatePartner",
			Handler:    _Partner_UpdatePartner_Handler,
		},
		{
			MethodName: "DeletePartner",
			Handler:    _Partner_DeletePartner_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/system/partner.proto",
}

Partner_ServiceDesc is the grpc.ServiceDesc for Partner service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Project_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "paralus.dev.rpc.v3.Project",
	HandlerType: (*ProjectServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateProject",
			Handler:    _Project_CreateProject_Handler,
		},
		{
			MethodName: "GetProjects",
			Handler:    _Project_GetProjects_Handler,
		},
		{
			MethodName: "GetProject",
			Handler:    _Project_GetProject_Handler,
		},
		{
			MethodName: "UpdateProject",
			Handler:    _Project_UpdateProject_Handler,
		},
		{
			MethodName: "DeleteProject",
			Handler:    _Project_DeleteProject_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/rpc/system/project.proto",
}

Project_ServiceDesc is the grpc.ServiceDesc for Project service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterIdpHandler 

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

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

func RegisterIdpHandlerClient 

func RegisterIdpHandlerClient(ctx context.Context, mux *runtime.ServeMux, client IdpClient) error

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

func RegisterIdpHandlerFromEndpoint 

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

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

func RegisterIdpHandlerServer 

func RegisterIdpHandlerServer(ctx context.Context, mux *runtime.ServeMux, server IdpServer) error

RegisterIdpHandlerServer registers the http handlers for service Idp to "mux". UnaryRPC :call IdpServer 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 RegisterIdpHandlerFromEndpoint instead.

func RegisterIdpServer 

func RegisterIdpServer(s grpc.ServiceRegistrar, srv IdpServer)

func RegisterLocationHandler 

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

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

func RegisterLocationHandlerClient 

func RegisterLocationHandlerClient(ctx context.Context, mux *runtime.ServeMux, client LocationClient) error

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

func RegisterLocationHandlerFromEndpoint 

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

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

func RegisterLocationHandlerServer 

func RegisterLocationHandlerServer(ctx context.Context, mux *runtime.ServeMux, server LocationServer) error

RegisterLocationHandlerServer registers the http handlers for service Location to "mux". UnaryRPC :call LocationServer 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 RegisterLocationHandlerFromEndpoint instead.

func RegisterLocationServer 

func RegisterLocationServer(s grpc.ServiceRegistrar, srv LocationServer)

func RegisterOIDCProviderHandler 

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

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

func RegisterOIDCProviderHandlerClient 

func RegisterOIDCProviderHandlerClient(ctx context.Context, mux *runtime.ServeMux, client OIDCProviderClient) error

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

func RegisterOIDCProviderHandlerFromEndpoint 

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

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

func RegisterOIDCProviderHandlerServer 

func RegisterOIDCProviderHandlerServer(ctx context.Context, mux *runtime.ServeMux, server OIDCProviderServer) error

RegisterOIDCProviderHandlerServer registers the http handlers for service OIDCProvider to "mux". UnaryRPC :call OIDCProviderServer 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 RegisterOIDCProviderHandlerFromEndpoint instead.

func RegisterOIDCProviderServer 

func RegisterOIDCProviderServer(s grpc.ServiceRegistrar, srv OIDCProviderServer)

func RegisterOrganizationHandler 

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

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

func RegisterOrganizationHandlerClient 

func RegisterOrganizationHandlerClient(ctx context.Context, mux *runtime.ServeMux, client OrganizationClient) error

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

func RegisterOrganizationHandlerFromEndpoint 

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

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

func RegisterOrganizationHandlerServer 

func RegisterOrganizationHandlerServer(ctx context.Context, mux *runtime.ServeMux, server OrganizationServer) error

RegisterOrganizationHandlerServer registers the http handlers for service Organization to "mux". UnaryRPC :call OrganizationServer 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 RegisterOrganizationHandlerFromEndpoint instead.

func RegisterOrganizationServer 

func RegisterOrganizationServer(s grpc.ServiceRegistrar, srv OrganizationServer)

func RegisterPartnerHandler 

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

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

func RegisterPartnerHandlerClient 

func RegisterPartnerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PartnerClient) error

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

func RegisterPartnerHandlerFromEndpoint 

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

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

func RegisterPartnerHandlerServer 

func RegisterPartnerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PartnerServer) error

RegisterPartnerHandlerServer registers the http handlers for service Partner to "mux". UnaryRPC :call PartnerServer 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 RegisterPartnerHandlerFromEndpoint instead.

func RegisterPartnerServer 

func RegisterPartnerServer(s grpc.ServiceRegistrar, srv PartnerServer)

func RegisterProjectHandler 

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

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

func RegisterProjectHandlerClient 

func RegisterProjectHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ProjectClient) error

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

func RegisterProjectHandlerFromEndpoint 

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

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

func RegisterProjectHandlerServer 

func RegisterProjectHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ProjectServer) error

RegisterProjectHandlerServer registers the http handlers for service Project to "mux". UnaryRPC :call ProjectServer 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 RegisterProjectHandlerFromEndpoint instead.

func RegisterProjectServer 

func RegisterProjectServer(s grpc.ServiceRegistrar, srv ProjectServer)

Types

type EmptyRequest 

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

func (*EmptyRequest) Descriptor deprecated 

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

Deprecated: Use EmptyRequest.ProtoReflect.Descriptor instead.

func (*EmptyRequest) ProtoMessage 

func (*EmptyRequest) ProtoMessage()

func (*EmptyRequest) ProtoReflect 

func (x *EmptyRequest) ProtoReflect() protoreflect.Message

func (*EmptyRequest) Reset 

func (x *EmptyRequest) Reset()

func (*EmptyRequest) String 

func (x *EmptyRequest) String() string

type IdpClient 

type IdpClient interface {
	CreateIdp(ctx context.Context, in *v3.Idp, opts ...grpc.CallOption) (*v3.Idp, error)
	GetIdp(ctx context.Context, in *v3.Idp, opts ...grpc.CallOption) (*v3.Idp, error)
	ListIdps(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*v3.IdpList, error)
	UpdateIdp(ctx context.Context, in *v3.Idp, opts ...grpc.CallOption) (*v3.Idp, error)
	DeleteIdp(ctx context.Context, in *v3.Idp, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

IdpClient is the client API for Idp service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewIdpClient 

func NewIdpClient(cc grpc.ClientConnInterface) IdpClient

type IdpServer 

type IdpServer interface {
	CreateIdp(context.Context, *v3.Idp) (*v3.Idp, error)
	GetIdp(context.Context, *v3.Idp) (*v3.Idp, error)
	ListIdps(context.Context, *emptypb.Empty) (*v3.IdpList, error)
	UpdateIdp(context.Context, *v3.Idp) (*v3.Idp, error)
	DeleteIdp(context.Context, *v3.Idp) (*emptypb.Empty, error)
}

IdpServer is the server API for Idp service. All implementations should embed UnimplementedIdpServer for forward compatibility

type LocationClient 

type LocationClient interface {
	CreateLocation(ctx context.Context, in *v3.Location, opts ...grpc.CallOption) (*v3.Location, error)
	GetLocations(ctx context.Context, in *v3.Location, opts ...grpc.CallOption) (*v3.LocationList, error)
	GetLocation(ctx context.Context, in *v3.Location, opts ...grpc.CallOption) (*v3.Location, error)
	UpdateLocation(ctx context.Context, in *v3.Location, opts ...grpc.CallOption) (*v3.Location, error)
	DeleteLocation(ctx context.Context, in *v3.Location, opts ...grpc.CallOption) (*v3.Location, error)
}

LocationClient is the client API for Location service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLocationClient 

func NewLocationClient(cc grpc.ClientConnInterface) LocationClient

type LocationServer 

type LocationServer interface {
	CreateLocation(context.Context, *v3.Location) (*v3.Location, error)
	GetLocations(context.Context, *v3.Location) (*v3.LocationList, error)
	GetLocation(context.Context, *v3.Location) (*v3.Location, error)
	UpdateLocation(context.Context, *v3.Location) (*v3.Location, error)
	DeleteLocation(context.Context, *v3.Location) (*v3.Location, error)
}

LocationServer is the server API for Location service. All implementations should embed UnimplementedLocationServer for forward compatibility

type OIDCProviderClient 

type OIDCProviderClient interface {
	CreateOIDCProvider(ctx context.Context, in *v3.OIDCProvider, opts ...grpc.CallOption) (*v3.OIDCProvider, error)
	GetOIDCProvider(ctx context.Context, in *v3.OIDCProvider, opts ...grpc.CallOption) (*v3.OIDCProvider, error)
	ListOIDCProvider(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*v3.OIDCProviderList, error)
	UpdateOIDCProvider(ctx context.Context, in *v3.OIDCProvider, opts ...grpc.CallOption) (*v3.OIDCProvider, error)
	DeleteOIDCProvider(ctx context.Context, in *v3.OIDCProvider, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

OIDCProviderClient is the client API for OIDCProvider service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOIDCProviderClient 

func NewOIDCProviderClient(cc grpc.ClientConnInterface) OIDCProviderClient

type OIDCProviderServer 

type OIDCProviderServer interface {
	CreateOIDCProvider(context.Context, *v3.OIDCProvider) (*v3.OIDCProvider, error)
	GetOIDCProvider(context.Context, *v3.OIDCProvider) (*v3.OIDCProvider, error)
	ListOIDCProvider(context.Context, *emptypb.Empty) (*v3.OIDCProviderList, error)
	UpdateOIDCProvider(context.Context, *v3.OIDCProvider) (*v3.OIDCProvider, error)
	DeleteOIDCProvider(context.Context, *v3.OIDCProvider) (*emptypb.Empty, error)
}

OIDCProviderServer is the server API for OIDCProvider service. All implementations should embed UnimplementedOIDCProviderServer for forward compatibility

type Option 

type Option func(*options)

Option is the functional argument for Pool options

func WithAddr 

func WithAddr(addr string) Option

WithAddr sets address of the pool

func WithCaCertPEM 

func WithCaCertPEM(caCert []byte) Option

WithCaCertPEM sets PEM encoded CA cert for pool

func WithClientCertPEM 

func WithClientCertPEM(cert []byte) Option

WithClientCertPEM sets PEM encoded client cert for pool

func WithClientKeyPEM 

func WithClientKeyPEM(key []byte) Option

WithClientKeyPEM sets PEM encoded client key for pool

func WithMaxConn 

func WithMaxConn(maxConn int) Option

WithMaxConn sets maximum number of connections of the pool if not set defaults to 10

type OrganizationClient 

type OrganizationClient interface {
	CreateOrganization(ctx context.Context, in *v3.Organization, opts ...grpc.CallOption) (*v3.Organization, error)
	GetOrganizations(ctx context.Context, in *v3.Organization, opts ...grpc.CallOption) (*v3.OrganizationList, error)
	GetOrganization(ctx context.Context, in *v3.Organization, opts ...grpc.CallOption) (*v3.Organization, error)
	UpdateOrganization(ctx context.Context, in *v3.Organization, opts ...grpc.CallOption) (*v3.Organization, error)
	DeleteOrganization(ctx context.Context, in *v3.Organization, opts ...grpc.CallOption) (*v3.Organization, error)
}

OrganizationClient is the client API for Organization service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOrganizationClient 

func NewOrganizationClient(cc grpc.ClientConnInterface) OrganizationClient

type OrganizationServer 

type OrganizationServer interface {
	CreateOrganization(context.Context, *v3.Organization) (*v3.Organization, error)
	GetOrganizations(context.Context, *v3.Organization) (*v3.OrganizationList, error)
	GetOrganization(context.Context, *v3.Organization) (*v3.Organization, error)
	UpdateOrganization(context.Context, *v3.Organization) (*v3.Organization, error)
	DeleteOrganization(context.Context, *v3.Organization) (*v3.Organization, error)
}

OrganizationServer is the server API for Organization service. All implementations should embed UnimplementedOrganizationServer for forward compatibility

type PartnerClient 

type PartnerClient interface {
	CreatePartner(ctx context.Context, in *v3.Partner, opts ...grpc.CallOption) (*v3.Partner, error)
	GetPartner(ctx context.Context, in *v3.Partner, opts ...grpc.CallOption) (*v3.Partner, error)
	GetInitPartner(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*v3.Partner, error)
	UpdatePartner(ctx context.Context, in *v3.Partner, opts ...grpc.CallOption) (*v3.Partner, error)
	DeletePartner(ctx context.Context, in *v3.Partner, opts ...grpc.CallOption) (*v3.Partner, error)
}

PartnerClient is the client API for Partner service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPartnerClient 

func NewPartnerClient(cc grpc.ClientConnInterface) PartnerClient

type PartnerServer 

type PartnerServer interface {
	CreatePartner(context.Context, *v3.Partner) (*v3.Partner, error)
	GetPartner(context.Context, *v3.Partner) (*v3.Partner, error)
	GetInitPartner(context.Context, *EmptyRequest) (*v3.Partner, error)
	UpdatePartner(context.Context, *v3.Partner) (*v3.Partner, error)
	DeletePartner(context.Context, *v3.Partner) (*v3.Partner, error)
}

PartnerServer is the server API for Partner service. All implementations should embed UnimplementedPartnerServer for forward compatibility

type ProjectClient 

type ProjectClient interface {
	CreateProject(ctx context.Context, in *v3.Project, opts ...grpc.CallOption) (*v3.Project, error)
	GetProjects(ctx context.Context, in *v3.Project, opts ...grpc.CallOption) (*v3.ProjectList, error)
	GetProject(ctx context.Context, in *v3.Project, opts ...grpc.CallOption) (*v3.Project, error)
	UpdateProject(ctx context.Context, in *v3.Project, opts ...grpc.CallOption) (*v3.Project, error)
	DeleteProject(ctx context.Context, in *v3.Project, opts ...grpc.CallOption) (*v3.Project, error)
}

ProjectClient is the client API for Project service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewProjectClient 

func NewProjectClient(cc grpc.ClientConnInterface) ProjectClient

type ProjectServer 

type ProjectServer interface {
	CreateProject(context.Context, *v3.Project) (*v3.Project, error)
	GetProjects(context.Context, *v3.Project) (*v3.ProjectList, error)
	GetProject(context.Context, *v3.Project) (*v3.Project, error)
	UpdateProject(context.Context, *v3.Project) (*v3.Project, error)
	DeleteProject(context.Context, *v3.Project) (*v3.Project, error)
}

ProjectServer is the server API for Project service. All implementations should embed UnimplementedProjectServer for forward compatibility

type SystemClient 

type SystemClient interface {
	Unhealthy()
	Close() error
	ProjectClient
	OrganizationClient
	PartnerClient
}

SystemClient is the interface for accessing all the RPCs exposed by Paralus Base

type SystemPool 

type SystemPool interface {
	Close()
	NewClient(ctx context.Context) (SystemClient, error)
}

SystemPool maintains pool of grpc connections to system base services

func NewSystemPool 

func NewSystemPool(addr string, maxConn int) SystemPool

NewSystemPool new system pool

type UnimplementedIdpServer 

type UnimplementedIdpServer struct {
}

UnimplementedIdpServer should be embedded to have forward compatible implementations.

func (UnimplementedIdpServer) CreateIdp 

func (UnimplementedIdpServer) CreateIdp(context.Context, *v3.Idp) (*v3.Idp, error)

func (UnimplementedIdpServer) DeleteIdp 

func (UnimplementedIdpServer) DeleteIdp(context.Context, *v3.Idp) (*emptypb.Empty, error)

func (UnimplementedIdpServer) GetIdp 

func (UnimplementedIdpServer) GetIdp(context.Context, *v3.Idp) (*v3.Idp, error)

func (UnimplementedIdpServer) ListIdps 

func (UnimplementedIdpServer) ListIdps(context.Context, *emptypb.Empty) (*v3.IdpList, error)

func (UnimplementedIdpServer) UpdateIdp 

func (UnimplementedIdpServer) UpdateIdp(context.Context, *v3.Idp) (*v3.Idp, error)

type UnimplementedLocationServer 

type UnimplementedLocationServer struct {
}

UnimplementedLocationServer should be embedded to have forward compatible implementations.

func (UnimplementedLocationServer) CreateLocation 

func (UnimplementedLocationServer) CreateLocation(context.Context, *v3.Location) (*v3.Location, error)

func (UnimplementedLocationServer) DeleteLocation 

func (UnimplementedLocationServer) DeleteLocation(context.Context, *v3.Location) (*v3.Location, error)

func (UnimplementedLocationServer) GetLocation 

func (UnimplementedLocationServer) GetLocation(context.Context, *v3.Location) (*v3.Location, error)

func (UnimplementedLocationServer) GetLocations 

func (UnimplementedLocationServer) GetLocations(context.Context, *v3.Location) (*v3.LocationList, error)

func (UnimplementedLocationServer) UpdateLocation 

func (UnimplementedLocationServer) UpdateLocation(context.Context, *v3.Location) (*v3.Location, error)

type UnimplementedOIDCProviderServer 

type UnimplementedOIDCProviderServer struct {
}

UnimplementedOIDCProviderServer should be embedded to have forward compatible implementations.

func (UnimplementedOIDCProviderServer) CreateOIDCProvider 

func (UnimplementedOIDCProviderServer) CreateOIDCProvider(context.Context, *v3.OIDCProvider) (*v3.OIDCProvider, error)

func (UnimplementedOIDCProviderServer) DeleteOIDCProvider 

func (UnimplementedOIDCProviderServer) DeleteOIDCProvider(context.Context, *v3.OIDCProvider) (*emptypb.Empty, error)

func (UnimplementedOIDCProviderServer) GetOIDCProvider 

func (UnimplementedOIDCProviderServer) GetOIDCProvider(context.Context, *v3.OIDCProvider) (*v3.OIDCProvider, error)

func (UnimplementedOIDCProviderServer) ListOIDCProvider 

func (UnimplementedOIDCProviderServer) ListOIDCProvider(context.Context, *emptypb.Empty) (*v3.OIDCProviderList, error)

func (UnimplementedOIDCProviderServer) UpdateOIDCProvider 

func (UnimplementedOIDCProviderServer) UpdateOIDCProvider(context.Context, *v3.OIDCProvider) (*v3.OIDCProvider, error)

type UnimplementedOrganizationServer 

type UnimplementedOrganizationServer struct {
}

UnimplementedOrganizationServer should be embedded to have forward compatible implementations.

func (UnimplementedOrganizationServer) CreateOrganization 

func (UnimplementedOrganizationServer) CreateOrganization(context.Context, *v3.Organization) (*v3.Organization, error)

func (UnimplementedOrganizationServer) DeleteOrganization 

func (UnimplementedOrganizationServer) DeleteOrganization(context.Context, *v3.Organization) (*v3.Organization, error)

func (UnimplementedOrganizationServer) GetOrganization 

func (UnimplementedOrganizationServer) GetOrganization(context.Context, *v3.Organization) (*v3.Organization, error)

func (UnimplementedOrganizationServer) GetOrganizations 

func (UnimplementedOrganizationServer) GetOrganizations(context.Context, *v3.Organization) (*v3.OrganizationList, error)

func (UnimplementedOrganizationServer) UpdateOrganization 

func (UnimplementedOrganizationServer) UpdateOrganization(context.Context, *v3.Organization) (*v3.Organization, error)

type UnimplementedPartnerServer 

type UnimplementedPartnerServer struct {
}

UnimplementedPartnerServer should be embedded to have forward compatible implementations.

func (UnimplementedPartnerServer) CreatePartner 

func (UnimplementedPartnerServer) CreatePartner(context.Context, *v3.Partner) (*v3.Partner, error)

func (UnimplementedPartnerServer) DeletePartner 

func (UnimplementedPartnerServer) DeletePartner(context.Context, *v3.Partner) (*v3.Partner, error)

func (UnimplementedPartnerServer) GetInitPartner 

func (UnimplementedPartnerServer) GetInitPartner(context.Context, *EmptyRequest) (*v3.Partner, error)

func (UnimplementedPartnerServer) GetPartner 

func (UnimplementedPartnerServer) GetPartner(context.Context, *v3.Partner) (*v3.Partner, error)

func (UnimplementedPartnerServer) UpdatePartner 

func (UnimplementedPartnerServer) UpdatePartner(context.Context, *v3.Partner) (*v3.Partner, error)

type UnimplementedProjectServer 

type UnimplementedProjectServer struct {
}

UnimplementedProjectServer should be embedded to have forward compatible implementations.

func (UnimplementedProjectServer) CreateProject 

func (UnimplementedProjectServer) CreateProject(context.Context, *v3.Project) (*v3.Project, error)

func (UnimplementedProjectServer) DeleteProject 

func (UnimplementedProjectServer) DeleteProject(context.Context, *v3.Project) (*v3.Project, error)

func (UnimplementedProjectServer) GetProject 

func (UnimplementedProjectServer) GetProject(context.Context, *v3.Project) (*v3.Project, error)

func (UnimplementedProjectServer) GetProjects 

func (UnimplementedProjectServer) GetProjects(context.Context, *v3.Project) (*v3.ProjectList, error)

func (UnimplementedProjectServer) UpdateProject 

func (UnimplementedProjectServer) UpdateProject(context.Context, *v3.Project) (*v3.Project, error)

type UnsafeIdpServer 

type UnsafeIdpServer interface {
	// contains filtered or unexported methods
}

UnsafeIdpServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IdpServer will result in compilation errors.

type UnsafeLocationServer 

type UnsafeLocationServer interface {
	// contains filtered or unexported methods
}

UnsafeLocationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LocationServer will result in compilation errors.

type UnsafeOIDCProviderServer 

type UnsafeOIDCProviderServer interface {
	// contains filtered or unexported methods
}

UnsafeOIDCProviderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OIDCProviderServer will result in compilation errors.

type UnsafeOrganizationServer 

type UnsafeOrganizationServer interface {
	// contains filtered or unexported methods
}

UnsafeOrganizationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OrganizationServer will result in compilation errors.

type UnsafePartnerServer 

type UnsafePartnerServer interface {
	// contains filtered or unexported methods
}

UnsafePartnerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PartnerServer will result in compilation errors.

type UnsafeProjectServer 

type UnsafeProjectServer interface {
	// contains filtered or unexported methods
}

UnsafeProjectServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProjectServer will result in compilation errors.

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.