ipc

Documentation

Index

• Constants
• func FindDesicionsSocketPath(chain string, baseDir string) string
• func FindSocketPath(chain string, kind string, baseDir string) string
• type Message
• type Socket
  • func Dial(socketPath string) (*Socket, error)
  • func DialTimeout(socketPath string, timeout time.Duration) (*Socket, error)
  • func (sock *Socket) Close() error
  • func (sock *Socket) Start(writer WriterFn) error
• type WriterFn

Constants

const (
	TypeDesicions = "decisions"
	TypeConsensus = "consensus"
)

Functions

func FindDesicionsSocketPath

func FindDesicionsSocketPath(chain string, baseDir string) string

func FindSocketPath

func FindSocketPath(chain string, kind string, baseDir string) string

Types

type Message

type Message struct {
	Data []byte
	Time time.Time
}

type Socket

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

func Dial

func Dial(socketPath string) (*Socket, error)

func DialTimeout

func DialTimeout(socketPath string, timeout time.Duration) (*Socket, error)

func (*Socket) Close

func (sock *Socket) Close() error

func (*Socket) Start

func (sock *Socket) Start(writer WriterFn) error

type WriterFn

type WriterFn func(Message) error