queryhandler

Documentation

Index

• func NewAuditLogClient(ctx context.Context, queryHandlerAddr string) (*grpc.ClientConn, doApi.AuditLogClient, error)
• func NewAuditLogServer(esClient esApi.EventStoreClient, efRegistry event.EventFormatterRegistry, ...) *auditLogServer
• func NewClusterAccessClient(ctx context.Context, queryHandlerAddr string) (*grpc.ClientConn, api.ClusterAccessClient, error)
• func NewClusterAccessServer(clusterAccessRepo repositories.ClusterAccessRepository, ...) *clusterAccessServer
• func NewClusterClient(ctx context.Context, queryHandlerAddr string) (*grpc.ClientConn, api.ClusterClient, error)
• func NewClusterServer(clusterRepo repositories.ClusterRepository) *clusterServer
• func NewTenantClient(ctx context.Context, queryHandlerAddr string) (*grpc.ClientConn, api.TenantClient, error)
• func NewTenantServer(tenantRepo repositories.TenantRepository, ...) *tenantServer
• 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.UserRepository) *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) GetCount(ctx context.Context, request *api.GetCountRequest) (*api.GetCountResult, error)
  • func (s *UserServer) GetRoleBindingsById(userId *wrappers.StringValue, stream api.User_GetRoleBindingsByIdServer) error

Functions

func NewAuditLogClient

func NewAuditLogClient(ctx context.Context, queryHandlerAddr string) (*grpc.ClientConn, doApi.AuditLogClient, error)

NewAuditLogClient returns a new configured instance of AuditLogClient along with the connection used

func NewAuditLogServer

func NewAuditLogServer(esClient esApi.EventStoreClient, efRegistry event.EventFormatterRegistry, userRepo repositories.UserRepository) *auditLogServer

NewAuditLogServer returns a new configured instance of auditLogServer

func NewClusterAccessClient

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

func NewClusterAccessServer

func NewClusterAccessServer(clusterAccessRepo repositories.ClusterAccessRepository, tenantClusterBindingRepo repositories.TenantClusterBindingRepository) *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.ClusterRepository) *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.TenantRepository, tenantUserRepo repositories.TenantUserRepository) *tenantServer

NewTenantServiceServer returns a new configured instance of tenantServiceServer

Types

type TestEnv

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

func NewTestEnvWithParent

func NewTestEnvWithParent(testeEnv *test.TestEnv, eventStoreTestEnv *eventstore.TestEnv, gatewayTestEnv *gateway.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.UserRepository) *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) GetCount

func (s *UserServer) GetCount(ctx context.Context, request *api.GetCountRequest) (*api.GetCountResult, error)

func (*UserServer) GetRoleBindingsById

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