decompressor

Documentation

Index

• func Load(filepath string) (out chan []byte)
• func Store(filePath string, ipChan chan net.IP)
• type Decompressor
  • func (p Decompressor) Expand(ipRangeChan chan model.IPRange) chan net.IP
  • func (p Decompressor) Load(filePath string) chan []byte
  • func (p Decompressor) Store(filePath string, ipChan chan net.IP)
  • func (p Decompressor) Unserialize(dataChan chan []byte) chan model.IPRange

Functions

func Load

func Load(filepath string) (out chan []byte)

Load reads a file line by line and returns a channel of net.IP

func Store

func Store(filePath string, ipChan chan net.IP)

Types

type Decompressor

type Decompressor struct {
}

func (Decompressor) Expand

func (p Decompressor) Expand(ipRangeChan chan model.IPRange) chan net.IP

func (Decompressor) Load

func (p Decompressor) Load(filePath string) chan []byte

func (Decompressor) Store

func (p Decompressor) Store(filePath string, ipChan chan net.IP)

func (Decompressor) Unserialize

func (p Decompressor) Unserialize(dataChan chan []byte) chan model.IPRange