plantd

package
v0.2.5 Latest Latest
Warning

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

 Go to latest Published: Sep 8, 2021 License: MIT Imports: 5 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Channel_Type_name = map[int32]string{
	0: "SOURCE",
	1: "SINK",
}
View Source 
var Channel_Type_value = map[string]int32{
	"SOURCE": 0,
	"SINK":   1,
}
View Source 
var Configuration_Namespace_name = map[int32]string{
	0: "ACQUIRE",
	1: "ANALYZE",
	2: "CONTROL",
	3: "EXPERIMENT",
	4: "MONITOR",
	5: "PRESENT",
	6: "RECORD",
	7: "STATE",
	8: "RECIPE",
}
View Source 
var Configuration_Namespace_value = map[string]int32{
	"ACQUIRE":    0,
	"ANALYZE":    1,
	"CONTROL":    2,
	"EXPERIMENT": 3,
	"MONITOR":    4,
	"PRESENT":    5,
	"RECORD":     6,
	"STATE":      7,
	"RECIPE":     8,
}
View Source 
var Job_Status_name = map[int32]string{
	0: "SUBMITTED",
	1: "READY",
	2: "STARTED",
	3: "RUNNING",
	4: "PAUSED",
	5: "RESUMED",
	6: "STOPPED",
	7: "FAILED",
	8: "CANCELLED",
}
View Source 
var Job_Status_value = map[string]int32{
	"SUBMITTED": 0,
	"READY":     1,
	"STARTED":   2,
	"RUNNING":   3,
	"PAUSED":    4,
	"RESUMED":   5,
	"STOPPED":   6,
	"FAILED":    7,
	"CANCELLED": 8,
}
View Source 
var Service_Type_name = map[int32]string{
	0: "ACQUIRE",
	1: "ANALYZE",
	2: "CONTROL",
	3: "EXPERIMENT",
	4: "MONITOR",
	5: "PRESENT",
	6: "RECORD",
	7: "STATE",
}
View Source 
var Service_Type_value = map[string]int32{
	"ACQUIRE":    0,
	"ANALYZE":    1,
	"CONTROL":    2,
	"EXPERIMENT": 3,
	"MONITOR":    4,
	"PRESENT":    5,
	"RECORD":     6,
	"STATE":      7,
}

Functions

func RegisterConfigureEndpointServer 

func RegisterConfigureEndpointServer(s *grpc.Server, srv ConfigureEndpointServer)

func RegisterEndpointServer 

func RegisterEndpointServer(s *grpc.Server, srv EndpointServer)

Types

type Bus 

type Bus struct {
	Endpoint             string     `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Sinks                []*Channel `protobuf:"bytes,2,rep,name=sinks,proto3" json:"sinks,omitempty"`
	Sources              []*Channel `protobuf:"bytes,3,rep,name=sources,proto3" json:"sources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

* TODO: document message

func (*Bus) Descriptor 

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

func (*Bus) GetEndpoint 

func (m *Bus) GetEndpoint() string

func (*Bus) GetSinks 

func (m *Bus) GetSinks() []*Channel

func (*Bus) GetSources 

func (m *Bus) GetSources() []*Channel

func (*Bus) ProtoMessage 

func (*Bus) ProtoMessage()

func (*Bus) Reset 

func (m *Bus) Reset()

func (*Bus) String 

func (m *Bus) String() string

func (*Bus) XXX_DiscardUnknown 

func (m *Bus) XXX_DiscardUnknown()

func (*Bus) XXX_Marshal 

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

func (*Bus) XXX_Merge 

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

func (*Bus) XXX_Size 

func (m *Bus) XXX_Size() int

func (*Bus) XXX_Unmarshal 

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

type Channel 

type Channel struct {
	Type                 Channel_Type `protobuf:"varint,1,opt,name=type,proto3,enum=plantd.Channel_Type" json:"type,omitempty"`
	Endpoint             string       `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Envelope             string       `protobuf:"bytes,3,opt,name=envelope,proto3" json:"envelope,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

* TODO: document message

func (*Channel) Descriptor 

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

func (*Channel) GetEndpoint 

func (m *Channel) GetEndpoint() string

func (*Channel) GetEnvelope 

func (m *Channel) GetEnvelope() string

func (*Channel) GetType 

func (m *Channel) GetType() Channel_Type

func (*Channel) ProtoMessage 

func (*Channel) ProtoMessage()

func (*Channel) Reset 

func (m *Channel) Reset()

func (*Channel) String 

func (m *Channel) String() string

func (*Channel) XXX_DiscardUnknown 

func (m *Channel) XXX_DiscardUnknown()

func (*Channel) XXX_Marshal 

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

func (*Channel) XXX_Merge 

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

func (*Channel) XXX_Size 

func (m *Channel) XXX_Size() int

func (*Channel) XXX_Unmarshal 

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

type ChannelRequest 

type ChannelRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*ChannelRequest) Descriptor 

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

func (*ChannelRequest) GetId 

func (m *ChannelRequest) GetId() string

func (*ChannelRequest) ProtoMessage 

func (*ChannelRequest) ProtoMessage()

func (*ChannelRequest) Reset 

func (m *ChannelRequest) Reset()

func (*ChannelRequest) String 

func (m *ChannelRequest) String() string

func (*ChannelRequest) XXX_DiscardUnknown 

func (m *ChannelRequest) XXX_DiscardUnknown()

func (*ChannelRequest) XXX_Marshal 

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

func (*ChannelRequest) XXX_Merge 

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

func (*ChannelRequest) XXX_Size 

func (m *ChannelRequest) XXX_Size() int

func (*ChannelRequest) XXX_Unmarshal 

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

type ChannelResponse 

type ChannelResponse struct {
	Channel              *Channel `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*ChannelResponse) Descriptor 

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

func (*ChannelResponse) GetChannel 

func (m *ChannelResponse) GetChannel() *Channel

func (*ChannelResponse) ProtoMessage 

func (*ChannelResponse) ProtoMessage()

func (*ChannelResponse) Reset 

func (m *ChannelResponse) Reset()

func (*ChannelResponse) String 

func (m *ChannelResponse) String() string

func (*ChannelResponse) XXX_DiscardUnknown 

func (m *ChannelResponse) XXX_DiscardUnknown()

func (*ChannelResponse) XXX_Marshal 

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

func (*ChannelResponse) XXX_Merge 

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

func (*ChannelResponse) XXX_Size 

func (m *ChannelResponse) XXX_Size() int

func (*ChannelResponse) XXX_Unmarshal 

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

type Channel_Type 

type Channel_Type int32

/ FIXME: type is the wrong word here, too much glib conflict 

const (
	Channel_SOURCE Channel_Type = 0
	Channel_SINK   Channel_Type = 1
)

func (Channel_Type) EnumDescriptor 

func (Channel_Type) EnumDescriptor() ([]byte, []int)

func (Channel_Type) String 

func (x Channel_Type) String() string

type ChannelsResponse 

type ChannelsResponse struct {
	Channels             []*Channel `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

* TODO: document message

func (*ChannelsResponse) Descriptor 

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

func (*ChannelsResponse) GetChannels 

func (m *ChannelsResponse) GetChannels() []*Channel

func (*ChannelsResponse) ProtoMessage 

func (*ChannelsResponse) ProtoMessage()

func (*ChannelsResponse) Reset 

func (m *ChannelsResponse) Reset()

func (*ChannelsResponse) String 

func (m *ChannelsResponse) String() string

func (*ChannelsResponse) XXX_DiscardUnknown 

func (m *ChannelsResponse) XXX_DiscardUnknown()

func (*ChannelsResponse) XXX_Marshal 

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

func (*ChannelsResponse) XXX_Merge 

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

func (*ChannelsResponse) XXX_Size 

func (m *ChannelsResponse) XXX_Size() int

func (*ChannelsResponse) XXX_Unmarshal 

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

type Configuration 

type Configuration struct {
	Id                   string                  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Namespace            Configuration_Namespace `protobuf:"varint,2,opt,name=namespace,proto3,enum=plantd.Configuration_Namespace" json:"namespace,omitempty"`
	Name                 string                  `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Properties           []*Property             `protobuf:"bytes,4,rep,name=properties,proto3" json:"properties,omitempty"`
	Objects              []*Object               `protobuf:"bytes,5,rep,name=objects,proto3" json:"objects,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

* TODO: document message

func (*Configuration) Descriptor 

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

func (*Configuration) GetId 

func (m *Configuration) GetId() string

func (*Configuration) GetName 

func (m *Configuration) GetName() string

func (*Configuration) GetNamespace 

func (m *Configuration) GetNamespace() Configuration_Namespace

func (*Configuration) GetObjects 

func (m *Configuration) GetObjects() []*Object

func (*Configuration) GetProperties 

func (m *Configuration) GetProperties() []*Property

func (*Configuration) ProtoMessage 

func (*Configuration) ProtoMessage()

func (*Configuration) Reset 

func (m *Configuration) Reset()

func (*Configuration) String 

func (m *Configuration) String() string

func (*Configuration) XXX_DiscardUnknown 

func (m *Configuration) XXX_DiscardUnknown()

func (*Configuration) XXX_Marshal 

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

func (*Configuration) XXX_Merge 

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

func (*Configuration) XXX_Size 

func (m *Configuration) XXX_Size() int

func (*Configuration) XXX_Unmarshal 

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

type ConfigurationRequest 

type ConfigurationRequest struct {
	Id                   string                  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Namespace            Configuration_Namespace `protobuf:"varint,2,opt,name=namespace,proto3,enum=plantd.Configuration_Namespace" json:"namespace,omitempty"`
	Configuration        *Configuration          `protobuf:"bytes,3,opt,name=configuration,proto3" json:"configuration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

* Used to request a configuration by ID

func (*ConfigurationRequest) Descriptor 

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

func (*ConfigurationRequest) GetConfiguration 

func (m *ConfigurationRequest) GetConfiguration() *Configuration

func (*ConfigurationRequest) GetId 

func (m *ConfigurationRequest) GetId() string

func (*ConfigurationRequest) GetNamespace 

func (m *ConfigurationRequest) GetNamespace() Configuration_Namespace

func (*ConfigurationRequest) ProtoMessage 

func (*ConfigurationRequest) ProtoMessage()

func (*ConfigurationRequest) Reset 

func (m *ConfigurationRequest) Reset()

func (*ConfigurationRequest) String 

func (m *ConfigurationRequest) String() string

func (*ConfigurationRequest) XXX_DiscardUnknown 

func (m *ConfigurationRequest) XXX_DiscardUnknown()

func (*ConfigurationRequest) XXX_Marshal 

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

func (*ConfigurationRequest) XXX_Merge 

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

func (*ConfigurationRequest) XXX_Size 

func (m *ConfigurationRequest) XXX_Size() int

func (*ConfigurationRequest) XXX_Unmarshal 

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

type ConfigurationResponse 

type ConfigurationResponse struct {
	Configuration        *Configuration `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

* Contains the configuration data requested

func (*ConfigurationResponse) Descriptor 

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

func (*ConfigurationResponse) GetConfiguration 

func (m *ConfigurationResponse) GetConfiguration() *Configuration

func (*ConfigurationResponse) ProtoMessage 

func (*ConfigurationResponse) ProtoMessage()

func (*ConfigurationResponse) Reset 

func (m *ConfigurationResponse) Reset()

func (*ConfigurationResponse) String 

func (m *ConfigurationResponse) String() string

func (*ConfigurationResponse) XXX_DiscardUnknown 

func (m *ConfigurationResponse) XXX_DiscardUnknown()

func (*ConfigurationResponse) XXX_Marshal 

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

func (*ConfigurationResponse) XXX_Merge 

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

func (*ConfigurationResponse) XXX_Size 

func (m *ConfigurationResponse) XXX_Size() int

func (*ConfigurationResponse) XXX_Unmarshal 

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

type Configuration_Namespace 

type Configuration_Namespace int32
const (
	Configuration_ACQUIRE    Configuration_Namespace = 0
	Configuration_ANALYZE    Configuration_Namespace = 1
	Configuration_CONTROL    Configuration_Namespace = 2
	Configuration_EXPERIMENT Configuration_Namespace = 3
	Configuration_MONITOR    Configuration_Namespace = 4
	Configuration_PRESENT    Configuration_Namespace = 5
	Configuration_RECORD     Configuration_Namespace = 6
	Configuration_STATE      Configuration_Namespace = 7
	Configuration_RECIPE     Configuration_Namespace = 8
)

func (Configuration_Namespace) EnumDescriptor 

func (Configuration_Namespace) EnumDescriptor() ([]byte, []int)

func (Configuration_Namespace) String 

func (x Configuration_Namespace) String() string

type ConfigurationsResponse 

type ConfigurationsResponse struct {
	Configurations       []*Configuration `protobuf:"bytes,1,rep,name=configurations,proto3" json:"configurations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

* TODO: document message

func (*ConfigurationsResponse) Descriptor 

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

func (*ConfigurationsResponse) GetConfigurations 

func (m *ConfigurationsResponse) GetConfigurations() []*Configuration

func (*ConfigurationsResponse) ProtoMessage 

func (*ConfigurationsResponse) ProtoMessage()

func (*ConfigurationsResponse) Reset 

func (m *ConfigurationsResponse) Reset()

func (*ConfigurationsResponse) String 

func (m *ConfigurationsResponse) String() string

func (*ConfigurationsResponse) XXX_DiscardUnknown 

func (m *ConfigurationsResponse) XXX_DiscardUnknown()

func (*ConfigurationsResponse) XXX_Marshal 

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

func (*ConfigurationsResponse) XXX_Merge 

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

func (*ConfigurationsResponse) XXX_Size 

func (m *ConfigurationsResponse) XXX_Size() int

func (*ConfigurationsResponse) XXX_Unmarshal 

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

type ConfigureEndpointClient 

type ConfigureEndpointClient interface {
	// List all configurations for a single namespace
	List(ctx context.Context, in *ConfigurationRequest, opts ...grpc.CallOption) (*ConfigurationsResponse, error)
	// List all configurations
	ListAll(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ConfigurationsResponse, error)
	Create(ctx context.Context, in *ConfigurationRequest, opts ...grpc.CallOption) (*ConfigurationResponse, error)
	Read(ctx context.Context, in *ConfigurationRequest, opts ...grpc.CallOption) (*ConfigurationResponse, error)
	Update(ctx context.Context, in *ConfigurationRequest, opts ...grpc.CallOption) (*ConfigurationResponse, error)
	Delete(ctx context.Context, in *ConfigurationRequest, opts ...grpc.CallOption) (*ConfigurationResponse, error)
}

ConfigureEndpointClient is the client API for ConfigureEndpoint service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewConfigureEndpointClient 

func NewConfigureEndpointClient(cc *grpc.ClientConn) ConfigureEndpointClient

type ConfigureEndpointServer 

type ConfigureEndpointServer interface {
	// List all configurations for a single namespace
	List(context.Context, *ConfigurationRequest) (*ConfigurationsResponse, error)
	// List all configurations
	ListAll(context.Context, *Empty) (*ConfigurationsResponse, error)
	Create(context.Context, *ConfigurationRequest) (*ConfigurationResponse, error)
	Read(context.Context, *ConfigurationRequest) (*ConfigurationResponse, error)
	Update(context.Context, *ConfigurationRequest) (*ConfigurationResponse, error)
	Delete(context.Context, *ConfigurationRequest) (*ConfigurationResponse, error)
}

ConfigureEndpointServer is the server API for ConfigureEndpoint service.

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* An empty message for when no input is needed in an RPC

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type EndpointClient 

type EndpointClient interface {
	// / Get the configuration currently loaded by the service
	GetConfiguration(ctx context.Context, in *ConfigurationRequest, opts ...grpc.CallOption) (*ConfigurationResponse, error)
	// / TODO: differentiate "get unit configuration" and "get configuration"
	GetUnitConfiguration(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ConfigurationResponse, error)
	// / Get the status of the service
	GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	// / Get the service settings
	GetSettings(ctx context.Context, in *SettingsRequest, opts ...grpc.CallOption) (*SettingsResponse, error)
	// / XXX: evaluate
	GetChannel(ctx context.Context, in *ChannelRequest, opts ...grpc.CallOption) (*ChannelResponse, error)
	// / XXX: evaluate
	GetChannels(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ChannelsResponse, error)
	// / TODO: implement
	GetJob(ctx context.Context, in *JobRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / Request all jobs running or queued on a service
	GetJobs(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*JobsResponse, error)
	// /
	GetJobStatus(ctx context.Context, in *JobRequest, opts ...grpc.CallOption) (*JobStatusResponse, error)
	// / List module loaded by the service
	GetModule(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*ModuleResponse, error)
	// / List all modules seen by the service
	GetModules(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ModulesResponse, error)
	// / XXX: evaluate
	TryModuleConnect(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / XXX: evaluate
	TryModuleDisconnect(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / XXX: evaluate
	TryModuleLoad(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / XXX: evaluate
	TryModuleUnload(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / XXX: evaluate
	TryModuleReload(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / XXX: evaluate
	TryModuleEnable(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / XXX: evaluate
	TryModuleDisable(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / Request the configuration currently loaded by a module
	GetModuleConfiguration(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*ConfigurationResponse, error)
	// / Request a module status
	GetModuleStatus(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	// / Request the settings held by a module
	GetModuleSettings(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*SettingsResponse, error)
	// / Request a job running or queued on a module by ID
	GetModuleJob(ctx context.Context, in *ModuleJobRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / Request all jobs running or queued on a module
	GetModuleJobs(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobsResponse, error)
	// / Request the currently running job on a service
	GetModuleActiveJob(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / Cancel a job running or queued on a module
	ModuleCancelJob(ctx context.Context, in *ModuleJobRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / Submit a new job to a module
	ModuleSubmitJob(ctx context.Context, in *ModuleJobRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / Submit a new event to a module
	ModuleSubmitEvent(ctx context.Context, in *ModuleEventRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / List all events a module can respond to
	ModuleAvailableEvents(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*EventsResponse, error)
	// / Request a single property from a module
	GetModuleProperty(ctx context.Context, in *PropertyRequest, opts ...grpc.CallOption) (*PropertyResponse, error)
	// / Submit a change for a single property of a module
	SetModuleProperty(ctx context.Context, in *PropertyRequest, opts ...grpc.CallOption) (*PropertyResponse, error)
	// / Request a list of properties from a module
	GetModuleProperties(ctx context.Context, in *PropertiesRequest, opts ...grpc.CallOption) (*PropertiesResponse, error)
	// / Submit a change for multiple properties of a module
	SetModuleProperties(ctx context.Context, in *PropertiesRequest, opts ...grpc.CallOption) (*PropertiesResponse, error)
}

EndpointClient is the client API for Endpoint service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEndpointClient 

func NewEndpointClient(cc *grpc.ClientConn) EndpointClient

type EndpointServer 

type EndpointServer interface {
	// / Get the configuration currently loaded by the service
	GetConfiguration(context.Context, *ConfigurationRequest) (*ConfigurationResponse, error)
	// / TODO: differentiate "get unit configuration" and "get configuration"
	GetUnitConfiguration(context.Context, *Empty) (*ConfigurationResponse, error)
	// / Get the status of the service
	GetStatus(context.Context, *StatusRequest) (*StatusResponse, error)
	// / Get the service settings
	GetSettings(context.Context, *SettingsRequest) (*SettingsResponse, error)
	// / XXX: evaluate
	GetChannel(context.Context, *ChannelRequest) (*ChannelResponse, error)
	// / XXX: evaluate
	GetChannels(context.Context, *Empty) (*ChannelsResponse, error)
	// / TODO: implement
	GetJob(context.Context, *JobRequest) (*JobResponse, error)
	// / Request all jobs running or queued on a service
	GetJobs(context.Context, *Empty) (*JobsResponse, error)
	// /
	GetJobStatus(context.Context, *JobRequest) (*JobStatusResponse, error)
	// / List module loaded by the service
	GetModule(context.Context, *ModuleRequest) (*ModuleResponse, error)
	// / List all modules seen by the service
	GetModules(context.Context, *Empty) (*ModulesResponse, error)
	// / XXX: evaluate
	TryModuleConnect(context.Context, *ModuleRequest) (*JobResponse, error)
	// / XXX: evaluate
	TryModuleDisconnect(context.Context, *ModuleRequest) (*JobResponse, error)
	// / XXX: evaluate
	TryModuleLoad(context.Context, *ModuleRequest) (*JobResponse, error)
	// / XXX: evaluate
	TryModuleUnload(context.Context, *ModuleRequest) (*JobResponse, error)
	// / XXX: evaluate
	TryModuleReload(context.Context, *ModuleRequest) (*JobResponse, error)
	// / XXX: evaluate
	TryModuleEnable(context.Context, *ModuleRequest) (*JobResponse, error)
	// / XXX: evaluate
	TryModuleDisable(context.Context, *ModuleRequest) (*JobResponse, error)
	// / Request the configuration currently loaded by a module
	GetModuleConfiguration(context.Context, *ModuleRequest) (*ConfigurationResponse, error)
	// / Request a module status
	GetModuleStatus(context.Context, *ModuleRequest) (*StatusResponse, error)
	// / Request the settings held by a module
	GetModuleSettings(context.Context, *ModuleRequest) (*SettingsResponse, error)
	// / Request a job running or queued on a module by ID
	GetModuleJob(context.Context, *ModuleJobRequest) (*JobResponse, error)
	// / Request all jobs running or queued on a module
	GetModuleJobs(context.Context, *ModuleRequest) (*JobsResponse, error)
	// / Request the currently running job on a service
	GetModuleActiveJob(context.Context, *ModuleRequest) (*JobResponse, error)
	// / Cancel a job running or queued on a module
	ModuleCancelJob(context.Context, *ModuleJobRequest) (*JobResponse, error)
	// / Submit a new job to a module
	ModuleSubmitJob(context.Context, *ModuleJobRequest) (*JobResponse, error)
	// / Submit a new event to a module
	ModuleSubmitEvent(context.Context, *ModuleEventRequest) (*JobResponse, error)
	// / List all events a module can respond to
	ModuleAvailableEvents(context.Context, *ModuleRequest) (*EventsResponse, error)
	// / Request a single property from a module
	GetModuleProperty(context.Context, *PropertyRequest) (*PropertyResponse, error)
	// / Submit a change for a single property of a module
	SetModuleProperty(context.Context, *PropertyRequest) (*PropertyResponse, error)
	// / Request a list of properties from a module
	GetModuleProperties(context.Context, *PropertiesRequest) (*PropertiesResponse, error)
	// / Submit a change for multiple properties of a module
	SetModuleProperties(context.Context, *PropertiesRequest) (*PropertiesResponse, error)
}

EndpointServer is the server API for Endpoint service.

type Error 

type Error struct {
	Code                 int32    `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*Error) Descriptor 

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

func (*Error) GetCode 

func (m *Error) GetCode() int32

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type Event 

type Event struct {
	Id                   int32    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description          string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*Event) Descriptor 

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

func (*Event) GetDescription 

func (m *Event) GetDescription() string

func (*Event) GetId 

func (m *Event) GetId() int32

func (*Event) GetName 

func (m *Event) GetName() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type EventRequest 

type EventRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	EventId              int32    `protobuf:"varint,2,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*EventRequest) Descriptor 

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

func (*EventRequest) GetEventId 

func (m *EventRequest) GetEventId() int32

func (*EventRequest) GetId 

func (m *EventRequest) GetId() string

func (*EventRequest) ProtoMessage 

func (*EventRequest) ProtoMessage()

func (*EventRequest) Reset 

func (m *EventRequest) Reset()

func (*EventRequest) String 

func (m *EventRequest) String() string

func (*EventRequest) XXX_DiscardUnknown 

func (m *EventRequest) XXX_DiscardUnknown()

func (*EventRequest) XXX_Marshal 

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

func (*EventRequest) XXX_Merge 

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

func (*EventRequest) XXX_Size 

func (m *EventRequest) XXX_Size() int

func (*EventRequest) XXX_Unmarshal 

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

type EventsResponse 

type EventsResponse struct {
	Events               []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*EventsResponse) Descriptor 

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

func (*EventsResponse) GetEvents 

func (m *EventsResponse) GetEvents() []*Event

func (*EventsResponse) ProtoMessage 

func (*EventsResponse) ProtoMessage()

func (*EventsResponse) Reset 

func (m *EventsResponse) Reset()

func (*EventsResponse) String 

func (m *EventsResponse) String() string

func (*EventsResponse) XXX_DiscardUnknown 

func (m *EventsResponse) XXX_DiscardUnknown()

func (*EventsResponse) XXX_Marshal 

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

func (*EventsResponse) XXX_Merge 

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

func (*EventsResponse) XXX_Size 

func (m *EventsResponse) XXX_Size() int

func (*EventsResponse) XXX_Unmarshal 

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

type Job 

type Job struct {
	Id                   string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Priority             int32       `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	Status               Job_Status  `protobuf:"varint,3,opt,name=status,proto3,enum=plantd.Job_Status" json:"status,omitempty"`
	Properties           []*Property `protobuf:"bytes,4,rep,name=properties,proto3" json:"properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

* TODO: document message

func (*Job) Descriptor 

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

func (*Job) GetId 

func (m *Job) GetId() string

func (*Job) GetPriority 

func (m *Job) GetPriority() int32

func (*Job) GetProperties 

func (m *Job) GetProperties() []*Property

func (*Job) GetStatus 

func (m *Job) GetStatus() Job_Status

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) String 

func (m *Job) String() string

func (*Job) XXX_DiscardUnknown 

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal 

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

func (*Job) XXX_Merge 

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

func (*Job) XXX_Size 

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal 

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

type JobRequest 

type JobRequest struct {
	Id                   string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	JobId                string      `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	JobValue             string      `protobuf:"bytes,3,opt,name=job_value,json=jobValue,proto3" json:"job_value,omitempty"`
	JobProperties        []*Property `protobuf:"bytes,4,rep,name=job_properties,json=jobProperties,proto3" json:"job_properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

* TODO: document message

func (*JobRequest) Descriptor 

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

func (*JobRequest) GetId 

func (m *JobRequest) GetId() string

func (*JobRequest) GetJobId 

func (m *JobRequest) GetJobId() string

func (*JobRequest) GetJobProperties 

func (m *JobRequest) GetJobProperties() []*Property

func (*JobRequest) GetJobValue 

func (m *JobRequest) GetJobValue() string

func (*JobRequest) ProtoMessage 

func (*JobRequest) ProtoMessage()

func (*JobRequest) Reset 

func (m *JobRequest) Reset()

func (*JobRequest) String 

func (m *JobRequest) String() string

func (*JobRequest) XXX_DiscardUnknown 

func (m *JobRequest) XXX_DiscardUnknown()

func (*JobRequest) XXX_Marshal 

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

func (*JobRequest) XXX_Merge 

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

func (*JobRequest) XXX_Size 

func (m *JobRequest) XXX_Size() int

func (*JobRequest) XXX_Unmarshal 

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

type JobResponse 

type JobResponse struct {
	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*JobResponse) Descriptor 

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

func (*JobResponse) GetJob 

func (m *JobResponse) GetJob() *Job

func (*JobResponse) ProtoMessage 

func (*JobResponse) ProtoMessage()

func (*JobResponse) Reset 

func (m *JobResponse) Reset()

func (*JobResponse) String 

func (m *JobResponse) String() string

func (*JobResponse) XXX_DiscardUnknown 

func (m *JobResponse) XXX_DiscardUnknown()

func (*JobResponse) XXX_Marshal 

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

func (*JobResponse) XXX_Merge 

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

func (*JobResponse) XXX_Size 

func (m *JobResponse) XXX_Size() int

func (*JobResponse) XXX_Unmarshal 

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

type JobStatusResponse 

type JobStatusResponse struct {
	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*JobStatusResponse) Descriptor 

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

func (*JobStatusResponse) GetJob 

func (m *JobStatusResponse) GetJob() *Job

func (*JobStatusResponse) ProtoMessage 

func (*JobStatusResponse) ProtoMessage()

func (*JobStatusResponse) Reset 

func (m *JobStatusResponse) Reset()

func (*JobStatusResponse) String 

func (m *JobStatusResponse) String() string

func (*JobStatusResponse) XXX_DiscardUnknown 

func (m *JobStatusResponse) XXX_DiscardUnknown()

func (*JobStatusResponse) XXX_Marshal 

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

func (*JobStatusResponse) XXX_Merge 

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

func (*JobStatusResponse) XXX_Size 

func (m *JobStatusResponse) XXX_Size() int

func (*JobStatusResponse) XXX_Unmarshal 

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

type Job_Status 

type Job_Status int32
const (
	Job_SUBMITTED Job_Status = 0
	Job_READY     Job_Status = 1
	Job_STARTED   Job_Status = 2
	Job_RUNNING   Job_Status = 3
	Job_PAUSED    Job_Status = 4
	Job_RESUMED   Job_Status = 5
	Job_STOPPED   Job_Status = 6
	Job_FAILED    Job_Status = 7
	Job_CANCELLED Job_Status = 8
)

func (Job_Status) EnumDescriptor 

func (Job_Status) EnumDescriptor() ([]byte, []int)

func (Job_Status) String 

func (x Job_Status) String() string

type JobsResponse 

type JobsResponse struct {
	Jobs                 []*Job   `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*JobsResponse) Descriptor 

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

func (*JobsResponse) GetJobs 

func (m *JobsResponse) GetJobs() []*Job

func (*JobsResponse) ProtoMessage 

func (*JobsResponse) ProtoMessage()

func (*JobsResponse) Reset 

func (m *JobsResponse) Reset()

func (*JobsResponse) String 

func (m *JobsResponse) String() string

func (*JobsResponse) XXX_DiscardUnknown 

func (m *JobsResponse) XXX_DiscardUnknown()

func (*JobsResponse) XXX_Marshal 

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

func (*JobsResponse) XXX_Merge 

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

func (*JobsResponse) XXX_Size 

func (m *JobsResponse) XXX_Size() int

func (*JobsResponse) XXX_Unmarshal 

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

type Module 

type Module struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	ServiceName          string   `protobuf:"bytes,3,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	ConfigurationId      string   `protobuf:"bytes,4,opt,name=configuration_id,json=configurationId,proto3" json:"configuration_id,omitempty"`
	Status               *Status  `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	State                *State   `protobuf:"bytes,6,opt,name=state,proto3" json:"state,omitempty"`
	Services             []string `protobuf:"bytes,7,rep,name=services,proto3" json:"services,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*Module) Descriptor 

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

func (*Module) GetConfigurationId 

func (m *Module) GetConfigurationId() string

func (*Module) GetId 

func (m *Module) GetId() string

func (*Module) GetName 

func (m *Module) GetName() string

func (*Module) GetServiceName 

func (m *Module) GetServiceName() string

func (*Module) GetServices 

func (m *Module) GetServices() []string

func (*Module) GetState 

func (m *Module) GetState() *State

func (*Module) GetStatus 

func (m *Module) GetStatus() *Status

func (*Module) ProtoMessage 

func (*Module) ProtoMessage()

func (*Module) Reset 

func (m *Module) Reset()

func (*Module) String 

func (m *Module) String() string

func (*Module) XXX_DiscardUnknown 

func (m *Module) XXX_DiscardUnknown()

func (*Module) XXX_Marshal 

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

func (*Module) XXX_Merge 

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

func (*Module) XXX_Size 

func (m *Module) XXX_Size() int

func (*Module) XXX_Unmarshal 

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

type ModuleEventRequest 

type ModuleEventRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	EventId              int32    `protobuf:"varint,2,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*ModuleEventRequest) Descriptor 

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

func (*ModuleEventRequest) GetEventId 

func (m *ModuleEventRequest) GetEventId() int32

func (*ModuleEventRequest) GetId 

func (m *ModuleEventRequest) GetId() string

func (*ModuleEventRequest) ProtoMessage 

func (*ModuleEventRequest) ProtoMessage()

func (*ModuleEventRequest) Reset 

func (m *ModuleEventRequest) Reset()

func (*ModuleEventRequest) String 

func (m *ModuleEventRequest) String() string

func (*ModuleEventRequest) XXX_DiscardUnknown 

func (m *ModuleEventRequest) XXX_DiscardUnknown()

func (*ModuleEventRequest) XXX_Marshal 

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

func (*ModuleEventRequest) XXX_Merge 

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

func (*ModuleEventRequest) XXX_Size 

func (m *ModuleEventRequest) XXX_Size() int

func (*ModuleEventRequest) XXX_Unmarshal 

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

type ModuleJobRequest 

type ModuleJobRequest struct {
	Id                   string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	JobId                string      `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	JobValue             string      `protobuf:"bytes,3,opt,name=job_value,json=jobValue,proto3" json:"job_value,omitempty"`
	JobProperties        []*Property `protobuf:"bytes,4,rep,name=job_properties,json=jobProperties,proto3" json:"job_properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

* TODO: document message

func (*ModuleJobRequest) Descriptor 

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

func (*ModuleJobRequest) GetId 

func (m *ModuleJobRequest) GetId() string

func (*ModuleJobRequest) GetJobId 

func (m *ModuleJobRequest) GetJobId() string

func (*ModuleJobRequest) GetJobProperties 

func (m *ModuleJobRequest) GetJobProperties() []*Property

func (*ModuleJobRequest) GetJobValue 

func (m *ModuleJobRequest) GetJobValue() string

func (*ModuleJobRequest) ProtoMessage 

func (*ModuleJobRequest) ProtoMessage()

func (*ModuleJobRequest) Reset 

func (m *ModuleJobRequest) Reset()

func (*ModuleJobRequest) String 

func (m *ModuleJobRequest) String() string

func (*ModuleJobRequest) XXX_DiscardUnknown 

func (m *ModuleJobRequest) XXX_DiscardUnknown()

func (*ModuleJobRequest) XXX_Marshal 

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

func (*ModuleJobRequest) XXX_Merge 

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

func (*ModuleJobRequest) XXX_Size 

func (m *ModuleJobRequest) XXX_Size() int

func (*ModuleJobRequest) XXX_Unmarshal 

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

type ModuleRequest 

type ModuleRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ModuleId             string   `protobuf:"bytes,2,opt,name=module_id,json=moduleId,proto3" json:"module_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*ModuleRequest) Descriptor 

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

func (*ModuleRequest) GetId 

func (m *ModuleRequest) GetId() string

func (*ModuleRequest) GetModuleId 

func (m *ModuleRequest) GetModuleId() string

func (*ModuleRequest) ProtoMessage 

func (*ModuleRequest) ProtoMessage()

func (*ModuleRequest) Reset 

func (m *ModuleRequest) Reset()

func (*ModuleRequest) String 

func (m *ModuleRequest) String() string

func (*ModuleRequest) XXX_DiscardUnknown 

func (m *ModuleRequest) XXX_DiscardUnknown()

func (*ModuleRequest) XXX_Marshal 

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

func (*ModuleRequest) XXX_Merge 

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

func (*ModuleRequest) XXX_Size 

func (m *ModuleRequest) XXX_Size() int

func (*ModuleRequest) XXX_Unmarshal 

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

type ModuleResponse 

type ModuleResponse struct {
	Module               *Module  `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*ModuleResponse) Descriptor 

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

func (*ModuleResponse) GetModule 

func (m *ModuleResponse) GetModule() *Module

func (*ModuleResponse) ProtoMessage 

func (*ModuleResponse) ProtoMessage()

func (*ModuleResponse) Reset 

func (m *ModuleResponse) Reset()

func (*ModuleResponse) String 

func (m *ModuleResponse) String() string

func (*ModuleResponse) XXX_DiscardUnknown 

func (m *ModuleResponse) XXX_DiscardUnknown()

func (*ModuleResponse) XXX_Marshal 

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

func (*ModuleResponse) XXX_Merge 

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

func (*ModuleResponse) XXX_Size 

func (m *ModuleResponse) XXX_Size() int

func (*ModuleResponse) XXX_Unmarshal 

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

type ModulesResponse 

type ModulesResponse struct {
	Modules              []*Module `protobuf:"bytes,1,rep,name=modules,proto3" json:"modules,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

* TODO: document message

func (*ModulesResponse) Descriptor 

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

func (*ModulesResponse) GetModules 

func (m *ModulesResponse) GetModules() []*Module

func (*ModulesResponse) ProtoMessage 

func (*ModulesResponse) ProtoMessage()

func (*ModulesResponse) Reset 

func (m *ModulesResponse) Reset()

func (*ModulesResponse) String 

func (m *ModulesResponse) String() string

func (*ModulesResponse) XXX_DiscardUnknown 

func (m *ModulesResponse) XXX_DiscardUnknown()

func (*ModulesResponse) XXX_Marshal 

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

func (*ModulesResponse) XXX_Merge 

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

func (*ModulesResponse) XXX_Size 

func (m *ModulesResponse) XXX_Size() int

func (*ModulesResponse) XXX_Unmarshal 

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

type Object 

type Object struct {
	Id                   string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string      `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type                 string      `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Properties           []*Property `protobuf:"bytes,4,rep,name=properties,proto3" json:"properties,omitempty"`
	Objects              []*Object   `protobuf:"bytes,5,rep,name=objects,proto3" json:"objects,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

* Nestable node in a tree

func (*Object) Descriptor 

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

func (*Object) GetId 

func (m *Object) GetId() string

func (*Object) GetName 

func (m *Object) GetName() string

func (*Object) GetObjects 

func (m *Object) GetObjects() []*Object

func (*Object) GetProperties 

func (m *Object) GetProperties() []*Property

func (*Object) GetType 

func (m *Object) GetType() string

func (*Object) ProtoMessage 

func (*Object) ProtoMessage()

func (*Object) Reset 

func (m *Object) Reset()

func (*Object) String 

func (m *Object) String() string

func (*Object) XXX_DiscardUnknown 

func (m *Object) XXX_DiscardUnknown()

func (*Object) XXX_Marshal 

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

func (*Object) XXX_Merge 

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

func (*Object) XXX_Size 

func (m *Object) XXX_Size() int

func (*Object) XXX_Unmarshal 

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

type PropertiesRequest 

type PropertiesRequest struct {
	Id                   string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Properties           []*Property `protobuf:"bytes,2,rep,name=properties,proto3" json:"properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

* TODO: document message

func (*PropertiesRequest) Descriptor 

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

func (*PropertiesRequest) GetId 

func (m *PropertiesRequest) GetId() string

func (*PropertiesRequest) GetProperties 

func (m *PropertiesRequest) GetProperties() []*Property

func (*PropertiesRequest) ProtoMessage 

func (*PropertiesRequest) ProtoMessage()

func (*PropertiesRequest) Reset 

func (m *PropertiesRequest) Reset()

func (*PropertiesRequest) String 

func (m *PropertiesRequest) String() string

func (*PropertiesRequest) XXX_DiscardUnknown 

func (m *PropertiesRequest) XXX_DiscardUnknown()

func (*PropertiesRequest) XXX_Marshal 

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

func (*PropertiesRequest) XXX_Merge 

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

func (*PropertiesRequest) XXX_Size 

func (m *PropertiesRequest) XXX_Size() int

func (*PropertiesRequest) XXX_Unmarshal 

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

type PropertiesResponse 

type PropertiesResponse struct {
	Properties           []*Property `protobuf:"bytes,1,rep,name=properties,proto3" json:"properties,omitempty"`
	Error                *Error      `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

* TODO: document message

func (*PropertiesResponse) Descriptor 

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

func (*PropertiesResponse) GetError 

func (m *PropertiesResponse) GetError() *Error

func (*PropertiesResponse) GetProperties 

func (m *PropertiesResponse) GetProperties() []*Property

func (*PropertiesResponse) ProtoMessage 

func (*PropertiesResponse) ProtoMessage()

func (*PropertiesResponse) Reset 

func (m *PropertiesResponse) Reset()

func (*PropertiesResponse) String 

func (m *PropertiesResponse) String() string

func (*PropertiesResponse) XXX_DiscardUnknown 

func (m *PropertiesResponse) XXX_DiscardUnknown()

func (*PropertiesResponse) XXX_Marshal 

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

func (*PropertiesResponse) XXX_Merge 

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

func (*PropertiesResponse) XXX_Size 

func (m *PropertiesResponse) XXX_Size() int

func (*PropertiesResponse) XXX_Unmarshal 

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

type Property 

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

* Key/Value entry that could probably be replaced by a map

func (*Property) Descriptor 

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

func (*Property) GetKey 

func (m *Property) GetKey() string

func (*Property) GetValue 

func (m *Property) GetValue() string

func (*Property) ProtoMessage 

func (*Property) ProtoMessage()

func (*Property) Reset 

func (m *Property) Reset()

func (*Property) String 

func (m *Property) String() string

func (*Property) XXX_DiscardUnknown 

func (m *Property) XXX_DiscardUnknown()

func (*Property) XXX_Marshal 

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

func (*Property) XXX_Merge 

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

func (*Property) XXX_Size 

func (m *Property) XXX_Size() int

func (*Property) XXX_Unmarshal 

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

type PropertyRequest 

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

* TODO: document message

func (*PropertyRequest) Descriptor 

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

func (*PropertyRequest) GetId 

func (m *PropertyRequest) GetId() string

func (*PropertyRequest) GetKey 

func (m *PropertyRequest) GetKey() string

func (*PropertyRequest) GetValue 

func (m *PropertyRequest) GetValue() string

func (*PropertyRequest) ProtoMessage 

func (*PropertyRequest) ProtoMessage()

func (*PropertyRequest) Reset 

func (m *PropertyRequest) Reset()

func (*PropertyRequest) String 

func (m *PropertyRequest) String() string

func (*PropertyRequest) XXX_DiscardUnknown 

func (m *PropertyRequest) XXX_DiscardUnknown()

func (*PropertyRequest) XXX_Marshal 

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

func (*PropertyRequest) XXX_Merge 

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

func (*PropertyRequest) XXX_Size 

func (m *PropertyRequest) XXX_Size() int

func (*PropertyRequest) XXX_Unmarshal 

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

type PropertyResponse 

type PropertyResponse struct {
	Property             *Property `protobuf:"bytes,1,opt,name=property,proto3" json:"property,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

* TODO: document message

func (*PropertyResponse) Descriptor 

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

func (*PropertyResponse) GetProperty 

func (m *PropertyResponse) GetProperty() *Property

func (*PropertyResponse) ProtoMessage 

func (*PropertyResponse) ProtoMessage()

func (*PropertyResponse) Reset 

func (m *PropertyResponse) Reset()

func (*PropertyResponse) String 

func (m *PropertyResponse) String() string

func (*PropertyResponse) XXX_DiscardUnknown 

func (m *PropertyResponse) XXX_DiscardUnknown()

func (*PropertyResponse) XXX_Marshal 

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

func (*PropertyResponse) XXX_Merge 

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

func (*PropertyResponse) XXX_Size 

func (m *PropertyResponse) XXX_Size() int

func (*PropertyResponse) XXX_Unmarshal 

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

type Request 

type Request struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*Request) Descriptor 

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

func (*Request) GetId 

func (m *Request) GetId() string

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) String 

func (m *Request) String() string

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type Service 

type Service struct {
	Name                 string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description          string       `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	ConfigurationId      string       `protobuf:"bytes,3,opt,name=configuration_id,json=configurationId,proto3" json:"configuration_id,omitempty"`
	Status               *Status      `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	State                *State       `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	Type                 Service_Type `protobuf:"varint,6,opt,name=type,proto3,enum=plantd.Service_Type" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

* Service type used in message responses

func (*Service) Descriptor 

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

func (*Service) GetConfigurationId 

func (m *Service) GetConfigurationId() string

func (*Service) GetDescription 

func (m *Service) GetDescription() string

func (*Service) GetName 

func (m *Service) GetName() string

func (*Service) GetState 

func (m *Service) GetState() *State

func (*Service) GetStatus 

func (m *Service) GetStatus() *Status

func (*Service) GetType 

func (m *Service) GetType() Service_Type

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) String 

func (m *Service) String() string

func (*Service) XXX_DiscardUnknown 

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal 

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

func (*Service) XXX_Merge 

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

func (*Service) XXX_Size 

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal 

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

type Service_Type 

type Service_Type int32
const (
	Service_ACQUIRE    Service_Type = 0
	Service_ANALYZE    Service_Type = 1
	Service_CONTROL    Service_Type = 2
	Service_EXPERIMENT Service_Type = 3
	Service_MONITOR    Service_Type = 4
	Service_PRESENT    Service_Type = 5
	Service_RECORD     Service_Type = 6
	Service_STATE      Service_Type = 7
)

func (Service_Type) EnumDescriptor 

func (Service_Type) EnumDescriptor() ([]byte, []int)

func (Service_Type) String 

func (x Service_Type) String() string

type Settings 

type Settings struct {
	// / TODO: find out how to make V generic
	Properties           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

* TODO: document message

func (*Settings) Descriptor 

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

func (*Settings) GetProperties 

func (m *Settings) GetProperties() map[string]string

func (*Settings) ProtoMessage 

func (*Settings) ProtoMessage()

func (*Settings) Reset 

func (m *Settings) Reset()

func (*Settings) String 

func (m *Settings) String() string

func (*Settings) XXX_DiscardUnknown 

func (m *Settings) XXX_DiscardUnknown()

func (*Settings) XXX_Marshal 

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

func (*Settings) XXX_Merge 

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

func (*Settings) XXX_Size 

func (m *Settings) XXX_Size() int

func (*Settings) XXX_Unmarshal 

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

type SettingsRequest 

type SettingsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SettingsRequest) Descriptor 

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

func (*SettingsRequest) ProtoMessage 

func (*SettingsRequest) ProtoMessage()

func (*SettingsRequest) Reset 

func (m *SettingsRequest) Reset()

func (*SettingsRequest) String 

func (m *SettingsRequest) String() string

func (*SettingsRequest) XXX_DiscardUnknown 

func (m *SettingsRequest) XXX_DiscardUnknown()

func (*SettingsRequest) XXX_Marshal 

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

func (*SettingsRequest) XXX_Merge 

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

func (*SettingsRequest) XXX_Size 

func (m *SettingsRequest) XXX_Size() int

func (*SettingsRequest) XXX_Unmarshal 

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

type SettingsResponse 

type SettingsResponse struct {
	Id                   string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Settings             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

* TODO: document message

func (*SettingsResponse) Descriptor 

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

func (*SettingsResponse) GetId 

func (m *SettingsResponse) GetId() string

func (*SettingsResponse) GetSettings 

func (m *SettingsResponse) GetSettings() map[string]string

func (*SettingsResponse) ProtoMessage 

func (*SettingsResponse) ProtoMessage()

func (*SettingsResponse) Reset 

func (m *SettingsResponse) Reset()

func (*SettingsResponse) String 

func (m *SettingsResponse) String() string

func (*SettingsResponse) XXX_DiscardUnknown 

func (m *SettingsResponse) XXX_DiscardUnknown()

func (*SettingsResponse) XXX_Marshal 

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

func (*SettingsResponse) XXX_Merge 

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

func (*SettingsResponse) XXX_Size 

func (m *SettingsResponse) XXX_Size() int

func (*SettingsResponse) XXX_Unmarshal 

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

type State 

type State struct {
	Id                   int32    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description          string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*State) Descriptor 

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

func (*State) GetDescription 

func (m *State) GetDescription() string

func (*State) GetId 

func (m *State) GetId() int32

func (*State) GetName 

func (m *State) GetName() string

func (*State) ProtoMessage 

func (*State) ProtoMessage()

func (*State) Reset 

func (m *State) Reset()

func (*State) String 

func (m *State) String() string

func (*State) XXX_DiscardUnknown 

func (m *State) XXX_DiscardUnknown()

func (*State) XXX_Marshal 

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

func (*State) XXX_Merge 

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

func (*State) XXX_Size 

func (m *State) XXX_Size() int

func (*State) XXX_Unmarshal 

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

type Status 

type Status struct {
	// / TODO: consider a different data type, protobuf-c sucks at bool types
	Enabled              bool              `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Loaded               bool              `protobuf:"varint,2,opt,name=loaded,proto3" json:"loaded,omitempty"`
	Active               bool              `protobuf:"varint,3,opt,name=active,proto3" json:"active,omitempty"`
	Details              map[string]string `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

* Service specific status message

func (*Status) Descriptor 

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

func (*Status) GetActive 

func (m *Status) GetActive() bool

func (*Status) GetDetails 

func (m *Status) GetDetails() map[string]string

func (*Status) GetEnabled 

func (m *Status) GetEnabled() bool

func (*Status) GetLoaded 

func (m *Status) GetLoaded() bool

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) String 

func (m *Status) String() string

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

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

func (*Status) XXX_Merge 

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

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

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

type StatusRequest 

type StatusRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) String 

func (m *StatusRequest) String() string

func (*StatusRequest) XXX_DiscardUnknown 

func (m *StatusRequest) XXX_DiscardUnknown()

func (*StatusRequest) XXX_Marshal 

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

func (*StatusRequest) XXX_Merge 

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

func (*StatusRequest) XXX_Size 

func (m *StatusRequest) XXX_Size() int

func (*StatusRequest) XXX_Unmarshal 

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

type StatusResponse 

type StatusResponse struct {
	Status               *Status  `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* TODO: document message

func (*StatusResponse) Descriptor 

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

func (*StatusResponse) GetStatus 

func (m *StatusResponse) GetStatus() *Status

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset 

func (m *StatusResponse) Reset()

func (*StatusResponse) String 

func (m *StatusResponse) String() string

func (*StatusResponse) XXX_DiscardUnknown 

func (m *StatusResponse) XXX_DiscardUnknown()

func (*StatusResponse) XXX_Marshal 

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

func (*StatusResponse) XXX_Merge 

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

func (*StatusResponse) XXX_Size 

func (m *StatusResponse) XXX_Size() int

func (*StatusResponse) XXX_Unmarshal 

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

type System 

type System struct {
	Master               *Service            `protobuf:"bytes,1,opt,name=master,proto3" json:"master,omitempty"`
	Broker               *Service            `protobuf:"bytes,2,opt,name=broker,proto3" json:"broker,omitempty"`
	Services             map[string]*Service `` /* 157-byte string literal not displayed */
	Modules              map[string]*Module  `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

* TODO: document message

func (*System) Descriptor 

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

func (*System) GetBroker 

func (m *System) GetBroker() *Service

func (*System) GetMaster 

func (m *System) GetMaster() *Service

func (*System) GetModules 

func (m *System) GetModules() map[string]*Module

func (*System) GetServices 

func (m *System) GetServices() map[string]*Service

func (*System) ProtoMessage 

func (*System) ProtoMessage()

func (*System) Reset 

func (m *System) Reset()

func (*System) String 

func (m *System) String() string

func (*System) XXX_DiscardUnknown 

func (m *System) XXX_DiscardUnknown()

func (*System) XXX_Marshal 

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

func (*System) XXX_Merge 

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

func (*System) XXX_Size 

func (m *System) XXX_Size() int

func (*System) XXX_Unmarshal 

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

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.