157 lines
3.4 KiB
Go
157 lines
3.4 KiB
Go
// Copyright 2017 AMIS Technologies
|
|
// This file is part of the go-ethereum library.
|
|
//
|
|
// The go-ethereum library is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU Lesser General Public License as published by
|
|
// the Free Software Foundation, either version 3 of the License, or
|
|
// (at your option) any later version.
|
|
//
|
|
// The go-ethereum library is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU Lesser General Public License for more details.
|
|
//
|
|
// You should have received a copy of the GNU Lesser General Public License
|
|
// along with the go-ethereum library. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
package k8s
|
|
|
|
import (
|
|
"time"
|
|
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
"k8s.io/client-go/kubernetes"
|
|
|
|
"github.com/ethereum/go-ethereum/accounts"
|
|
"github.com/ethereum/go-ethereum/common"
|
|
|
|
"github.com/getamis/istanbul-tools/charts"
|
|
"github.com/getamis/istanbul-tools/client"
|
|
istcommon "github.com/getamis/istanbul-tools/common"
|
|
)
|
|
|
|
func NewEthereum(options ...Option) *ethereum {
|
|
eth := ðereum{
|
|
name: istcommon.RandomHex(),
|
|
}
|
|
|
|
for _, opt := range options {
|
|
opt(eth)
|
|
}
|
|
|
|
eth.chart = charts.NewValidatorChart(eth.name, eth.args)
|
|
|
|
return eth
|
|
}
|
|
|
|
type ethereum struct {
|
|
chart *charts.ValidatorChart
|
|
name string
|
|
args []string
|
|
|
|
k8sClient *kubernetes.Clientset
|
|
}
|
|
|
|
func (eth *ethereum) Init(genesisFile string) error {
|
|
return nil
|
|
}
|
|
|
|
func (eth *ethereum) Start() error {
|
|
if err := eth.chart.Install(false); err != nil {
|
|
return err
|
|
}
|
|
|
|
eth.k8sClient = k8sClient(eth.chart.Name() + "-0")
|
|
return nil
|
|
}
|
|
|
|
func (eth *ethereum) Stop() error {
|
|
return eth.chart.Uninstall()
|
|
}
|
|
|
|
func (eth *ethereum) Wait(t time.Duration) error {
|
|
return nil
|
|
}
|
|
|
|
func (eth *ethereum) Running() bool {
|
|
return false
|
|
}
|
|
|
|
func (eth *ethereum) ContainerID() string {
|
|
return ""
|
|
}
|
|
|
|
func (eth *ethereum) DockerEnv() []string {
|
|
return nil
|
|
}
|
|
|
|
func (eth *ethereum) DockerBinds() []string {
|
|
return nil
|
|
}
|
|
|
|
func (eth *ethereum) NewClient() *client.Client {
|
|
client, err := client.Dial("ws://" + eth.Host() + ":8545")
|
|
if err != nil {
|
|
return nil
|
|
}
|
|
return client
|
|
}
|
|
|
|
func (eth *ethereum) NodeAddress() string {
|
|
return ""
|
|
}
|
|
|
|
func (eth *ethereum) Address() common.Address {
|
|
return common.Address{}
|
|
}
|
|
|
|
func (eth *ethereum) ConsensusMonitor(errCh chan<- error, quit chan struct{}) {
|
|
|
|
}
|
|
|
|
func (eth *ethereum) WaitForProposed(expectedAddress common.Address, timeout time.Duration) error {
|
|
return nil
|
|
}
|
|
|
|
func (eth *ethereum) WaitForPeersConnected(expectedPeercount int) error {
|
|
return nil
|
|
}
|
|
|
|
func (eth *ethereum) WaitForBlocks(num int, waitingTime ...time.Duration) error {
|
|
return nil
|
|
}
|
|
|
|
func (eth *ethereum) WaitForBlockHeight(num int) error {
|
|
return nil
|
|
}
|
|
|
|
func (eth *ethereum) WaitForNoBlocks(num int, duration time.Duration) error {
|
|
return nil
|
|
}
|
|
|
|
func (eth *ethereum) AddPeer(address string) error {
|
|
return nil
|
|
}
|
|
|
|
func (eth *ethereum) StartMining() error {
|
|
return nil
|
|
}
|
|
|
|
func (eth *ethereum) StopMining() error {
|
|
return nil
|
|
}
|
|
|
|
func (eth *ethereum) Accounts() []accounts.Account {
|
|
return nil
|
|
}
|
|
|
|
// ----------------------------------------------------------------------------
|
|
|
|
func (eth *ethereum) Host() string {
|
|
svc, err := eth.k8sClient.CoreV1().Services(defaultNamespace).Get(eth.chart.Name()+"-0", metav1.GetOptions{})
|
|
if err != nil {
|
|
return ""
|
|
}
|
|
return svc.Spec.LoadBalancerIP
|
|
}
|