Documentation
¶
Index ¶
- Constants
- type CachingAuditLog
- func (ll *CachingAuditLog) Close() error
- func (ll *CachingAuditLog) EmitAuditEvent(eventType string, fields events.EventFields) error
- func (ll *CachingAuditLog) GetSessionChunk(string, session.ID, int, int) ([]byte, error)
- func (ll *CachingAuditLog) GetSessionEvents(string, session.ID, int) ([]events.EventFields, error)
- func (ll *CachingAuditLog) PostSessionChunk(namespace string, sid session.ID, reader io.Reader) error
- func (ll *CachingAuditLog) SearchEvents(time.Time, time.Time, string) ([]events.EventFields, error)
- type CachingAuthClient
- func (cs *CachingAuthClient) GetCertAuthorities(ct services.CertAuthType, loadKeys bool) ([]services.CertAuthority, error)
- func (cs *CachingAuthClient) GetDomainName() (string, error)
- func (cs *CachingAuthClient) GetNamespaces() ([]services.Namespace, error)
- func (cs *CachingAuthClient) GetNodes(namespace string) ([]services.Server, error)
- func (cs *CachingAuthClient) GetProxies() ([]services.Server, error)
- func (cs *CachingAuthClient) GetRole(name string) (services.Role, error)
- func (cs *CachingAuthClient) GetRoles() ([]services.Role, error)
- func (cs *CachingAuthClient) GetUsers() ([]services.User, error)
- func (cs *CachingAuthClient) UpsertNode(s services.Server, ttl time.Duration) error
- func (cs *CachingAuthClient) UpsertProxy(s services.Server, ttl time.Duration) error
Constants ¶
const ( // MaxQueueSize determines how many logging events to queue in-memory // before start dropping them (probably because logging server is down) MaxQueueSize = 10 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CachingAuditLog ¶
type CachingAuditLog struct {
// contains filtered or unexported fields
}
CachingAuditLog implements events.IAuditLog on the recording machine (SSH server) It captures the local recording and forwards it to the AuditLog network server
func MakeCachingAuditLog ¶
func MakeCachingAuditLog(logServer events.IAuditLog) *CachingAuditLog
MakeCachingAuditLog creaets a new & fully initialized instance of the alog
func (*CachingAuditLog) Close ¶
func (ll *CachingAuditLog) Close() error
func (*CachingAuditLog) EmitAuditEvent ¶
func (ll *CachingAuditLog) EmitAuditEvent(eventType string, fields events.EventFields) error
func (*CachingAuditLog) GetSessionChunk ¶
func (*CachingAuditLog) GetSessionEvents ¶
func (ll *CachingAuditLog) GetSessionEvents(string, session.ID, int) ([]events.EventFields, error)
func (*CachingAuditLog) PostSessionChunk ¶
func (*CachingAuditLog) SearchEvents ¶
func (ll *CachingAuditLog) SearchEvents(time.Time, time.Time, string) ([]events.EventFields, error)
type CachingAuthClient ¶
CachingAuthClient implements auth.AccessPoint interface and remembers the previously returned upstream value for each API call.
This which can be used if the upstream AccessPoint goes offline
func NewCachingAuthClient ¶
func NewCachingAuthClient(ap auth.AccessPoint) (*CachingAuthClient, error)
NewCachingAuthClient creates a new instance of CachingAuthClient using a live connection to the auth server (ap)
func (*CachingAuthClient) GetCertAuthorities ¶
func (cs *CachingAuthClient) GetCertAuthorities(ct services.CertAuthType, loadKeys bool) ([]services.CertAuthority, error)
GetCertAuthorities is a part of auth.AccessPoint implementation
func (*CachingAuthClient) GetDomainName ¶
func (cs *CachingAuthClient) GetDomainName() (string, error)
GetDomainName is a part of auth.AccessPoint implementation
func (*CachingAuthClient) GetNamespaces ¶
func (cs *CachingAuthClient) GetNamespaces() ([]services.Namespace, error)
GetNamespaces is a part of auth.AccessPoint implementation
func (*CachingAuthClient) GetNodes ¶
func (cs *CachingAuthClient) GetNodes(namespace string) ([]services.Server, error)
GetNodes is a part of auth.AccessPoint implementation
func (*CachingAuthClient) GetProxies ¶
func (cs *CachingAuthClient) GetProxies() ([]services.Server, error)
GetProxies is a part of auth.AccessPoint implementation
func (*CachingAuthClient) GetRole ¶
func (cs *CachingAuthClient) GetRole(name string) (services.Role, error)
GetRoles is a part of auth.AccessPoint implementation
func (*CachingAuthClient) GetRoles ¶
func (cs *CachingAuthClient) GetRoles() ([]services.Role, error)
GetRoles is a part of auth.AccessPoint implementation
func (*CachingAuthClient) GetUsers ¶
func (cs *CachingAuthClient) GetUsers() ([]services.User, error)
GetUsers is a part of auth.AccessPoint implementation
func (*CachingAuthClient) UpsertNode ¶
UpsertNode is part of auth.AccessPoint implementation
func (*CachingAuthClient) UpsertProxy ¶
UpsertProxy is part of auth.AccessPoint implementation
Source Files