gaffer

package
v2.0.2 Latest Latest
Warning

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

Go to latest
Published: Apr 26, 2020 License: BSD-2-Clause Imports: 13 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ErrorToString

func ErrorToString(err error) string

func NewMutable

func NewMutable(service rpc.GafferService) rpc.MutableGafferService

func ProtoFromEvent

func ProtoFromEvent(event GafferKernelEvent) *pb.KernelProcessEvent

func ProtoFromExecutablesList

func ProtoFromExecutablesList(executables []string) *pb.KernelExecutableList

func ProtoFromProcess

func ProtoFromProcess(process rpc.GafferProcess) *pb.KernelProcess

func ProtoFromProcessId

func ProtoFromProcessId(id uint32) *pb.ProcessId

func ProtoFromProcessList

func ProtoFromProcessList(process []rpc.GafferProcess) *pb.KernelProcessList

func ProtoFromService

func ProtoFromService(service rpc.GafferService) *pb.Service

func ProtoFromServiceId

func ProtoFromServiceId(sid uint32) *pb.ServiceId

func ProtoFromServiceList

func ProtoFromServiceList(services []rpc.GafferService) *pb.ServiceList

func ProtoFromServiceListOne

func ProtoFromServiceListOne(service rpc.GafferService) *pb.ServiceList

func ProtoToProcess

func ProtoToProcess(pb *pb.KernelProcess) rpc.GafferProcess

func ProtoToService

func ProtoToService(proto *pb.Service) rpc.GafferService

Types

type GafferClient

type GafferClient struct {
	Conn gopi.RPCClientConn
}

func (GafferClient) Name

func (GafferClient) Name() string

func (GafferClient) New

func (config GafferClient) New(log gopi.Logger) (gopi.Unit, error)

type GafferKernelEvent

type GafferKernelEvent interface {
	State() rpc.GafferState
	Process() rpc.GafferProcess
	Buf() []byte
	Error() error
}

type GafferService

type GafferService struct {
	Server gopi.RPCServer
	Gaffer rpc.Gaffer
}

func (GafferService) Name

func (GafferService) Name() string

func (GafferService) New

func (config GafferService) New(log gopi.Logger) (gopi.Unit, error)

type KernelClient

type KernelClient struct {
	Conn gopi.RPCClientConn
}

func (KernelClient) Name

func (KernelClient) Name() string

func (KernelClient) New

func (config KernelClient) New(log gopi.Logger) (gopi.Unit, error)

type KernelService

type KernelService struct {
	Server gopi.RPCServer
	Kernel gaffer.GafferKernel
}

func (KernelService) Name

func (KernelService) Name() string

func (KernelService) New

func (config KernelService) New(log gopi.Logger) (gopi.Unit, error)

Jump to

Keyboard shortcuts

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