identity

Documentation

Index

• type IdentifiableController
  • func NewIdentifiableController(c node.Controller, i Identifier) *IdentifiableController
  • func (c *IdentifiableController) Authenticate(sid string, env *common.SessionEnv) (*common.ConnectResult, error)
  • func (c *IdentifiableController) Disconnect(sid string, env *common.SessionEnv, id string, subscriptions []string) error
  • func (c *IdentifiableController) Perform(sid string, env *common.SessionEnv, id string, channel string, data string) (*common.CommandResult, error)
  • func (c *IdentifiableController) Shutdown() error
  • func (c *IdentifiableController) Start() error
  • func (c *IdentifiableController) Subscribe(sid string, env *common.SessionEnv, id string, channel string) (*common.CommandResult, error)
  • func (c *IdentifiableController) Unsubscribe(sid string, env *common.SessionEnv, id string, channel string) (*common.CommandResult, error)
• type Identifier
• type IdentifierPipeline
  • func NewIdentifierPipeline(identifiers ...Identifier) *IdentifierPipeline
  • func (p *IdentifierPipeline) Identify(sid string, env *common.SessionEnv) (*common.ConnectResult, error)
• type JWTConfig
  • func NewJWTConfig(secret string) JWTConfig
  • func (c JWTConfig) Enabled() bool
  • func (c JWTConfig) ToToml() string
• type JWTIdentifier
  • func NewJWTIdentifier(config *JWTConfig, l *slog.Logger) *JWTIdentifier
  • func (i *JWTIdentifier) Identify(sid string, env *common.SessionEnv) (*common.ConnectResult, error)
• type PublicIdentifier
  • func NewPublicIdentifier() *PublicIdentifier
  • func (pi *PublicIdentifier) Identify(sid string, env *common.SessionEnv) (*common.ConnectResult, error)

Types

type IdentifiableController

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

func NewIdentifiableController

func NewIdentifiableController(c node.Controller, i Identifier) *IdentifiableController

func (*IdentifiableController) Authenticate

func (c *IdentifiableController) Authenticate(sid string, env *common.SessionEnv) (*common.ConnectResult, error)

func (*IdentifiableController) Disconnect

func (c *IdentifiableController) Disconnect(sid string, env *common.SessionEnv, id string, subscriptions []string) error

func (*IdentifiableController) Perform

func (c *IdentifiableController) Perform(sid string, env *common.SessionEnv, id string, channel string, data string) (*common.CommandResult, error)

func (*IdentifiableController) Shutdown

func (c *IdentifiableController) Shutdown() error

func (*IdentifiableController) Start

func (c *IdentifiableController) Start() error

func (*IdentifiableController) Subscribe

func (c *IdentifiableController) Subscribe(sid string, env *common.SessionEnv, id string, channel string) (*common.CommandResult, error)

func (*IdentifiableController) Unsubscribe

func (c *IdentifiableController) Unsubscribe(sid string, env *common.SessionEnv, id string, channel string) (*common.CommandResult, error)

type Identifier

type Identifier interface {
	Identify(sid string, env *common.SessionEnv) (*common.ConnectResult, error)
}

type IdentifierPipeline

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

func NewIdentifierPipeline

func NewIdentifierPipeline(identifiers ...Identifier) *IdentifierPipeline

func (*IdentifierPipeline) Identify

func (p *IdentifierPipeline) Identify(sid string, env *common.SessionEnv) (*common.ConnectResult, error)

type JWTConfig

type JWTConfig struct {
	Secret string `toml:"secret"`
	Param  string `toml:"param"`
	Algo   jwt.SigningMethod
	Force  bool `toml:"force"`
}

func NewJWTConfig

func NewJWTConfig(secret string) JWTConfig

func (JWTConfig) Enabled

func (c JWTConfig) Enabled() bool

func (JWTConfig) ToToml

func (c JWTConfig) ToToml() string

type JWTIdentifier

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

func NewJWTIdentifier

func NewJWTIdentifier(config *JWTConfig, l *slog.Logger) *JWTIdentifier

func (*JWTIdentifier) Identify

func (i *JWTIdentifier) Identify(sid string, env *common.SessionEnv) (*common.ConnectResult, error)

type PublicIdentifier

type PublicIdentifier struct {
}

PublicIdentifier identifies all clients and use their sid as the only identifier

func NewPublicIdentifier

func NewPublicIdentifier() *PublicIdentifier

func (*PublicIdentifier) Identify

func (pi *PublicIdentifier) Identify(sid string, env *common.SessionEnv) (*common.ConnectResult, error)