Versions in this module Expand all Collapse all v0 v0.2.1 Feb 9, 2024 Changes in this version + const CERT_MAGIG_LOG_SRC + const CSP_HEADER_NAME + const DEFAULT_ACCEPT_HEADER + const DEFAULT_EVENT_STREAM_BUFFER_SIZE + const DEFAULT_HTTPS_PORT + const DEFAULT_HTTP_CLIENT_TIMEOUT + const DEFAULT_HTTP_SERVER_MAX_HEADER_BYTES + const DEFAULT_HTTP_SERVER_READ_HEADER_TIMEOUT + const DEFAULT_HTTP_SERVER_READ_TIMEOUT + const DEFAULT_HTTP_SERVER_TX_TIMEOUT + const DEFAULT_HTTP_SERVER_WRITE_TIMEOUT + const DEFAULT_NONCE_BYTE_COUNT + const DEFAULT_SELF_SIGNED_CERT_VALIDITY_DURATION + const DEFAULT_SESSION_ID_BYTE_COUNT + const DEFAULT_SESSION_ID_COOKIE_NAME + const DEFAULT_SUBSCRIPTION_CHAN_SIZE + const FS_ROUTING_LOG_SRC + const HANDLING_DESC_CERTIFICATE_PROPNAME + const HANDLING_DESC_DEFAULT_CSP_PROPNAME + const HANDLING_DESC_DEFAULT_LIMITS_PROPNAME + const HANDLING_DESC_KEY_PROPNAME + const HANDLING_DESC_MAX_LIMITS_PROPNAME + const HANDLING_DESC_ROUTING_PROPNAME + const HANDLING_DESC_SESSIONS_PROPNAME + const HTTP_DELETE_PERM_MIGHT_BE_MISSING + const HTTP_PROVIDE_PERM_MIGHT_BE_MISSING + const HTTP_READ_PERM_MIGHT_BE_MISSING + const HTTP_REQUEST_RATE_LIMIT_NAME + const HTTP_SERVER_GRACEFUL_SHUTDOWN_TIMEOUT + const HTTP_SERVER_SRC + const HTTP_SERVER_STARTING_WAIT_TIME + const HTTP_UPLOAD_RATE_LIMIT_NAME + const HTTP_WRITE_PERM_MIGHT_BE_MISSING + const INITIAL_SSE_CLIENT_BUFFER_SIZE + const INOX_FILE_EXTENSION + const MAX_SESSION_ID_BYTE_COUNT + const MAX_SSE_CLIENT_BUFFER_SIZE + const MIN_SESSION_ID_BYTE_COUNT + const MISSING_URL_ARG + const NO_HANDLER_PLACEHOLDER_MESSAGE + const OPTION_DOES_NOT_EXIST_FMT + const PATH_PARAMS_CTX_DATA_NAMESPACE + const RELATIVE_SELF_SIGNED_CERT_FILEPATH + const RELATIVE_SELF_SIGNED_CERT_KEY_FILEPATH + const REQUEST_ID_LOG_FIELD_NAME + const RESULT_INIT_BODY_PROPNAME + const RESULT_INIT_HEADERS_PROPNAME + const RESULT_INIT_SESSION_PROPNAME + const RESULT_INIT_STATUS_PROPNAME + const SERVER_HANDLING_ARG_NAME + const SESSIONS_DESC_COLLECTION_PROPNAME + const SESSION_CTX_DATA_KEY + const SESSION_ID_PROPNAME + const SHARED_READ_BURST_WINDOW + const SHARED_READ_BURST_WINDOW_REQ + const SHARED_WRITE_BURST_WINDOW + const SHARED_WRITE_BURST_WINDOW_REQ + const SOCKET_MAX_READ_REQ_COUNT + const SOCKET_MAX_WRITE_REQ_COUNT + const SOCKET_RLIMIT_WINDOW + const SSE_STREAM_WRITE_TIMEOUT + const STOPPING_SUB_WAIT_TIME + const VIEW_UPDATE_SSE_STREAM_STOP_TIMEOUT + const VIEW_UPDATE_WATCHING_TIMEOUT + var BYTESTREAM_CHUNK_WAIT_TIMEOUT = 2 * time.Millisecond + var BYTESTREAM_SSE_STREAM_STOP_TIMEOUT = 10 * time.Millisecond + var CALLABLE_HTTP_REQUEST_PATTERN = &core.TypePattern + var DEFAULT_CSP = NewCSPWithDirectives(nil) + var DEFAULT_DIRECTIVE_VALUES = map[string][]CSPDirectiveValue + var DEFAULT_HTTP_PROFILE_CONFIG = ClientConfig + var DEFAULT_HTTP_REQUEST_OPTIONS = &RequestOptions + var DEFAULT_PUSHED_BYTESTREAM_CHUNK_SIZE_RANGE = core.NewIntRange(100, 1000) + var ErrCannotMutateInitializedServer = errors.New("cannot mutate initialized server") + var ErrCannotMutateWriterOfFinishedResponse = errors.New("cannot mutate writer of finished response") + var ErrCannotMutateWriterWithDetachedRespWriter = errors.New("cannot mutate writer with detached response writer") + var ErrHandlerNotSharable = errors.New("handler is not sharable") + var ErrNotAcceptedContentType = errors.New("not accepted content type") + var ErrOutOfBoundsStatusCode = errors.New("out of bounds status code") + var ErrSessionIdTooLong = errors.New("session id is too long") + var ErrSessionIdTooShort = errors.New("session id is too short") + var ErrSessionNotFound = errors.New("session not found") + var ErrStatusAlreadySent = errors.New("status already sent") + var FS_ROUTING_METHODS = spec.FS_ROUTING_METHODS + var HANDLER_DISABLED_ARGS = []bool + var HTTP_REQUEST_PATTERN_PATTERN = &core.TypePattern + var HTTP_ROUTING_SYMB_OBJ = symbolic.NewInexactObject(map[string]symbolic.Serializable{ ... }, map[string]struct{}{ ... }, nil) + var MAKE_STATUS_CODE_PARAMS = &[]symbolic.Value + var MAKE_STATUS_CODE_PARAM_NAMES = []string + var MAX_SESSION_ID_LEN = hex.EncodedLen(MAX_SESSION_ID_BYTE_COUNT) + var MIN_SESSION_ID_LEN = hex.EncodedLen(MIN_SESSION_ID_BYTE_COUNT) + var NEWLINE_BYTES = []byte + var NEW_RESULT_PARAMS = &[]symbolic.Value + var NEW_RESULT_PARAM_NAMES = []string + var NEW_SERVER_SINGLE_PARAM_NAME = []string + var NEW_SERVER_TWO_PARAM_NAMES = []string + var SESSIONS_CONFIG_SYMB_OBJ = symbolic.NewInexactObject2(map[string]symbolic.Serializable{ ... }) + var SSE_DATA_HEADER = []byte("data:") + var SSE_EVENT_HEADER = []byte("event:") + var SSE_ID_HEADER = []byte("id:") + var SSE_RETRY_HEADER = []byte("retry:") + var STATUS_NAMESPACE = core.NewNamespace("status", map[string]core.Value{ ... }) + var SYMBOLIC_HANDLING_DESC = symbolic.NewInexactObject(map[string]symbolic.Serializable{ ... }, map[string]struct{}{ ... }, nil) + var SYMBOLIC_RESULT_INIT_ARG = symbolic.NewInexactObject(map[string]symbolic.Serializable{ ... }, map[string]struct{}{ ... }, nil) + func DeserializeHttpRequestPattern(ctx *core.Context, it *jsoniter.Iterator, pattern core.Pattern, try bool) (_ core.Pattern, finalErr error) + func GenerateSelfSignedCertAndKey(args SelfSignedCertParams) (cert *pem.Block, key *pem.Block, err error) + func GetTLSConfig(ctx *core.Context, pemEncodedCert string, pemEncodedKey string) (*tls.Config, error) + func HttpRead(ctx *core.Context, u core.URL, args ...core.Value) (result core.Value, finalErr error) + func IsMutationMethod(method string) bool + func MakeHTTPProxy(ctx *core.Context, params HTTPProxyParams) (*http.Server, error) + func Mime_(ctx *core.Context, arg core.String) (core.Mimetype, error) + func NewGolangHttpServer(ctx *core.Context, config GolangHttpServerConfig) (*http.Server, error) + func NewHttpNamespace() *core.Namespace + func PercentDecode(ctx *core.Context, s core.StringLike) (core.String, error) + func PercentEncode(ctx *core.Context, s core.StringLike) core.String + func ServeFile(ctx *core.Context, rw *ResponseWriter, r *Request, pth core.Path) error + type API = spec.API + type ApiEndpoint = spec.ApiEndpoint + type CSPDirective struct + type CSPDirectiveValue struct + type CSPHeaderValueParams struct + ScriptsNonce string + type Client struct + func NewClient(ctx *core.Context, configObject *core.Object) (*Client, error) + func NewHttpClientFromPreExistingClient(client *http.Client, insecure bool) *Client + func (*Client) PropertyNames(ctx *core.Context) []string + func (*Client) SetProp(ctx *core.Context, name string, value core.Value) error + func (c *Client) DoRequest(ctx *core.Context, req *Request) (*Response, error) + func (c *Client) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, ...) bool + func (c *Client) GetGoMethod(name string) (*core.GoFunction, bool) + func (c *Client) GetHostCookieObjects(ctx *core.Context, h core.Host) *core.List + func (c *Client) GetHostCookies(h core.Host) []*http.Cookie + func (c *Client) IsMutable() bool + func (c *Client) MakeRequest(ctx *core.Context, method string, u core.URL, body io.Reader, ...) (*Request, error) + func (c *Client) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, ...) + func (c *Client) Prop(ctx *core.Context, name string) core.Value + func (c *Client) Schemes() []core.Scheme + func (c *Client) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error) + type ClientConfig struct + Finalization *core.Dictionary + Insecure bool + SaveCookies bool + type ContentSecurityPolicy struct + func NewCSP(ctx *core.Context, desc *core.Object) (*ContentSecurityPolicy, error) + func NewCSPWithDirectives(directives []CSPDirective) (*ContentSecurityPolicy, error) + func (*ContentSecurityPolicy) IsMutable() bool + func (*ContentSecurityPolicy) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error) + func (c *ContentSecurityPolicy) Directive(directiveName string) (CSPDirective, bool) + func (c *ContentSecurityPolicy) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, ...) bool + func (c *ContentSecurityPolicy) HeaderValue(params CSPHeaderValueParams) string + func (c *ContentSecurityPolicy) WriteJSONRepresentation(ctx *core.Context, w *jsoniter.Stream, config core.JSONSerializationConfig, ...) error + func (c *ContentSecurityPolicy) WriteRepresentation(ctx *core.Context, w io.Writer, config *core.ReprConfig, depth int) error + func (csp *ContentSecurityPolicy) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, ...) + func (csp *ContentSecurityPolicy) String() string + type GolangHttpServerConfig struct + Addr string + AllowSelfSignedCertCreationEvenIfExposed bool + Handler http.Handler + MaxHeaderBytes int + PemEncodedCert string + PemEncodedKey string + PersistCreatedLocalCert bool + ReadHeaderTimeout time.Duration + ReadTimeout time.Duration + SelfSignedCertValidityDuration time.Duration + WriteTimeout time.Duration + type HTTPProxyParams struct + GetContext func(req *http.Request) *core.Context + Logger zerolog.Logger + OnRequest func(req *http.Request, proxyCtx *goproxy.ProxyCtx) (*http.Request, *http.Response) + Port int + RemovedRequestHeaders []string + type HttpsServer struct + func NewFileServer(ctx *core.Context, args ...core.Value) (*HttpsServer, error) + func NewHttpsServer(ctx *core.Context, host core.Host, args ...core.Value) (*HttpsServer, error) + func (*HttpsServer) PropertyNames(ctx *core.Context) []string + func (*HttpsServer) SetProp(ctx *core.Context, name string, value core.Value) error + func (s *HttpsServer) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, ...) bool + func (s *HttpsServer) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, ...) + func (s *HttpsServer) Prop(ctx *core.Context, name string) core.Value + func (serv *HttpsServer) Close(ctx *core.Context) + func (serv *HttpsServer) GetGoMethod(name string) (*core.GoFunction, bool) + func (serv *HttpsServer) ImmediatelyClose(ctx *core.Context) + func (serv *HttpsServer) IsMutable() bool + func (serv *HttpsServer) ListeningAddr() core.Host + func (serv *HttpsServer) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error) + func (serv *HttpsServer) WaitClosed(ctx *core.Context) + type IncomingRequestInfo struct + ContentType string + CookieNames []string + CreationTime time.Time + EndTime time.Time + Errors []string + HandlingDurationMillis int64 + HeaderNames []string + Hostname string + Info []string + Method string + Path core.Path + Referer string + RemoteAddrAndPort string + ResourceWaitingDurationMicrosec int64 + ResponseStatusCode int + SeeOtherRedirectURL string + SentBodyBytes int + SessionCookieStart string + SetCookieHeaderValueStart string + ULID ulid.ULID + URL core.URL + UserAgent string + func NewIncomingRequestInfo(r *Request) *IncomingRequestInfo + func (reqInfo IncomingRequestInfo) RemoteIpAddress() string + type Request struct + AcceptHeader string + Body *core.Reader + ContentType mimeheader.MimeType + Cookies []*http.Cookie + CreationTime time.Time + HeaderNames []string + Hostname string + Method core.String + ParsedAcceptHeader mimeheader.AcceptHeader + Path core.Path + RemoteAddrAndPort netaddr.RemoteAddrWithPort + RemoteIpAddr netaddr.RemoteIpAddr + Session *core.Object + ULID ulid.ULID + ULIDString string + URL core.URL + UserAgent string + func NewClientSideRequest(r *http.Request) (*Request, error) + func NewServerSideRequest(r *http.Request, logger zerolog.Logger, server *HttpsServer) (*Request, error) + func (*Request) PropertyNames(ctx *core.Context) []string + func (*Request) SetProp(ctx *core.Context, name string, value core.Value) error + func (r *Request) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, ...) bool + func (r *Request) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, ...) + func (r *Request) WriteJSONRepresentation(ctx *core.Context, w *jsoniter.Stream, config core.JSONSerializationConfig, ...) error + func (r *Request) WriteRepresentation(ctx *core.Context, w io.Writer, config *core.ReprConfig, depth int) error + func (req *Request) AcceptAny() bool + func (req *Request) GetGoMethod(name string) (*core.GoFunction, bool) + func (req *Request) IsGetOrHead() bool + func (req *Request) IsMutable() bool + func (req *Request) IsSharable(originState *core.GlobalState) (bool, string) + func (req *Request) IsShared() bool + func (req *Request) Prop(ctx *core.Context, name string) core.Value + func (req *Request) Request() *http.Request + func (req *Request) Share(originState *core.GlobalState) + func (req *Request) SmartLock(state *core.GlobalState) + func (req *Request) SmartUnlock(state *core.GlobalState) + func (req *Request) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error) + type RequestOptions struct + InsecureSkipVerify bool + Jar http.CookieJar + Timeout time.Duration + type RequestPattern struct + func (*RequestPattern) IsMutable() bool + func (*RequestPattern) Iterator(*core.Context, core.IteratorConfiguration) core.Iterator + func (*RequestPattern) Random(ctx *core.Context, options ...core.Option) core.Value + func (*RequestPattern) StringPattern() (core.StringPattern, bool) + func (*RequestPattern) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error) + func (p *RequestPattern) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, ...) bool + func (p *RequestPattern) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, ...) + func (p *RequestPattern) Test(ctx *core.Context, v core.Value) bool + func (p *RequestPattern) WriteJSONRepresentation(ctx *core.Context, w *jsoniter.Stream, config core.JSONSerializationConfig, ...) error + type Response struct + func HttpDelete(ctx *core.Context, args ...core.Value) (*Response, error) + func HttpGet(ctx *core.Context, u core.URL, args ...core.Value) (*Response, error) + func HttpPatch(ctx *core.Context, args ...core.Value) (*Response, error) + func HttpPost(ctx *core.Context, args ...core.Value) (*Response, error) + func (*Response) PropertyNames(ctx *core.Context) []string + func (*Response) SetProp(ctx *core.Context, name string, value core.Value) error + func (r *Response) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, ...) bool + func (r *Response) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, ...) + func (resp *Response) Body(ctx *core.Context) io.ReadCloser + func (resp *Response) ContentType(ctx *core.Context) (core.Mimetype, bool, error) + func (resp *Response) GetGoMethod(name string) (*core.GoFunction, bool) + func (resp *Response) IsMutable() bool + func (resp *Response) Prop(ctx *core.Context, name string) core.Value + func (resp *Response) Status(ctx *core.Context) string + func (resp *Response) StatusCode(ctx *core.Context) int + func (resp *Response) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error) + type ResponseWriter struct + func NewResponseWriter(req *Request, rw http.ResponseWriter, serverLogger zerolog.Logger) *ResponseWriter + func (*ResponseWriter) SetProp(ctx *core.Context, name string, value core.Value) error + func (resp *ResponseWriter) IsMutable() bool + func (resp *ResponseWriter) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error) + func (rw *ResponseWriter) AddHeader(ctx *core.Context, k, v core.String) + func (rw *ResponseWriter) DetachBodyWriter() io.Writer + func (rw *ResponseWriter) DetachRespWriter() http.ResponseWriter + func (rw *ResponseWriter) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, ...) bool + func (rw *ResponseWriter) FinalLog() + func (rw *ResponseWriter) Finish(ctx *core.Context) + func (rw *ResponseWriter) GetGoMethod(name string) (*core.GoFunction, bool) + func (rw *ResponseWriter) IsStatusSent() bool + func (rw *ResponseWriter) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, ...) + func (rw *ResponseWriter) Prop(ctx *core.Context, name string) core.Value + func (rw *ResponseWriter) PropertyNames(ctx *core.Context) []string + func (rw *ResponseWriter) SetContentType(s string) + func (rw *ResponseWriter) SetCookie(ctx *core.Context, obj *core.Object) error + func (rw *ResponseWriter) SetStatus(ctx *core.Context, status StatusCode) + func (rw *ResponseWriter) SetWriteDeadline(timeout time.Duration) + func (rw *ResponseWriter) WriteBinary(ctx *core.Context, bytes *core.ByteSlice) (core.Int, error) + func (rw *ResponseWriter) WriteCSS(ctx *core.Context, v core.Value) (core.Int, error) + func (rw *ResponseWriter) WriteError(ctx *core.Context, err core.Error, code StatusCode) + func (rw *ResponseWriter) WriteHTML(ctx *core.Context, v core.Value) (core.Int, error) + func (rw *ResponseWriter) WriteHeaders(ctx *core.Context, status *core.OptionalParam[StatusCode]) + func (rw *ResponseWriter) WriteJS(ctx *core.Context, v core.Value) (core.Int, error) + func (rw *ResponseWriter) WriteJSON(ctx *core.Context, v core.Serializable) (core.Int, error) + func (rw *ResponseWriter) WritePlainText(ctx *core.Context, bytes *core.ByteSlice) (core.Int, error) + func (rw ResponseWriter) PlannedStatus() int + func (rw ResponseWriter) SentStatus() int + type Result struct + func NewResult(ctx *core.Context, init *core.Object) *Result + func (r *Result) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, ...) bool + func (r *Result) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, ...) + func (res *Result) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error) + func (resp *Result) IsMutable() bool + type SelfSignedCertParams struct + Localhost bool + NonLocalhostIPs bool + ValidityDuration time.Duration + type ServerSentEvent struct + Comment []byte + Data []byte + Event []byte + ID []byte + Retry []byte + func (e *ServerSentEvent) HasContent() bool + func (e *ServerSentEvent) ToEvent() *core.Event + type ServerSentEventSource struct + func NewEventSource(ctx *core.Context, resourceNameOrPattern core.Value) (*ServerSentEventSource, error) + func (*ServerSentEventSource) IsMutable() bool + func (*ServerSentEventSource) PropertyNames(ctx *core.Context) []string + func (*ServerSentEventSource) SetProp(ctx *core.Context, name string, value core.Value) error + func (evs *ServerSentEventSource) Close() + func (evs *ServerSentEventSource) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, ...) bool + func (evs *ServerSentEventSource) GetGoMethod(name string) (*core.GoFunction, bool) + func (evs *ServerSentEventSource) IsClosed() bool + func (evs *ServerSentEventSource) Iterator(ctx *core.Context, config core.IteratorConfiguration) core.Iterator + func (evs *ServerSentEventSource) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, ...) + func (evs *ServerSentEventSource) Prop(ctx *core.Context, name string) core.Value + func (evs *ServerSentEventSource) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error) + type SseServer struct + func NewSseServer() *SseServer + func (s *SseServer) Close() + func (s *SseServer) CreateStream(id string) *multiSubscriptionSSEStream + func (s *SseServer) Publish(streamId string, event *ServerSentEvent) + func (s *SseServer) PushSubscriptionEvents(config eventPushConfig) + func (s *SseServer) RemoveStream(id string) + type Status struct + func MakeStatus(code StatusCode) (Status, error) + func ParseStatus(str string) (Status, error) + func (*Status) GetGoMethod(name string) (*core.GoFunction, bool) + func (Status) PropertyNames(*core.Context) []string + func (Status) SetProp(ctx *core.Context, name string, value core.Value) error + func (Status) WriteRepresentation(ctx *core.Context, w io.Writer, config *core.ReprConfig, depth int) error + func (s *Status) Prop(ctx *core.Context, name string) core.Value + func (s Status) Code() StatusCode + func (s Status) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, ...) bool + func (s Status) FullText() string + func (s Status) IsMutable() bool + func (s Status) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, ...) + func (s Status) ReasonPhrase() string + func (s Status) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error) + func (s Status) WriteJSONRepresentation(ctx *core.Context, w *jsoniter.Stream, config core.JSONSerializationConfig, ...) error + type StatusCode uint16 + func MakeStatusCode(_ *core.Context, n core.Int) (StatusCode, error) + func (StatusCode) WriteRepresentation(ctx *core.Context, w io.Writer, config *core.ReprConfig, depth int) error + func (c StatusCode) Equal(ctx *core.Context, other core.Value, alreadyCompared map[uintptr]uintptr, ...) bool + func (c StatusCode) IsMutable() bool + func (c StatusCode) PrettyPrint(w *bufio.Writer, config *core.PrettyPrintConfig, depth int, ...) + func (c StatusCode) ToSymbolicValue(ctx *core.Context, encountered map[uintptr]symbolic.Value) (symbolic.Value, error) + func (c StatusCode) WriteJSONRepresentation(ctx *core.Context, w *jsoniter.Stream, config core.JSONSerializationConfig, ...) error + type Subscription struct + func (s *Subscription) IsStopped() bool + func (s *Subscription) StopAsync()
Go to main page