domain

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Oct 8, 2021 License: Apache-2.0 Imports: 12 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 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 K8SOperator_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "domain.K8sOperator",
	HandlerType: (*K8SOperatorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetCluster",
			Handler:    _K8SOperator_GetCluster_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Retrieve",
			Handler:       _K8SOperator_Retrieve_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/domain/queryhandler_service.proto",
}

K8SOperator_ServiceDesc is the grpc.ServiceDesc for K8SOperator 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 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 RegisterClusterServer 

func RegisterClusterServer(s grpc.ServiceRegistrar, srv ClusterServer)

func RegisterCommandHandlerExtensionsServer 

func RegisterCommandHandlerExtensionsServer(s grpc.ServiceRegistrar, srv CommandHandlerExtensionsServer)

func RegisterK8SOperatorServer 

func RegisterK8SOperatorServer(s grpc.ServiceRegistrar, srv K8SOperatorServer)

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

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

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

type K8SOperatorClient 

type K8SOperatorClient interface {
	GetCluster(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*projections.Cluster, error)
	Retrieve(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (K8SOperator_RetrieveClient, error)
}

K8SOperatorClient is the client API for K8SOperator 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 NewK8SOperatorClient 

func NewK8SOperatorClient(cc grpc.ClientConnInterface) K8SOperatorClient

type K8SOperatorServer 

type K8SOperatorServer interface {
	GetCluster(context.Context, *emptypb.Empty) (*projections.Cluster, error)
	Retrieve(*emptypb.Empty, K8SOperator_RetrieveServer) error
	// contains filtered or unexported methods
}

K8SOperatorServer is the server API for K8SOperator service. All implementations must embed UnimplementedK8SOperatorServer for forward compatibility

type K8SOperator_RetrieveClient 

type K8SOperator_RetrieveClient interface {
	Recv() (*eventsourcing.Event, error)
	grpc.ClientStream
}

type K8SOperator_RetrieveServer 

type K8SOperator_RetrieveServer interface {
	Send(*eventsourcing.Event) error
	grpc.ServerStream
}

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

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

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

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 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 UnimplementedK8SOperatorServer 

type UnimplementedK8SOperatorServer struct {
}

UnimplementedK8SOperatorServer must be embedded to have forward compatible implementations.

func (UnimplementedK8SOperatorServer) GetCluster 

func (UnimplementedK8SOperatorServer) GetCluster(context.Context, *emptypb.Empty) (*projections.Cluster, error)

func (UnimplementedK8SOperatorServer) Retrieve 

func (UnimplementedK8SOperatorServer) Retrieve(*emptypb.Empty, K8SOperator_RetrieveServer) 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 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 UnsafeK8SOperatorServer 

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

UnsafeK8SOperatorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to K8SOperatorServer 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.