Documentation
¶
Index ¶
- type ConcurrencyType
- type Instr
- type RunOpts
- type Runner
- func (r *Runner) AccessTokens(hsDomain string) map[string]string
- func (r *Runner) DeviceIDs(hsDomain string) map[string]string
- func (r *Runner) GetStoredValue(opts RunOpts, key string) string
- func (r *Runner) Run(hs b.Homeserver, hsURL string) (resErr error)
- func (r *Runner) RunInstructions(opts RunOpts, instrs []Instr) (resErr error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConcurrencyType ¶
type ConcurrencyType int
const ( // No concurrency: instructions execute in serial. ConcurrencyTypeNone ConcurrencyType = iota // Per-user concurrency: User requests execute in serial but multiple users can have concurrent requests. ConcurrencyTypePerUser // All concurrency: All requests are executed at the same time. ConcurrencyTypeAll )
type Instr ¶
type Instr struct {
UserID string
Method string
Path string
Queries map[string]string
Body interface{}
Store map[string]string
}
An instruction for the runner to run.
type RunOpts ¶
type RunOpts struct {
Concurrency ConcurrencyType
HSURL string
StoreNamespace string
}
type Runner ¶
type Runner struct {
// contains filtered or unexported fields
}
func (*Runner) AccessTokens ¶
AccessTokens returns the access tokens for all users who were created on the given HS domain. Returns a map of user_id => access_token
func (*Runner) DeviceIDs ¶
DeviceIDs returns the device ids for all users who were created on the given HS domain. Returns a map of user_id => device_id
func (*Runner) GetStoredValue ¶
Load a previously stored value from RunInstructions
Source Files
Click to show internal directories.
Click to hide internal directories.