Versions in this module Expand all Collapse all v0 v0.0.10 Apr 10, 2026 v0.0.9 Mar 17, 2026 Changes in this version + const AppName + type ConnectionCloseEvent struct + BytesReceived int64 + BytesSent int64 + CloseReason string + CloseTime time.Time + Duration int64 + SessionID string + type ConnectionEvent struct + ConnectTime time.Time + Metadata map[string]string + Protocol Protocol + ResourceID string + SessionID string + SourceIP string + SourcePort int + TargetHost string + TargetPort int + UserID string + Username string + type DataFlowEvent struct + Direction string + EventType EventType + Protocol Protocol + ProtocolData interface{} + SessionID string + Size int64 + Timestamp time.Time + type EventType string + const EventTypeConnectionClose + const EventTypeConnectionOpen + const EventTypeDataRecv + const EventTypeDataSend + const EventTypeMySQLDDL + const EventTypeMySQLDML + const EventTypeMySQLLogin + const EventTypeMySQLQuery + const EventTypeRDPFileTransfer + const EventTypeRDPLogin + const EventTypeRDPLogout + const EventTypeRDPScreenshot + const EventTypeSSHCommand + const EventTypeSSHFileDownload + const EventTypeSSHFileUpload + const EventTypeSSHLogin + const EventTypeSessionClose + type GetSessionReplayRequest struct + Format string + SessionID string + URLExpiry int + type GetSessionRequest struct + SessionID string + type ObjectStorage interface + BatchDownloadToDir func(ctx context.Context, paths []string, destDir string) error + Delete func(ctx context.Context, path string) error + Download func(ctx context.Context, path string) ([]byte, error) + Exists func(ctx context.Context, path string) (bool, error) + GetURL func(ctx context.Context, path string, expiry time.Duration) (string, error) + ListWithPrefix func(ctx context.Context, prefix string) ([]string, error) + Upload func(ctx context.Context, path string, data io.Reader) error + type OperationEvent struct + Blocked bool + CreatedAt int64 + Data string + ErrorMessage string + EventType EventType + ID int64 + Operation string + Protocol Protocol + Result string + RiskLevel string + SessionID string + Timestamp int64 + UserID string + Username string + func (*OperationEvent) TableName() string + type Protocol string + const ProtocolMySQL + const ProtocolRDP + const ProtocolSSH + type QuerySessionRequest struct + EndTime int64 + Page int64 + PageSize int64 + Protocol Protocol + ResourceID string + StartTime int64 + Status string + UserID string + Username string + func (r *QuerySessionRequest) ComputeOffset() int64 + type Service interface + CloseConnection func(context.Context, *ConnectionCloseEvent) error + GetObjectStorage func() ObjectStorage + GetSession func(context.Context, *GetSessionRequest) (*Session, error) + GetSessionReplay func(context.Context, *GetSessionReplayRequest) (*SessionReplay, error) + QuerySessions func(context.Context, *QuerySessionRequest) (*SessionSet, error) + RecordConnection func(context.Context, *ConnectionEvent) error + RecordDataFlow func(context.Context, *DataFlowEvent) error + RecordEvent func(context.Context, *OperationEvent) error + func GetService() Service + type Session struct + BytesReceived int64 + BytesSent int64 + ConnectionID string + CreatedAt int64 + Duration int64 + EndTime int64 + EventCount int + ID string + Metadata string + Protocol Protocol + RecordingPath string + ResourceID string + ResourceName string + SourceIP string + SourcePort int + StartTime int64 + Status string + TargetHost string + TargetPort int + UpdatedAt int64 + UserID string + Username string + func (*Session) TableName() string + type SessionReplay struct + Data interface{} + EndTime int64 + Protocol Protocol + RecordingURL string + SessionID string + StartTime int64 + type SessionSet struct + Items []*Session + Total int64
Go to main page