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
Click to show internal directories.
Click to hide internal directories.