identity

Documentation

Index

• type IdentityHeartbeatStore
  • func NewIdentityHeartbeatStore(timeout time.Duration) *IdentityHeartbeatStore
  • func (i *IdentityHeartbeatStore) Delete(identity string)
  • func (i *IdentityHeartbeatStore) GC()
  • func (i *IdentityHeartbeatStore) IsAlive(identity string) bool
  • func (i *IdentityHeartbeatStore) MarkAlive(identity string, t time.Time)

Types

type IdentityHeartbeatStore

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

IdentityHeartbeatStore keeps track of the heartbeat of identities

func NewIdentityHeartbeatStore

func NewIdentityHeartbeatStore(timeout time.Duration) *IdentityHeartbeatStore

NewIdentityHeartbeatStore returns a new identity heartbeat store

func (*IdentityHeartbeatStore) Delete

func (i *IdentityHeartbeatStore) Delete(identity string)

Delete deletes an identity from the store

func (*IdentityHeartbeatStore) GC

func (i *IdentityHeartbeatStore) GC()

GC removes all lifesign entries which have exceeded the heartbeat by a large amount. This happens when the CiliumIdentity is deleted before the CiliumEndpoint that refers to it. In that case, the lifesign entry will continue to exist. Remove it once has not been updated for a long time.

func (*IdentityHeartbeatStore) IsAlive

func (i *IdentityHeartbeatStore) IsAlive(identity string) bool

IsAlive returns true if the identity is still alive

func (*IdentityHeartbeatStore) MarkAlive

func (i *IdentityHeartbeatStore) MarkAlive(identity string, t time.Time)

MarkAlive marks an identity as alive