synapse

Documentation

Index

• Constants
• Variables
• func CheckBuiltInTorrentFsError(err error) bool
• func RLPHashString(x interface{}) string
• func ReadData(inputFilePath string) ([]byte, error)
• func SwitchEndian(data []byte, bytes int) ([]byte, error)
• func ToAlignedData(data []byte, bytes int) ([]byte, error)
• type Config
• type Synapse
  • func Engine() *Synapse
  • func New(config *Config) *Synapse
  • func (s *Synapse) Close()
  • func (s *Synapse) GetGasByInfoHash(modelInfoHash string) (gas uint64, err error)
  • func (s *Synapse) InferByInfoHash(modelInfoHash, inputInfoHash string) ([]byte, error)
  • func (s *Synapse) InferByInputContent(modelInfoHash string, inputContent []byte) ([]byte, error)

Constants

const MinMemoryUsage int64 = 2 * 1024 * 1024 * 1024

const PLUGIN_PATH string = "plugins/"

const PLUGIN_POST_FIX string = "_cvm.so"

const ReservedMemoryUsage int64 = 512 * 1024 * 1024

Variables

var (
	ErrBuiltInTorrentFsPrefix = "BUILT-IN TORRENT FS ERROR"

	ErrInputFileNotExistFlag = "[ " + ErrBuiltInTorrentFsPrefix + " ] input file not exist"
	ErrModelFileNotExistFlag = "[ " + ErrBuiltInTorrentFsPrefix + " ] model file not exist"

	ErrInputFileNotExist = errors.New(ErrInputFileNotExistFlag)
	ErrModelFileNotExist = errors.New(ErrModelFileNotExistFlag)

	ErrFatal = errors.New("fatal")
)

Functions

func CheckBuiltInTorrentFsError

func CheckBuiltInTorrentFsError(err error) bool

If infered by local, check struct error is enough. Else infered by remote, must be checked by error's text

func RLPHashString

func RLPHashString(x interface{}) string

func ReadData

func ReadData(inputFilePath string) ([]byte, error)

func SwitchEndian

func SwitchEndian(data []byte, bytes int) ([]byte, error)

func ToAlignedData

func ToAlignedData(data []byte, bytes int) ([]byte, error)

Types

type Config

type Config struct {
	// StorageDir    string `toml:",omitempty"`
	IsNotCache     bool   `toml:",omitempty"`
	DeviceType     string `toml:",omitempty"`
	DeviceId       int    `toml:",omitempty"`
	IsRemoteInfer  bool   `toml:",omitempty"`
	InferURI       string `toml:",omitempty"`
	Debug          bool   `toml:",omitempty"`
	MaxMemoryUsage int64
	Storagefs      torrentfs.CVMStorage
}

var DefaultConfig Config = Config{

	IsNotCache:     false,
	DeviceType:     "cpu",
	DeviceId:       0,
	IsRemoteInfer:  false,
	InferURI:       "",
	Debug:          false,
	MaxMemoryUsage: 4 * 1024 * 1024 * 1024,
}

type Synapse

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

func Engine

func Engine() *Synapse

func New

func New(config *Config) *Synapse

func (*Synapse) Close

func (s *Synapse) Close()

func (*Synapse) GetGasByInfoHash

func (s *Synapse) GetGasByInfoHash(modelInfoHash string) (gas uint64, err error)

func (*Synapse) InferByInfoHash

func (s *Synapse) InferByInfoHash(modelInfoHash, inputInfoHash string) ([]byte, error)

func (*Synapse) InferByInputContent

func (s *Synapse) InferByInputContent(modelInfoHash string, inputContent []byte) ([]byte, error)