Versions in this module Expand all Collapse all v8 v8.6.0 Sep 24, 2024 Changes in this version + const DefaultContainerWaitTimeout + const DefaultTestTimeout + const DefaultTestTimeoutInMs + func AwaitJobStreamExists(workerName string, monitoringAddress string) bool + func MapMapMarshal(value reflect.Value, tag string, omitempty, omitminus bool) map[string]interface + func MapMarshal(iface interface{}, tag string, omitempty, omitminus bool) map[string]interface + func MapStructMarshal(value reflect.Value, tag string, omitempty, omitminus bool) map[string]interface + func MapValueMarshal(value reflect.Value, tag string, omitempty, omitminus, dostrconv bool) (iface interface{}) + type JSONStringSerializer struct + func (validator *JSONStringSerializer) AsJSON(name string, value interface{}, ignoreOmitempty bool) (string, error) + func (validator *JSONStringSerializer) Validate(name string, value string) error + type RPCTestMsg struct + Msg proto.Message + func (r *RPCTestMsg) Matches(msg interface{}) bool + func (r *RPCTestMsg) String() string + type RemoteJobStream struct + Consumers []RemoteJobStreamConsumer + JobType string + Metadata RemoteJobStreamMetadata + type RemoteJobStreamConsumer struct + ID string + Receiver string + type RemoteJobStreamMetadata struct + FetchVariables []string + Timeout string + Worker string + type SerializerMixin interface + AsJSON func(string, interface{}, bool) (string, error) + Validate func(string, string) error + func NewJSONStringSerializer() SerializerMixin
Go to main page