Documentation
¶
Index ¶
- type EnvelopeStorage
- func (s *EnvelopeStorage) CheckStalled(id api.UUID, delay time.Duration) bool
- func (s *EnvelopeStorage) GetEventTypes(id api.UUID) ([]string, bool)
- func (s *EnvelopeStorage) Purge(filter storage.EnvelopeFilter)
- func (s *EnvelopeStorage) ReadEnvelope(id api.UUID, position storage.EnvelopeReadPos, maxsize int) (api.Envelope, storage.EnvelopeReadPos, error)
- func (s *EnvelopeStorage) SetEventHandler(handler storage.EnvelopeStorageEventHandler)
- func (s *EnvelopeStorage) StoreEnvelope(e api.Envelope) (storage.EnvelopeState, error)
- type JobStorage
- func (s *JobStorage) GetState(id storage.JobID) storage.JobState
- func (s *JobStorage) ListDetachedJobByActor(actorID api.UUID) (storage.JobList, error)
- func (s *JobStorage) ListJobByProcess(processID api.UUID) (jobs []storage.Job)
- func (s *JobStorage) ListPendingJobByActor(actorID api.UUID, after *storage.JobID, limit int) (jobs []storage.Job)
- func (s *JobStorage) ListRunningJobByEnvelopeID(envelopeID api.UUID) (jobs []storage.Job)
- func (s *JobStorage) NewJob(id storage.JobID, state storage.JobState)
- func (s *JobStorage) Purge([]api.UUID) error
- func (s *JobStorage) SetState(id storage.JobID, state storage.JobState)
- type ProcessStorage
- func (s *ProcessStorage) CreateProcess(p storage.Process) (api.UUID, error)
- func (s *ProcessStorage) GetProcess(id api.UUID) (storage.Process, error)
- func (s *ProcessStorage) GetProcessByTrigger(emitter api.Actor, envelopeID api.UUID) (storage.Process, error)
- func (s *ProcessStorage) ListActiveEmissions(targetActor api.UUID) ([]storage.Emission, error)
- type SessionStorage
- func (store *SessionStorage) Delete(token string) error
- func (store *SessionStorage) DeleteOlderThan(time time.Time) error
- func (store *SessionStorage) Get(token string) (*storage.Session, error)
- func (store *SessionStorage) List() ([]storage.Session, error)
- func (store *SessionStorage) Set(session storage.Session) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EnvelopeStorage ¶
type EnvelopeStorage struct {
// contains filtered or unexported fields
}
EnvelopeStorage implements EnvelopeStorage on top of a SQL database
func NewEnvelopeStorage ¶
func NewEnvelopeStorage(logger xbus.Logger) *EnvelopeStorage
NewEnvelopeStorage init an empty EnvelopeStorage suitable for tests
func (*EnvelopeStorage) CheckStalled ¶
CheckStalled ...
func (*EnvelopeStorage) GetEventTypes ¶
func (s *EnvelopeStorage) GetEventTypes(id api.UUID) ([]string, bool)
GetEventTypes returns an envelop event types
func (*EnvelopeStorage) Purge ¶
func (s *EnvelopeStorage) Purge(filter storage.EnvelopeFilter)
Purge removes the envelopes fitered by the given filter
func (*EnvelopeStorage) ReadEnvelope ¶
func (s *EnvelopeStorage) ReadEnvelope(id api.UUID, position storage.EnvelopeReadPos, maxsize int) (api.Envelope, storage.EnvelopeReadPos, error)
ReadEnvelope reads as much as it can of an envelope, starting at 'position' The returned envelope should be suitable for encrypted nats transfert, ie its total jsonified size should be under maxsize
func (*EnvelopeStorage) SetEventHandler ¶
func (s *EnvelopeStorage) SetEventHandler(handler storage.EnvelopeStorageEventHandler)
SetEventHandler sets the event handler
func (*EnvelopeStorage) StoreEnvelope ¶
func (s *EnvelopeStorage) StoreEnvelope(e api.Envelope) (storage.EnvelopeState, error)
StoreEnvelope store a part of an envelope and returns its status in the storage
type JobStorage ¶
type JobStorage struct {
// contains filtered or unexported fields
}
JobStorage is a mock for storage.Storage
func (*JobStorage) GetState ¶
func (s *JobStorage) GetState(id storage.JobID) storage.JobState
GetState ...
func (*JobStorage) ListDetachedJobByActor ¶
ListDetachedJobByActor ...
func (*JobStorage) ListJobByProcess ¶
func (s *JobStorage) ListJobByProcess(processID api.UUID) (jobs []storage.Job)
ListJobByProcess ...
func (*JobStorage) ListPendingJobByActor ¶
func (s *JobStorage) ListPendingJobByActor(actorID api.UUID, after *storage.JobID, limit int) (jobs []storage.Job)
ListPendingJobByActor ...
func (*JobStorage) ListRunningJobByEnvelopeID ¶
func (s *JobStorage) ListRunningJobByEnvelopeID(envelopeID api.UUID) (jobs []storage.Job)
ListRunningJobByEnvelopeID ...
type ProcessStorage ¶
type ProcessStorage struct {
// contains filtered or unexported fields
}
ProcessStorage implements storage.ProcessStorage
func NewProcessStorage ¶
func NewProcessStorage() *ProcessStorage
NewProcessStorage returns a new ProcessStorage
func (*ProcessStorage) CreateProcess ¶
CreateProcess saves a process
func (*ProcessStorage) GetProcess ¶
GetProcess returns a process data
func (*ProcessStorage) GetProcessByTrigger ¶
func (s *ProcessStorage) GetProcessByTrigger(emitter api.Actor, envelopeID api.UUID) (storage.Process, error)
GetProcessByTrigger returns a process matching a trigger or an empty value if not found
func (*ProcessStorage) ListActiveEmissions ¶
ListActiveEmissions returns the active emissions
type SessionStorage ¶
type SessionStorage struct {
// contains filtered or unexported fields
}
SessionStorage is a in-memory implementation of storage.SessionStorage
func (*SessionStorage) Delete ¶
func (store *SessionStorage) Delete(token string) error
Delete deletes a token
func (*SessionStorage) DeleteOlderThan ¶
func (store *SessionStorage) DeleteOlderThan(time time.Time) error
DeleteOlderThan deletes the sessions based on their 'validUntil'
func (*SessionStorage) Get ¶
func (store *SessionStorage) Get(token string) (*storage.Session, error)
Get returns a Session from its token
Source Files