state

Documentation

Index

• Constants
• type CachingAuditLog
  • func MakeCachingAuditLog(logServer events.IAuditLog) *CachingAuditLog
  • func (ll *CachingAuditLog) Close() error
  • func (ll *CachingAuditLog) EmitAuditEvent(eventType string, fields events.EventFields) error
  • func (ll *CachingAuditLog) GetSessionChunk(session.ID, int, int) ([]byte, error)
  • func (ll *CachingAuditLog) GetSessionEvents(session.ID, int) ([]events.EventFields, error)
  • func (ll *CachingAuditLog) PostSessionChunk(sid session.ID, reader io.Reader) error
  • func (ll *CachingAuditLog) SearchEvents(time.Time, time.Time, string) ([]events.EventFields, error)
• type CachingAuthClient
  • func NewCachingAuthClient(ap auth.AccessPoint) (*CachingAuthClient, error)
  • func (cs *CachingAuthClient) GetCertAuthorities(ct services.CertAuthType, loadKeys bool) ([]*services.CertAuthority, error)
  • func (cs *CachingAuthClient) GetDomainName() (string, error)
  • func (cs *CachingAuthClient) GetNodes() ([]services.Server, error)
  • func (cs *CachingAuthClient) GetProxies() ([]services.Server, 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
)

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 (ll *CachingAuditLog) GetSessionChunk(session.ID, int, int) ([]byte, error)

func (*CachingAuditLog) GetSessionEvents

func (ll *CachingAuditLog) GetSessionEvents(session.ID, int) ([]events.EventFields, error)

func (*CachingAuditLog) PostSessionChunk

func (ll *CachingAuditLog) PostSessionChunk(sid session.ID, reader io.Reader) error

func (*CachingAuditLog) SearchEvents

func (ll *CachingAuditLog) SearchEvents(time.Time, time.Time, string) ([]events.EventFields, error)

type CachingAuthClient

type CachingAuthClient struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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) GetNodes

func (cs *CachingAuthClient) GetNodes() ([]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) GetUsers

func (cs *CachingAuthClient) GetUsers() ([]services.User, error)

GetUsers is a part of auth.AccessPoint implementation

func (*CachingAuthClient) UpsertNode

func (cs *CachingAuthClient) UpsertNode(s services.Server, ttl time.Duration) error

UpsertNode is part of auth.AccessPoint implementation

func (*CachingAuthClient) UpsertProxy

func (cs *CachingAuthClient) UpsertProxy(s services.Server, ttl time.Duration) error

UpsertProxy is part of auth.AccessPoint implementation