project

Documentation

Index

• type Config
  • func (c *Config) GetOutput(privateKeyECDSA, privateKeyED25519 string) (output.Output, error)
• type Manager
  • func NewManager(chainEndpoint, contractAddress, projectFileDirectory string) (*Manager, error)
  • func (m *Manager) Get(projectID uint64, version string) (*Config, error)
  • func (m *Manager) GetAllProjectID() []uint64
• 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() ([]*Config, error)

Types

type Config

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

func (*Config) GetOutput

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

type Manager

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

func NewManager

func NewManager(chainEndpoint, contractAddress, projectFileDirectory 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

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 struct {
		ChainEndpoint   string `json:"chainEndpoint"`
		ContractAddress string `json:"contractAddress"`
		ContractMethod  string `json:"contractMethod"`
		ContractAbiJSON string `json:"contractAbiJSON"`
	} `json:"ethereum,omitempty"`

	Solana struct {
		ChainEndpoint  string `json:"chainEndpoint"`
		ProgramID      string `json:"programID"`
		StateAccountPK string `json:"stateAccountPK"`
	} `json:"solana,omitempty"`
}

type ProjectMeta

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

func (*ProjectMeta) GetConfigs

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