cmd

Documentation

Index

• Constants
• Variables
• func CaptureAndDisplayTogether(r1 io.Reader, r2 io.Reader, offset int, label1 string, label2 string)
• func CaptureAndOutput(r io.Reader)
• func Execute()
• func GetRawProfileFromJwt(jwt string) ([]byte, error)
• func LoadBiomeAddress() error
• func LoadProfile() error
• func PadString(str string, target int) string
• type BuildStatus
• type Config
• type Contracts
• type Node
  • func GetNodes() ([]Node, error)
• type Organization
• type Profile
• type Resources
• type Spinner
  • func (this *Spinner) Kill()
  • func (this *Spinner) Run(ms int)
  • func (this *Spinner) SetText(txt string)
• type SqlQueryRequestPayload
• type WebsocketConnection
  • func (wsc *WebsocketConnection) Close()
  • func (wsc *WebsocketConnection) GetMessage() (message string, err error)
  • func (wsc *WebsocketConnection) PingParams() (interval, timeout time.Duration)
  • func (wsc *WebsocketConnection) WriteMessage(message string) error
• type WebsocketTransport
  • func GetDefaultWebsocketTransport() *WebsocketTransport
  • func (wst *WebsocketTransport) Connect(url string) (conn transport.Connection, err error)
  • func (wst *WebsocketTransport) HandleConnection(w http.ResponseWriter, r *http.Request) (conn transport.Connection, err error)
  • func (wst *WebsocketTransport) Serve(w http.ResponseWriter, r *http.Request)

Constants

const (
	// VERSION is set during build
	VERSION = "DEFAULT_VERSION"
)

Variables

var (
	ErrorMethodNotAllowed = errors.New("Method not allowed")
)

var RootCmd = &cobra.Command{
	Use:     "whiteblock",
	Version: VERSION,
	Short:   "Create and test blockchains",
	Long: `This application will deploy a blockchain, create nodes, and allow those nodes to interact in the network.
	Documentation, usages, and exmaples can be found at https://docs.whiteblock.io/.
	`,
}

Functions

func CaptureAndDisplayTogether

func CaptureAndDisplayTogether(r1 io.Reader, r2 io.Reader, offset int, label1 string, label2 string)

Display the contents of two readers, line by line, together

func CaptureAndOutput

func CaptureAndOutput(r io.Reader)

func Execute

func Execute()

func GetRawProfileFromJwt

func GetRawProfileFromJwt(jwt string) ([]byte, error)

func LoadBiomeAddress

func LoadBiomeAddress() error

func LoadProfile

func LoadProfile() error

func PadString

func PadString(str string, target int) string

Types

type BuildStatus

type BuildStatus struct {
	Error    map[string]string `json:"error"`
	Progress float64           `json:"progress"`
	Stage    string            `json:"stage"`
	Frozen   bool              `json:"frozen"`
}

type Config

type Config struct {
	Servers      []int                  `json:"servers"`
	Blockchain   string                 `json:"blockchain"`
	Nodes        int                    `json:"nodes"`
	Images       []string               `json:"images"`
	Resources    []Resources            `json:"resources"`
	Params       map[string]interface{} `json:"params"`
	Environments []map[string]string    `json:"environments"`
	Files        []map[string]string    `json:"files"`
	Logs         []map[string]string    `json:"logs"`
	Extras       map[string]interface{} `json:"extras"`
}

type Contracts

type Contracts struct {
	DeployedNodeAddress string `json:",omitempty"`
	ContractName        string `json:",omitempty"`
	ContractAddress     string `json:",omitempty"`
}

type Node

type Node struct {
	ID        string `json:"id"`
	TestNetID string `json:"testnetId"`
	Server    int    `json:"server"`
	LocalID   int    `json:"localId"`
	IP        string `json:"ip"`
	Label     string `json:"label"`
}

func GetNodes

func GetNodes() ([]Node, error)

type Organization

type Organization struct {
	Id        int                      `json:"id"`
	Name      string                   `json:"name"`
	CreatedAt string                   `json:"created_at"`
	UpdatedAt string                   `json:"updated_at"`
	Biomes    []map[string]interface{} `json:"biomes"`
}

type Profile

type Profile struct {
	Id           int          `json:"id"`
	Organization Organization `json:"organization"`
}

type Resources

type Resources struct {
	Cpus   string `json:"cpus"`
	Memory string `json:"memory"`
}

type Spinner

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

func (*Spinner) Kill

func (this *Spinner) Kill()

func (*Spinner) Run

func (this *Spinner) Run(ms int)

func (*Spinner) SetText

func (this *Spinner) SetText(txt string)

type SqlQueryRequestPayload

type SqlQueryRequestPayload struct {
	Q string `json:"q"`
}

type WebsocketConnection

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

func (*WebsocketConnection) Close

func (wsc *WebsocketConnection) Close()

func (*WebsocketConnection) GetMessage

func (wsc *WebsocketConnection) GetMessage() (message string, err error)

func (*WebsocketConnection) PingParams

func (wsc *WebsocketConnection) PingParams() (interval, timeout time.Duration)

func (*WebsocketConnection) WriteMessage

func (wsc *WebsocketConnection) WriteMessage(message string) error

type WebsocketTransport

type WebsocketTransport struct {
	PingInterval   time.Duration
	PingTimeout    time.Duration
	ReceiveTimeout time.Duration
	SendTimeout    time.Duration

	BufferSize int

	RequestHeader http.Header
}

func GetDefaultWebsocketTransport

func GetDefaultWebsocketTransport() *WebsocketTransport

* Returns websocket connection with default params

func (*WebsocketTransport) Connect

func (wst *WebsocketTransport) Connect(url string) (conn transport.Connection, err error)

func (*WebsocketTransport) HandleConnection

func (wst *WebsocketTransport) HandleConnection(
	w http.ResponseWriter, r *http.Request) (conn transport.Connection, err error)

func (*WebsocketTransport) Serve

func (wst *WebsocketTransport) Serve(w http.ResponseWriter, r *http.Request)

* Websocket connection do not require any additional processing