worker

package

Go to main page

Versions in this module

v1

v1.0.21

May 31, 2024

Changes in this version

type Worker

+ func (w *Worker) DeleteMessage(key string)

+ func (w *Worker) GetMessage(key string) (*ws.Msg, bool)

+ func (w *Worker) SetMessage(key string, msg *ws.Msg)

v1.0.20

May 30, 2024

v1.0.19

May 27, 2024

v1.0.18

May 27, 2024

v1.0.17

Apr 29, 2024

Changes in this version

type HTTPMultiStepsRequest

+ Assertions AssertionsOptions

v1.0.16

Apr 13, 2024

v1.0.15

Apr 13, 2024

Changes in this version

+ type SpecifyTimeRange struct

+ DaysOfWeek []string

+ EndTime string

+ IsChecked bool

+ StartTime string

+ Timezone string

v1.0.14

Mar 13, 2024

v1.0.13

Jan 18, 2024

v1.0.12

Jan 17, 2024

v1.0.11

Jan 15, 2024

v1.0.10

Jan 12, 2024

Changes in this version

type Worker

+ func (w *Worker) RealDirectRun(v SyntheticCheck) (map[string]interface{}, error)

v1.0.9

Nov 30, 2023

v1.0.8

Nov 30, 2023

v1.0.7

Nov 30, 2023

v1.0.6

Nov 29, 2023

v1.0.5

Nov 29, 2023

v1.0.4

Nov 29, 2023

v1.0.3

Nov 29, 2023

v1.0.2

Nov 28, 2023

Changes in this version

type Worker

+ func (w *Worker) DirectRun(v SyntheticCheck) (map[string]interface{}, error)

v1.0.1

Nov 28, 2023

Changes in this version

+ func CreateScriptSnippet(req SyntheticCheck) string

+ func TimerNew(fun func(), fireInNs time.Duration, interval time.Duration) func()

+ type AlertConditionsOptions struct

+ RetryCount int

+ RetryIntervalSeconds int

+ type AssertionsCasesOptions struct

+ Cases []CaseOptions

+ type AssertionsOptions struct

+ DNS AssertionsCasesOptions

+ GRPC AssertionsCasesOptions

+ HTTP AssertionsCasesOptions

+ ICMP AssertionsCasesOptions

+ Ssl AssertionsCasesOptions

+ TCP AssertionsCasesOptions

+ UDP AssertionsCasesOptions

+ WebSocket AssertionsCasesOptions

+ type Authentication struct

+ AwsSignature AwsSignature

+ Basic Basic

+ ClientCertificate ClientCertificate

+ Digest Digest

+ Ntlm Ntlm

+ Oauth21 Oauth21

+ Type string

+ type AwsSignature struct

+ AccessKeyID string

+ Region string

+ SecretAccessKey string

+ ServiceName string

+ SessionToken string

+ type Basic struct

+ Password string

+ Username string

+ type CaseOptions struct

+ Config struct{ ... }

+ Type string

+ type CheckState struct

+ type CheckTestRequest struct

+ Headers map[string]string

+ URL string

+ type CheckTestRequestHeaders struct

+ AccountID int

+ AccountUID string

+ Authorization string

+ CheckId int

+ UserId int

+ type ClientCertificate struct

+ Certificate string

+ PrivateKey string

+ type Config struct

+ CaptureEndpoint string

+ Hostname string

+ Location string

+ Mode Mode

+ NCAPassword string

+ PulsarHost string

+ Token string

+ UnsubscribeEndpoint string

+ type Digest struct

+ Password string

+ Username string

+ type GRPCPayloadOptions struct

+ Certificate string

+ CheckType string

+ IgnoreServerCertificateError bool

+ Message string

+ Metadata []struct{ ... }

+ MethodSelection string

+ PrivateKey string

+ ProtoFileContent string

+ Service string

+ ServiceDefinition string

+ type HTTPHeadersOptions struct

+ Name string

+ Value string

+ type HTTPMultiStepsOptions struct

+ Endpoint string

+ Expect SyntheticsExpectMeta

+ Request HTTPMultiStepsRequest

+ StepName string

+ type HTTPMultiStepsRequest struct

+ HTTPHeaders []HTTPHeadersOptions

+ HTTPMethod string

+ HTTPPayload HTTPPayloadOptions

+ HTTPVersion string

+ type HTTPPayloadOptions struct

+ Authentication Authentication

+ Cookies string

+ FollowRedirects bool

+ IgnoreServerCertificateError bool

+ Privacy struct{ ... }

+ Proxy struct{ ... }

+ QueryParams []struct{ ... }

+ RequestBody RequestBody

+ type ICMPPayloadOptions struct

+ PingsPerTest int

+ type Mode uint16

+ var ModeAgent Mode = 1

+ var ModeLocation Mode = 0

+ func (m Mode) String() string

+ type MonitorOptions struct

+ NotifyTo []interface{}

+ Priority string

+ Renotify bool

+ RenotifyIntervalSeconds int

+ Source string

+ TriggerFailsCase bool

+ TriggerFailsCaseCount int

+ type Ntlm struct

+ Domain string

+ Password string

+ Username string

+ WorkStation string

+ type Oauth21 struct

+ AccessTokenURL string

+ Audience string

+ ClientID string

+ ClientSecret string

+ CredentialsType string

+ Password string

+ Resource string

+ Scopes string

+ TokenAPIAuthentication string

+ Username string

+ type ProtocolChecker interface

+ func NewProtocolChecker(c SyntheticCheck) (ProtocolChecker, error)

+ type RequestBody struct

+ Content string

+ Type string

+ type RequestOptions struct

+ Body map[string]interface{}

+ Headers map[string]string

+ Method string

+ URL string

+ type SpecifyFrequencyOptions struct

+ IntervalType string

+ SpecifyTimeRange struct{ ... }

+ Type string

+ type SyntheticCheck struct

+ Uid string

+ type SyntheticsExpectMeta struct

+ HttpCode int

+ LatencyLimit float64

+ PacketLossLimit float64

+ ResponseText string

+ ResponseTimeLessThen int

+ type SyntheticsModel struct

+ AccountId int

+ AccountKey string

+ AccountUID string

+ Action string

+ CheckTestRequest CheckTestRequest

+ CreatedAt time.Time

+ Details map[string]interface{}

+ Endpoint string

+ Expect SyntheticsExpectMeta

+ Id int

+ IntervalSeconds int

+ Locations string

+ Proto string

+ Request SyntheticsRequestOptions

+ SlugName string

+ Status string

+ Tags []string

+ UpdatedAt time.Time

+ UserId int

+ type SyntheticsRequestOptions struct

+ AlertConditions AlertConditionsOptions

+ Assertions AssertionsOptions

+ CurrentAction string

+ DNSServer string

+ Environment []interface{}

+ GRPCPayload GRPCPayloadOptions

+ HTTPHeaders []HTTPHeadersOptions

+ HTTPMethod string

+ HTTPMultiSteps []HTTPMultiStepsOptions

+ HTTPMultiTest bool

+ HTTPPayload HTTPPayloadOptions

+ HTTPVersion string

+ ICMPPayload ICMPPayloadOptions

+ Monitor MonitorOptions

+ Port string

+ Premise []string

+ SpecifyFrequency SpecifyFrequencyOptions

+ SslCertificate string

+ SslCertificatePrivateKey string

+ SslMaxVersion int

+ SslMinVersion int

+ SslRevokedCertificateFail bool

+ SslServerName string

+ SslSignedCertificate bool

+ StepTestIndex int

+ TTL bool

+ Topic string

+ UDPPayload UDPPayloadOptions

+ WSPayload WSPayloadOptions

+ type SyntheticsTags struct

+ Key string

+ Value string

+ type Timer struct

+ func SetTimeout(fn func(), duration time.Duration, id int) *Timer

+ func (timer *Timer) Reset()

+ func (timer *Timer) Start()

+ func (timer *Timer) Stop()

+ type UDPPayloadOptions struct

+ Message string

+ type WSPayloadAuthentication struct

+ Password string

+ Username string

+ type WSPayloadHeaders struct

+ Name string

+ Value string

+ type WSPayloadOptions struct

+ Authentication WSPayloadAuthentication

+ Headers []WSPayloadHeaders

+ Message string

+ type Worker struct

+ func New(cfg *Config) (*Worker, error)

+ func (w *Worker) Run()

+ func (w *Worker) SubscribeUpdates(topic string, token string)

+ func (w *Worker) UnsubscribeUpdates(topic string, token string)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL