project

Documentation

Index

• type AggregationConfig
• type Config
  • func (c *Config) GetOutput(privateKeyECDSA, privateKeyED25519 string) (output.Output, error)
• type EthereumConfig
• type Manager
  • func NewManager(chainEndpoint, contractAddress, projectFileDir, ipfsEndpoint string) (*Manager, error)
  • func (m *Manager) Get(projectID uint64, version string) (*Config, error)
  • func (m *Manager) GetAllProjectID() []uint64
  • func (m *Manager) GetNotify() <-chan uint64
  • func (m *Manager) Set(projectID uint64, version string, c *Config)
• type Monitor
  • func NewDefaultMonitor(chainEndpoint string, addresses []string, topics []string) (*Monitor, error)
  • func NewMonitor(chainEndpoint string, addresses []string, topics []string, from, step int64, ...) (*Monitor, error)
  • func (m *Monitor) Err() <-chan error
  • func (m *Monitor) Events(topic string) (<-chan *types.Log, bool)
  • func (m *Monitor) MustEvents(topic string) <-chan *types.Log
  • func (m *Monitor) Unsubscribe()
• type OutputConfig
• type ProjectMeta
  • func (m *ProjectMeta) GetConfigs(ipfsEndpoint string) ([]*Config, error)
• type SolanaConfig
• type TextileConfig

Types

type AggregationConfig

type AggregationConfig struct {
	Amount uint `json:"amount,omitempty"`
}

type Config

type Config struct {
	Code         string            `json:"code"`
	CodeExpParam string            `json:"codeExpParam,omitempty"`
	VMType       types.VM          `json:"vmType"`
	Output       OutputConfig      `json:"output"`
	Aggregation  AggregationConfig `json:"aggregation"`
	Version      string            `json:"version"`
}

func (*Config) GetOutput

func (c *Config) GetOutput(privateKeyECDSA, privateKeyED25519 string) (output.Output, error)

type EthereumConfig

type EthereumConfig struct {
	ChainEndpoint   string `json:"chainEndpoint"`
	ContractAddress string `json:"contractAddress"`
	ReceiverAddress string `json:"receiverAddress,omitempty"`
	ContractMethod  string `json:"contractMethod"`
	ContractAbiJSON string `json:"contractAbiJSON"`
}

type Manager

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

func NewManager

func NewManager(chainEndpoint, contractAddress, projectFileDir, ipfsEndpoint string) (*Manager, error)

func (*Manager) Get

func (m *Manager) Get(projectID uint64, version string) (*Config, error)

func (*Manager) GetAllProjectID

func (m *Manager) GetAllProjectID() []uint64

TODO will delete when node konw how to fetch message

func (*Manager) GetNotify

func (m *Manager) GetNotify() <-chan uint64

func (*Manager) Set

func (m *Manager) Set(projectID uint64, version string, c *Config)

type Monitor

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

func NewDefaultMonitor

func NewDefaultMonitor(chainEndpoint string, addresses []string, topics []string) (*Monitor, error)

func NewMonitor

func NewMonitor(chainEndpoint string, addresses []string, topics []string, from, step int64, interval time.Duration) (*Monitor, error)

func (*Monitor) Err

func (m *Monitor) Err() <-chan error

func (*Monitor) Events

func (m *Monitor) Events(topic string) (<-chan *types.Log, bool)

func (*Monitor) MustEvents

func (m *Monitor) MustEvents(topic string) <-chan *types.Log

func (*Monitor) Unsubscribe

func (m *Monitor) Unsubscribe()

type OutputConfig

type OutputConfig struct {
	Type     types.Output   `json:"type"`
	Ethereum EthereumConfig `json:"ethereum,omitempty"`
	Solana   SolanaConfig   `json:"solana,omitempty"`
	Textile  TextileConfig  `json:"textile,omitempty"`
}

type ProjectMeta

type ProjectMeta struct {
	ProjectID uint64
	Uri       string
	Hash      [32]byte
	Paused    bool
}

func (*ProjectMeta) GetConfigs

func (m *ProjectMeta) GetConfigs(ipfsEndpoint string) ([]*Config, error)

type SolanaConfig

type SolanaConfig struct {
	ChainEndpoint  string `json:"chainEndpoint"`
	ProgramID      string `json:"programID"`
	StateAccountPK string `json:"stateAccountPK"`
}

type TextileConfig

type TextileConfig struct {
	VaultID string `json:"vaultID"`
}