kronosutil

package

v0.0.0-...-2c42c2a Latest Latest Go to latest Published: May 24, 2021 License: MIT Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/BMWE30/kronos

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AddToURLPath(baseURL url.URL, path string) url.URL
func AddrToURL(addr *kronospb.NodeAddr, secure bool) url.URL
func CloseWithErrorLog(ctx context.Context, o io.Closer)
func NodeAddr(addr string) (*kronospb.NodeAddr, error)
func NodeAddrToString(addr *kronospb.NodeAddr) string
func SSLCreds(certsDir string) (credentials.TransportCredentials, error)
func TLSInfo(certsDir string) transport.TLSInfo
func ValidateTimeInConsensus(ctx context.Context, maxDiffAllowed time.Duration, ...) error
type StoppableListener
- func NewStoppableListener(addr string, stopc <-chan struct{}) (*StoppableListener, error)
- func (ln StoppableListener) Accept() (c net.Conn, err error)

Constants ¶

View Source

const (
	// CACert is the file name for CA certificate
	CACert = "ca.crt"
	// NodeCert is the file name for Node certificate
	NodeCert = "node.crt"
	// NodeKey is the file name for Node Key
	NodeKey = "node.key"
)

Variables ¶

This section is empty.

Functions ¶

func AddToURLPath ¶

func AddToURLPath(baseURL url.URL, path string) url.URL

AddToURLPath resolves baseURL to the given path.

func AddrToURL ¶

func AddrToURL(addr *kronospb.NodeAddr, secure bool) url.URL

AddrToURL converts kronos NodeAddr to http URL

func CloseWithErrorLog ¶

func CloseWithErrorLog(ctx context.Context, o io.Closer)

CloseWithErrorLog closes the given closer and logs the error. There are lint checks which prevent defer close() if close() returns an error, this closer is useful in such cases.

func NodeAddr ¶

func NodeAddr(addr string) (*kronospb.NodeAddr, error)

NodeAddr converts address in host:port format to NodeAddr.

func NodeAddrToString ¶

func NodeAddrToString(addr *kronospb.NodeAddr) string

NodeAddrToString joins host and port and returns the address in the form of "127.0.0.1:5766"

func SSLCreds ¶

func SSLCreds(certsDir string) (credentials.TransportCredentials, error)

SSLCreds returns credentials by reading keys and certificates from certsDir

func TLSInfo ¶

func TLSInfo(certsDir string) transport.TLSInfo

TLSInfo returns the tlsInfo with certificates in the certsDir. if certsDir is empty, it returns empty tlsInfo.

func ValidateTimeInConsensus ¶

func ValidateTimeInConsensus(
	ctx context.Context, maxDiffAllowed time.Duration, timeOnNodes map[string]int64,
) error

ValidateTimeInConsensus validates that the kronos time across the given nodes (difference between maxTime and minTime) is within maxDiffAllowed.

Types ¶

type StoppableListener ¶

type StoppableListener struct {
	*net.TCPListener
	// contains filtered or unexported fields
}

StoppableListener sets TCP keep-alive timeouts on accepted connections. It stops listening when stopC is closed.

func NewStoppableListener ¶

func NewStoppableListener(addr string, stopc <-chan struct{}) (*StoppableListener, error)

NewStoppableListener returns an instance of StoppableListener

func (StoppableListener) Accept ¶

func (ln StoppableListener) Accept() (c net.Conn, err error)

Accept listens to and accepts TCP connections It returns the connection accepted

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
log

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL