ethconnect

Documentation

Index

• type Config
  • func (e *Config) WriteConfig(filename string, extraConnectorConfigPath string) error
• type DeployContractResponseBody
• type Ethconnect
  • func NewEthconnect(ctx context.Context) *Ethconnect
  • func (e *Ethconnect) DeployContract(contract *ethtypes.CompiledContract, contractName string, ...) (*types.ContractDeploymentResult, error)
  • func (e *Ethconnect) FirstTimeSetup(stack *types.Stack) error
  • func (e *Ethconnect) GenerateConfig(stack *types.Stack, member *types.Organization, blockchainServiceName string) connector.Config
  • func (e *Ethconnect) GetServiceDefinitions(s *types.Stack, dependentServices map[string]string) []*docker.ServiceDefinition
  • func (e *Ethconnect) Name() string
  • func (e *Ethconnect) Port() int
• type EthconnectMessageHeaders
• type EthconnectMessageRequest
• type EthconnectMessageResponse
• type EthconnectReply
• type EthconnectReplyHeaders
• type HTTP
• type OpenAPI
• type PublishAbiResponseBody
• type RPC
• type RegisterResponseBody
• type Rest
• type RestGateway

Types

type Config

type Config struct {
	Rest *Rest `yaml:"rest,omitempty"`
}

func (*Config) WriteConfig

func (e *Config) WriteConfig(filename string, extraConnectorConfigPath string) error

type DeployContractResponseBody

type DeployContractResponseBody struct {
	ContractAddress string `json:"contractAddress,omitempty"`
}

type Ethconnect

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

func NewEthconnect

func NewEthconnect(ctx context.Context) *Ethconnect

func (*Ethconnect) DeployContract

func (e *Ethconnect) DeployContract(contract *ethtypes.CompiledContract, contractName string, member *types.Organization, extraArgs []string) (*types.ContractDeploymentResult, error)

func (*Ethconnect) FirstTimeSetup

func (e *Ethconnect) FirstTimeSetup(stack *types.Stack) error

func (*Ethconnect) GenerateConfig

func (e *Ethconnect) GenerateConfig(stack *types.Stack, member *types.Organization, blockchainServiceName string) connector.Config

func (*Ethconnect) GetServiceDefinitions

func (e *Ethconnect) GetServiceDefinitions(s *types.Stack, dependentServices map[string]string) []*docker.ServiceDefinition

func (*Ethconnect) Name

func (e *Ethconnect) Name() string

func (*Ethconnect) Port

func (e *Ethconnect) Port() int

type EthconnectMessageHeaders

type EthconnectMessageHeaders struct {
	Type string `json:"type,omitempty"`
	ID   string `json:"id,omitempty"`
}

type EthconnectMessageRequest

type EthconnectMessageRequest struct {
	Headers  EthconnectMessageHeaders `json:"headers,omitempty"`
	To       string                   `json:"to"`
	From     string                   `json:"from,omitempty"`
	ABI      interface{}              `json:"abi,omitempty"`
	Bytecode string                   `json:"compiled"`
	Params   []interface{}            `json:"params"`
}

type EthconnectMessageResponse

type EthconnectMessageResponse struct {
	Sent bool   `json:"sent,omitempty"`
	ID   string `json:"id,omitempty"`
}

type EthconnectReply

type EthconnectReply struct {
	ID              string                  `json:"_id,omitempty"`
	Headers         *EthconnectReplyHeaders `json:"headers,omitempty"`
	ContractAddress string                  `json:"contractAddress,omitempty"`
	ErrorCode       string                  `json:"errorCode,omitempty"`
	ErrorMessage    string                  `json:"errorMessage,omitempty"`
}

type EthconnectReplyHeaders

type EthconnectReplyHeaders struct {
	ID            string  `json:"id,omitempty"`
	RequestID     string  `json:"requestId,omitempty"`
	RequestOffset string  `json:"requestOffset,omitempty"`
	TimeElapsed   float64 `json:"timeElapsed,omitempty"`
	TimeReceived  string  `json:"timeReceived,omitempty"`
	Type          string  `json:"type,omitempty"`
}

type HTTP

type HTTP struct {
	Port int `yaml:"port,omitempty"`
}

type OpenAPI

type OpenAPI struct {
	EventPollingIntervalSec int    `yaml:"eventPollingIntervalSec,omitempty"`
	StoragePath             string `yaml:"storagePath,omitempty"`
	EventsDB                string `yaml:"eventsDB,omitempty"`
}

type PublishAbiResponseBody

type PublishAbiResponseBody struct {
	ID string `json:"id,omitempty"`
}

type RPC

type RPC struct {
	URL string `yaml:"url,omitempty"`
}

type RegisterResponseBody

type RegisterResponseBody struct {
	Created      string `json:"created,omitempty"`
	Address      string `json:"string,omitempty"`
	Path         string `json:"path,omitempty"`
	ABI          string `json:"ABI,omitempty"`
	OpenAPI      string `json:"openapi,omitempty"`
	RegisteredAs string `json:"registeredAs,omitempty"`
}

type Rest

type Rest struct {
	RestGateway *RestGateway `yaml:"rest-gateway,omitempty"`
}

type RestGateway

type RestGateway struct {
	RPC           *RPC     `yaml:"rpc,omitempty"`
	OpenAPI       *OpenAPI `yaml:"openapi,omitempty"`
	HTTP          *HTTP    `yaml:"http,omitempty"`
	MaxTXWaitTime int      `yaml:"maxTXWaitTime,omitempty"`
	MaxInFlight   int      `yaml:"maxInFlight,omitempty"`
}