server

Documentation

Index

• Constants
• type FileServer
  • func NewFileServer(opts FileServerOpts) *FileServer
  • func (fs *FileServer) Delete(key string) error
  • func (fs *FileServer) DeleteLocally(key string) error
  • func (fs *FileServer) Load(key string) (io.Reader, error)
  • func (fs *FileServer) LoadLocally(key string) (int64, io.Reader, error)
  • func (fs *FileServer) OnPeer(p p2p.Peer) error
  • func (fs *FileServer) Save(key string, r io.Reader) error
  • func (fs *FileServer) SaveLocally(key string, r io.Reader) error
  • func (fs *FileServer) Start() error
  • func (fs *FileServer) Stop()
• type FileServerOpts
• type Message
• type MessageDeleteFile
• type MessageLoadFile
• type MessageSaveFile
• type MessageType
• type MessageWrapper

Constants

const AESBlockSize = 16

Types

type FileServer

type FileServer struct {
	FileServerOpts
	// contains filtered or unexported fields
}

func NewFileServer

func NewFileServer(opts FileServerOpts) *FileServer

func (*FileServer) Delete

func (fs *FileServer) Delete(key string) error

func (*FileServer) DeleteLocally

func (fs *FileServer) DeleteLocally(key string) error

func (*FileServer) Load

func (fs *FileServer) Load(key string) (io.Reader, error)

func (*FileServer) LoadLocally

func (fs *FileServer) LoadLocally(key string) (int64, io.Reader, error)

func (*FileServer) OnPeer

func (fs *FileServer) OnPeer(p p2p.Peer) error

func (*FileServer) Save

func (fs *FileServer) Save(key string, r io.Reader) error

func (*FileServer) SaveLocally

func (fs *FileServer) SaveLocally(key string, r io.Reader) error

func (*FileServer) Start

func (fs *FileServer) Start() error

func (*FileServer) Stop

func (fs *FileServer) Stop()

type FileServerOpts

type FileServerOpts struct {
	ID                string
	EncKey            []byte
	StorageRoot       string
	PathTransformFunc storage.PathTransformFunc
	Transport         p2p.Transport
	BootstrapNodes    []string
}

type Message

type Message struct {
	ID  string
	Key string
}

type MessageDeleteFile

type MessageDeleteFile struct {
	Message
}

type MessageLoadFile

type MessageLoadFile struct {
	Message
}

type MessageSaveFile

type MessageSaveFile struct {
	Message
	Size int64
}

type MessageType

type MessageType int

const (
	None MessageType = iota
	MessageTypeSave
	MessageTypeLoad
	MessageTypeDelete
)

type MessageWrapper

type MessageWrapper struct {
	Payload any
	Type    MessageType
}