ipc

type ConnectionListener struct {
	// contains filtered or unexported fields
}

type CronListener struct {
}

type FatimaIPCClientSession interface {
	SendCommand(Message) error
	ReadCommand() (Message, error)
	Disconnect()
}

type FatimaIPCSessionListener interface {
	StartSession(ctx SessionContext)
	OnReceiveCommand(ctx SessionContext, message Message)
	OnClose(ctx SessionContext)
}

type GoAwaySessionListener struct {
}

type Initiator struct {
	Process string `json:"process"`
	Command string `json:"command"`
	Sock    string `json:"sock"`
}

type JsonBody map[string]interface{}

type Message struct {
	Initiator Initiator `json:"initiator"`
	Data      JsonBody  `json:"data,omitempty"`
}

type SessionContext interface {
	String() string
	Close()
	GetConnection() net.Conn
	SendCommand(message Message) error
}

type SessionEvent struct {
	// contains filtered or unexported fields
}

type SessionEventType uint8

type SessionType uint8