providers

Documentation

Index

• type AuthProvider
  • func NewAuthProvider() (AuthProvider, error)
• type AuthProviderImpl
  • func (a *AuthProviderImpl) GenerateToken(username, role string) (string, error)
  • func (a *AuthProviderImpl) HandleLogin(username, password string) (string, error)
  • func (a *AuthProviderImpl) NewTokenAuth() *jwtauth.JWTAuth
  • func (a *AuthProviderImpl) RefreshToken(token string) (string, error)
  • func (a *AuthProviderImpl) ValidateToken(token string) (bool, error)
  • func (a *AuthProviderImpl) ValidateUserPassword(username, password string) (role string, valid bool, err error)
• type SessionProvider
  • func NewSessionProvider(repository repositories.SessionsRepository) (SessionProvider, error)
• type SessionProviderImpl
  • func (s *SessionProviderImpl) CreateSession(request SessionRequest) error
  • func (s *SessionProviderImpl) DeleteSession(id string) error
  • func (s *SessionProviderImpl) GetSession(id string) (entities.Session, error)
• type SessionRequest
• type TektonClient
  • func NewTektonClient() (TektonClient, error)
• type TektonClientImpl
  • func (c *TektonClientImpl) GetTaskRun(ctx context.Context, namespace string, id uuid.UUID) (*tektonAPI.TaskRun, error)
  • func (c *TektonClientImpl) GetTaskRunLogs(ctx context.Context, taskRun *tektonAPI.TaskRun) (string, error)
  • func (c *TektonClientImpl) Logs(ctx context.Context, taskRun *tektonAPI.TaskRun) (string, error)
  • func (c *TektonClientImpl) RunTaskRun(ctx context.Context, taskRun *tektonAPI.TaskRun) error
  • func (c *TektonClientImpl) WatchTaskRun(ctx context.Context, taskRun *tektonAPI.TaskRun, id uuid.UUID) (<-chan watch.Event, error)

Types

type AuthProvider

type AuthProvider interface {
	// HandleLogin is a method that will be implemented by the auth provider
	HandleLogin(username, password string) (string, error)
	// ValidateToken is a method that will be implemented by the auth provider
	ValidateToken(token string) (bool, error)
	// ValidateUserPassword is a method that will be implemented by the auth provider
	ValidateUserPassword(username, password string) (role string, valid bool, err error)
	// RefreshToken is a method that will be implemented by the auth provider
	RefreshToken(token string) (string, error)
	// GenerateToken is a method that will be implemented by the auth provider
	GenerateToken(username, role string) (string, error)
	// NewTokenAuth is a method that will be implemented by the auth provider
	NewTokenAuth() *jwtauth.JWTAuth
}

func NewAuthProvider

func NewAuthProvider() (AuthProvider, error)

NewAuthProvider creates a new AuthProvider

type AuthProviderImpl

type AuthProviderImpl struct {
	JWTSecret string
	JWTAuth   *jwtauth.JWTAuth
}

AuthProviderImpl is the default implementation of the AuthProvider interface

func (*AuthProviderImpl) GenerateToken

func (a *AuthProviderImpl) GenerateToken(username, role string) (string, error)

GetToken is a method that will be implemented by the auth provider

func (*AuthProviderImpl) HandleLogin

func (a *AuthProviderImpl) HandleLogin(username, password string) (string, error)

HandleLogin is a method that will be implemented by the auth provider

func (*AuthProviderImpl) NewTokenAuth

func (a *AuthProviderImpl) NewTokenAuth() *jwtauth.JWTAuth

NewTokenAuth is a method that will be implemented by the auth provider

func (*AuthProviderImpl) RefreshToken

func (a *AuthProviderImpl) RefreshToken(token string) (string, error)

RefreshToken is a method that will be implemented by the auth provider

func (*AuthProviderImpl) ValidateToken

func (a *AuthProviderImpl) ValidateToken(token string) (bool, error)

ValidateToken is a method that will be implemented by the auth provider

func (*AuthProviderImpl) ValidateUserPassword

func (a *AuthProviderImpl) ValidateUserPassword(username, password string) (role string, valid bool, err error)

ValidateUserPassword is a method that will be implemented by the auth provider

type SessionProvider

type SessionProvider interface {
	// CreateSession is a method that will be implemented by the session provider
	CreateSession(request SessionRequest) error
	// GetSession is a method that will be implemented by the session provider
	GetSession(id string) (entities.Session, error)
	// DeleteSession is a method that will be implemented by the session provider
	DeleteSession(id string) error
}

func NewSessionProvider

func NewSessionProvider(repository repositories.SessionsRepository) (SessionProvider, error)

type SessionProviderImpl

type SessionProviderImpl struct {
	Repository repositories.SessionsRepository
}

func (*SessionProviderImpl) CreateSession

func (s *SessionProviderImpl) CreateSession(request SessionRequest) error

func (*SessionProviderImpl) DeleteSession

func (s *SessionProviderImpl) DeleteSession(id string) error

func (*SessionProviderImpl) GetSession

func (s *SessionProviderImpl) GetSession(id string) (entities.Session, error)

type SessionRequest

type SessionRequest struct {
	ID       uuid.UUID `json:"id"`
	Username string    `json:"username"`
	Password string    `json:"password"`
	Token    string    `json:"token"`
}

type TektonClient

type TektonClient interface {
	// GetTaskRun returns a task run by name.
	GetTaskRun(ctx context.Context, namespace string, id uuid.UUID) (*tektonAPI.TaskRun, error)
	// RunTask runs a task.
	RunTaskRun(ctx context.Context, taskRun *tektonAPI.TaskRun) error
	// WatchTaskRun watches a task run.
	WatchTaskRun(ctx context.Context, taskRun *tektonAPI.TaskRun, id uuid.UUID) (<-chan watch.Event, error)
	// GetTaskRunLogs returns a stream of logs for a task run.
	GetTaskRunLogs(ctx context.Context, taskRun *tektonAPI.TaskRun) (string, error)
}

TektonClient is a client for interacting with Tekton.

func NewTektonClient

func NewTektonClient() (TektonClient, error)

NewTektonClient creates a new TektonClient.

type TektonClientImpl

type TektonClientImpl struct {
	// contains filtered or unexported fields
}

func (*TektonClientImpl) GetTaskRun

func (c *TektonClientImpl) GetTaskRun(ctx context.Context, namespace string, id uuid.UUID) (*tektonAPI.TaskRun, error)

GetTaskRun returns a task run by ID.

func (*TektonClientImpl) GetTaskRunLogs

func (c *TektonClientImpl) GetTaskRunLogs(ctx context.Context, taskRun *tektonAPI.TaskRun) (string, error)

func (*TektonClientImpl) Logs

func (c *TektonClientImpl) Logs(ctx context.Context, taskRun *tektonAPI.TaskRun) (string, error)

Logs returns the logs of a task run.

func (*TektonClientImpl) RunTaskRun

func (c *TektonClientImpl) RunTaskRun(ctx context.Context, taskRun *tektonAPI.TaskRun) error

func (*TektonClientImpl) WatchTaskRun

func (c *TektonClientImpl) WatchTaskRun(ctx context.Context, taskRun *tektonAPI.TaskRun, id uuid.UUID) (<-chan watch.Event, error)