apex

package

Go to main page

Versions in this module

v0

v0.1.20

May 16, 2019

v0.1.19

May 11, 2019

Changes in this version

+ type Error struct

+ Code int32

+ Message string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Error) ProtoMessage()

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

+ func (m *Error) GetCode() int32

+ func (m *Error) GetMessage() string

+ func (m *Error) Reset()

+ func (m *Error) String() string

+ func (m *Error) XXX_DiscardUnknown()

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

+ func (m *Error) XXX_Size() int

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

type PropertiesResponse

+ Error *Error

+ func (m *PropertiesResponse) GetError() *Error

v0.1.18

May 10, 2019

Changes in this version

type JobRequest

+ JobId string

+ JobProperties []*Property

+ JobValue string

+ func (m *JobRequest) GetJobId() string

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

+ func (m *JobRequest) GetJobValue() string

v0.1.17

May 3, 2019

v0.1.10

Apr 22, 2019

Changes in this version

type PropertiesRequest

+ Properties []*Property

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

v0.1.9

Apr 15, 2019

Changes in this version

type PropertiesRequest

+ Keys string

+ Values string

+ func (m *PropertiesRequest) GetKeys() string

+ func (m *PropertiesRequest) GetValues() string

type PropertyRequest

+ Key string

+ Value string

+ func (m *PropertyRequest) GetKey() string

+ func (m *PropertyRequest) GetValue() string

v0.1.8

Apr 15, 2019

Changes in this version

type EndpointClient

+ GetModuleProperties func(ctx context.Context, in *PropertiesRequest, opts ...grpc.CallOption) (*PropertiesResponse, error)

+ GetModuleProperty func(ctx context.Context, in *PropertyRequest, opts ...grpc.CallOption) (*PropertyResponse, error)

+ SetModuleProperties func(ctx context.Context, in *PropertiesRequest, opts ...grpc.CallOption) (*PropertiesResponse, error)

+ SetModuleProperty func(ctx context.Context, in *PropertyRequest, opts ...grpc.CallOption) (*PropertyResponse, error)

type EndpointServer

+ GetModuleProperties func(context.Context, *PropertiesRequest) (*PropertiesResponse, error)

+ GetModuleProperty func(context.Context, *PropertyRequest) (*PropertyResponse, error)

+ SetModuleProperties func(context.Context, *PropertiesRequest) (*PropertiesResponse, error)

+ SetModuleProperty func(context.Context, *PropertyRequest) (*PropertyResponse, error)

type ModuleJobRequest

+ JobProperties []*Property

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

+ type PropertiesRequest struct

+ Id string

+ PropertyKeys []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PropertiesRequest) ProtoMessage()

+ func (m *PropertiesRequest) GetId() string

+ func (m *PropertiesRequest) GetPropertyKeys() []string

+ func (m *PropertiesRequest) Reset()

+ func (m *PropertiesRequest) String() string

+ func (m *PropertiesRequest) XXX_DiscardUnknown()

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

+ func (m *PropertiesRequest) XXX_Merge(src proto.Message)

+ func (m *PropertiesRequest) XXX_Size() int

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

+ type PropertiesResponse struct

+ Properties []*Property

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PropertiesResponse) ProtoMessage()

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

+ func (m *PropertiesResponse) Reset()

+ func (m *PropertiesResponse) String() string

+ func (m *PropertiesResponse) XXX_DiscardUnknown()

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

+ func (m *PropertiesResponse) XXX_Merge(src proto.Message)

+ func (m *PropertiesResponse) XXX_Size() int

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

+ type PropertyRequest struct

+ Id string

+ PropertyKey string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PropertyRequest) ProtoMessage()

+ func (m *PropertyRequest) GetId() string

+ func (m *PropertyRequest) GetPropertyKey() string

+ func (m *PropertyRequest) Reset()

+ func (m *PropertyRequest) String() string

+ func (m *PropertyRequest) XXX_DiscardUnknown()

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

+ func (m *PropertyRequest) XXX_Merge(src proto.Message)

+ func (m *PropertyRequest) XXX_Size() int

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

+ type PropertyResponse struct

+ Property *Property

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PropertyResponse) ProtoMessage()

+ func (m *PropertyResponse) GetProperty() *Property

+ func (m *PropertyResponse) Reset()

+ func (m *PropertyResponse) String() string

+ func (m *PropertyResponse) XXX_DiscardUnknown()

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

+ func (m *PropertyResponse) XXX_Merge(src proto.Message)

+ func (m *PropertyResponse) XXX_Size() int

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

v0.1.7

Apr 2, 2019

Changes in this version

type Configuration

+ Name string

+ func (m *Configuration) GetName() string

type Configuration_Namespace

+ const Configuration_RECIPE

type ModuleJobRequest

+ JobValue string

+ func (m *ModuleJobRequest) GetJobValue() string

v0.1.6

Mar 25, 2019

v0.1.5

Mar 25, 2019

Changes in this version

type ConfigurationRequest

+ Configuration *Configuration

+ func (m *ConfigurationRequest) GetConfiguration() *Configuration

type ConfigureEndpointClient

+ ListNamespace func(ctx context.Context, in *ConfigurationRequest, opts ...grpc.CallOption) (*ConfigurationsResponse, error)

type ConfigureEndpointServer

+ ListNamespace func(context.Context, *ConfigurationRequest) (*ConfigurationsResponse, error)

type Job_Status

+ const Job_CANCELLED

v0.1.4

Mar 16, 2019

v0.1.3

Mar 12, 2019

v0.1.2

Mar 12, 2019

Changes in this version

type Job

+ Priority int32

+ func (m *Job) GetPriority() int32

v0.1.1

Mar 7, 2019

Changes in this version

+ type Bus struct

+ Endpoint string

+ Sinks []*Channel

+ Sources []*Channel

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Bus) ProtoMessage()

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

+ func (m *Bus) GetEndpoint() string

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

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

+ func (m *Bus) Reset()

+ func (m *Bus) String() string

+ func (m *Bus) XXX_DiscardUnknown()

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

+ func (m *Bus) XXX_Size() int

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

type EndpointClient

+ GetUnitConfiguration func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ConfigurationResponse, error)

+ ModuleSubmitJob func(ctx context.Context, in *ModuleJobRequest, opts ...grpc.CallOption) (*JobResponse, error)

type EndpointServer

+ GetUnitConfiguration func(context.Context, *Empty) (*ConfigurationResponse, error)

+ ModuleSubmitJob func(context.Context, *ModuleJobRequest) (*JobResponse, error)

type Job

+ Properties []*Property

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

type Module

+ Services []string

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

v0.1.0

Jan 29, 2019

Changes in this version

+ var Channel_Type_name = map[int32]string

+ var Channel_Type_value = map[string]int32

+ var Configuration_Namespace_name = map[int32]string

+ var Configuration_Namespace_value = map[string]int32

+ var JobRequest_Type_name = map[int32]string

+ var JobRequest_Type_value = map[string]int32

+ var Job_Status_name = map[int32]string

+ var Job_Status_value = map[string]int32

+ var Service_Type_name = map[int32]string

+ var Service_Type_value = map[string]int32

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

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

+ type Channel struct

+ Endpoint string

+ Envelope string

+ Type Channel_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Channel) ProtoMessage()

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

+ func (m *Channel) GetEndpoint() string

+ func (m *Channel) GetEnvelope() string

+ func (m *Channel) GetType() Channel_Type

+ func (m *Channel) Reset()

+ func (m *Channel) String() string

+ func (m *Channel) XXX_DiscardUnknown()

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

+ func (m *Channel) XXX_Size() int

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

+ type ChannelRequest struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ChannelRequest) ProtoMessage()

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

+ func (m *ChannelRequest) GetId() string

+ func (m *ChannelRequest) Reset()

+ func (m *ChannelRequest) String() string

+ func (m *ChannelRequest) XXX_DiscardUnknown()

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

+ func (m *ChannelRequest) XXX_Size() int

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

+ type ChannelResponse struct

+ Channel *Channel

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ChannelResponse) ProtoMessage()

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

+ func (m *ChannelResponse) GetChannel() *Channel

+ func (m *ChannelResponse) Reset()

+ func (m *ChannelResponse) String() string

+ func (m *ChannelResponse) XXX_DiscardUnknown()

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

+ func (m *ChannelResponse) XXX_Size() int

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

+ type Channel_Type int32

+ const Channel_SINK

+ const Channel_SOURCE

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

+ func (x Channel_Type) String() string

+ type ChannelsResponse struct

+ Channels []*Channel

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ChannelsResponse) ProtoMessage()

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

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

+ func (m *ChannelsResponse) Reset()

+ func (m *ChannelsResponse) String() string

+ func (m *ChannelsResponse) XXX_DiscardUnknown()

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

+ func (m *ChannelsResponse) XXX_Size() int

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

+ type Configuration struct

+ Id string

+ Namespace Configuration_Namespace

+ Objects []*Object

+ Properties []*Property

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Configuration) ProtoMessage()

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

+ func (m *Configuration) GetId() string

+ func (m *Configuration) GetNamespace() Configuration_Namespace

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

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

+ func (m *Configuration) Reset()

+ func (m *Configuration) String() string

+ func (m *Configuration) XXX_DiscardUnknown()

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

+ func (m *Configuration) XXX_Size() int

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

+ type ConfigurationRequest struct

+ Id string

+ Namespace Configuration_Namespace

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ConfigurationRequest) ProtoMessage()

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

+ func (m *ConfigurationRequest) GetId() string

+ func (m *ConfigurationRequest) GetNamespace() Configuration_Namespace

+ func (m *ConfigurationRequest) Reset()

+ func (m *ConfigurationRequest) String() string

+ func (m *ConfigurationRequest) XXX_DiscardUnknown()

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

+ func (m *ConfigurationRequest) XXX_Size() int

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

+ type ConfigurationResponse struct

+ Configuration *Configuration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ConfigurationResponse) ProtoMessage()

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

+ func (m *ConfigurationResponse) GetConfiguration() *Configuration

+ func (m *ConfigurationResponse) Reset()

+ func (m *ConfigurationResponse) String() string

+ func (m *ConfigurationResponse) XXX_DiscardUnknown()

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

+ func (m *ConfigurationResponse) XXX_Size() int

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

+ type Configuration_Namespace int32

+ const Configuration_ACQUIRE

+ const Configuration_ANALYZE

+ const Configuration_CONTROL

+ const Configuration_EXPERIMENT

+ const Configuration_MONITOR

+ const Configuration_PRESENT

+ const Configuration_RECORD

+ const Configuration_STATE

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

+ func (x Configuration_Namespace) String() string

+ type ConfigurationsResponse struct

+ Configurations []*Configuration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ConfigurationsResponse) ProtoMessage()

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

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

+ func (m *ConfigurationsResponse) Reset()

+ func (m *ConfigurationsResponse) String() string

+ func (m *ConfigurationsResponse) XXX_DiscardUnknown()

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

+ func (m *ConfigurationsResponse) XXX_Size() int

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

+ type ConfigureEndpointClient interface

+ Create func(ctx context.Context, in *ConfigurationRequest, opts ...grpc.CallOption) (*ConfigurationResponse, error)

+ Delete func(ctx context.Context, in *ConfigurationRequest, opts ...grpc.CallOption) (*ConfigurationResponse, error)

+ List func(ctx context.Context, in *ConfigurationRequest, opts ...grpc.CallOption) (*ConfigurationsResponse, error)

+ ListAll func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ConfigurationsResponse, error)

+ Read func(ctx context.Context, in *ConfigurationRequest, opts ...grpc.CallOption) (*ConfigurationResponse, error)

+ Update func(ctx context.Context, in *ConfigurationRequest, opts ...grpc.CallOption) (*ConfigurationResponse, error)

+ func NewConfigureEndpointClient(cc *grpc.ClientConn) ConfigureEndpointClient

+ type ConfigureEndpointServer interface

+ Create func(context.Context, *ConfigurationRequest) (*ConfigurationResponse, error)

+ Delete func(context.Context, *ConfigurationRequest) (*ConfigurationResponse, error)

+ List func(context.Context, *ConfigurationRequest) (*ConfigurationsResponse, error)

+ ListAll func(context.Context, *Empty) (*ConfigurationsResponse, error)

+ Read func(context.Context, *ConfigurationRequest) (*ConfigurationResponse, error)

+ Update func(context.Context, *ConfigurationRequest) (*ConfigurationResponse, error)

+ type Empty struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Empty) ProtoMessage()

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

+ func (m *Empty) Reset()

+ func (m *Empty) String() string

+ func (m *Empty) XXX_DiscardUnknown()

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

+ func (m *Empty) XXX_Size() int

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

+ type EndpointClient interface

+ GetChannel func(ctx context.Context, in *ChannelRequest, opts ...grpc.CallOption) (*ChannelResponse, error)

+ GetChannels func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ChannelsResponse, error)

+ GetConfiguration func(ctx context.Context, in *ConfigurationRequest, opts ...grpc.CallOption) (*ConfigurationResponse, error)

+ GetJob func(ctx context.Context, in *JobRequest, opts ...grpc.CallOption) (*JobResponse, error)

+ GetJobStatus func(ctx context.Context, in *JobRequest, opts ...grpc.CallOption) (*JobStatusResponse, error)

+ GetJobs func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*JobsResponse, error)

+ GetModule func(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*ModuleResponse, error)

+ GetModuleActiveJob func(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)

+ GetModuleConfiguration func(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*ConfigurationResponse, error)

+ GetModuleJob func(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)

+ GetModuleJobs func(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobsResponse, error)

+ GetModuleSettings func(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*SettingsResponse, error)

+ GetModuleStatus func(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*StatusResponse, error)

+ GetModules func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ModulesResponse, error)

+ GetSettings func(ctx context.Context, in *SettingsRequest, opts ...grpc.CallOption) (*SettingsResponse, error)

+ GetStatus func(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)

+ ModuleAvailableEvents func(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*EventsResponse, error)

+ ModuleCancelJob func(ctx context.Context, in *ModuleJobRequest, opts ...grpc.CallOption) (*JobResponse, error)

+ ModuleSubmitEvent func(ctx context.Context, in *ModuleEventRequest, opts ...grpc.CallOption) (*JobResponse, error)

+ TryModuleConnect func(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)

+ TryModuleDisable func(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)

+ TryModuleDisconnect func(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)

+ TryModuleEnable func(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)

+ TryModuleLoad func(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)

+ TryModuleReload func(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)

+ TryModuleUnload func(ctx context.Context, in *ModuleRequest, opts ...grpc.CallOption) (*JobResponse, error)

+ func NewEndpointClient(cc *grpc.ClientConn) EndpointClient

+ type EndpointServer interface

+ GetChannel func(context.Context, *ChannelRequest) (*ChannelResponse, error)

+ GetChannels func(context.Context, *Empty) (*ChannelsResponse, error)

+ GetConfiguration func(context.Context, *ConfigurationRequest) (*ConfigurationResponse, error)

+ GetJob func(context.Context, *JobRequest) (*JobResponse, error)

+ GetJobStatus func(context.Context, *JobRequest) (*JobStatusResponse, error)

+ GetJobs func(context.Context, *Empty) (*JobsResponse, error)

+ GetModule func(context.Context, *ModuleRequest) (*ModuleResponse, error)

+ GetModuleActiveJob func(context.Context, *ModuleRequest) (*JobResponse, error)

+ GetModuleConfiguration func(context.Context, *ModuleRequest) (*ConfigurationResponse, error)

+ GetModuleJob func(context.Context, *ModuleRequest) (*JobResponse, error)

+ GetModuleJobs func(context.Context, *ModuleRequest) (*JobsResponse, error)

+ GetModuleSettings func(context.Context, *ModuleRequest) (*SettingsResponse, error)

+ GetModuleStatus func(context.Context, *ModuleRequest) (*StatusResponse, error)

+ GetModules func(context.Context, *Empty) (*ModulesResponse, error)

+ GetSettings func(context.Context, *SettingsRequest) (*SettingsResponse, error)

+ GetStatus func(context.Context, *StatusRequest) (*StatusResponse, error)

+ ModuleAvailableEvents func(context.Context, *ModuleRequest) (*EventsResponse, error)

+ ModuleCancelJob func(context.Context, *ModuleJobRequest) (*JobResponse, error)

+ ModuleSubmitEvent func(context.Context, *ModuleEventRequest) (*JobResponse, error)

+ TryModuleConnect func(context.Context, *ModuleRequest) (*JobResponse, error)

+ TryModuleDisable func(context.Context, *ModuleRequest) (*JobResponse, error)

+ TryModuleDisconnect func(context.Context, *ModuleRequest) (*JobResponse, error)

+ TryModuleEnable func(context.Context, *ModuleRequest) (*JobResponse, error)

+ TryModuleLoad func(context.Context, *ModuleRequest) (*JobResponse, error)

+ TryModuleReload func(context.Context, *ModuleRequest) (*JobResponse, error)

+ TryModuleUnload func(context.Context, *ModuleRequest) (*JobResponse, error)

+ type Event struct

+ Description string

+ Id int32

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Event) ProtoMessage()

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

+ func (m *Event) GetDescription() string

+ func (m *Event) GetId() int32

+ func (m *Event) GetName() string

+ func (m *Event) Reset()

+ func (m *Event) String() string

+ func (m *Event) XXX_DiscardUnknown()

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

+ func (m *Event) XXX_Size() int

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

+ type EventRequest struct

+ Event *Event

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*EventRequest) ProtoMessage()

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

+ func (m *EventRequest) GetEvent() *Event

+ func (m *EventRequest) Reset()

+ func (m *EventRequest) String() string

+ func (m *EventRequest) XXX_DiscardUnknown()

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

+ func (m *EventRequest) XXX_Size() int

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

+ type EventsResponse struct

+ Events []*Event

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*EventsResponse) ProtoMessage()

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

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

+ func (m *EventsResponse) Reset()

+ func (m *EventsResponse) String() string

+ func (m *EventsResponse) XXX_DiscardUnknown()

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

+ func (m *EventsResponse) XXX_Size() int

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

+ type Job struct

+ Id string

+ Status Job_Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Job) ProtoMessage()

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

+ func (m *Job) GetId() string

+ func (m *Job) GetStatus() Job_Status

+ func (m *Job) Reset()

+ func (m *Job) String() string

+ func (m *Job) XXX_DiscardUnknown()

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

+ func (m *Job) XXX_Size() int

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

+ type JobRequest struct

+ Id string

+ Type JobRequest_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*JobRequest) ProtoMessage()

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

+ func (m *JobRequest) GetId() string

+ func (m *JobRequest) GetType() JobRequest_Type

+ func (m *JobRequest) Reset()

+ func (m *JobRequest) String() string

+ func (m *JobRequest) XXX_DiscardUnknown()

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

+ func (m *JobRequest) XXX_Size() int

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

+ type JobRequest_Type int32

+ const JobRequest_NEW

+ func (JobRequest_Type) EnumDescriptor() ([]byte, []int)

+ func (x JobRequest_Type) String() string

+ type JobResponse struct

+ Job *Job

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*JobResponse) ProtoMessage()

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

+ func (m *JobResponse) GetJob() *Job

+ func (m *JobResponse) Reset()

+ func (m *JobResponse) String() string

+ func (m *JobResponse) XXX_DiscardUnknown()

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

+ func (m *JobResponse) XXX_Size() int

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

+ type JobStatusResponse struct

+ Job *Job

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*JobStatusResponse) ProtoMessage()

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

+ func (m *JobStatusResponse) GetJob() *Job

+ func (m *JobStatusResponse) Reset()

+ func (m *JobStatusResponse) String() string

+ func (m *JobStatusResponse) XXX_DiscardUnknown()

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

+ func (m *JobStatusResponse) XXX_Size() int

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

+ type Job_Status int32

+ const Job_FAILED

+ const Job_PAUSED

+ const Job_READY

+ const Job_RESUMED

+ const Job_RUNNING

+ const Job_STARTED

+ const Job_STOPPED

+ const Job_SUBMITTED

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

+ func (x Job_Status) String() string

+ type JobsResponse struct

+ Jobs []*Job

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*JobsResponse) ProtoMessage()

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

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

+ func (m *JobsResponse) Reset()

+ func (m *JobsResponse) String() string

+ func (m *JobsResponse) XXX_DiscardUnknown()

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

+ func (m *JobsResponse) XXX_Size() int

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

+ type Module struct

+ ConfigurationId string

+ Id string

+ Name string

+ ServiceName string

+ State *State

+ Status *Status

+ Types []Service_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Module) ProtoMessage()

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

+ func (m *Module) GetConfigurationId() string

+ func (m *Module) GetId() string

+ func (m *Module) GetName() string

+ func (m *Module) GetServiceName() string

+ func (m *Module) GetState() *State

+ func (m *Module) GetStatus() *Status

+ func (m *Module) GetTypes() []Service_Type

+ func (m *Module) Reset()

+ func (m *Module) String() string

+ func (m *Module) XXX_DiscardUnknown()

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

+ func (m *Module) XXX_Size() int

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

+ type ModuleEventRequest struct

+ EventId int32

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ModuleEventRequest) ProtoMessage()

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

+ func (m *ModuleEventRequest) GetEventId() int32

+ func (m *ModuleEventRequest) GetId() string

+ func (m *ModuleEventRequest) Reset()

+ func (m *ModuleEventRequest) String() string

+ func (m *ModuleEventRequest) XXX_DiscardUnknown()

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

+ func (m *ModuleEventRequest) XXX_Size() int

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

+ type ModuleJobRequest struct

+ Id string

+ JobId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ModuleJobRequest) ProtoMessage()

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

+ func (m *ModuleJobRequest) GetId() string

+ func (m *ModuleJobRequest) GetJobId() string

+ func (m *ModuleJobRequest) Reset()

+ func (m *ModuleJobRequest) String() string

+ func (m *ModuleJobRequest) XXX_DiscardUnknown()

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

+ func (m *ModuleJobRequest) XXX_Size() int

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

+ type ModuleRequest struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ModuleRequest) ProtoMessage()

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

+ func (m *ModuleRequest) GetId() string

+ func (m *ModuleRequest) Reset()

+ func (m *ModuleRequest) String() string

+ func (m *ModuleRequest) XXX_DiscardUnknown()

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

+ func (m *ModuleRequest) XXX_Size() int

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

+ type ModuleResponse struct

+ Module *Module

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ModuleResponse) ProtoMessage()

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

+ func (m *ModuleResponse) GetModule() *Module

+ func (m *ModuleResponse) Reset()

+ func (m *ModuleResponse) String() string

+ func (m *ModuleResponse) XXX_DiscardUnknown()

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

+ func (m *ModuleResponse) XXX_Size() int

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

+ type ModulesResponse struct

+ Modules []*Module

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ModulesResponse) ProtoMessage()

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

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

+ func (m *ModulesResponse) Reset()

+ func (m *ModulesResponse) String() string

+ func (m *ModulesResponse) XXX_DiscardUnknown()

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

+ func (m *ModulesResponse) XXX_Size() int

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

+ type Object struct

+ Id string

+ Name string

+ Objects []*Object

+ Properties []*Property

+ Type string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Object) ProtoMessage()

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

+ func (m *Object) GetId() string

+ func (m *Object) GetName() string

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

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

+ func (m *Object) GetType() string

+ func (m *Object) Reset()

+ func (m *Object) String() string

+ func (m *Object) XXX_DiscardUnknown()

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

+ func (m *Object) XXX_Size() int

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

+ type Property struct

+ Key string

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Property) ProtoMessage()

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

+ func (m *Property) GetKey() string

+ func (m *Property) GetValue() string

+ func (m *Property) Reset()

+ func (m *Property) String() string

+ func (m *Property) XXX_DiscardUnknown()

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

+ func (m *Property) XXX_Size() int

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

+ type Service struct

+ ConfigurationId string

+ Description string

+ Name string

+ State *State

+ Status *Status

+ Type Service_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Service) ProtoMessage()

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

+ func (m *Service) GetConfigurationId() string

+ func (m *Service) GetDescription() string

+ func (m *Service) GetName() string

+ func (m *Service) GetState() *State

+ func (m *Service) GetStatus() *Status

+ func (m *Service) GetType() Service_Type

+ func (m *Service) Reset()

+ func (m *Service) String() string

+ func (m *Service) XXX_DiscardUnknown()

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

+ func (m *Service) XXX_Size() int

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

+ type Service_Type int32

+ const Service_ACQUIRE

+ const Service_ANALYZE

+ const Service_CONTROL

+ const Service_EXPERIMENT

+ const Service_MONITOR

+ const Service_PRESENT

+ const Service_RECORD

+ const Service_STATE

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

+ func (x Service_Type) String() string

+ type Settings struct

+ Properties map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Settings) ProtoMessage()

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

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

+ func (m *Settings) Reset()

+ func (m *Settings) String() string

+ func (m *Settings) XXX_DiscardUnknown()

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

+ func (m *Settings) XXX_Size() int

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

+ type SettingsRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SettingsRequest) ProtoMessage()

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

+ func (m *SettingsRequest) Reset()

+ func (m *SettingsRequest) String() string

+ func (m *SettingsRequest) XXX_DiscardUnknown()

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

+ func (m *SettingsRequest) XXX_Size() int

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

+ type SettingsResponse struct

+ Id string

+ Settings map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SettingsResponse) ProtoMessage()

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

+ func (m *SettingsResponse) GetId() string

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

+ func (m *SettingsResponse) Reset()

+ func (m *SettingsResponse) String() string

+ func (m *SettingsResponse) XXX_DiscardUnknown()

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

+ func (m *SettingsResponse) XXX_Size() int

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

+ type State struct

+ Description string

+ Id int32

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*State) ProtoMessage()

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

+ func (m *State) GetDescription() string

+ func (m *State) GetId() int32

+ func (m *State) GetName() string

+ func (m *State) Reset()

+ func (m *State) String() string

+ func (m *State) XXX_DiscardUnknown()

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

+ func (m *State) XXX_Size() int

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

+ type Status struct

+ Active bool

+ Details map[string]string

+ Enabled bool

+ Loaded bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Status) ProtoMessage()

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

+ func (m *Status) GetActive() bool

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

+ func (m *Status) GetEnabled() bool

+ func (m *Status) GetLoaded() bool

+ func (m *Status) Reset()

+ func (m *Status) String() string

+ func (m *Status) XXX_DiscardUnknown()

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

+ func (m *Status) XXX_Size() int

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

+ type StatusRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StatusRequest) ProtoMessage()

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

+ func (m *StatusRequest) Reset()

+ func (m *StatusRequest) String() string

+ func (m *StatusRequest) XXX_DiscardUnknown()

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

+ func (m *StatusRequest) XXX_Size() int

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

+ type StatusResponse struct

+ Status *Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StatusResponse) ProtoMessage()

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

+ func (m *StatusResponse) GetStatus() *Status

+ func (m *StatusResponse) Reset()

+ func (m *StatusResponse) String() string

+ func (m *StatusResponse) XXX_DiscardUnknown()

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

+ func (m *StatusResponse) XXX_Size() int

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

+ type System struct

+ Broker *Service

+ Master *Service

+ Modules map[string]*Module

+ Services map[string]*Service

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*System) ProtoMessage()

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

+ func (m *System) GetBroker() *Service

+ func (m *System) GetMaster() *Service

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

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

+ func (m *System) Reset()

+ func (m *System) String() string

+ func (m *System) XXX_DiscardUnknown()

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

+ func (m *System) XXX_Size() int

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

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