maingoroutine

Documentation

Overview

Package maingoroutine 简化[https://github.com/ethereum/go-ethereum]供当前项目使用

Index

• Variables
• type API
• type Config
• type Goroutine
  • func New(config Config) (stack *Goroutine)
  • func (g *Goroutine) AttachRPC(ctx context.Context) *rpc.Client
  • func (g *Goroutine) Close() (errs []error)
  • func (g *Goroutine) RegisterRPC(apis ...API) error
  • func (g *Goroutine) RegisterService(service Service) error
  • func (g *Goroutine) Start() error
  • func (g *Goroutine) Wait()
• type Service

Variables

var (
	ErrGoroutineRunning = fmt.Errorf("main goroutine already running")
	ErrGoroutineClosed  = fmt.Errorf("main goroutine not started")
)

var (
	ErrHttpServerRunning = fmt.Errorf("http server already running")
)

Types

type API

type API struct {
	Namespace string
	Service   interface{}
	Public    bool
}

type Config

type Config struct {
	Logger *zap.Logger

	EnableHTTP    bool
	HTTPHost      string
	HTTPPort      uint16
	EnableHTTPRPC bool
}

type Goroutine

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

func New

func New(config Config) (stack *Goroutine)

func (*Goroutine) AttachRPC

func (g *Goroutine) AttachRPC(ctx context.Context) *rpc.Client

func (*Goroutine) Close

func (g *Goroutine) Close() (errs []error)

func (*Goroutine) RegisterRPC

func (g *Goroutine) RegisterRPC(apis ...API) error

func (*Goroutine) RegisterService

func (g *Goroutine) RegisterService(service Service) error

func (*Goroutine) Start

func (g *Goroutine) Start() error

func (*Goroutine) Wait

func (g *Goroutine) Wait()

type Service

type Service interface {
	Start() error
	Stop() error
}