persistenceBbolt

README

Persistence BoltDB

BoltDB based persistence plugin for VolantMQ

╔════════════════════════════════════╗                     
║ V: count - total amount of sessions║                     
║ B: sessions - actuall sessions     ║                     
╚═▲══════════════════════════════════╝                     
  │                                                        
  │.n                                                      
╔═╩═══════════════╗      .1 ┌─────────────────────┐        
║ V: subscriptions◀─────────┤Encoded subscriptions│        
║ B: state        ◀────┐    └─────────────────────┘        
║ B: packets      ◀───┐│ .1 ╔═════════════╗                
╚═════════════════╝   │└────╣ V: version  ║                
                      │     ║ V: since    ║                
                      │     ║ V: expireIn ║                
                      │     ║ V: willIn   ║                
                      │     ║ V: willData ║                
┌───────────────┐     │     ╚═════════════╝                
│ Legend        │     │  .1 ╔═════╗.1  .n ╔═══════════════╗
│ V - value     │     └─────╣ Seq ◀───────╣ V: data       ║
│ B - bucket    │           ╚═════╝       ║ V: unAck      ║
└───────────────┘                         ║ V: expireAt   ║
                                          ╚═══════════════╝

Documentation

Index

• func Load(c interface{}, params *vlplugin.SysParams) (persistence.IFace, error)
• type Config

Functions

func Load

func Load(c interface{}, params *vlplugin.SysParams) (persistence.IFace, error)

nolint: golint

Types

type Config

type Config struct {
	File string `json:"file"`
}

Config configuration of the BoltDB backend