server

package
v0.6.2 Latest Latest
Warning

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

 Go to latest Published: Feb 21, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidRequest = kerrors.BadRequest("INVALID_REQUEST", "invalid request")
	ErrUserNotFound   = kerrors.NotFound("USER_NOT_FOUND", "user not found")
	ErrUnauthorized   = kerrors.Unauthorized("UNAUTHORIZED", "unauthorized")
)
View Source 
var (
	ErrDriftEventNotFound = kerrors.NotFound("DRIFT_EVENT_NOT_FOUND", "drift event not found")
)

Functions

func NewDebugServer added in v0.3.0 

func NewDebugServer(cfg *config.Server, logger log.Logger) *kratosHttp.Server

func NewGRPCServer added in v0.3.0 

func NewGRPCServer(cfg *config.Server,
	registryServer *RegistryServer,
	metadataServer *MetadataServer,
	usersServer *UsersServer,
	driftServer *DriftServer,
	userRepo data.UserRepository,
	aclRepo data.ACLRepository,
	logger log.Logger,
) *grpc.Server

NewGRPCServer new a gRPC server.

func NewHTTPServer added in v0.3.0 

func NewHTTPServer(cfg *config.Server,
	registryServer *RegistryServer,
	metadataServer *MetadataServer,
	usersServer *UsersServer,
	driftServer *DriftServer,
	userRepo data.UserRepository,
	aclRepo data.ACLRepository,
	logger log.Logger,
) *kratosHttp.Server

NewHTTPServer new a HTTP server.

Types

type DriftServer added in v0.6.0 

type DriftServer struct {
	v1.UnimplementedDriftServiceServer
	// contains filtered or unexported fields
}

DriftServer implements the DriftService gRPC service

func NewDriftServer added in v0.6.0 

func NewDriftServer(driftRepo data.DriftRepository, logger log.Logger) *DriftServer

NewDriftServer creates a new DriftServer

func (*DriftServer) AcknowledgeDriftEvent added in v0.6.0 

func (s *DriftServer) AcknowledgeDriftEvent(ctx context.Context, request *v1.AcknowledgeDriftEventRequest) (*v1.AcknowledgeDriftEventResponse, error)

AcknowledgeDriftEvent acknowledges a drift event

func (*DriftServer) GetModuleDependencyDriftStatus added in v0.6.2 

func (s *DriftServer) GetModuleDependencyDriftStatus(ctx context.Context, request *v1.GetModuleDependencyDriftStatusRequest) (*v1.GetModuleDependencyDriftStatusResponse, error)

GetModuleDependencyDriftStatus returns dependency drift status for a specific module.

func (*DriftServer) GetModuleDriftEvents added in v0.6.0 

func (s *DriftServer) GetModuleDriftEvents(ctx context.Context, request *v1.GetModuleDriftEventsRequest) (*v1.GetModuleDriftEventsResponse, error)

GetModuleDriftEvents returns drift events for a specific module

func (*DriftServer) ListDriftEvents added in v0.6.0 

func (s *DriftServer) ListDriftEvents(ctx context.Context, request *v1.ListDriftEventsRequest) (*v1.ListDriftEventsResponse, error)

ListDriftEvents returns all unacknowledged drift events

type MetadataServer added in v0.4.0 

type MetadataServer struct {
	v1.UnimplementedMetadataServiceServer
	// contains filtered or unexported fields
}

func NewMetadataServer added in v0.4.0 

func NewMetadataServer(registryRepository data.RegistryRepository, metadataRepository data.MetadataRepository, logger log.Logger) *MetadataServer

func (MetadataServer) GetMetadata added in v0.4.0 

func (m MetadataServer) GetMetadata(ctx context.Context, request *v1.GetMetadataRequest) (*v1.GetMetadataResponse, error)

type RegistryServer 

type RegistryServer struct {
	v1.UnimplementedRegistryServer
	// contains filtered or unexported fields
}

func NewRegistryServer 

func NewRegistryServer(registryRepository data.RegistryRepository, metadataRepository data.MetadataRepository, logger log.Logger) *RegistryServer

func (*RegistryServer) DeleteModule 

func (r *RegistryServer) DeleteModule(ctx context.Context, request *v1.DeleteModuleRequest) (*v1.DeleteModuleResponse, error)

func (*RegistryServer) DeleteModuleTag 

func (r *RegistryServer) DeleteModuleTag(ctx context.Context, request *v1.DeleteModuleTagRequest) (*v1.DeleteModuleTagResponse, error)

func (*RegistryServer) GetModule 

func (r *RegistryServer) GetModule(ctx context.Context, request *v1.GetModuleRequest) (*v1.Module, error)

func (*RegistryServer) GetModuleDependencies added in v0.2.0 

func (r *RegistryServer) GetModuleDependencies(ctx context.Context, request *v1.GetModuleDependenciesRequest) (*v1.GetModuleDependenciesResponse, error)

func (*RegistryServer) ListModules 

func (r *RegistryServer) ListModules(ctx context.Context, request *v1.ListModulesRequest) (*v1.ListModulesResponse, error)

func (*RegistryServer) PullModule 

func (r *RegistryServer) PullModule(ctx context.Context, request *v1.PullModuleRequest) (*v1.PullModuleResponse, error)

func (*RegistryServer) PushModule 

func (r *RegistryServer) PushModule(ctx context.Context, request *v1.PushModuleRequest) (*v1.Module, error)

func (*RegistryServer) RegisterModule 

func (r *RegistryServer) RegisterModule(ctx context.Context, request *v1.RegisterModuleRequest) (*v1.Module, error)

type UsersServer added in v0.5.0 

type UsersServer struct {
	v1.UnimplementedUserServiceServer
	// contains filtered or unexported fields
}

func NewUsersServer added in v0.5.0 

func NewUsersServer(userRepo data.UserRepository, aclRepo data.ACLRepository, logger log.Logger) *UsersServer

func (*UsersServer) CreateUser added in v0.5.0 

func (s *UsersServer) CreateUser(ctx context.Context, request *v1.CreateUserRequest) (*v1.CreateUserResponse, error)

func (*UsersServer) DeleteUser added in v0.5.0 

func (s *UsersServer) DeleteUser(ctx context.Context, request *v1.DeleteUserRequest) (*v1.DeleteUserResponse, error)

func (*UsersServer) GetUser added in v0.5.0 

func (s *UsersServer) GetUser(ctx context.Context, request *v1.GetUserRequest) (*v1.User, error)

func (*UsersServer) GrantPermission added in v0.5.0 

func (s *UsersServer) GrantPermission(ctx context.Context, request *v1.GrantPermissionRequest) (*v1.GrantPermissionResponse, error)

func (*UsersServer) ListUserPermissions added in v0.5.0 

func (s *UsersServer) ListUserPermissions(ctx context.Context, request *v1.ListUserPermissionsRequest) (*v1.ListUserPermissionsResponse, error)

func (*UsersServer) ListUsers added in v0.5.0 

func (s *UsersServer) ListUsers(ctx context.Context, request *v1.ListUsersRequest) (*v1.ListUsersResponse, error)

func (*UsersServer) RegenerateToken added in v0.5.0 

func (s *UsersServer) RegenerateToken(ctx context.Context, request *v1.RegenerateTokenRequest) (*v1.RegenerateTokenResponse, error)

func (*UsersServer) RevokePermission added in v0.5.0 

func (s *UsersServer) RevokePermission(ctx context.Context, request *v1.RevokePermissionRequest) (*v1.RevokePermissionResponse, error)

func (*UsersServer) UpdateUser added in v0.5.0 

func (s *UsersServer) UpdateUser(ctx context.Context, request *v1.UpdateUserRequest) (*v1.User, error)

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.