gateway

Documentation

Index

• Constants
• func LoggingInterceptor(l *slog.Logger) grpc.UnaryServerInterceptor
• type Gateway
  • func NewGateway(opts ...Option) (*Gateway, error)
  • func (g *Gateway) Bootstrap(ctx context.Context) error
  • func (g *Gateway) Check(ctx context.Context, req *healthgrpc.HealthCheckRequest) (*healthgrpc.HealthCheckResponse, error)
  • func (g *Gateway) CreateTerminal(ctx context.Context, req *terminal.TerminalCreateRequest) (*terminal.TerminalCreateResponse, error)
  • func (g *Gateway) CreateUser(ctx context.Context, req *user.UserCreateRequest) (*emptypb.Empty, error)
  • func (g *Gateway) DeleteTerminal(ctx context.Context, req *terminal.TerminalDeleteRequest) (*empty.Empty, error)
  • func (g *Gateway) DeleteUser(ctx context.Context, req *user.UserDeleteRequest) (*emptypb.Empty, error)
  • func (g *Gateway) GetUser(ctx context.Context, req *user.UserGetRequest) (*user.User, error)
  • func (g *Gateway) ListUser(ctx context.Context, req *user.UserListRequest) (*user.UserListResponse, error)
  • func (g *Gateway) Login(ctx context.Context, req *auth.LoginRequest) (*auth.LoginResponse, error)
  • func (g *Gateway) Register(s *grpc.Server)
  • func (g *Gateway) TokenAuthInterceptor() grpc.UnaryServerInterceptor
  • func (g *Gateway) UpdateUser(ctx context.Context, req *user.UserUpdateRequest) (*emptypb.Empty, error)
  • func (g *Gateway) Watch(req *healthgrpc.HealthCheckRequest, server healthgrpc.Health_WatchServer) error
• type Option
  • func WithAccessList(imagesAccessList images.ImagesAccessList) Option
  • func WithAuthDriver(driver auth.Driver) Option
  • func WithKubeConfig(config *rest.Config) Option
  • func WithLogger(logger *slog.Logger) Option
  • func WithNamespace(namespace string) Option

Constants

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

	UserMetadataFieldName = "username"
)

const (
	LabelKeyTerminalName = "terminal.marina.io/name"
	LabelKeyUsername     = "user.marina.io/username"
)

const (
	DefaultNamespace string = "marina-system"
)

const (
	DefaultRoleName = "marina-user"
)

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) (*terminal.TerminalCreateResponse, 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 WithAccessList

func WithAccessList(imagesAccessList images.ImagesAccessList) Option

func WithAuthDriver

func WithAuthDriver(driver auth.Driver) Option

func WithKubeConfig

func WithKubeConfig(config *rest.Config) Option

func WithLogger

func WithLogger(logger *slog.Logger) Option

func WithNamespace

func WithNamespace(namespace string) Option