rpc

Jun 5, 2019

Changes in this version

+ func Client(config gopi.AppConfig, timeout time.Duration, task ClientTask) int

+ func FilterBySubtype(services []gopi.RPCServiceRecord, subtype string) []gopi.RPCServiceRecord

+ func HasHostPort(addr string) bool

+ func LookupServiceRecords(app *gopi.AppInstance, addr string, timeout time.Duration) ([]gopi.RPCServiceRecord, error)

+ type ClientTask func(app *gopi.AppInstance, services []gopi.RPCServiceRecord, done chan<- struct{}) error

type ServiceRecord

+ SetHostPort func(addr string) error

May 26, 2019

Changes in this version

+ type Gaffer interface

+ AddGroupForName func(string) (GafferServiceGroup, error)

+ AddServiceForPath func(string) (GafferService, error)

+ GenerateInstanceId func() uint32

+ GetExecutables func(recursive bool) []string

+ GetGroups func() []GafferServiceGroup

+ GetGroupsForNames func([]string) []GafferServiceGroup

+ GetInstanceForId func(id uint32) GafferServiceInstance

+ GetInstances func() []GafferServiceInstance

+ GetServiceForName func(string) GafferService

+ GetServices func() []GafferService

+ RemoveGroupForName func(string) error

+ RemoveServiceForName func(string) error

+ SetGroupEnvForName func(string, Tuples) error

+ SetGroupFlagsForName func(string, Tuples) error

+ SetGroupNameForName func(group string, new string) error

+ SetServiceFlagsForName func(string, Tuples) error

+ SetServiceGroupsForName func(service string, groups []string) error

+ SetServiceInstanceCountForName func(service string, count uint) error

+ SetServiceModeForName func(string, GafferServiceMode) error

+ SetServiceNameForName func(service string, new string) error

+ StartInstanceForServiceName func(service string, id uint32) (GafferServiceInstance, error)

+ StopInstanceForId func(id uint32) error

+ type GafferClient interface

+ AddGroupForName func(string) (GafferServiceGroup, error)

+ AddServiceForPath func(path string, groups []string) (GafferService, error)

+ GetGroup func(string) (GafferServiceGroup, error)

+ GetInstanceId func() (uint32, error)

+ GetService func(string) (GafferService, error)

+ ListExecutables func() ([]string, error)

+ ListGroups func() ([]GafferServiceGroup, error)

+ ListGroupsForService func(string) ([]GafferServiceGroup, error)

+ ListInstances func() ([]GafferServiceInstance, error)

+ ListServices func() ([]GafferService, error)

+ ListServicesForGroup func(string) ([]GafferService, error)

+ Ping func() error

+ RemoveGroupForName func(string) error

+ RemoveServiceForName func(string) error

+ SetEnvForGroup func(string, Tuples) (GafferServiceGroup, error)

+ SetFlagsForGroup func(string, Tuples) (GafferServiceGroup, error)

+ SetFlagsForService func(string, Tuples) (GafferService, error)

+ SetServiceGroups func(string, []string) (GafferService, error)

+ StartInstance func(string, uint32) (GafferServiceInstance, error)

+ StopInstance func(uint32) (GafferServiceInstance, error)

+ StreamEvents func(chan<- GafferEvent) error

+ type GafferEvent interface

+ Data func() []byte

+ Group func() GafferServiceGroup

+ Instance func() GafferServiceInstance

+ Service func() GafferService

+ Type func() GafferEventType

+ type GafferEventType uint

+ const GAFFER_EVENT_GROUP_ADD

+ const GAFFER_EVENT_GROUP_CHANGE

+ const GAFFER_EVENT_GROUP_REMOVE

+ const GAFFER_EVENT_INSTANCE_ADD

+ const GAFFER_EVENT_INSTANCE_RUN

+ const GAFFER_EVENT_INSTANCE_START

+ const GAFFER_EVENT_INSTANCE_STOP_ERROR

+ const GAFFER_EVENT_INSTANCE_STOP_KILLED

+ const GAFFER_EVENT_INSTANCE_STOP_OK

+ const GAFFER_EVENT_LOG_STDERR

+ const GAFFER_EVENT_LOG_STDOUT

+ const GAFFER_EVENT_NONE

+ const GAFFER_EVENT_SERVICE_ADD

+ const GAFFER_EVENT_SERVICE_CHANGE

+ const GAFFER_EVENT_SERVICE_REMOVE

+ func (t GafferEventType) String() string

+ type GafferService interface

+ Flags func() Tuples

+ Groups func() []string

+ IdleTime func() time.Duration

+ InstanceCount func() uint

+ IsMemberOfGroup func(string) bool

+ Mode func() GafferServiceMode

+ Name func() string

+ Path func() string

+ RunTime func() time.Duration

+ type GafferServiceGroup interface

+ Env func() Tuples

+ Flags func() Tuples

+ Name func() string

+ type GafferServiceInstance interface

+ Env func() Tuples

+ ExitCode func() int64

+ Flags func() Tuples

+ Id func() uint32

+ Service func() GafferService

+ Start func() time.Time

+ Stop func() time.Time

+ type GafferServiceMode uint

+ const GAFFER_MODE_AUTO

+ const GAFFER_MODE_MANUAL

+ const GAFFER_MODE_NONE

+ func (m *GafferServiceMode) UnmarshalJSON(data []byte) error

+ func (m GafferServiceMode) MarshalJSON() ([]byte, error)

+ func (m GafferServiceMode) String() string

+ type Tuples struct

+ func (t *Tuples) UnmarshalJSON(data []byte) error

+ func (t Tuples) MarshalJSON() ([]byte, error)

+ func (this *Tuples) ExistsForKey(k string) bool

+ func (this *Tuples) Keys() []string

+ func (this *Tuples) Len() int

+ func (this *Tuples) RemoveAll()

+ func (this *Tuples) SetStringForKey(k, v string) error

+ func (this *Tuples) StringForKey(k string) string

+ func (this Tuples) Copy() Tuples

+ func (this Tuples) Env() []string

+ func (this Tuples) Equals(that Tuples) bool

+ func (this Tuples) Flags() []string

+ func (this Tuples) String() string

May 6, 2019

Changes in this version

+ func MainTask(app *gopi.AppInstance, done chan<- struct{}) error

+ func ProcessEvent(app *gopi.AppInstance, server gopi.RPCServer, ...) error

+ func RegisterTask(app *gopi.AppInstance, start chan<- struct{}, stop <-chan struct{}) error

+ func Server(config gopi.AppConfig, background_tasks ...gopi.BackgroundTask) int

+ func ServerTask(app *gopi.AppInstance, start chan<- struct{}, stop <-chan struct{}) error

+ type GoogleCast interface

+ Devices func() []GoogleCastDevice

+ type GoogleCastClient interface

+ Devices func() ([]GoogleCastDevice, error)

+ Ping func() error

+ StreamEvents func(string, chan<- GoogleCastEvent) error

+ type GoogleCastDevice interface

+ Id func() string

+ Model func() string

+ Name func() string

+ Service func() string

+ State func() uint

+ type GoogleCastEvent interface

+ Device func() GoogleCastDevice

+ Timestamp func() time.Time

+ Type func() gopi.RPCEventType

May 5, 2019

Changes in this version

type ServiceRecord

+ A func(zone string, ttl time.Duration) []*dns.A

+ AAAA func(zone string, ttl time.Duration) []*dns.AAAA

+ PTR func(zone string, ttl time.Duration) *dns.PTR

+ SRV func(zone string, ttl time.Duration) *dns.SRV

type Util

+ Reader func(fh io.Reader) ([]ServiceRecord, error)

+ Writer func(fh io.Writer, records []ServiceRecord, indent bool) error

May 4, 2019

Changes in this version

+ const DISCOVERY_SERVICE_QUERY

+ type DiscoveryClient interface

+ Enumerate func(DiscoveryType, time.Duration) ([]string, error)

+ Lookup func(string, DiscoveryType, time.Duration) ([]gopi.RPCServiceRecord, error)

+ Ping func() error

+ Register func(gopi.RPCServiceRecord) error

+ StreamEvents func(string, chan<- gopi.RPCEvent) error

+ type GreeterClient interface

+ Ping func() error

+ SayHello func(name string) (string, error)

type ServiceRecord

+ AppendIP func(...net.IP) error

+ AppendTXT func(value string) error

+ SetAddr func(addr string) error

+ SetName func(name string) error

+ SetService func(service, subtype string) error

+ SetTTL func(time.Duration) error

+ Source func() DiscoveryType

+ type Util interface

+ NewEvent func(gopi.Driver, gopi.RPCEventType, gopi.RPCServiceRecord) gopi.RPCEvent

+ NewServiceRecord func(source DiscoveryType) ServiceRecord

+ type VersionClient interface

+ Ping func() error

+ Version func() (map[string]string, error)

Apr 28, 2019

Changes in this version

+ type DiscoveryType uint

+ const DISCOVERY_TYPE_DB

+ const DISCOVERY_TYPE_DNS

+ const DISCOVERY_TYPE_NONE

type ServiceRecord

+ Local_ bool

Apr 27, 2019

Changes in this version

+ type Duration struct

+ Duration time.Duration

+ func (this *Duration) MarshalJSON() ([]byte, error)

+ func (this *Duration) UnmarshalJSON(data []byte) error

+ type Event struct

+ func NewEvent(source gopi.Driver, type_ gopi.RPCEventType, service gopi.RPCServiceRecord) *Event

+ func (*Event) Name() string

+ func (this *Event) ServiceRecord() gopi.RPCServiceRecord

+ func (this *Event) Source() gopi.Driver

+ func (this *Event) String() string

+ func (this *Event) Type() gopi.RPCEventType

type ServiceRecord

+ Host_ string

+ Ipv4_ []net.IP

+ Ipv6_ []net.IP

+ Key_ string

+ Name_ string

+ Port_ uint

+ Service_ string

+ Ts_ time.Time

+ Ttl_ *Duration

+ Txt_ []string

+ func NewServiceRecord() *ServiceRecord

+ func NewServiceRecordWithAddr(name, addr string) *ServiceRecord

+ func (this *ServiceRecord) AppendIP4(rr *dns.A)

+ func (this *ServiceRecord) AppendIP6(rr *dns.AAAA)

+ func (this *ServiceRecord) Expired() bool

+ func (this *ServiceRecord) Host() string

+ func (this *ServiceRecord) IP4() []net.IP

+ func (this *ServiceRecord) IP6() []net.IP

+ func (this *ServiceRecord) Key() string

+ func (this *ServiceRecord) SetPTR(zone string, rr *dns.PTR)

+ func (this *ServiceRecord) SetSRV(rr *dns.SRV)

+ func (this *ServiceRecord) SetTXT(rr *dns.TXT)

+ func (this *ServiceRecord) Text() []string

Apr 23, 2019

Changes in this version

+ type Discovery interface

+ EnumerateServiceNames func(ctx context.Context) error

Aug 3, 2018

Changes in this version

+ var MDNS_ADDR_IPV4 = &net.UDPAddr

+ var MDNS_ADDR_IPV6 = &net.UDPAddr

+ func Main(app *gopi.AppInstance, done chan<- struct{}) error

+ type Listener struct

+ Interface *net.Interface

+ func (config Listener) Open(logger gopi.Logger) (gopi.Driver, error)

+ type ServiceRecord struct

+ Hostname string

+ IPv4 []net.IP

+ IPv6 []net.IP

+ Id string

+ Name string

+ Port uint16

+ Service string

+ TTL time.Duration

+ TXT []string

+ Timestamp time.Time

+ func (this *ServiceRecord) String() string