plantd

package
Version: v0.1.22 Latest Latest
Warning

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

Go to latest
Published: Feb 25, 2020 License: MIT Imports: 5 Imported by: 0

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,
}

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 (*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 {
	// / Request the configuration currently loaded by a service
	GetConfiguration(ctx context.Context, in *Request, opts ...grpc.CallOption) (*ConfigurationResponse, error)
	// / Request a service status
	GetStatus(ctx context.Context, in *Request, opts ...grpc.CallOption) (*StatusResponse, error)
	// / Request a job running or queued on a service by ID
	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 *Request, opts ...grpc.CallOption) (*JobsResponse, error)
	// / TODO: implement
	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 *Request, opts ...grpc.CallOption) (*ModulesResponse, error)
	// / Request the settings held by a service
	GetSettings(ctx context.Context, in *Request, opts ...grpc.CallOption) (*SettingsResponse, error)
	// / Request the currently running job on a service
	GetActiveJob(ctx context.Context, in *Request, opts ...grpc.CallOption) (*JobResponse, error)
	// / Cancel a job running or queued on a service
	CancelJob(ctx context.Context, in *JobRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / Submit a new job to a service
	SubmitJob(ctx context.Context, in *JobRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / Submit a new event to a service
	SubmitEvent(ctx context.Context, in *EventRequest, opts ...grpc.CallOption) (*JobResponse, error)
	// / List all events a service can handle to
	AvailableEvents(ctx context.Context, in *Request, opts ...grpc.CallOption) (*EventsResponse, error)
	// / Request a single property from a service
	GetProperty(ctx context.Context, in *PropertyRequest, opts ...grpc.CallOption) (*PropertyResponse, error)
	// / Request a list of properties from a service
	GetProperties(ctx context.Context, in *PropertiesRequest, opts ...grpc.CallOption) (*PropertiesResponse, error)
	// / Submit a change for a single property of a service
	SetProperty(ctx context.Context, in *PropertyRequest, opts ...grpc.CallOption) (*PropertyResponse, error)
	// / Submit a change for multiple properties of a service
	SetProperties(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 {
	// / Request the configuration currently loaded by a service
	GetConfiguration(context.Context, *Request) (*ConfigurationResponse, error)
	// / Request a service status
	GetStatus(context.Context, *Request) (*StatusResponse, error)
	// / Request a job running or queued on a service by ID
	GetJob(context.Context, *JobRequest) (*JobResponse, error)
	// / Request all jobs running or queued on a service
	GetJobs(context.Context, *Request) (*JobsResponse, error)
	// / TODO: implement
	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, *Request) (*ModulesResponse, error)
	// / Request the settings held by a service
	GetSettings(context.Context, *Request) (*SettingsResponse, error)
	// / Request the currently running job on a service
	GetActiveJob(context.Context, *Request) (*JobResponse, error)
	// / Cancel a job running or queued on a service
	CancelJob(context.Context, *JobRequest) (*JobResponse, error)
	// / Submit a new job to a service
	SubmitJob(context.Context, *JobRequest) (*JobResponse, error)
	// / Submit a new event to a service
	SubmitEvent(context.Context, *EventRequest) (*JobResponse, error)
	// / List all events a service can handle to
	AvailableEvents(context.Context, *Request) (*EventsResponse, error)
	// / Request a single property from a service
	GetProperty(context.Context, *PropertyRequest) (*PropertyResponse, error)
	// / Request a list of properties from a service
	GetProperties(context.Context, *PropertiesRequest) (*PropertiesResponse, error)
	// / Submit a change for a single property of a service
	SetProperty(context.Context, *PropertyRequest) (*PropertyResponse, error)
	// / Submit a change for multiple properties of a service
	SetProperties(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 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:"-"`
}

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"`
	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) 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 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 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL