gateway

package
v0.0.0-...-0687549 Latest Latest
Warning

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

 Go to latest Published: Dec 29, 2023 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TokenSigningSecretName  = "jwt-signing-key"
	TokenSigningSecretField = "value"

	UserAccessFieldKeyName = "user-access-list"
)
View Source 
const (
	DefaultNamespace string = "marina-system"
)
View Source 
const (
	DefaultRoleName = "marina-user"
)

Variables

This section is empty.

Functions

func LoggingInterceptor 

func LoggingInterceptor(l *slog.Logger) grpc.UnaryServerInterceptor

Types

type Gateway 

type Gateway struct {
	terminal.UnimplementedTerminalServiceServer
	user.UnimplementedUserServiceServer
	auth.UnimplementedAuthServiceServer
	// contains filtered or unexported fields
}

func NewGateway 

func NewGateway(opts ...Option) (*Gateway, error)

func (*Gateway) Bootstrap 

func (g *Gateway) Bootstrap(ctx context.Context) error

func (*Gateway) Check 

func (g *Gateway) Check(ctx context.Context, req *healthgrpc.HealthCheckRequest) (*healthgrpc.HealthCheckResponse, error)

Check implements grpc_health_v1.HealthServer.

func (*Gateway) CreateTerminal 

func (g *Gateway) CreateTerminal(ctx context.Context, req *terminal.TerminalCreateRequest) (*empty.Empty, error)

func (*Gateway) CreateUser 

func (g *Gateway) CreateUser(ctx context.Context, req *user.UserCreateRequest) (*emptypb.Empty, error)

func (*Gateway) DeleteTerminal 

func (g *Gateway) DeleteTerminal(ctx context.Context, req *terminal.TerminalDeleteRequest) (*empty.Empty, error)

func (*Gateway) DeleteUser 

func (g *Gateway) DeleteUser(ctx context.Context, req *user.UserDeleteRequest) (*emptypb.Empty, error)

func (*Gateway) GetUser 

func (g *Gateway) GetUser(ctx context.Context, req *user.UserGetRequest) (*user.User, error)

func (*Gateway) ListUser 

func (g *Gateway) ListUser(ctx context.Context, req *user.UserListRequest) (*user.UserListResponse, error)

func (*Gateway) Login 

func (g *Gateway) Login(ctx context.Context, req *auth.LoginRequest) (*auth.LoginResponse, error)

func (*Gateway) Register 

func (g *Gateway) Register(s *grpc.Server)

func (*Gateway) TokenAuthInterceptor 

func (g *Gateway) TokenAuthInterceptor() grpc.UnaryServerInterceptor

func (*Gateway) UpdateUser 

func (g *Gateway) UpdateUser(ctx context.Context, req *user.UserUpdateRequest) (*emptypb.Empty, error)

func (*Gateway) Watch 

func (g *Gateway) Watch(req *healthgrpc.HealthCheckRequest, server healthgrpc.Health_WatchServer) error

Watch implements grpc_health_v1.HealthServer.

type Option 

type Option func(*Gateway)

func WithAuthDriver 

func WithAuthDriver(driver auth.Driver) Option

func WithKubeClient 

func WithKubeClient(client client.Client) Option

func WithLogger 

func WithLogger(logger *slog.Logger) Option

func WithNamespace 

func WithNamespace(namespace string) Option

Source Files

View all Source files

Directories

Path Synopsis
drivers
auth
storage

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.