common

package
v0.0.0-...-868bdbc Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 8, 2020 License: AGPL-3.0 Imports: 19 Imported by: 0

Documentation

Overview

Used for Herdius Requirements Original Copyright (c) Tendermint Core. https://github.com/tendermint/tendermint/blob/master/LICENSE

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ErrAlreadyStarted is returned when somebody tries to start an already
	// running service.
	ErrAlreadyStarted = errors.New("already started")
	// ErrAlreadyStopped is returned when somebody tries to stop an already
	// stopped service (without resetting it).
	ErrAlreadyStopped = errors.New("already stopped")
	// ErrNotStarted is returned when somebody tries to stop a not running
	// service.
	ErrNotStarted = errors.New("not started")
)

Functions

func CreateRandSalt 

func CreateRandSalt(n int) string

CreateRandSalt - Creates a salt and will be used in creating the keys

func CreateTxID 

func CreateTxID(txbBeforeSign []byte) string

CreateTxID creates an ID for a given encoded transaction

func Exit 

func Exit(s string)

func FileExists 

func FileExists(filePath string) bool

FileExists - ...

func IsEmpty 

func IsEmpty(o interface{}) bool

Returns true if it has zero length.

func IsTypedNil 

func IsTypedNil(o interface{}) bool

Go lacks a simple and safe way to see if something is a typed nil. See:

func MustReadFile 

func MustReadFile(filePath string) []byte

func PanicCrisis 

func PanicCrisis(v interface{})

PanicCrisis ... A panic here means something has gone horribly wrong, in the form of data corruption or failure of the operating system. In a correct/healthy system, these should never fire. If they do, it's indicative of a much more serious problem.

func RandBool 

func RandBool() bool

func RandBytes 

func RandBytes(n int) []byte

func RandFloat32 

func RandFloat32() float32

func RandFloat64 

func RandFloat64() float64

func RandInt 

func RandInt() int

func RandInt16 

func RandInt16() int16

func RandInt31 

func RandInt31() int32

func RandInt31n 

func RandInt31n(n int32) int32

func RandInt32 

func RandInt32() int32

func RandInt63 

func RandInt63() int64

func RandInt63n 

func RandInt63n(n int64) int64

func RandInt64 

func RandInt64() int64

func RandIntn 

func RandIntn(n int) int

func RandPerm 

func RandPerm(n int) []int

func RandStr 

func RandStr(length int) string

func RandTime 

func RandTime() time.Time

func RandUint 

func RandUint() uint

func RandUint16 

func RandUint16() uint16

func RandUint32 

func RandUint32() uint32

func RandUint64 

func RandUint64() uint64

func ReadFile 

func ReadFile(filePath string) ([]byte, error)

func Seed 

func Seed(seed int64)

func WriteFile 

func WriteFile(filePath string, contents []byte, mode os.FileMode) error

Types

type BaseService 

type BaseService struct {
	Logger log.Logger
	// contains filtered or unexported fields
}

Classical-inheritance-style service declarations. Services can be started, then stopped, then optionally restarted.

Users can override the OnStart/OnStop methods. In the absence of errors, these methods are guaranteed to be called at most once. If OnStart returns an error, service won't be marked as started, so the user can call Start again.

A call to Reset will panic, unless OnReset is overwritten, allowing OnStart/OnStop to be called again.

The caller must ensure that Start and Stop are not called concurrently.

It is ok to call Stop without calling Start first.

Typical usage: 

type FooService struct {
	BaseService
	// private fields
}

func NewFooService() *FooService {
	fs := &FooService{
		// init
	}
	fs.BaseService = *NewBaseService(log, "FooService", fs)
	return fs
}

func (fs *FooService) OnStart() error {
	fs.BaseService.OnStart() // Always call the overridden method.
	// initialize private fields
	// start subroutines, etc.
}

func (fs *FooService) OnStop() error {
	fs.BaseService.OnStop() // Always call the overridden method.
	// close/destroy private fields
	// stop subroutines, etc.
}

func NewBaseService 

func NewBaseService(logger log.Logger, name string, impl Service) *BaseService

NewBaseService creates a new BaseService.

func (*BaseService) IsRunning 

func (bs *BaseService) IsRunning() bool

IsRunning implements Service by returning true or false depending on the service's state.

func (*BaseService) OnReset 

func (bs *BaseService) OnReset() error

OnReset implements Service by panicking.

func (*BaseService) OnStart 

func (bs *BaseService) OnStart() error

OnStart implements Service by doing nothing. NOTE: Do not put anything in here, that way users don't need to call BaseService.OnStart()

func (*BaseService) OnStop 

func (bs *BaseService) OnStop()

OnStop implements Service by doing nothing. NOTE: Do not put anything in here, that way users don't need to call BaseService.OnStop()

func (*BaseService) Quit 

func (bs *BaseService) Quit() <-chan struct{}

Quit Implements Service by returning a quit channel.

func (*BaseService) Reset 

func (bs *BaseService) Reset() error

Reset implements Service by calling OnReset callback (if defined). An error will be returned if the service is running.

func (*BaseService) SetLogger 

func (bs *BaseService) SetLogger(l log.Logger)

SetLogger implements Service by setting a logger.

func (*BaseService) Start 

func (bs *BaseService) Start() error

Start implements Service by calling OnStart (if defined). An error will be returned if the service is already running or stopped. Not to start the stopped service, you need to call Reset.

func (*BaseService) Stop 

func (bs *BaseService) Stop() error

Stop implements Service by calling OnStop (if defined) and closing quit channel. An error will be returned if the service is already stopped.

func (*BaseService) String 

func (bs *BaseService) String() string

String implements Servce by returning a string representation of the service.

func (*BaseService) Wait 

func (bs *BaseService) Wait()

Wait blocks until the service is stopped.

type Error 

type Error interface {
	Error() string
	Stacktrace() Error
	Trace(offset int, format string, args ...interface{}) Error
	Data() interface{}
}

Error ...

func NewError 

func NewError(format string, args ...interface{}) Error

New Error with formatted message. The Error's Data will be a FmtError type.

type FmtError 

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

type HexBytes 

type HexBytes []byte

HexBytes : The main purpose of HexBytes is to enable HEX-encoding for json/encoding.

func (HexBytes) Bytes 

func (bz HexBytes) Bytes() []byte

Bytes : Allow it to fulfill various interfaces in light-client, etc...

func (HexBytes) Format 

func (bz HexBytes) Format(s fmt.State, verb rune)

Format : HexBytes format using untyped constant against 32-bit integer values

func (HexBytes) Marshal 

func (bz HexBytes) Marshal() ([]byte, error)

Marshal needed for protobuf compatibility

func (HexBytes) MarshalJSON 

func (bz HexBytes) MarshalJSON() ([]byte, error)

MarshalJSON : This is the point of Bytes.

func (HexBytes) String 

func (bz HexBytes) String() string

func (*HexBytes) Unmarshal 

func (bz *HexBytes) Unmarshal(data []byte) error

Unmarshal needed for protobuf compatibility

func (*HexBytes) UnmarshalJSON 

func (bz *HexBytes) UnmarshalJSON(data []byte) error

UnmarshalJSON : This is the point of Bytes.

type KVPair 

type KVPair struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Define these here for compatibility but use libs/common.KVPair.

func (*KVPair) Descriptor 

func (*KVPair) Descriptor() ([]byte, []int)

func (*KVPair) GetKey 

func (m *KVPair) GetKey() []byte

func (*KVPair) GetValue 

func (m *KVPair) GetValue() []byte

func (*KVPair) ProtoMessage 

func (*KVPair) ProtoMessage()

func (*KVPair) Reset 

func (m *KVPair) Reset()

func (*KVPair) String 

func (m *KVPair) String() string

func (*KVPair) XXX_DiscardUnknown 

func (m *KVPair) XXX_DiscardUnknown()

func (*KVPair) XXX_Marshal 

func (m *KVPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KVPair) XXX_Merge 

func (dst *KVPair) XXX_Merge(src proto.Message)

func (*KVPair) XXX_Size 

func (m *KVPair) XXX_Size() int

func (*KVPair) XXX_Unmarshal 

func (m *KVPair) XXX_Unmarshal(b []byte) error

type KVPairs 

type KVPairs []KVPair

func (KVPairs) Len 

func (kvs KVPairs) Len() int

Sorting

func (KVPairs) Less 

func (kvs KVPairs) Less(i, j int) bool

func (KVPairs) Sort 

func (kvs KVPairs) Sort()

func (KVPairs) Swap 

func (kvs KVPairs) Swap(i, j int)

type Rand 

type Rand struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Rand is a prng, that is seeded with OS randomness. The OS randomness is obtained from crypto/rand, however none of the provided methods are suitable for cryptographic usage. They all utilize math/rand's prng internally.

All of the methods here are suitable for concurrent use. This is achieved by using a mutex lock on all of the provided methods.

func NewRand 

func NewRand() *Rand

func (*Rand) Bool 

func (r *Rand) Bool() bool

Bool returns a uniformly random boolean

func (*Rand) Bytes 

func (r *Rand) Bytes(n int) []byte

Bytes returns n random bytes generated from the internal prng.

func (*Rand) Float32 

func (r *Rand) Float32() float32

func (*Rand) Float64 

func (r *Rand) Float64() float64

func (*Rand) Int 

func (r *Rand) Int() int

func (*Rand) Int16 

func (r *Rand) Int16() int16

func (*Rand) Int31 

func (r *Rand) Int31() int32

func (*Rand) Int31n 

func (r *Rand) Int31n(n int32) int32

func (*Rand) Int32 

func (r *Rand) Int32() int32

func (*Rand) Int63 

func (r *Rand) Int63() int64

func (*Rand) Int63n 

func (r *Rand) Int63n(n int64) int64

func (*Rand) Int64 

func (r *Rand) Int64() int64

func (*Rand) Intn 

func (r *Rand) Intn(n int) int

Intn returns, as an int, a uniform pseudo-random number in the range [0, n). It panics if n <= 0.

func (*Rand) Perm 

func (r *Rand) Perm(n int) []int

Perm returns a pseudo-random permutation of n integers in [0, n).

func (*Rand) Seed 

func (r *Rand) Seed(seed int64)

func (*Rand) Str 

func (r *Rand) Str(length int) string

Str constructs a random alphanumeric string of given length.

func (*Rand) Time 

func (r *Rand) Time() time.Time

func (*Rand) Uint 

func (r *Rand) Uint() uint

func (*Rand) Uint16 

func (r *Rand) Uint16() uint16

func (*Rand) Uint32 

func (r *Rand) Uint32() uint32

func (*Rand) Uint64 

func (r *Rand) Uint64() uint64

type Service 

type Service interface {
	// Start the service.
	// If it's already started or stopped, will return an error.
	// If OnStart() returns an error, it's returned by Start()
	Start() error
	OnStart() error

	// Stop the service.
	// If it's already stopped, will return an error.
	// OnStop must never error.
	Stop() error
	OnStop()

	// Reset the service.
	// Panics by default - must be overwritten to enable reset.
	Reset() error
	OnReset() error

	// Return true if the service is running
	IsRunning() bool

	// Quit returns a channel, which is closed once service is stopped.
	Quit() <-chan struct{}

	// String representation of the service
	String() string

	// SetLogger sets a logger.
	SetLogger(log.Logger)
}

Service defines a service that can be started, stopped, and reset.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.