memory

Documentation

Index

• type InMemoryOrganizationRepository
  • func NewInMemoryOrganizationRepository() *InMemoryOrganizationRepository
  • func (r *InMemoryOrganizationRepository) AddMember(ctx context.Context, organizationID, userID uuid.UUID, role string) error
  • func (r *InMemoryOrganizationRepository) AddTeam(ctx context.Context, organizationID, teamID uuid.UUID) error
  • func (r *InMemoryOrganizationRepository) Create(ctx context.Context, organization *entities.Organization) error
  • func (r *InMemoryOrganizationRepository) Delete(ctx context.Context, id uuid.UUID) error
  • func (r *InMemoryOrganizationRepository) FindAll(ctx context.Context) ([]*entities.Organization, error)
  • func (r *InMemoryOrganizationRepository) FindByID(ctx context.Context, id uuid.UUID) (*entities.Organization, error)
  • func (r *InMemoryOrganizationRepository) FindMember(ctx context.Context, organizationID, userID uuid.UUID) (*entities.OrganizationMember, error)
  • func (r *InMemoryOrganizationRepository) FindMemberMemberships(ctx context.Context, userID uuid.UUID) ([]*entities.OrganizationMember, error)
  • func (r *InMemoryOrganizationRepository) FindMembers(ctx context.Context, organizationID uuid.UUID) ([]*entities.OrganizationMember, error)
  • func (r *InMemoryOrganizationRepository) RemoveMember(ctx context.Context, organizationID, userID uuid.UUID) error
  • func (r *InMemoryOrganizationRepository) RemoveTeam(ctx context.Context, organizationID, teamID uuid.UUID) error
  • func (r *InMemoryOrganizationRepository) Update(ctx context.Context, organization *entities.Organization) error
  • func (r *InMemoryOrganizationRepository) UpdateMemberRole(ctx context.Context, organizationID, userID uuid.UUID, role string) error
• type InMemoryTaskRepository
  • func NewInMemoryTaskRepository() *InMemoryTaskRepository
  • func (r *InMemoryTaskRepository) Create(ctx context.Context, task *entities.Task) error
  • func (r *InMemoryTaskRepository) Delete(ctx context.Context, id uuid.UUID) error
  • func (r *InMemoryTaskRepository) FindAll(ctx context.Context, scope *entities.TaskScope) ([]*entities.Task, error)
  • func (r *InMemoryTaskRepository) FindByID(ctx context.Context, id uuid.UUID, scope *entities.TaskScope) (*entities.Task, error)
  • func (r *InMemoryTaskRepository) Update(ctx context.Context, task *entities.Task) error
• type InMemoryTaskRunRepository
  • func NewInMemoryTaskRunRepository() *InMemoryTaskRunRepository
  • func (r *InMemoryTaskRunRepository) Create(ctx context.Context, taskRun *entities.TaskRun) error
  • func (r *InMemoryTaskRunRepository) Delete(ctx context.Context, id uuid.UUID) error
  • func (r *InMemoryTaskRunRepository) FindAll(ctx context.Context) ([]*entities.TaskRun, error)
  • func (r *InMemoryTaskRunRepository) FindByID(ctx context.Context, id uuid.UUID) (*entities.TaskRun, error)
  • func (r *InMemoryTaskRunRepository) FindByTaskID(ctx context.Context, taskID uuid.UUID) ([]*entities.TaskRun, error)
  • func (r *InMemoryTaskRunRepository) Update(ctx context.Context, taskRun *entities.TaskRun) error
• type InMemoryTeamRepository
  • func NewInMemoryTeamRepository() *InMemoryTeamRepository
  • func (r *InMemoryTeamRepository) AddMember(ctx context.Context, teamID, userID uuid.UUID, role string) error
  • func (r *InMemoryTeamRepository) Create(ctx context.Context, team *entities.Team) error
  • func (r *InMemoryTeamRepository) Delete(ctx context.Context, id uuid.UUID) error
  • func (r *InMemoryTeamRepository) FindAll(ctx context.Context) ([]*entities.Team, error)
  • func (r *InMemoryTeamRepository) FindByID(ctx context.Context, id uuid.UUID) (*entities.Team, error)
  • func (r *InMemoryTeamRepository) FindMember(ctx context.Context, teamID, userID uuid.UUID) (*entities.TeamMember, error)
  • func (r *InMemoryTeamRepository) FindMemberMemberships(ctx context.Context, userID uuid.UUID) ([]*entities.TeamMember, error)
  • func (r *InMemoryTeamRepository) FindMembers(ctx context.Context, teamID uuid.UUID) ([]*entities.TeamMember, error)
  • func (r *InMemoryTeamRepository) RemoveMember(ctx context.Context, teamID, userID uuid.UUID) error
  • func (r *InMemoryTeamRepository) Update(ctx context.Context, team *entities.Team) error
  • func (r *InMemoryTeamRepository) UpdateMemberRole(ctx context.Context, teamID, userID uuid.UUID, role string) error
• type InMemoryUserRepository
  • func NewInMemoryUserRepository() *InMemoryUserRepository
  • func (r *InMemoryUserRepository) Create(ctx context.Context, user *entities.User) error
  • func (r *InMemoryUserRepository) Delete(ctx context.Context, id uuid.UUID) error
  • func (r *InMemoryUserRepository) FindAll(ctx context.Context) ([]*entities.User, error)
  • func (r *InMemoryUserRepository) FindByEmail(ctx context.Context, email string) (*entities.User, error)
  • func (r *InMemoryUserRepository) FindByID(ctx context.Context, id uuid.UUID) (*entities.User, error)
  • func (r *InMemoryUserRepository) Update(ctx context.Context, user *entities.User) error
• type TriggerRepository
  • func NewInMemoryTriggerRepository() *TriggerRepository
  • func (r *TriggerRepository) Create(ctx context.Context, trigger *entities.Trigger) error
  • func (r *TriggerRepository) Delete(ctx context.Context, id uuid.UUID) error
  • func (r *TriggerRepository) FindAll(ctx context.Context) ([]*entities.Trigger, error)
  • func (r *TriggerRepository) FindByID(ctx context.Context, id uuid.UUID) (*entities.Trigger, error)
  • func (r *TriggerRepository) Update(ctx context.Context, trigger *entities.Trigger) error

Types

type InMemoryOrganizationRepository

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

func NewInMemoryOrganizationRepository

func NewInMemoryOrganizationRepository() *InMemoryOrganizationRepository

func (*InMemoryOrganizationRepository) AddMember

func (r *InMemoryOrganizationRepository) AddMember(ctx context.Context, organizationID, userID uuid.UUID, role string) error

func (*InMemoryOrganizationRepository) AddTeam

func (r *InMemoryOrganizationRepository) AddTeam(ctx context.Context, organizationID, teamID uuid.UUID) error

func (*InMemoryOrganizationRepository) Create

func (r *InMemoryOrganizationRepository) Create(ctx context.Context, organization *entities.Organization) error

func (*InMemoryOrganizationRepository) Delete

func (r *InMemoryOrganizationRepository) Delete(ctx context.Context, id uuid.UUID) error

func (*InMemoryOrganizationRepository) FindAll

func (r *InMemoryOrganizationRepository) FindAll(ctx context.Context) ([]*entities.Organization, error)

func (*InMemoryOrganizationRepository) FindByID

func (r *InMemoryOrganizationRepository) FindByID(ctx context.Context, id uuid.UUID) (*entities.Organization, error)

func (*InMemoryOrganizationRepository) FindMember

func (r *InMemoryOrganizationRepository) FindMember(ctx context.Context, organizationID, userID uuid.UUID) (*entities.OrganizationMember, error)

func (*InMemoryOrganizationRepository) FindMemberMemberships

func (r *InMemoryOrganizationRepository) FindMemberMemberships(ctx context.Context, userID uuid.UUID) ([]*entities.OrganizationMember, error)

func (*InMemoryOrganizationRepository) FindMembers

func (r *InMemoryOrganizationRepository) FindMembers(ctx context.Context, organizationID uuid.UUID) ([]*entities.OrganizationMember, error)

func (*InMemoryOrganizationRepository) RemoveMember

func (r *InMemoryOrganizationRepository) RemoveMember(ctx context.Context, organizationID, userID uuid.UUID) error

func (*InMemoryOrganizationRepository) RemoveTeam

func (r *InMemoryOrganizationRepository) RemoveTeam(ctx context.Context, organizationID, teamID uuid.UUID) error

func (*InMemoryOrganizationRepository) Update

func (r *InMemoryOrganizationRepository) Update(ctx context.Context, organization *entities.Organization) error

func (*InMemoryOrganizationRepository) UpdateMemberRole

func (r *InMemoryOrganizationRepository) UpdateMemberRole(ctx context.Context, organizationID, userID uuid.UUID, role string) error

type InMemoryTaskRepository

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

InMemoryTaskRepository is an in-memory task repository.

func NewInMemoryTaskRepository

func NewInMemoryTaskRepository() *InMemoryTaskRepository

NewInMemoryTaskRepository creates a new instance of InMemoryTaskRepository.

func (*InMemoryTaskRepository) Create

func (r *InMemoryTaskRepository) Create(ctx context.Context, task *entities.Task) error

Create adds a new task to the repository.

func (*InMemoryTaskRepository) Delete

func (r *InMemoryTaskRepository) Delete(ctx context.Context, id uuid.UUID) error

Delete removes a task from the repository.

func (*InMemoryTaskRepository) FindAll

func (r *InMemoryTaskRepository) FindAll(ctx context.Context, scope *entities.TaskScope) ([]*entities.Task, error)

FindAll returns all tasks in the repository.

func (*InMemoryTaskRepository) FindByID

func (r *InMemoryTaskRepository) FindByID(ctx context.Context, id uuid.UUID, scope *entities.TaskScope) (*entities.Task, error)

FindByID returns the task with the specified ID.

func (*InMemoryTaskRepository) Update

func (r *InMemoryTaskRepository) Update(ctx context.Context, task *entities.Task) error

Update updates an existing task in the repository.

type InMemoryTaskRunRepository

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

InMemoryTaskRunRepository is an in-memory task run repository.

func NewInMemoryTaskRunRepository

func NewInMemoryTaskRunRepository() *InMemoryTaskRunRepository

NewInMemoryTaskRunRepository creates a new instance of InMemoryTaskRunRepository.

func (*InMemoryTaskRunRepository) Create

func (r *InMemoryTaskRunRepository) Create(ctx context.Context, taskRun *entities.TaskRun) error

Create adds a new task run to the repository.

func (*InMemoryTaskRunRepository) Delete

func (r *InMemoryTaskRunRepository) Delete(ctx context.Context, id uuid.UUID) error

Delete removes a task run from the repository.

func (*InMemoryTaskRunRepository) FindAll

func (r *InMemoryTaskRunRepository) FindAll(ctx context.Context) ([]*entities.TaskRun, error)

FindAll returns all task runs in the repository.

func (*InMemoryTaskRunRepository) FindByID

func (r *InMemoryTaskRunRepository) FindByID(ctx context.Context, id uuid.UUID) (*entities.TaskRun, error)

FindByID returns the task run with the specified ID.

func (*InMemoryTaskRunRepository) FindByTaskID

func (r *InMemoryTaskRunRepository) FindByTaskID(ctx context.Context, taskID uuid.UUID) ([]*entities.TaskRun, error)

FindByTaskID returns all task runs for a task.

func (*InMemoryTaskRunRepository) Update

func (r *InMemoryTaskRunRepository) Update(ctx context.Context, taskRun *entities.TaskRun) error

Update updates an existing task run in the repository.

type InMemoryTeamRepository

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

InMemoryTeamRepository is an in-memory repository that manages teams.

func NewInMemoryTeamRepository

func NewInMemoryTeamRepository() *InMemoryTeamRepository

NewInMemoryTeamRepository creates a new in-memory team repository.

func (*InMemoryTeamRepository) AddMember

func (r *InMemoryTeamRepository) AddMember(ctx context.Context, teamID, userID uuid.UUID, role string) error

AddMember adds a member to a team.

func (*InMemoryTeamRepository) Create

func (r *InMemoryTeamRepository) Create(ctx context.Context, team *entities.Team) error

Create adds a new team to the repository.

func (*InMemoryTeamRepository) Delete

func (r *InMemoryTeamRepository) Delete(ctx context.Context, id uuid.UUID) error

Delete removes a team from the repository.

func (*InMemoryTeamRepository) FindAll

func (r *InMemoryTeamRepository) FindAll(ctx context.Context) ([]*entities.Team, error)

FindAll returns all teams in the repository.

func (*InMemoryTeamRepository) FindByID

func (r *InMemoryTeamRepository) FindByID(ctx context.Context, id uuid.UUID) (*entities.Team, error)

FindByID returns the team with the specified ID.

func (*InMemoryTeamRepository) FindMember

func (r *InMemoryTeamRepository) FindMember(ctx context.Context, teamID, userID uuid.UUID) (*entities.TeamMember, error)

FindMember returns a member of a team.

func (*InMemoryTeamRepository) FindMemberMemberships

func (r *InMemoryTeamRepository) FindMemberMemberships(ctx context.Context, userID uuid.UUID) ([]*entities.TeamMember, error)

FindMemberMemberships returns all memberships of a member.

func (*InMemoryTeamRepository) FindMembers

func (r *InMemoryTeamRepository) FindMembers(ctx context.Context, teamID uuid.UUID) ([]*entities.TeamMember, error)

FindMembers returns all members of a team.

func (*InMemoryTeamRepository) RemoveMember

func (r *InMemoryTeamRepository) RemoveMember(ctx context.Context, teamID, userID uuid.UUID) error

RemoveMember removes a member from a team.

func (*InMemoryTeamRepository) Update

func (r *InMemoryTeamRepository) Update(ctx context.Context, team *entities.Team) error

Update updates an existing team in the repository.

func (*InMemoryTeamRepository) UpdateMemberRole

func (r *InMemoryTeamRepository) UpdateMemberRole(ctx context.Context, teamID, userID uuid.UUID, role string) error

UpdateMemberRole updates the role of a member in a team.

type InMemoryUserRepository

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

InMemoryUserRepository is an in-memory user repository.

func NewInMemoryUserRepository

func NewInMemoryUserRepository() *InMemoryUserRepository

NewInMemoryUserRepository creates a new in-memory user repository.

func (*InMemoryUserRepository) Create

func (r *InMemoryUserRepository) Create(ctx context.Context, user *entities.User) error

Create adds a new user to the repository.

func (*InMemoryUserRepository) Delete

func (r *InMemoryUserRepository) Delete(ctx context.Context, id uuid.UUID) error

Delete removes a user from the repository.

func (*InMemoryUserRepository) FindAll

func (r *InMemoryUserRepository) FindAll(ctx context.Context) ([]*entities.User, error)

FindAll returns all users in the repository.

func (*InMemoryUserRepository) FindByEmail

func (r *InMemoryUserRepository) FindByEmail(ctx context.Context, email string) (*entities.User, error)

FindByEmail returns the user with the specified email.

func (*InMemoryUserRepository) FindByID

func (r *InMemoryUserRepository) FindByID(ctx context.Context, id uuid.UUID) (*entities.User, error)

FindByID returns the user with the specified ID.

func (*InMemoryUserRepository) Update

func (r *InMemoryUserRepository) Update(ctx context.Context, user *entities.User) error

Update updates an existing user in the repository.

type TriggerRepository

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

TriggerRepository is a repository that manages triggers in memory.

func NewInMemoryTriggerRepository

func NewInMemoryTriggerRepository() *TriggerRepository

NewInMemoryTriggerRepository creates a new in-memory trigger repository.

func (*TriggerRepository) Create

func (r *TriggerRepository) Create(ctx context.Context, trigger *entities.Trigger) error

Create creates a new trigger.

func (*TriggerRepository) Delete

func (r *TriggerRepository) Delete(ctx context.Context, id uuid.UUID) error

Delete deletes a trigger by ID.

func (*TriggerRepository) FindAll

func (r *TriggerRepository) FindAll(ctx context.Context) ([]*entities.Trigger, error)

FindAll returns all triggers.

func (*TriggerRepository) FindByID

func (r *TriggerRepository) FindByID(ctx context.Context, id uuid.UUID) (*entities.Trigger, error)

FindByID returns a trigger by ID.

func (*TriggerRepository) Update

func (r *TriggerRepository) Update(ctx context.Context, trigger *entities.Trigger) error

Update updates a trigger.