storage

func (*AuthorizationStorage) Delete ¶

func (as *AuthorizationStorage) Delete(workspaceID int, externalServiceID domain.IntegrationID) error

func (*AuthorizationStorage) Load ¶

func (as *AuthorizationStorage) Load(workspaceID int, externalServiceID domain.IntegrationID, a *domain.Authorization) error

func (*AuthorizationStorage) LoadWorkspaceAuthorizations ¶

func (as *AuthorizationStorage) LoadWorkspaceAuthorizations(workspaceID int) (map[domain.IntegrationID]bool, error)

LoadWorkspaceAuthorizations loads map with authorizations status for each externalService. Map format: map[externalServiceID]isAuthorized

func (*AuthorizationStorage) Save ¶

func (as *AuthorizationStorage) Save(a *domain.Authorization) error

func (*IdMappingStorage) Delete ¶

func (ims *IdMappingStorage) Delete(workspaceID int, pipeConnectionKey, pipeStatusKey string) (err error)

func (*IdMappingStorage) Load ¶

func (ims *IdMappingStorage) Load(workspaceID int, key string) (*domain.IDMapping, error)

func (*IdMappingStorage) LoadReversed ¶

func (ims *IdMappingStorage) LoadReversed(workspaceID int, key string) (*domain.ReversedIDMapping, error)

func (*IdMappingStorage) Save ¶

func (ims *IdMappingStorage) Save(c *domain.IDMapping) error

func (*ImportStorage) DeleteAccountsFor ¶

func (is *ImportStorage) DeleteAccountsFor(s domain.PipeIntegration) error

func (*ImportStorage) DeleteUsersFor ¶

func (is *ImportStorage) DeleteUsersFor(s domain.PipeIntegration) error

func (*ImportStorage) LoadAccountsFor ¶

func (is *ImportStorage) LoadAccountsFor(s domain.PipeIntegration) (*domain.AccountsResponse, error)

func (*ImportStorage) LoadClientsFor ¶

func (is *ImportStorage) LoadClientsFor(s domain.PipeIntegration) (*domain.ClientsResponse, error)

func (*ImportStorage) LoadProjectsFor ¶

func (is *ImportStorage) LoadProjectsFor(s domain.PipeIntegration) (*domain.ProjectsResponse, error)

func (*ImportStorage) LoadTasksFor ¶

func (is *ImportStorage) LoadTasksFor(s domain.PipeIntegration) (*domain.TasksResponse, error)

func (*ImportStorage) LoadTodoListsFor ¶

func (is *ImportStorage) LoadTodoListsFor(s domain.PipeIntegration) (*domain.TasksResponse, error)

func (*ImportStorage) LoadUsersFor ¶

func (is *ImportStorage) LoadUsersFor(s domain.PipeIntegration) (*domain.UsersResponse, error)

func (*ImportStorage) SaveAccountsFor ¶

func (is *ImportStorage) SaveAccountsFor(s domain.PipeIntegration, res domain.AccountsResponse) error

func (*ImportStorage) SaveClientsFor ¶

func (is *ImportStorage) SaveClientsFor(s domain.PipeIntegration, res domain.ClientsResponse) error

func (*ImportStorage) SaveProjectsFor ¶

func (is *ImportStorage) SaveProjectsFor(s domain.PipeIntegration, res domain.ProjectsResponse) error

func (*ImportStorage) SaveTasksFor ¶

func (is *ImportStorage) SaveTasksFor(s domain.PipeIntegration, res domain.TasksResponse) error

func (*ImportStorage) SaveTodoListsFor ¶

func (is *ImportStorage) SaveTodoListsFor(s domain.PipeIntegration, res domain.TasksResponse) error

func (*ImportStorage) SaveUsersFor ¶

func (is *ImportStorage) SaveUsersFor(s domain.PipeIntegration, res domain.UsersResponse) error

func (*IntegrationStorage) IsValidPipe ¶

func (is *IntegrationStorage) IsValidPipe(pipeID domain.PipeID) bool

func (*IntegrationStorage) IsValidService ¶

func (is *IntegrationStorage) IsValidService(serviceID domain.IntegrationID) bool

func (*IntegrationStorage) LoadAuthorizationType ¶

func (is *IntegrationStorage) LoadAuthorizationType(serviceID domain.IntegrationID) (string, error)

func (*IntegrationStorage) LoadIntegrations ¶

func (is *IntegrationStorage) LoadIntegrations() ([]*domain.Integration, error)

func (*IntegrationStorage) SaveAuthorizationType ¶

func (is *IntegrationStorage) SaveAuthorizationType(serviceID domain.IntegrationID, authType string) error

func (*PipeStorage) Delete ¶

func (ps *PipeStorage) Delete(p *domain.Pipe, workspaceID int) error

func (*PipeStorage) DeleteByWorkspaceIDServiceID ¶

func (ps *PipeStorage) DeleteByWorkspaceIDServiceID(workspaceID int, serviceID domain.IntegrationID) error

func (*PipeStorage) IsDown ¶

func (ps *PipeStorage) IsDown() bool

func (*PipeStorage) Load ¶

func (ps *PipeStorage) Load(p *domain.Pipe) error

func (*PipeStorage) LoadAll ¶

func (ps *PipeStorage) LoadAll(workspaceID int) (map[string]*domain.Pipe, error)

func (*PipeStorage) LoadAllStatuses ¶

func (ps *PipeStorage) LoadAllStatuses(workspaceID int) (map[string]*domain.Status, error)

func (*PipeStorage) LoadLastSyncFor ¶

func (ps *PipeStorage) LoadLastSyncFor(p *domain.Pipe)

func (*PipeStorage) LoadStatus ¶

func (ps *PipeStorage) LoadStatus(workspaceID int, sid domain.IntegrationID, pid domain.PipeID) (*domain.Status, error)

func (*PipeStorage) Save ¶

func (ps *PipeStorage) Save(p *domain.Pipe) error

func (*PipeStorage) SaveStatus ¶

func (ps *PipeStorage) SaveStatus(p *domain.Status) error