queryhandler

Documentation

Index

• func NewCertificateClient(ctx context.Context, queryHandlerAddr string) (*grpc.ClientConn, api.CertificateClient, error)
• func NewCertificateServer(certificateRepo repositories.ReadOnlyCertificateRepository) *certificateServer
• func NewClusterAccessClient(ctx context.Context, queryHandlerAddr string) (*grpc.ClientConn, api.ClusterAccessClient, error)
• func NewClusterAccessServer(clusterAccessRepo repositories.ReadOnlyClusterAccessRepository, ...) *clusterAccessServer
• func NewClusterClient(ctx context.Context, queryHandlerAddr string) (*grpc.ClientConn, api.ClusterClient, error)
• func NewClusterServer(clusterRepo repositories.ReadOnlyClusterRepository) *clusterServer
• func NewTenantClient(ctx context.Context, queryHandlerAddr string) (*grpc.ClientConn, api.TenantClient, error)
• func NewTenantServer(tenantRepo repositories.ReadOnlyTenantRepository, ...) *tenantServer
• func NewUserClient(ctx context.Context, queryHandlerAddr string) (*grpc.ClientConn, api.UserClient, error)
• type TestEnv
  • func NewTestEnvWithParent(testeEnv *test.TestEnv, eventStoreTestEnv *eventstore.TestEnv) (*TestEnv, error)
  • func (env *TestEnv) GetApiAddr() string
  • func (env *TestEnv) Shutdown() error
• type UserServer
  • func NewUserServer(userRepo repositories.ReadOnlyUserRepository) *UserServer
  • func (s *UserServer) GetAll(request *api.GetAllRequest, stream api.User_GetAllServer) error
  • func (s *UserServer) GetByEmail(ctx context.Context, email *wrappers.StringValue) (*projections.User, error)
  • func (s *UserServer) GetById(ctx context.Context, userId *wrappers.StringValue) (*projections.User, error)
  • func (s *UserServer) GetRoleBindingsById(userId *wrappers.StringValue, stream api.User_GetRoleBindingsByIdServer) error

Functions

func NewCertificateClient

func NewCertificateClient(ctx context.Context, queryHandlerAddr string) (*grpc.ClientConn, api.CertificateClient, error)

func NewCertificateServer

func NewCertificateServer(certificateRepo repositories.ReadOnlyCertificateRepository) *certificateServer

NewCertificateServiceServer returns a new configured instance of certificateServiceServer

func NewClusterAccessClient

func NewClusterAccessClient(ctx context.Context, queryHandlerAddr string) (*grpc.ClientConn, api.ClusterAccessClient, error)

func NewClusterAccessServer

func NewClusterAccessServer(clusterAccessRepo repositories.ReadOnlyClusterAccessRepository, tenantClusterBindingRepo repositories.ReadOnlyTenantClusterBindingRepository) *clusterAccessServer

NewClusterServiceServer returns a new configured instance of clusterServiceServer

func NewClusterClient

func NewClusterClient(ctx context.Context, queryHandlerAddr string) (*grpc.ClientConn, api.ClusterClient, error)

func NewClusterServer

func NewClusterServer(clusterRepo repositories.ReadOnlyClusterRepository) *clusterServer

NewClusterServiceServer returns a new configured instance of clusterServiceServer

func NewTenantClient

func NewTenantClient(ctx context.Context, queryHandlerAddr string) (*grpc.ClientConn, api.TenantClient, error)

func NewTenantServer

func NewTenantServer(tenantRepo repositories.ReadOnlyTenantRepository, tenantUserRepo repositories.ReadOnlyTenantUserRepository) *tenantServer

NewTenantServiceServer returns a new configured instance of tenantServiceServer

func NewUserClient

func NewUserClient(ctx context.Context, queryHandlerAddr string) (*grpc.ClientConn, api.UserClient, error)

Types

type TestEnv

type TestEnv struct {
	*test.TestEnv
	// contains filtered or unexported fields
}

func NewTestEnvWithParent

func NewTestEnvWithParent(testeEnv *test.TestEnv, eventStoreTestEnv *eventstore.TestEnv) (*TestEnv, error)

func (*TestEnv) GetApiAddr

func (env *TestEnv) GetApiAddr() string

func (*TestEnv) Shutdown

func (env *TestEnv) Shutdown() error

type UserServer

type UserServer struct {
	api.UnimplementedUserServer
	// contains filtered or unexported fields
}

UserServer is the implementation of the TenantService API

func NewUserServer

func NewUserServer(userRepo repositories.ReadOnlyUserRepository) *UserServer

NewUserServer returns a new configured instance of UserServer

func (*UserServer) GetAll

func (s *UserServer) GetAll(request *api.GetAllRequest, stream api.User_GetAllServer) error

func (*UserServer) GetByEmail

func (s *UserServer) GetByEmail(ctx context.Context, email *wrappers.StringValue) (*projections.User, error)

GetByEmail returns the user found by the given email address.

func (*UserServer) GetById

func (s *UserServer) GetById(ctx context.Context, userId *wrappers.StringValue) (*projections.User, error)

GetById returns the user found by the given id.

func (*UserServer) GetRoleBindingsById

func (s *UserServer) GetRoleBindingsById(userId *wrappers.StringValue, stream api.User_GetRoleBindingsByIdServer) error