domain

package
v0.3.0-rc0 Latest Latest
Warning

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

 Go to latest Published: Dec 15, 2021 License: Apache-2.0 Imports: 24 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Certificate_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "domain.Certificate",
	HandlerType: (*CertificateServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetCertificate",
			Handler:    _Certificate_GetCertificate_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/domain/queryhandler_service.proto",
}

Certificate_ServiceDesc is the grpc.ServiceDesc for Certificate 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 ClusterAccess_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "domain.ClusterAccess",
	HandlerType: (*ClusterAccessServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetTenantClusterMappingByTenantAndClusterId",
			Handler:    _ClusterAccess_GetTenantClusterMappingByTenantAndClusterId_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetClusterAccessByTenantId",
			Handler:       _ClusterAccess_GetClusterAccessByTenantId_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetClusterAccessByUserId",
			Handler:       _ClusterAccess_GetClusterAccessByUserId_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetTenantClusterMappingsByTenantId",
			Handler:       _ClusterAccess_GetTenantClusterMappingsByTenantId_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetTenantClusterMappingsByClusterId",
			Handler:       _ClusterAccess_GetTenantClusterMappingsByClusterId_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/domain/queryhandler_service.proto",
}

ClusterAccess_ServiceDesc is the grpc.ServiceDesc for ClusterAccess 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 Cluster_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "domain.Cluster",
	HandlerType: (*ClusterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetById",
			Handler:    _Cluster_GetById_Handler,
		},
		{
			MethodName: "GetByName",
			Handler:    _Cluster_GetByName_Handler,
		},
		{
			MethodName: "GetBootstrapToken",
			Handler:    _Cluster_GetBootstrapToken_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetAll",
			Handler:       _Cluster_GetAll_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/domain/queryhandler_service.proto",
}

Cluster_ServiceDesc is the grpc.ServiceDesc for Cluster 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 CommandHandlerExtensions_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "domain.CommandHandlerExtensions",
	HandlerType: (*CommandHandlerExtensionsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetPermissionModel",
			Handler:    _CommandHandlerExtensions_GetPermissionModel_Handler,
		},
		{
			MethodName: "GetPolicyOverview",
			Handler:    _CommandHandlerExtensions_GetPolicyOverview_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/domain/commandhandler_service.proto",
}

CommandHandlerExtensions_ServiceDesc is the grpc.ServiceDesc for CommandHandlerExtensions 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 File_api_domain_commandhandler_service_proto protoreflect.FileDescriptor
View Source 
var File_api_domain_queryhandler_service_proto protoreflect.FileDescriptor
View Source 
var Tenant_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "domain.Tenant",
	HandlerType: (*TenantServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetById",
			Handler:    _Tenant_GetById_Handler,
		},
		{
			MethodName: "GetByName",
			Handler:    _Tenant_GetByName_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetAll",
			Handler:       _Tenant_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetUsers",
			Handler:       _Tenant_GetUsers_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/domain/queryhandler_service.proto",
}

Tenant_ServiceDesc is the grpc.ServiceDesc for Tenant 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 User_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "domain.User",
	HandlerType: (*UserServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetById",
			Handler:    _User_GetById_Handler,
		},
		{
			MethodName: "GetByEmail",
			Handler:    _User_GetByEmail_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetAll",
			Handler:       _User_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetRoleBindingsById",
			Handler:       _User_GetRoleBindingsById_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/domain/queryhandler_service.proto",
}

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

Functions

func RegisterCertificateServer 

func RegisterCertificateServer(s grpc.ServiceRegistrar, srv CertificateServer)

func RegisterClusterAccessServer added in v0.3.0 

func RegisterClusterAccessServer(s grpc.ServiceRegistrar, srv ClusterAccessServer)

func RegisterClusterServer 

func RegisterClusterServer(s grpc.ServiceRegistrar, srv ClusterServer)

func RegisterCommandHandlerExtensionsServer 

func RegisterCommandHandlerExtensionsServer(s grpc.ServiceRegistrar, srv CommandHandlerExtensionsServer)

func RegisterTenantServer 

func RegisterTenantServer(s grpc.ServiceRegistrar, srv TenantServer)

func RegisterUserServer 

func RegisterUserServer(s grpc.ServiceRegistrar, srv UserServer)

Types

type CertificateClient 

type CertificateClient interface {
	GetCertificate(ctx context.Context, in *GetCertificateRequest, opts ...grpc.CallOption) (*projections.Certificate, error)
}

CertificateClient is the client API for Certificate 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 NewCertificateClient 

func NewCertificateClient(cc grpc.ClientConnInterface) CertificateClient

type CertificateServer 

type CertificateServer interface {
	GetCertificate(context.Context, *GetCertificateRequest) (*projections.Certificate, error)
	// contains filtered or unexported methods
}

CertificateServer is the server API for Certificate service. All implementations must embed UnimplementedCertificateServer for forward compatibility

type ClusterAccessClient added in v0.3.0 

type ClusterAccessClient interface {
	// GetClusterAccessByTenantId returns clusters which the given tenant has access to by it's UUID
	GetClusterAccessByTenantId(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (ClusterAccess_GetClusterAccessByTenantIdClient, error)
	// GetClusterAccessByUserId returns clusters which the given user has access to by it's UUID
	GetClusterAccessByUserId(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (ClusterAccess_GetClusterAccessByUserIdClient, error)
	// GetTenantClusterMappingsByTenantId returns bindings which belong to the given tenant by it's UUID
	GetTenantClusterMappingsByTenantId(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (ClusterAccess_GetTenantClusterMappingsByTenantIdClient, error)
	// GetTenantClusterMappingsByClusterId returns bindings which belong to the given cluster by it's UUID
	GetTenantClusterMappingsByClusterId(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (ClusterAccess_GetTenantClusterMappingsByClusterIdClient, error)
	// GetTenantClusterMappingsByClusterId returns the binding which belongs to the given tenant and cluster by their UUIDs
	GetTenantClusterMappingByTenantAndClusterId(ctx context.Context, in *GetClusterMappingRequest, opts ...grpc.CallOption) (*projections.TenantClusterBinding, error)
}

ClusterAccessClient is the client API for ClusterAccess 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 NewClusterAccessClient added in v0.3.0 

func NewClusterAccessClient(cc grpc.ClientConnInterface) ClusterAccessClient

type ClusterAccessServer added in v0.3.0 

type ClusterAccessServer interface {
	// GetClusterAccessByTenantId returns clusters which the given tenant has access to by it's UUID
	GetClusterAccessByTenantId(*wrapperspb.StringValue, ClusterAccess_GetClusterAccessByTenantIdServer) error
	// GetClusterAccessByUserId returns clusters which the given user has access to by it's UUID
	GetClusterAccessByUserId(*wrapperspb.StringValue, ClusterAccess_GetClusterAccessByUserIdServer) error
	// GetTenantClusterMappingsByTenantId returns bindings which belong to the given tenant by it's UUID
	GetTenantClusterMappingsByTenantId(*wrapperspb.StringValue, ClusterAccess_GetTenantClusterMappingsByTenantIdServer) error
	// GetTenantClusterMappingsByClusterId returns bindings which belong to the given cluster by it's UUID
	GetTenantClusterMappingsByClusterId(*wrapperspb.StringValue, ClusterAccess_GetTenantClusterMappingsByClusterIdServer) error
	// GetTenantClusterMappingsByClusterId returns the binding which belongs to the given tenant and cluster by their UUIDs
	GetTenantClusterMappingByTenantAndClusterId(context.Context, *GetClusterMappingRequest) (*projections.TenantClusterBinding, error)
	// contains filtered or unexported methods
}

ClusterAccessServer is the server API for ClusterAccess service. All implementations must embed UnimplementedClusterAccessServer for forward compatibility

type ClusterAccess_GetClusterAccessByTenantIdClient added in v0.3.0 

type ClusterAccess_GetClusterAccessByTenantIdClient interface {
	Recv() (*projections.Cluster, error)
	grpc.ClientStream
}

type ClusterAccess_GetClusterAccessByTenantIdServer added in v0.3.0 

type ClusterAccess_GetClusterAccessByTenantIdServer interface {
	Send(*projections.Cluster) error
	grpc.ServerStream
}

type ClusterAccess_GetClusterAccessByUserIdClient added in v0.3.0 

type ClusterAccess_GetClusterAccessByUserIdClient interface {
	Recv() (*projections.Cluster, error)
	grpc.ClientStream
}

type ClusterAccess_GetClusterAccessByUserIdServer added in v0.3.0 

type ClusterAccess_GetClusterAccessByUserIdServer interface {
	Send(*projections.Cluster) error
	grpc.ServerStream
}

type ClusterAccess_GetTenantClusterMappingsByClusterIdClient added in v0.3.0 

type ClusterAccess_GetTenantClusterMappingsByClusterIdClient interface {
	Recv() (*projections.TenantClusterBinding, error)
	grpc.ClientStream
}

type ClusterAccess_GetTenantClusterMappingsByClusterIdServer added in v0.3.0 

type ClusterAccess_GetTenantClusterMappingsByClusterIdServer interface {
	Send(*projections.TenantClusterBinding) error
	grpc.ServerStream
}

type ClusterAccess_GetTenantClusterMappingsByTenantIdClient added in v0.3.0 

type ClusterAccess_GetTenantClusterMappingsByTenantIdClient interface {
	Recv() (*projections.TenantClusterBinding, error)
	grpc.ClientStream
}

type ClusterAccess_GetTenantClusterMappingsByTenantIdServer added in v0.3.0 

type ClusterAccess_GetTenantClusterMappingsByTenantIdServer interface {
	Send(*projections.TenantClusterBinding) error
	grpc.ServerStream
}

type ClusterClient 

type ClusterClient interface {
	// GetAll returns all known clusters
	GetAll(ctx context.Context, in *GetAllRequest, opts ...grpc.CallOption) (Cluster_GetAllClient, error)
	// GetById returns a cluster by its UUID
	GetById(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*projections.Cluster, error)
	// GetByName returns a cluster by its name
	GetByName(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*projections.Cluster, error)
	// GetBootstrapToken returns the JWT token for cluster authentication for the
	// cluster with the given UUID
	GetBootstrapToken(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*wrapperspb.StringValue, error)
}

ClusterClient is the client API for Cluster 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 NewClusterClient 

func NewClusterClient(cc grpc.ClientConnInterface) ClusterClient

type ClusterServer 

type ClusterServer interface {
	// GetAll returns all known clusters
	GetAll(*GetAllRequest, Cluster_GetAllServer) error
	// GetById returns a cluster by its UUID
	GetById(context.Context, *wrapperspb.StringValue) (*projections.Cluster, error)
	// GetByName returns a cluster by its name
	GetByName(context.Context, *wrapperspb.StringValue) (*projections.Cluster, error)
	// GetBootstrapToken returns the JWT token for cluster authentication for the
	// cluster with the given UUID
	GetBootstrapToken(context.Context, *wrapperspb.StringValue) (*wrapperspb.StringValue, error)
	// contains filtered or unexported methods
}

ClusterServer is the server API for Cluster service. All implementations must embed UnimplementedClusterServer for forward compatibility

type Cluster_GetAllClient 

type Cluster_GetAllClient interface {
	Recv() (*projections.Cluster, error)
	grpc.ClientStream
}

type Cluster_GetAllServer 

type Cluster_GetAllServer interface {
	Send(*projections.Cluster) error
	grpc.ServerStream
}

type CommandHandlerExtensionsClient 

type CommandHandlerExtensionsClient interface {
	// Returns roles and scopes available.
	GetPermissionModel(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PermissionModel, error)
	// Returns overview of commands and which policies are necessary to execute
	// them.
	GetPolicyOverview(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PolicyOverview, error)
}

CommandHandlerExtensionsClient is the client API for CommandHandlerExtensions 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 NewCommandHandlerExtensionsClient 

func NewCommandHandlerExtensionsClient(cc grpc.ClientConnInterface) CommandHandlerExtensionsClient

type CommandHandlerExtensionsServer 

type CommandHandlerExtensionsServer interface {
	// Returns roles and scopes available.
	GetPermissionModel(context.Context, *emptypb.Empty) (*PermissionModel, error)
	// Returns overview of commands and which policies are necessary to execute
	// them.
	GetPolicyOverview(context.Context, *emptypb.Empty) (*PolicyOverview, error)
	// contains filtered or unexported methods
}

CommandHandlerExtensionsServer is the server API for CommandHandlerExtensions service. All implementations must embed UnimplementedCommandHandlerExtensionsServer for forward compatibility

type GetAllRequest 

type GetAllRequest struct {
	IncludeDeleted bool `protobuf:"varint,1,opt,name=include_deleted,json=includeDeleted,proto3" json:"include_deleted,omitempty"`
	// contains filtered or unexported fields
}

GetAllRequest is the generic request to query all instances of a certain projection

func (*GetAllRequest) Descriptor deprecated 

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

Deprecated: Use GetAllRequest.ProtoReflect.Descriptor instead.

func (*GetAllRequest) GetIncludeDeleted 

func (x *GetAllRequest) GetIncludeDeleted() bool

func (*GetAllRequest) ProtoMessage 

func (*GetAllRequest) ProtoMessage()

func (*GetAllRequest) ProtoReflect 

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

func (*GetAllRequest) Reset 

func (x *GetAllRequest) Reset()

func (*GetAllRequest) String 

func (x *GetAllRequest) String() string

func (*GetAllRequest) Validate added in v0.3.0 

func (m *GetAllRequest) Validate() error

Validate checks the field values on GetAllRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetAllRequest) ValidateAll added in v0.3.0 

func (m *GetAllRequest) ValidateAll() error

ValidateAll checks the field values on GetAllRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetAllRequestMultiError, or nil if none found.

type GetAllRequestMultiError added in v0.3.0 

type GetAllRequestMultiError []error

GetAllRequestMultiError is an error wrapping multiple validation errors returned by GetAllRequest.ValidateAll() if the designated constraints aren't met.

func (GetAllRequestMultiError) AllErrors added in v0.3.0 

func (m GetAllRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetAllRequestMultiError) Error added in v0.3.0 

func (m GetAllRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetAllRequestValidationError added in v0.3.0 

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

GetAllRequestValidationError is the validation error returned by GetAllRequest.Validate if the designated constraints aren't met.

func (GetAllRequestValidationError) Cause added in v0.3.0 

func (e GetAllRequestValidationError) Cause() error

Cause function returns cause value.

func (GetAllRequestValidationError) Error added in v0.3.0 

func (e GetAllRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetAllRequestValidationError) ErrorName added in v0.3.0 

func (e GetAllRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetAllRequestValidationError) Field added in v0.3.0 

func (e GetAllRequestValidationError) Field() string

Field function returns field value.

func (GetAllRequestValidationError) Key added in v0.3.0 

func (e GetAllRequestValidationError) Key() bool

Key function returns key value.

func (GetAllRequestValidationError) Reason added in v0.3.0 

func (e GetAllRequestValidationError) Reason() string

Reason function returns reason value.

type GetCertificateRequest 

type GetCertificateRequest struct {

	// Unique identifier of the aggregate referenced (UUID 128-bit number)
	AggregateId string `protobuf:"bytes,1,opt,name=aggregate_id,json=aggregateId,proto3" json:"aggregate_id,omitempty"`
	// Type of the aggregate referenced
	AggregateType string `protobuf:"bytes,2,opt,name=aggregate_type,json=aggregateType,proto3" json:"aggregate_type,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCertificateRequest) Descriptor deprecated 

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

Deprecated: Use GetCertificateRequest.ProtoReflect.Descriptor instead.

func (*GetCertificateRequest) GetAggregateId 

func (x *GetCertificateRequest) GetAggregateId() string

func (*GetCertificateRequest) GetAggregateType 

func (x *GetCertificateRequest) GetAggregateType() string

func (*GetCertificateRequest) ProtoMessage 

func (*GetCertificateRequest) ProtoMessage()

func (*GetCertificateRequest) ProtoReflect 

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

func (*GetCertificateRequest) Reset 

func (x *GetCertificateRequest) Reset()

func (*GetCertificateRequest) String 

func (x *GetCertificateRequest) String() string

func (*GetCertificateRequest) Validate added in v0.3.0 

func (m *GetCertificateRequest) Validate() error

Validate checks the field values on GetCertificateRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetCertificateRequest) ValidateAll added in v0.3.0 

func (m *GetCertificateRequest) ValidateAll() error

ValidateAll checks the field values on GetCertificateRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetCertificateRequestMultiError, or nil if none found.

type GetCertificateRequestMultiError added in v0.3.0 

type GetCertificateRequestMultiError []error

GetCertificateRequestMultiError is an error wrapping multiple validation errors returned by GetCertificateRequest.ValidateAll() if the designated constraints aren't met.

func (GetCertificateRequestMultiError) AllErrors added in v0.3.0 

func (m GetCertificateRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetCertificateRequestMultiError) Error added in v0.3.0 

func (m GetCertificateRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetCertificateRequestValidationError added in v0.3.0 

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

GetCertificateRequestValidationError is the validation error returned by GetCertificateRequest.Validate if the designated constraints aren't met.

func (GetCertificateRequestValidationError) Cause added in v0.3.0 

func (e GetCertificateRequestValidationError) Cause() error

Cause function returns cause value.

func (GetCertificateRequestValidationError) Error added in v0.3.0 

func (e GetCertificateRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetCertificateRequestValidationError) ErrorName added in v0.3.0 

func (e GetCertificateRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetCertificateRequestValidationError) Field added in v0.3.0 

func (e GetCertificateRequestValidationError) Field() string

Field function returns field value.

func (GetCertificateRequestValidationError) Key added in v0.3.0 

func (e GetCertificateRequestValidationError) Key() bool

Key function returns key value.

func (GetCertificateRequestValidationError) Reason added in v0.3.0 

func (e GetCertificateRequestValidationError) Reason() string

Reason function returns reason value.

type GetClusterMappingRequest added in v0.3.0 

type GetClusterMappingRequest struct {
	TenantId  string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetClusterMappingRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use GetClusterMappingRequest.ProtoReflect.Descriptor instead.

func (*GetClusterMappingRequest) GetClusterId added in v0.3.0 

func (x *GetClusterMappingRequest) GetClusterId() string

func (*GetClusterMappingRequest) GetTenantId added in v0.3.0 

func (x *GetClusterMappingRequest) GetTenantId() string

func (*GetClusterMappingRequest) ProtoMessage added in v0.3.0 

func (*GetClusterMappingRequest) ProtoMessage()

func (*GetClusterMappingRequest) ProtoReflect added in v0.3.0 

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

func (*GetClusterMappingRequest) Reset added in v0.3.0 

func (x *GetClusterMappingRequest) Reset()

func (*GetClusterMappingRequest) String added in v0.3.0 

func (x *GetClusterMappingRequest) String() string

func (*GetClusterMappingRequest) Validate added in v0.3.0 

func (m *GetClusterMappingRequest) Validate() error

Validate checks the field values on GetClusterMappingRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetClusterMappingRequest) ValidateAll added in v0.3.0 

func (m *GetClusterMappingRequest) ValidateAll() error

ValidateAll checks the field values on GetClusterMappingRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetClusterMappingRequestMultiError, or nil if none found.

type GetClusterMappingRequestMultiError added in v0.3.0 

type GetClusterMappingRequestMultiError []error

GetClusterMappingRequestMultiError is an error wrapping multiple validation errors returned by GetClusterMappingRequest.ValidateAll() if the designated constraints aren't met.

func (GetClusterMappingRequestMultiError) AllErrors added in v0.3.0 

func (m GetClusterMappingRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetClusterMappingRequestMultiError) Error added in v0.3.0 

func (m GetClusterMappingRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetClusterMappingRequestValidationError added in v0.3.0 

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

GetClusterMappingRequestValidationError is the validation error returned by GetClusterMappingRequest.Validate if the designated constraints aren't met.

func (GetClusterMappingRequestValidationError) Cause added in v0.3.0 

func (e GetClusterMappingRequestValidationError) Cause() error

Cause function returns cause value.

func (GetClusterMappingRequestValidationError) Error added in v0.3.0 

func (e GetClusterMappingRequestValidationError) Error() string

Error satisfies the builtin error interface

func (GetClusterMappingRequestValidationError) ErrorName added in v0.3.0 

func (e GetClusterMappingRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetClusterMappingRequestValidationError) Field added in v0.3.0 

func (e GetClusterMappingRequestValidationError) Field() string

Field function returns field value.

func (GetClusterMappingRequestValidationError) Key added in v0.3.0 

func (e GetClusterMappingRequestValidationError) Key() bool

Key function returns key value.

func (GetClusterMappingRequestValidationError) Reason added in v0.3.0 

func (e GetClusterMappingRequestValidationError) Reason() string

Reason function returns reason value.

type PermissionModel 

type PermissionModel struct {
	Roles  []string `protobuf:"bytes,1,rep,name=roles,proto3" json:"roles,omitempty"`
	Scopes []string `protobuf:"bytes,2,rep,name=scopes,proto3" json:"scopes,omitempty"`
	// contains filtered or unexported fields
}

func (*PermissionModel) Descriptor deprecated 

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

Deprecated: Use PermissionModel.ProtoReflect.Descriptor instead.

func (*PermissionModel) GetRoles 

func (x *PermissionModel) GetRoles() []string

func (*PermissionModel) GetScopes 

func (x *PermissionModel) GetScopes() []string

func (*PermissionModel) ProtoMessage 

func (*PermissionModel) ProtoMessage()

func (*PermissionModel) ProtoReflect 

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

func (*PermissionModel) Reset 

func (x *PermissionModel) Reset()

func (*PermissionModel) String 

func (x *PermissionModel) String() string

func (*PermissionModel) Validate added in v0.3.0 

func (m *PermissionModel) Validate() error

Validate checks the field values on PermissionModel with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PermissionModel) ValidateAll added in v0.3.0 

func (m *PermissionModel) ValidateAll() error

ValidateAll checks the field values on PermissionModel with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PermissionModelMultiError, or nil if none found.

type PermissionModelMultiError added in v0.3.0 

type PermissionModelMultiError []error

PermissionModelMultiError is an error wrapping multiple validation errors returned by PermissionModel.ValidateAll() if the designated constraints aren't met.

func (PermissionModelMultiError) AllErrors added in v0.3.0 

func (m PermissionModelMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PermissionModelMultiError) Error added in v0.3.0 

func (m PermissionModelMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PermissionModelValidationError added in v0.3.0 

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

PermissionModelValidationError is the validation error returned by PermissionModel.Validate if the designated constraints aren't met.

func (PermissionModelValidationError) Cause added in v0.3.0 

func (e PermissionModelValidationError) Cause() error

Cause function returns cause value.

func (PermissionModelValidationError) Error added in v0.3.0 

func (e PermissionModelValidationError) Error() string

Error satisfies the builtin error interface

func (PermissionModelValidationError) ErrorName added in v0.3.0 

func (e PermissionModelValidationError) ErrorName() string

ErrorName returns error name.

func (PermissionModelValidationError) Field added in v0.3.0 

func (e PermissionModelValidationError) Field() string

Field function returns field value.

func (PermissionModelValidationError) Key added in v0.3.0 

func (e PermissionModelValidationError) Key() bool

Key function returns key value.

func (PermissionModelValidationError) Reason added in v0.3.0 

func (e PermissionModelValidationError) Reason() string

Reason function returns reason value.

type Policy 

type Policy struct {
	Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	Role    string `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
	Scope   string `protobuf:"bytes,3,opt,name=scope,proto3" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

func (*Policy) Descriptor deprecated 

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

Deprecated: Use Policy.ProtoReflect.Descriptor instead.

func (*Policy) GetCommand 

func (x *Policy) GetCommand() string

func (*Policy) GetRole 

func (x *Policy) GetRole() string

func (*Policy) GetScope 

func (x *Policy) GetScope() string

func (*Policy) ProtoMessage 

func (*Policy) ProtoMessage()

func (*Policy) ProtoReflect 

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

func (*Policy) Reset 

func (x *Policy) Reset()

func (*Policy) String 

func (x *Policy) String() string

func (*Policy) Validate added in v0.3.0 

func (m *Policy) Validate() error

Validate checks the field values on Policy with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Policy) ValidateAll added in v0.3.0 

func (m *Policy) ValidateAll() error

ValidateAll checks the field values on Policy with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PolicyMultiError, or nil if none found.

type PolicyMultiError added in v0.3.0 

type PolicyMultiError []error

PolicyMultiError is an error wrapping multiple validation errors returned by Policy.ValidateAll() if the designated constraints aren't met.

func (PolicyMultiError) AllErrors added in v0.3.0 

func (m PolicyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PolicyMultiError) Error added in v0.3.0 

func (m PolicyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PolicyOverview 

type PolicyOverview struct {
	Policies []*Policy `protobuf:"bytes,1,rep,name=policies,proto3" json:"policies,omitempty"`
	// contains filtered or unexported fields
}

func (*PolicyOverview) Descriptor deprecated 

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

Deprecated: Use PolicyOverview.ProtoReflect.Descriptor instead.

func (*PolicyOverview) GetPolicies 

func (x *PolicyOverview) GetPolicies() []*Policy

func (*PolicyOverview) ProtoMessage 

func (*PolicyOverview) ProtoMessage()

func (*PolicyOverview) ProtoReflect 

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

func (*PolicyOverview) Reset 

func (x *PolicyOverview) Reset()

func (*PolicyOverview) String 

func (x *PolicyOverview) String() string

func (*PolicyOverview) Validate added in v0.3.0 

func (m *PolicyOverview) Validate() error

Validate checks the field values on PolicyOverview with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PolicyOverview) ValidateAll added in v0.3.0 

func (m *PolicyOverview) ValidateAll() error

ValidateAll checks the field values on PolicyOverview with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PolicyOverviewMultiError, or nil if none found.

type PolicyOverviewMultiError added in v0.3.0 

type PolicyOverviewMultiError []error

PolicyOverviewMultiError is an error wrapping multiple validation errors returned by PolicyOverview.ValidateAll() if the designated constraints aren't met.

func (PolicyOverviewMultiError) AllErrors added in v0.3.0 

func (m PolicyOverviewMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PolicyOverviewMultiError) Error added in v0.3.0 

func (m PolicyOverviewMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PolicyOverviewValidationError added in v0.3.0 

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

PolicyOverviewValidationError is the validation error returned by PolicyOverview.Validate if the designated constraints aren't met.

func (PolicyOverviewValidationError) Cause added in v0.3.0 

func (e PolicyOverviewValidationError) Cause() error

Cause function returns cause value.

func (PolicyOverviewValidationError) Error added in v0.3.0 

func (e PolicyOverviewValidationError) Error() string

Error satisfies the builtin error interface

func (PolicyOverviewValidationError) ErrorName added in v0.3.0 

func (e PolicyOverviewValidationError) ErrorName() string

ErrorName returns error name.

func (PolicyOverviewValidationError) Field added in v0.3.0 

func (e PolicyOverviewValidationError) Field() string

Field function returns field value.

func (PolicyOverviewValidationError) Key added in v0.3.0 

func (e PolicyOverviewValidationError) Key() bool

Key function returns key value.

func (PolicyOverviewValidationError) Reason added in v0.3.0 

func (e PolicyOverviewValidationError) Reason() string

Reason function returns reason value.

type PolicyValidationError added in v0.3.0 

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

PolicyValidationError is the validation error returned by Policy.Validate if the designated constraints aren't met.

func (PolicyValidationError) Cause added in v0.3.0 

func (e PolicyValidationError) Cause() error

Cause function returns cause value.

func (PolicyValidationError) Error added in v0.3.0 

func (e PolicyValidationError) Error() string

Error satisfies the builtin error interface

func (PolicyValidationError) ErrorName added in v0.3.0 

func (e PolicyValidationError) ErrorName() string

ErrorName returns error name.

func (PolicyValidationError) Field added in v0.3.0 

func (e PolicyValidationError) Field() string

Field function returns field value.

func (PolicyValidationError) Key added in v0.3.0 

func (e PolicyValidationError) Key() bool

Key function returns key value.

func (PolicyValidationError) Reason added in v0.3.0 

func (e PolicyValidationError) Reason() string

Reason function returns reason value.

type TenantClient 

type TenantClient interface {
	// GetAll returns all tenants.
	GetAll(ctx context.Context, in *GetAllRequest, opts ...grpc.CallOption) (Tenant_GetAllClient, error)
	// GetById returns the tenant found by the given id.
	GetById(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*projections.Tenant, error)
	// GetByName returns the tenant found by the given name
	GetByName(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*projections.Tenant, error)
	// GetUsers returns users belonging to the given tenant id.
	GetUsers(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (Tenant_GetUsersClient, error)
}

TenantClient is the client API for Tenant 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 NewTenantClient 

func NewTenantClient(cc grpc.ClientConnInterface) TenantClient

type TenantServer 

type TenantServer interface {
	// GetAll returns all tenants.
	GetAll(*GetAllRequest, Tenant_GetAllServer) error
	// GetById returns the tenant found by the given id.
	GetById(context.Context, *wrapperspb.StringValue) (*projections.Tenant, error)
	// GetByName returns the tenant found by the given name
	GetByName(context.Context, *wrapperspb.StringValue) (*projections.Tenant, error)
	// GetUsers returns users belonging to the given tenant id.
	GetUsers(*wrapperspb.StringValue, Tenant_GetUsersServer) error
	// contains filtered or unexported methods
}

TenantServer is the server API for Tenant service. All implementations must embed UnimplementedTenantServer for forward compatibility

type Tenant_GetAllClient 

type Tenant_GetAllClient interface {
	Recv() (*projections.Tenant, error)
	grpc.ClientStream
}

type Tenant_GetAllServer 

type Tenant_GetAllServer interface {
	Send(*projections.Tenant) error
	grpc.ServerStream
}

type Tenant_GetUsersClient 

type Tenant_GetUsersClient interface {
	Recv() (*projections.TenantUser, error)
	grpc.ClientStream
}

type Tenant_GetUsersServer 

type Tenant_GetUsersServer interface {
	Send(*projections.TenantUser) error
	grpc.ServerStream
}

type UnimplementedCertificateServer 

type UnimplementedCertificateServer struct {
}

UnimplementedCertificateServer must be embedded to have forward compatible implementations.

func (UnimplementedCertificateServer) GetCertificate 

func (UnimplementedCertificateServer) GetCertificate(context.Context, *GetCertificateRequest) (*projections.Certificate, error)

type UnimplementedClusterAccessServer added in v0.3.0 

type UnimplementedClusterAccessServer struct {
}

UnimplementedClusterAccessServer must be embedded to have forward compatible implementations.

func (UnimplementedClusterAccessServer) GetClusterAccessByTenantId added in v0.3.0 

func (UnimplementedClusterAccessServer) GetClusterAccessByTenantId(*wrapperspb.StringValue, ClusterAccess_GetClusterAccessByTenantIdServer) error

func (UnimplementedClusterAccessServer) GetClusterAccessByUserId added in v0.3.0 

func (UnimplementedClusterAccessServer) GetClusterAccessByUserId(*wrapperspb.StringValue, ClusterAccess_GetClusterAccessByUserIdServer) error

func (UnimplementedClusterAccessServer) GetTenantClusterMappingByTenantAndClusterId added in v0.3.0 

func (UnimplementedClusterAccessServer) GetTenantClusterMappingByTenantAndClusterId(context.Context, *GetClusterMappingRequest) (*projections.TenantClusterBinding, error)

func (UnimplementedClusterAccessServer) GetTenantClusterMappingsByClusterId added in v0.3.0 

func (UnimplementedClusterAccessServer) GetTenantClusterMappingsByClusterId(*wrapperspb.StringValue, ClusterAccess_GetTenantClusterMappingsByClusterIdServer) error

func (UnimplementedClusterAccessServer) GetTenantClusterMappingsByTenantId added in v0.3.0 

func (UnimplementedClusterAccessServer) GetTenantClusterMappingsByTenantId(*wrapperspb.StringValue, ClusterAccess_GetTenantClusterMappingsByTenantIdServer) error

type UnimplementedClusterServer 

type UnimplementedClusterServer struct {
}

UnimplementedClusterServer must be embedded to have forward compatible implementations.

func (UnimplementedClusterServer) GetAll 

func (UnimplementedClusterServer) GetAll(*GetAllRequest, Cluster_GetAllServer) error

func (UnimplementedClusterServer) GetBootstrapToken 

func (UnimplementedClusterServer) GetBootstrapToken(context.Context, *wrapperspb.StringValue) (*wrapperspb.StringValue, error)

func (UnimplementedClusterServer) GetById 

func (UnimplementedClusterServer) GetById(context.Context, *wrapperspb.StringValue) (*projections.Cluster, error)

func (UnimplementedClusterServer) GetByName 

func (UnimplementedClusterServer) GetByName(context.Context, *wrapperspb.StringValue) (*projections.Cluster, error)

type UnimplementedCommandHandlerExtensionsServer 

type UnimplementedCommandHandlerExtensionsServer struct {
}

UnimplementedCommandHandlerExtensionsServer must be embedded to have forward compatible implementations.

func (UnimplementedCommandHandlerExtensionsServer) GetPermissionModel 

func (UnimplementedCommandHandlerExtensionsServer) GetPermissionModel(context.Context, *emptypb.Empty) (*PermissionModel, error)

func (UnimplementedCommandHandlerExtensionsServer) GetPolicyOverview 

func (UnimplementedCommandHandlerExtensionsServer) GetPolicyOverview(context.Context, *emptypb.Empty) (*PolicyOverview, error)

type UnimplementedTenantServer 

type UnimplementedTenantServer struct {
}

UnimplementedTenantServer must be embedded to have forward compatible implementations.

func (UnimplementedTenantServer) GetAll 

func (UnimplementedTenantServer) GetAll(*GetAllRequest, Tenant_GetAllServer) error

func (UnimplementedTenantServer) GetById 

func (UnimplementedTenantServer) GetById(context.Context, *wrapperspb.StringValue) (*projections.Tenant, error)

func (UnimplementedTenantServer) GetByName 

func (UnimplementedTenantServer) GetByName(context.Context, *wrapperspb.StringValue) (*projections.Tenant, error)

func (UnimplementedTenantServer) GetUsers 

func (UnimplementedTenantServer) GetUsers(*wrapperspb.StringValue, Tenant_GetUsersServer) error

type UnimplementedUserServer 

type UnimplementedUserServer struct {
}

UnimplementedUserServer must be embedded to have forward compatible implementations.

func (UnimplementedUserServer) GetAll 

func (UnimplementedUserServer) GetAll(*GetAllRequest, User_GetAllServer) error

func (UnimplementedUserServer) GetByEmail 

func (UnimplementedUserServer) GetByEmail(context.Context, *wrapperspb.StringValue) (*projections.User, error)

func (UnimplementedUserServer) GetById 

func (UnimplementedUserServer) GetById(context.Context, *wrapperspb.StringValue) (*projections.User, error)

func (UnimplementedUserServer) GetRoleBindingsById 

func (UnimplementedUserServer) GetRoleBindingsById(*wrapperspb.StringValue, User_GetRoleBindingsByIdServer) error

type UnsafeCertificateServer 

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

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

type UnsafeClusterAccessServer added in v0.3.0 

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

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

type UnsafeClusterServer 

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

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

type UnsafeCommandHandlerExtensionsServer 

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

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

type UnsafeTenantServer 

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

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

type UnsafeUserServer 

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

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

type UserClient 

type UserClient interface {
	// GetAll returns all users.
	GetAll(ctx context.Context, in *GetAllRequest, opts ...grpc.CallOption) (User_GetAllClient, error)
	// GetById returns the user found by the given id.
	GetById(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*projections.User, error)
	// GetByEmail returns the user found by the given email address.
	GetByEmail(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*projections.User, error)
	// GetRoleBindingsById returns all role bindings related to the given user id.
	GetRoleBindingsById(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (User_GetRoleBindingsByIdClient, error)
}

UserClient is the client API for User 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 NewUserClient 

func NewUserClient(cc grpc.ClientConnInterface) UserClient

type UserServer 

type UserServer interface {
	// GetAll returns all users.
	GetAll(*GetAllRequest, User_GetAllServer) error
	// GetById returns the user found by the given id.
	GetById(context.Context, *wrapperspb.StringValue) (*projections.User, error)
	// GetByEmail returns the user found by the given email address.
	GetByEmail(context.Context, *wrapperspb.StringValue) (*projections.User, error)
	// GetRoleBindingsById returns all role bindings related to the given user id.
	GetRoleBindingsById(*wrapperspb.StringValue, User_GetRoleBindingsByIdServer) error
	// contains filtered or unexported methods
}

UserServer is the server API for User service. All implementations must embed UnimplementedUserServer for forward compatibility

type User_GetAllClient 

type User_GetAllClient interface {
	Recv() (*projections.User, error)
	grpc.ClientStream
}

type User_GetAllServer 

type User_GetAllServer interface {
	Send(*projections.User) error
	grpc.ServerStream
}

type User_GetRoleBindingsByIdClient 

type User_GetRoleBindingsByIdClient interface {
	Recv() (*projections.UserRoleBinding, error)
	grpc.ClientStream
}

type User_GetRoleBindingsByIdServer 

type User_GetRoleBindingsByIdServer interface {
	Send(*projections.UserRoleBinding) error
	grpc.ServerStream
}

Source Files

View all Source files

Directories

Path Synopsis

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.