Documentation ¶
Index ¶
- type Cipher
- type Conn
- func (c *Conn) Close() error
- func (c *Conn) LocalAddr() net.Addr
- func (c *Conn) Read(b []byte) (n int, err error)
- func (c *Conn) RemoteAddr() net.Addr
- func (c *Conn) SetDeadline(t time.Time) error
- func (c *Conn) SetReadDeadline(t time.Time) error
- func (c *Conn) SetWriteDeadline(t time.Time) error
- func (c *Conn) Write(b []byte) (n int, err error)
- type DFA
- type FSM
- func (m *FSM) Cipher(regex string, n int) (marionette.Cipher, error)
- func (m *FSM) Clone(doc *mar.Document) marionette.FSM
- func (m *FSM) Close() error
- func (m *FSM) Conn() *marionette.BufferedConn
- func (m *FSM) DFA(regex string, msgLen int) (marionette.DFA, error)
- func (m *FSM) Dead() bool
- func (m *FSM) Execute(ctx context.Context) error
- func (m *FSM) Host() string
- func (m *FSM) InstanceID() int
- func (m *FSM) Listen() (int, error)
- func (m *FSM) Logger() *zap.Logger
- func (m *FSM) Next(ctx context.Context) error
- func (m *FSM) Party() string
- func (m *FSM) Port() int
- func (m *FSM) Reset()
- func (m *FSM) SetInstanceID(id int)
- func (m *FSM) SetVar(key string, value interface{})
- func (m *FSM) State() string
- func (m *FSM) StreamSet() *marionette.StreamSet
- func (m *FSM) UUID() int
- func (m *FSM) Var(key string) interface{}
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cipher ¶
type Cipher struct { CapacityFn func() int EncryptFn func(plaintext []byte) (ciphertext []byte, err error) DecryptFn func(ciphertext []byte) (plaintext, remainder []byte, err error) }
type Conn ¶
type Conn struct { ReadFn func(b []byte) (n int, err error) WriteFn func(b []byte) (n int, err error) CloseFn func() error LocalAddrFn func() net.Addr RemoteAddrFn func() net.Addr SetDeadlineFn func(t time.Time) error SetReadDeadlineFn func(t time.Time) error SetWriteDeadlineFn func(t time.Time) error }
func DefaultConn ¶
func DefaultConn() Conn
func (*Conn) RemoteAddr ¶
type DFA ¶
type FSM ¶
type FSM struct { CloseFn func() error UUIDFn func() int InstanceIDFn func() int SetInstanceIDFn func(int) HostFn func() string PartyFn func() string PortFn func() int StateFn func() string DeadFn func() bool NextFn func(ctx context.Context) error ExecuteFn func(ctx context.Context) error ResetFn func() ListenFn func() (int, error) ConnFn func() *marionette.BufferedConn StreamSetFn func() *marionette.StreamSet CipherFn func(regex string, n int) (marionette.Cipher, error) DFAFn func(regex string, n int) (marionette.DFA, error) SetVarFn func(key string, value interface{}) VarFn func(key string) interface{} CloneFn func(doc *mar.Document) marionette.FSM LoggerFn func() *zap.Logger BufferedConn *marionette.BufferedConn }
func NewFSM ¶
func NewFSM(conn net.Conn, streamSet *marionette.StreamSet) FSM
NewFSM returns an instance of FSM with conn and streamSet attached.
func (*FSM) Conn ¶
func (m *FSM) Conn() *marionette.BufferedConn
func (*FSM) InstanceID ¶
func (*FSM) SetInstanceID ¶
func (*FSM) StreamSet ¶
func (m *FSM) StreamSet() *marionette.StreamSet
Click to show internal directories.
Click to hide internal directories.