client

Documentation

Index

• func LoadP12(filename, password string) (*tls.Certificate, []*x509.Certificate, error)
• type CertificateConfig
• type ClientHandler
• type ConnClientHandler
  • func NewConnClientHandler(name string, conn net.Conn, config *HandlerConfig) *ConnClientHandler
  • func (h *ConnClientHandler) CanSeeScope(scope string) bool
  • func (h *ConnClientHandler) ForAllUID(fn func(string, string) bool)
  • func (h *ConnClientHandler) GetLastSeen() *time.Time
  • func (h *ConnClientHandler) GetName() string
  • func (h *ConnClientHandler) GetSerial() string
  • func (h *ConnClientHandler) GetUID(callsign string) string
  • func (h *ConnClientHandler) GetUids() map[string]string
  • func (h *ConnClientHandler) GetUser() *model.User
  • func (h *ConnClientHandler) GetVersion() int32
  • func (h *ConnClientHandler) HasUID(uid string) bool
  • func (h *ConnClientHandler) IsActive() bool
  • func (h *ConnClientHandler) SendCot(msg *cotproto.TakMessage) error
  • func (h *ConnClientHandler) SendMsg(msg *cot.CotMessage) error
  • func (h *ConnClientHandler) SetVersion(n int32)
  • func (h *ConnClientHandler) Start()
  • func (h *ConnClientHandler) Stop()
• type Enroller
  • func NewEnroller(host, user, passwd string, save bool, p12Password string) *Enroller
  • func (e *Enroller) GetOrEnrollCert(ctx context.Context, uid, version string) (*tls.Certificate, []*x509.Certificate, error)
• type HandlerConfig

Functions

func LoadP12

func LoadP12(filename, password string) (*tls.Certificate, []*x509.Certificate, error)

Types

type CertificateConfig

type CertificateConfig struct {
	XMLName      xml.Name `xml:"certificateConfig"`
	ValidityDays string   `xml:"validityDays,attr"`
	NameEntries  struct {
		NameEntry []struct {
			Value string `xml:"value,attr"`
			Name  string `xml:"name,attr"`
		} `xml:"nameEntry"`
	} `xml:"nameEntries"`
}

type ClientHandler

type ClientHandler interface {
	GetName() string
	HasUID(uid string) bool
	GetUids() map[string]string
	GetUser() *model.User
	GetSerial() string
	GetVersion() int32
	SendMsg(msg *cot.CotMessage) error
	GetLastSeen() *time.Time
	CanSeeScope(scope string) bool
	Stop()
}

type ConnClientHandler

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

func NewConnClientHandler

func NewConnClientHandler(name string, conn net.Conn, config *HandlerConfig) *ConnClientHandler

func (*ConnClientHandler) CanSeeScope

func (h *ConnClientHandler) CanSeeScope(scope string) bool

func (*ConnClientHandler) ForAllUID

func (h *ConnClientHandler) ForAllUID(fn func(string, string) bool)

func (*ConnClientHandler) GetLastSeen

func (h *ConnClientHandler) GetLastSeen() *time.Time

func (*ConnClientHandler) GetName

func (h *ConnClientHandler) GetName() string

func (*ConnClientHandler) GetSerial

func (h *ConnClientHandler) GetSerial() string

func (*ConnClientHandler) GetUID

func (h *ConnClientHandler) GetUID(callsign string) string

func (*ConnClientHandler) GetUids

func (h *ConnClientHandler) GetUids() map[string]string

func (*ConnClientHandler) GetUser

func (h *ConnClientHandler) GetUser() *model.User

func (*ConnClientHandler) GetVersion

func (h *ConnClientHandler) GetVersion() int32

func (*ConnClientHandler) HasUID

func (h *ConnClientHandler) HasUID(uid string) bool

func (*ConnClientHandler) IsActive

func (h *ConnClientHandler) IsActive() bool

func (*ConnClientHandler) SendCot

func (h *ConnClientHandler) SendCot(msg *cotproto.TakMessage) error

func (*ConnClientHandler) SendMsg

func (h *ConnClientHandler) SendMsg(msg *cot.CotMessage) error

func (*ConnClientHandler) SetVersion

func (h *ConnClientHandler) SetVersion(n int32)

func (*ConnClientHandler) Start

func (h *ConnClientHandler) Start()

func (*ConnClientHandler) Stop

func (h *ConnClientHandler) Stop()

type Enroller

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

func NewEnroller

func NewEnroller(host, user, passwd string, save bool, p12Password string) *Enroller

func (*Enroller) GetOrEnrollCert

func (e *Enroller) GetOrEnrollCert(ctx context.Context, uid, version string) (*tls.Certificate, []*x509.Certificate, error)

type HandlerConfig

type HandlerConfig struct {
	User         *model.User
	Serial       string
	UID          string
	IsClient     bool
	MessageCb    func(msg *cot.CotMessage)
	RemoveCb     func(ch ClientHandler)
	NewContactCb func(uid, callsign string)
	Logger       *slog.Logger
	DropMetric   *prometheus.CounterVec
	UidChecker   func(uid string) bool
}