sigsci

Jul 6, 2023

Changes in this version

type ModuleConfigOption

+ func ExtendContentTypes(v bool) ModuleConfigOption

Jan 10, 2023

Changes in this version

type ModuleConfig

+ func (c *ModuleConfig) RawHeaderExtractor() RawHeaderExtractorFunc

type ModuleConfigOption

+ func RawHeaderExtractor(fn RawHeaderExtractorFunc) ModuleConfigOption

+ type RawHeaderExtractorFunc func(*http.Request) [][2]string

Jan 18, 2022

Changes in this version

type ModuleConfig

+ func (c *ModuleConfig) ExpectedContentTypes() []string

+ func (c *ModuleConfig) IsExpectedContentType(s string) bool

type ModuleConfigOption

+ func ExpectedContentType(s string) ModuleConfigOption

Oct 22, 2020

Changes in this version

+ var DefaultServerFlavor = ""

type ModuleConfig

+ func (c *ModuleConfig) ServerFlavor() string

type ModuleConfigOption

+ func ServerFlavor(serverFlavor string) ModuleConfigOption

type RPCMsgIn

+ func NewRPCMsgInWithModuleConfig(mcfg *ModuleConfig, r *http.Request, postbody []byte) *RPCMsgIn

Mar 12, 2020

Changes in this version

+ var DefaultAllowUnknownContentLength = false

+ var DefaultAnomalyDuration = 1 * time.Second

+ var DefaultAnomalySize = int64(512 * 1024)

+ var DefaultDebug = false

+ var DefaultInspector = Inspector(nil)

+ var DefaultMaxContentLength = int64(100000)

+ var DefaultModuleIdentifier = "sigsci-module-golang " + version

+ var DefaultRPCAddress = "/var/run/sigsci.sock"

+ var DefaultRPCNetwork = "unix"

+ var DefaultServerIdentifier = runtime.Version()

+ var DefaultTimeout = 100 * time.Millisecond

+ type HeaderExtractorFunc func(*http.Request) (http.Header, error)

type Module

+ func (m *Module) ModuleConfig() *ModuleConfig

+ type ModuleConfig struct

+ func NewModuleConfig(options ...ModuleConfigOption) (*ModuleConfig, error)

+ func (c *ModuleConfig) AllowUnknownContentLength() bool

+ func (c *ModuleConfig) AltResponseCodes() []int

+ func (c *ModuleConfig) AnomalyDuration() time.Duration

+ func (c *ModuleConfig) AnomalySize() int64

+ func (c *ModuleConfig) Debug() bool

+ func (c *ModuleConfig) HeaderExtractor() func(r *http.Request) (http.Header, error)

+ func (c *ModuleConfig) Inspector() Inspector

+ func (c *ModuleConfig) InspectorFini() InspectorFiniFunc

+ func (c *ModuleConfig) InspectorInit() InspectorInitFunc

+ func (c *ModuleConfig) IsAllowCode(code int) bool

+ func (c *ModuleConfig) IsBlockCode(code int) bool

+ func (c *ModuleConfig) MaxContentLength() int64

+ func (c *ModuleConfig) ModuleIdentifier() string

+ func (c *ModuleConfig) RPCAddress() string

+ func (c *ModuleConfig) RPCAddressString() string

+ func (c *ModuleConfig) RPCNetwork() string

+ func (c *ModuleConfig) ServerIdentifier() string

+ func (c *ModuleConfig) SetOptions(options ...ModuleConfigOption) error

+ func (c *ModuleConfig) Timeout() time.Duration

type ModuleConfigOption

+ func AltResponseCodes(codes ...int) ModuleConfigOption

+ func FromModuleConfig(mcfg *ModuleConfig) ModuleConfigOption

Nov 6, 2019

Changes in this version

type ModuleConfigOption

+ func AllowUnknownContentLength(allow bool) ModuleConfigOption

Aug 26, 2019

Changes in this version

type ModuleConfigOption

+ func CustomHeaderExtractor(fn func(r *http.Request) (http.Header, error)) ModuleConfigOption

Aug 23, 2019

Changes in this version

+ func NewMsgpClientCodec(conn io.ReadWriteCloser) rpc.ClientCodec

+ func Version() string

+ type Inspector interface

+ ModuleInit func(*RPCMsgIn, *RPCMsgOut) error

+ PostRequest func(*RPCMsgIn, *RPCMsgOut) error

+ PreRequest func(*RPCMsgIn, *RPCMsgOut) error

+ UpdateRequest func(*RPCMsgIn2, *RPCMsgOut) error

+ type InspectorFiniFunc func(*http.Request)

+ type InspectorInitFunc func(*http.Request) bool

+ type Module struct

+ func NewModule(h http.Handler, options ...ModuleConfigOption) (*Module, error)

+ func (m *Module) Inspector() Inspector

+ func (m *Module) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ func (m *Module) ServerVersion() string

+ func (m *Module) Version() string

+ type ModuleConfigOption func(*Module) error

+ func AnomalyDuration(dur time.Duration) ModuleConfigOption

+ func AnomalySize(size int64) ModuleConfigOption

+ func CustomInspector(insp Inspector, init InspectorInitFunc, fini InspectorFiniFunc) ModuleConfigOption

+ func Debug(enable bool) ModuleConfigOption

+ func MaxContentLength(size int64) ModuleConfigOption

+ func ModuleIdentifier(name, version string) ModuleConfigOption

+ func ServerIdentifier(id string) ModuleConfigOption

+ func Socket(network, address string) ModuleConfigOption

+ func Timeout(t time.Duration) ModuleConfigOption

+ type RPCInspector struct

+ Address string

+ Debug bool

+ FiniRPCClientFunc func(*rpc.Client, error)

+ InitRPCClientFunc func() (*rpc.Client, error)

+ Network string

+ Timeout time.Duration

+ func (ri *RPCInspector) CloseRPCClient(client *rpc.Client, err error)

+ func (ri *RPCInspector) GetRPCClient() (*rpc.Client, error)

+ func (ri *RPCInspector) ModuleInit(in *RPCMsgIn, out *RPCMsgOut) error

+ func (ri *RPCInspector) PostRequest(in *RPCMsgIn, out *RPCMsgOut) error

+ func (ri *RPCInspector) PreRequest(in *RPCMsgIn, out *RPCMsgOut) error

+ func (ri *RPCInspector) UpdateRequest(in *RPCMsgIn2, out *RPCMsgOut) error

+ type RPCMsgIn struct

+ AccessKeyID string

+ HeadersIn [][2]string

+ HeadersOut [][2]string

+ Method string

+ ModuleVersion string

+ NowMillis int64

+ PostBody string

+ Protocol string

+ RemoteAddr string

+ ResponseCode int32

+ ResponseMillis int64

+ ResponseSize int64

+ Scheme string

+ ServerFlavor string

+ ServerName string

+ ServerVersion string

+ TLSCipher string

+ TLSProtocol string

+ Timestamp int64

+ URI string

+ WAFResponse int32

+ func NewRPCMsgIn(r *http.Request, postbody []byte, code int, size int64, dur time.Duration, ...) *RPCMsgIn

+ func (z *RPCMsgIn) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *RPCMsgIn) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *RPCMsgIn) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *RPCMsgIn) Msgsize() (s int)

+ func (z *RPCMsgIn) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type RPCMsgIn2 struct

+ HeadersOut [][2]string

+ RequestID string

+ ResponseCode int32

+ ResponseMillis int64

+ ResponseSize int64

+ func (z *RPCMsgIn2) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *RPCMsgIn2) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *RPCMsgIn2) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *RPCMsgIn2) Msgsize() (s int)

+ func (z *RPCMsgIn2) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type RPCMsgOut struct

+ RequestHeaders [][2]string

+ RequestID string

+ WAFResponse int32

+ func (z *RPCMsgOut) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *RPCMsgOut) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *RPCMsgOut) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *RPCMsgOut) Msgsize() (s int)

+ func (z *RPCMsgOut) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type ResponseWriter interface

+ BaseResponseWriter func() http.ResponseWriter

+ BytesWritten func() int64

+ StatusCode func() int

+ func NewResponseWriter(base http.ResponseWriter) ResponseWriter

+ type ResponseWriterFlusher interface