managers

Documentation

Index

• Constants
• type Broadcast
• type BroadcastAction
• type BroadcastPayload
• type BroadcasterMgr
  • func NewInternalBroadcasterMgr() BroadcasterMgr
• type InternalBroadcasterMgr
  • func (ibm *InternalBroadcasterMgr) Send(team, vault string, action BroadcastAction, secret *models.Secret)
  • func (ibm *InternalBroadcasterMgr) Stop()
  • func (ibm *InternalBroadcasterMgr) Subscribe(sid string) <-chan *Broadcast
  • func (ibm *InternalBroadcasterMgr) Unsubscribe(sid string)
• type MailMgr
  • func NewMailMgrNULL() MailMgr
  • func NewMailMgrSMTP(server, user, pass, from string) MailMgr
  • func NewMailMgrSparkpost(key, from string, eu bool) MailMgr
• type Session
• type SessionMgr
  • func NewSessionMgrDB(dbp *sql.DB) SessionMgr
  • func NewSessionMgrRedis(connUrl string, dbId int) (SessionMgr, error)

Constants

const (
	BCAST_ACTION_SECRET_NEW    = BroadcastAction("secret:new")
	BCAST_ACTION_SECRET_CHANGE = BroadcastAction("secret:change")
	BCAST_ACTION_SECRET_REMOVE = BroadcastAction("secret:remove")
	BCAST_ACTION_VAULT_VERSION = BroadcastAction("vault:version")
)

Types

type Broadcast

type Broadcast struct {
	Team    string
	Vault   string
	Message []byte
}

type BroadcastAction

type BroadcastAction string

type BroadcastPayload

type BroadcastPayload struct {
	Action       BroadcastAction              `json:"action"`
	Team         string                       `json:"team,omitempty"`
	Vault        string                       `json:"vault,omitempty"`
	Secret       *models.Secret               `json:"secret,omitempty"`
	VaultVersion map[string]map[string]uint32 `json:"vault_version,omitempty"`
}

type BroadcasterMgr

type BroadcasterMgr interface {
	Subscribe(address string) <-chan *Broadcast
	Unsubscribe(address string)
	Send(team, vault string, action BroadcastAction, secret *models.Secret)
	Stop()
}

func NewInternalBroadcasterMgr

func NewInternalBroadcasterMgr() BroadcasterMgr

type InternalBroadcasterMgr

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

func (*InternalBroadcasterMgr) Send

func (ibm *InternalBroadcasterMgr) Send(team, vault string, action BroadcastAction, secret *models.Secret)

func (*InternalBroadcasterMgr) Stop

func (ibm *InternalBroadcasterMgr) Stop()

func (*InternalBroadcasterMgr) Subscribe

func (ibm *InternalBroadcasterMgr) Subscribe(sid string) <-chan *Broadcast

func (*InternalBroadcasterMgr) Unsubscribe

func (ibm *InternalBroadcasterMgr) Unsubscribe(sid string)

type MailMgr

type MailMgr interface {
	SendMail(to string, subject string, data string) error
}

func NewMailMgrNULL

func NewMailMgrNULL() MailMgr

func NewMailMgrSMTP

func NewMailMgrSMTP(server, user, pass, from string) MailMgr

func NewMailMgrSparkpost

func NewMailMgrSparkpost(key, from string, eu bool) MailMgr

type Session

type Session struct {
	Id           string    `json:"id" scaneo:"pk"`
	User         string    `json:"user"`
	Agent        string    `json:"agent"`
	RequiresCSRF bool      `json:"csrf_required"`
	LastAccess   time.Time `json:"last_access"`
	StoreToken   string    `json:"-"`
	LastIp       string    `json:"last_ip"`
}

type SessionMgr

type SessionMgr interface {
	NewSession(userId string, ip string, agent string, csrf bool) (*Session, error)
	UpdateSession(id, ip, agent string) (*Session, error)
	GetSession(id string) (*Session, error)
	DeleteSession(id string) error
	GetAllSessions(userId string) ([]*Session, error)
	DeleteAllSessions(userId string) error
}

func NewSessionMgrDB

func NewSessionMgrDB(dbp *sql.DB) SessionMgr

func NewSessionMgrRedis

func NewSessionMgrRedis(connUrl string, dbId int) (SessionMgr, error)