proto

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: May 17, 2021 License: BSD-3-Clause Imports: 14 Imported by: 17

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthModuleAPI        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowModuleAPI          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupModuleAPI = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthNode        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNode          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupNode = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthServiceInstance        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowServiceInstance          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupServiceInstance = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthStateSyncMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStateSyncMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStateSyncMessage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var EventControl_Type_name = map[int32]string{
	0: "StateChange",
	1: "Mutation",
	2: "Discovery",
}
View Source 
var EventControl_Type_value = map[string]int32{
	"StateChange": 0,
	"Mutation":    1,
	"Discovery":   2,
}
View Source 
var MutationControl_Type_name = map[int32]string{
	0: "MUTATE",
	1: "INTERRUPT",
}
View Source 
var MutationControl_Type_value = map[string]int32{
	"MUTATE":    0,
	"INTERRUPT": 1,
}
View Source 
var Node_FreeBusy_name = map[int32]string{
	0: "FREE",
	1: "BUSY",
}
View Source 
var Node_FreeBusy_value = map[string]int32{
	"FREE": 0,
	"BUSY": 1,
}
View Source 
var Node_PhysState_name = map[int32]string{
	0: "PHYS_UNKNOWN",
	1: "POWER_OFF",
	2: "POWER_ON",
	3: "POWER_CYCLE",
	4: "PHYS_HANG",
	5: "PHYS_ERROR",
}
View Source 
var Node_PhysState_value = map[string]int32{
	"PHYS_UNKNOWN": 0,
	"POWER_OFF":    1,
	"POWER_ON":     2,
	"POWER_CYCLE":  3,
	"PHYS_HANG":    4,
	"PHYS_ERROR":   5,
}
View Source 
var Node_RunState_name = map[int32]string{
	0: "UNKNOWN",
	1: "INIT",
	2: "SYNC",
	3: "ERROR",
}
View Source 
var Node_RunState_value = map[string]int32{
	"UNKNOWN": 0,
	"INIT":    1,
	"SYNC":    2,
	"ERROR":   3,
}
View Source 
var ServiceControl_Command_name = map[int32]string{
	0: "STOP",
	1: "UPDATE",
	2: "INIT",
}
View Source 
var ServiceControl_Command_value = map[string]int32{
	"STOP":   0,
	"UPDATE": 1,
	"INIT":   2,
}
View Source 
var ServiceInstance_ServiceState_name = map[int32]string{
	0: "UNKNOWN",
	1: "INIT",
	2: "STOP",
	3: "RUN",
	4: "ERROR",
}
View Source 
var ServiceInstance_ServiceState_value = map[string]int32{
	"UNKNOWN": 0,
	"INIT":    1,
	"STOP":    2,
	"RUN":     3,
	"ERROR":   4,
}
View Source 
var StateChangeControl_Type_name = map[int32]string{
	0: "CREATE",
	1: "READ",
	2: "UPDATE",
	3: "DELETE",
	4: "CFG_READ",
	5: "CFG_UPDATE",
}
View Source 
var StateChangeControl_Type_value = map[string]int32{
	"CREATE":     0,
	"READ":       1,
	"UPDATE":     2,
	"DELETE":     3,
	"CFG_READ":   4,
	"CFG_UPDATE": 5,
}

Functions

func RegisterModuleAPIServer 

func RegisterModuleAPIServer(s *grpc.Server, srv ModuleAPIServer)

func RegisterStateSyncServer 

func RegisterStateSyncServer(s *grpc.Server, srv StateSyncServer)

Types

type DiscoveryEvent 

type DiscoveryEvent struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Url                  string   `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	ValueId              string   `protobuf:"bytes,3,opt,name=value_id,json=valueId,proto3" json:"value_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiscoveryEvent) Descriptor 

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

func (*DiscoveryEvent) GetId 

func (m *DiscoveryEvent) GetId() string

func (*DiscoveryEvent) GetUrl 

func (m *DiscoveryEvent) GetUrl() string

func (*DiscoveryEvent) GetValueId 

func (m *DiscoveryEvent) GetValueId() string

func (*DiscoveryEvent) Marshal 

func (m *DiscoveryEvent) Marshal() (dAtA []byte, err error)

func (*DiscoveryEvent) MarshalTo 

func (m *DiscoveryEvent) MarshalTo(dAtA []byte) (int, error)

func (*DiscoveryEvent) MarshalToSizedBuffer 

func (m *DiscoveryEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DiscoveryEvent) ProtoMessage 

func (*DiscoveryEvent) ProtoMessage()

func (*DiscoveryEvent) Reset 

func (m *DiscoveryEvent) Reset()

func (*DiscoveryEvent) Size 

func (m *DiscoveryEvent) Size() (n int)

func (*DiscoveryEvent) String 

func (m *DiscoveryEvent) String() string

func (*DiscoveryEvent) Unmarshal 

func (m *DiscoveryEvent) Unmarshal(dAtA []byte) error

func (*DiscoveryEvent) XXX_DiscardUnknown 

func (m *DiscoveryEvent) XXX_DiscardUnknown()

func (*DiscoveryEvent) XXX_Marshal 

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

func (*DiscoveryEvent) XXX_Merge 

func (m *DiscoveryEvent) XXX_Merge(src proto.Message)

func (*DiscoveryEvent) XXX_MessageName 

func (*DiscoveryEvent) XXX_MessageName() string

func (*DiscoveryEvent) XXX_Size 

func (m *DiscoveryEvent) XXX_Size() int

func (*DiscoveryEvent) XXX_Unmarshal 

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

type EdgeColor 

type EdgeColor struct {
	Color                string   `protobuf:"bytes,1,opt,name=color,proto3" json:"color,omitempty"`
	Highlight            string   `protobuf:"bytes,2,opt,name=highlight,proto3" json:"highlight,omitempty"`
	Inherit              bool     `protobuf:"varint,3,opt,name=inherit,proto3" json:"inherit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

This is only nessessary for the json mutation edge color to output in the correct format for the dashboard

func (*EdgeColor) Descriptor 

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

func (*EdgeColor) GetColor 

func (m *EdgeColor) GetColor() string

func (*EdgeColor) GetHighlight 

func (m *EdgeColor) GetHighlight() string

func (*EdgeColor) GetInherit 

func (m *EdgeColor) GetInherit() bool

func (*EdgeColor) Marshal 

func (m *EdgeColor) Marshal() (dAtA []byte, err error)

func (*EdgeColor) MarshalTo 

func (m *EdgeColor) MarshalTo(dAtA []byte) (int, error)

func (*EdgeColor) MarshalToSizedBuffer 

func (m *EdgeColor) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EdgeColor) ProtoMessage 

func (*EdgeColor) ProtoMessage()

func (*EdgeColor) Reset 

func (m *EdgeColor) Reset()

func (*EdgeColor) Size 

func (m *EdgeColor) Size() (n int)

func (*EdgeColor) String 

func (m *EdgeColor) String() string

func (*EdgeColor) Unmarshal 

func (m *EdgeColor) Unmarshal(dAtA []byte) error

func (*EdgeColor) XXX_DiscardUnknown 

func (m *EdgeColor) XXX_DiscardUnknown()

func (*EdgeColor) XXX_Marshal 

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

func (*EdgeColor) XXX_Merge 

func (m *EdgeColor) XXX_Merge(src proto.Message)

func (*EdgeColor) XXX_MessageName 

func (*EdgeColor) XXX_MessageName() string

func (*EdgeColor) XXX_Size 

func (m *EdgeColor) XXX_Size() int

func (*EdgeColor) XXX_Unmarshal 

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

type EventControl 

type EventControl struct {
	Type EventControl_Type `protobuf:"varint,1,opt,name=type,proto3,enum=proto.EventControl_Type" json:"type,omitempty"`
	// Types that are valid to be assigned to Event:
	//	*EventControl_StateChangeControl
	//	*EventControl_MutationControl
	//	*EventControl_DiscoveryEvent
	Event                isEventControl_Event `protobuf_oneof:"event"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*EventControl) Descriptor 

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

func (*EventControl) GetDiscoveryEvent 

func (m *EventControl) GetDiscoveryEvent() *DiscoveryEvent

func (*EventControl) GetEvent 

func (m *EventControl) GetEvent() isEventControl_Event

func (*EventControl) GetMutationControl 

func (m *EventControl) GetMutationControl() *MutationControl

func (*EventControl) GetStateChangeControl 

func (m *EventControl) GetStateChangeControl() *StateChangeControl

func (*EventControl) GetType 

func (m *EventControl) GetType() EventControl_Type

func (*EventControl) Marshal 

func (m *EventControl) Marshal() (dAtA []byte, err error)

func (*EventControl) MarshalTo 

func (m *EventControl) MarshalTo(dAtA []byte) (int, error)

func (*EventControl) MarshalToSizedBuffer 

func (m *EventControl) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventControl) ProtoMessage 

func (*EventControl) ProtoMessage()

func (*EventControl) Reset 

func (m *EventControl) Reset()

func (*EventControl) Size 

func (m *EventControl) Size() (n int)

func (*EventControl) String 

func (m *EventControl) String() string

func (*EventControl) Unmarshal 

func (m *EventControl) Unmarshal(dAtA []byte) error

func (*EventControl) XXX_DiscardUnknown 

func (m *EventControl) XXX_DiscardUnknown()

func (*EventControl) XXX_Marshal 

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

func (*EventControl) XXX_Merge 

func (m *EventControl) XXX_Merge(src proto.Message)

func (*EventControl) XXX_MessageName 

func (*EventControl) XXX_MessageName() string

func (*EventControl) XXX_OneofWrappers 

func (*EventControl) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*EventControl) XXX_Size 

func (m *EventControl) XXX_Size() int

func (*EventControl) XXX_Unmarshal 

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

type EventControl_DiscoveryEvent 

type EventControl_DiscoveryEvent struct {
	DiscoveryEvent *DiscoveryEvent `protobuf:"bytes,4,opt,name=discoveryEvent,proto3,oneof" json:"discoveryEvent,omitempty"`
}

func (*EventControl_DiscoveryEvent) MarshalTo 

func (m *EventControl_DiscoveryEvent) MarshalTo(dAtA []byte) (int, error)

func (*EventControl_DiscoveryEvent) MarshalToSizedBuffer 

func (m *EventControl_DiscoveryEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventControl_DiscoveryEvent) Size 

func (m *EventControl_DiscoveryEvent) Size() (n int)

type EventControl_MutationControl 

type EventControl_MutationControl struct {
	MutationControl *MutationControl `protobuf:"bytes,3,opt,name=mutationControl,proto3,oneof" json:"mutationControl,omitempty"`
}

func (*EventControl_MutationControl) MarshalTo 

func (m *EventControl_MutationControl) MarshalTo(dAtA []byte) (int, error)

func (*EventControl_MutationControl) MarshalToSizedBuffer 

func (m *EventControl_MutationControl) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventControl_MutationControl) Size 

func (m *EventControl_MutationControl) Size() (n int)

type EventControl_StateChangeControl 

type EventControl_StateChangeControl struct {
	StateChangeControl *StateChangeControl `protobuf:"bytes,2,opt,name=stateChangeControl,proto3,oneof" json:"stateChangeControl,omitempty"`
}

func (*EventControl_StateChangeControl) MarshalTo 

func (m *EventControl_StateChangeControl) MarshalTo(dAtA []byte) (int, error)

func (*EventControl_StateChangeControl) MarshalToSizedBuffer 

func (m *EventControl_StateChangeControl) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventControl_StateChangeControl) Size 

func (m *EventControl_StateChangeControl) Size() (n int)

type EventControl_Type 

type EventControl_Type int32
const (
	EventControl_StateChange EventControl_Type = 0
	EventControl_Mutation    EventControl_Type = 1
	EventControl_Discovery   EventControl_Type = 2
)

func (EventControl_Type) EnumDescriptor 

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

func (EventControl_Type) String 

func (x EventControl_Type) String() string

type LogMessage 

type LogMessage struct {
	Origin               string   `protobuf:"bytes,1,opt,name=origin,proto3" json:"origin,omitempty"`
	Level                uint32   `protobuf:"varint,2,opt,name=level,proto3" json:"level,omitempty"`
	Msg                  string   `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogMessage) Descriptor 

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

func (*LogMessage) GetLevel 

func (m *LogMessage) GetLevel() uint32

func (*LogMessage) GetMsg 

func (m *LogMessage) GetMsg() string

func (*LogMessage) GetOrigin 

func (m *LogMessage) GetOrigin() string

func (*LogMessage) Marshal 

func (m *LogMessage) Marshal() (dAtA []byte, err error)

func (*LogMessage) MarshalTo 

func (m *LogMessage) MarshalTo(dAtA []byte) (int, error)

func (*LogMessage) MarshalToSizedBuffer 

func (m *LogMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogMessage) ProtoMessage 

func (*LogMessage) ProtoMessage()

func (*LogMessage) Reset 

func (m *LogMessage) Reset()

func (*LogMessage) Size 

func (m *LogMessage) Size() (n int)

func (*LogMessage) String 

func (m *LogMessage) String() string

func (*LogMessage) Unmarshal 

func (m *LogMessage) Unmarshal(dAtA []byte) error

func (*LogMessage) XXX_DiscardUnknown 

func (m *LogMessage) XXX_DiscardUnknown()

func (*LogMessage) XXX_Marshal 

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

func (*LogMessage) XXX_Merge 

func (m *LogMessage) XXX_Merge(src proto.Message)

func (*LogMessage) XXX_MessageName 

func (*LogMessage) XXX_MessageName() string

func (*LogMessage) XXX_Size 

func (m *LogMessage) XXX_Size() int

func (*LogMessage) XXX_Unmarshal 

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

type ModuleAPIClient 

type ModuleAPIClient interface {
	// Query language
	// TODO: create API for bulk CRUD operations
	QueryCreate(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Query, error)
	QueryRead(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Query, error)
	QueryReadDsc(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Query, error)
	QueryUpdate(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Query, error)
	QueryUpdateDsc(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Query, error)
	QueryDelete(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Query, error)
	QueryReadAll(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*QueryMulti, error)
	QueryReadAllDsc(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*QueryMulti, error)
	QueryMutationNodes(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*Query, error)
	QueryMutationEdges(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*Query, error)
	QueryNodeMutationNodes(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Query, error)
	QueryNodeMutationEdges(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Query, error)
	QueryNodeMutationPath(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Query, error)
	QueryDeleteAll(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*QueryMulti, error)
	QueryFreeze(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*Query, error)
	QueryThaw(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*Query, error)
	QueryFrozen(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*Query, error)
	// Service management
	ServiceInit(ctx context.Context, in *ServiceInitRequest, opts ...grpc.CallOption) (ModuleAPI_ServiceInitClient, error)
	// Mutation/Discover management
	MutationInit(ctx context.Context, in *ServiceInitRequest, opts ...grpc.CallOption) (ModuleAPI_MutationInitClient, error)
	// Event management
	EventInit(ctx context.Context, in *ServiceInitRequest, opts ...grpc.CallOption) (ModuleAPI_EventInitClient, error)
	// Discovery management
	DiscoveryInit(ctx context.Context, opts ...grpc.CallOption) (ModuleAPI_DiscoveryInitClient, error)
	// Logging
	LoggerInit(ctx context.Context, opts ...grpc.CallOption) (ModuleAPI_LoggerInitClient, error)
}

ModuleAPIClient is the client API for ModuleAPI service.

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

func NewModuleAPIClient 

func NewModuleAPIClient(cc *grpc.ClientConn) ModuleAPIClient

type ModuleAPIServer 

type ModuleAPIServer interface {
	// Query language
	// TODO: create API for bulk CRUD operations
	QueryCreate(context.Context, *Query) (*Query, error)
	QueryRead(context.Context, *Query) (*Query, error)
	QueryReadDsc(context.Context, *Query) (*Query, error)
	QueryUpdate(context.Context, *Query) (*Query, error)
	QueryUpdateDsc(context.Context, *Query) (*Query, error)
	QueryDelete(context.Context, *Query) (*Query, error)
	QueryReadAll(context.Context, *types.Empty) (*QueryMulti, error)
	QueryReadAllDsc(context.Context, *types.Empty) (*QueryMulti, error)
	QueryMutationNodes(context.Context, *types.Empty) (*Query, error)
	QueryMutationEdges(context.Context, *types.Empty) (*Query, error)
	QueryNodeMutationNodes(context.Context, *Query) (*Query, error)
	QueryNodeMutationEdges(context.Context, *Query) (*Query, error)
	QueryNodeMutationPath(context.Context, *Query) (*Query, error)
	QueryDeleteAll(context.Context, *types.Empty) (*QueryMulti, error)
	QueryFreeze(context.Context, *types.Empty) (*Query, error)
	QueryThaw(context.Context, *types.Empty) (*Query, error)
	QueryFrozen(context.Context, *types.Empty) (*Query, error)
	// Service management
	ServiceInit(*ServiceInitRequest, ModuleAPI_ServiceInitServer) error
	// Mutation/Discover management
	MutationInit(*ServiceInitRequest, ModuleAPI_MutationInitServer) error
	// Event management
	EventInit(*ServiceInitRequest, ModuleAPI_EventInitServer) error
	// Discovery management
	DiscoveryInit(ModuleAPI_DiscoveryInitServer) error
	// Logging
	LoggerInit(ModuleAPI_LoggerInitServer) error
}

ModuleAPIServer is the server API for ModuleAPI service.

type ModuleAPI_DiscoveryInitClient 

type ModuleAPI_DiscoveryInitClient interface {
	Send(*DiscoveryEvent) error
	CloseAndRecv() (*types.Empty, error)
	grpc.ClientStream
}

type ModuleAPI_DiscoveryInitServer 

type ModuleAPI_DiscoveryInitServer interface {
	SendAndClose(*types.Empty) error
	Recv() (*DiscoveryEvent, error)
	grpc.ServerStream
}

type ModuleAPI_EventInitClient 

type ModuleAPI_EventInitClient interface {
	Recv() (*EventControl, error)
	grpc.ClientStream
}

type ModuleAPI_EventInitServer 

type ModuleAPI_EventInitServer interface {
	Send(*EventControl) error
	grpc.ServerStream
}

type ModuleAPI_LoggerInitClient 

type ModuleAPI_LoggerInitClient interface {
	Send(*LogMessage) error
	CloseAndRecv() (*types.Empty, error)
	grpc.ClientStream
}

type ModuleAPI_LoggerInitServer 

type ModuleAPI_LoggerInitServer interface {
	SendAndClose(*types.Empty) error
	Recv() (*LogMessage, error)
	grpc.ServerStream
}

type ModuleAPI_MutationInitClient 

type ModuleAPI_MutationInitClient interface {
	Recv() (*MutationControl, error)
	grpc.ClientStream
}

type ModuleAPI_MutationInitServer 

type ModuleAPI_MutationInitServer interface {
	Send(*MutationControl) error
	grpc.ServerStream
}

type ModuleAPI_ServiceInitClient 

type ModuleAPI_ServiceInitClient interface {
	Recv() (*ServiceControl, error)
	grpc.ClientStream
}

type ModuleAPI_ServiceInitServer 

type ModuleAPI_ServiceInitServer interface {
	Send(*ServiceControl) error
	grpc.ServerStream
}

type MutationControl 

type MutationControl struct {
	Module               string               `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	Id                   string               `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Type                 MutationControl_Type `protobuf:"varint,3,opt,name=type,proto3,enum=proto.MutationControl_Type" json:"type,omitempty"`
	Cfg                  *Node                `protobuf:"bytes,4,opt,name=cfg,proto3" json:"cfg,omitempty"`
	Dsc                  *Node                `protobuf:"bytes,5,opt,name=dsc,proto3" json:"dsc,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*MutationControl) Descriptor 

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

func (*MutationControl) GetCfg 

func (m *MutationControl) GetCfg() *Node

func (*MutationControl) GetDsc 

func (m *MutationControl) GetDsc() *Node

func (*MutationControl) GetId 

func (m *MutationControl) GetId() string

func (*MutationControl) GetModule 

func (m *MutationControl) GetModule() string

func (*MutationControl) GetType 

func (m *MutationControl) GetType() MutationControl_Type

func (*MutationControl) Marshal 

func (m *MutationControl) Marshal() (dAtA []byte, err error)

func (*MutationControl) MarshalTo 

func (m *MutationControl) MarshalTo(dAtA []byte) (int, error)

func (*MutationControl) MarshalToSizedBuffer 

func (m *MutationControl) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MutationControl) ProtoMessage 

func (*MutationControl) ProtoMessage()

func (*MutationControl) Reset 

func (m *MutationControl) Reset()

func (*MutationControl) Size 

func (m *MutationControl) Size() (n int)

func (*MutationControl) String 

func (m *MutationControl) String() string

func (*MutationControl) Unmarshal 

func (m *MutationControl) Unmarshal(dAtA []byte) error

func (*MutationControl) XXX_DiscardUnknown 

func (m *MutationControl) XXX_DiscardUnknown()

func (*MutationControl) XXX_Marshal 

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

func (*MutationControl) XXX_Merge 

func (m *MutationControl) XXX_Merge(src proto.Message)

func (*MutationControl) XXX_MessageName 

func (*MutationControl) XXX_MessageName() string

func (*MutationControl) XXX_Size 

func (m *MutationControl) XXX_Size() int

func (*MutationControl) XXX_Unmarshal 

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

type MutationControl_Type 

type MutationControl_Type int32
const (
	MutationControl_MUTATE    MutationControl_Type = 0
	MutationControl_INTERRUPT MutationControl_Type = 1
)

func (MutationControl_Type) EnumDescriptor 

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

func (MutationControl_Type) String 

func (x MutationControl_Type) String() string

type MutationEdge 

type MutationEdge struct {
	From                 string     `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	To                   string     `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	Id                   string     `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	Color                *EdgeColor `protobuf:"bytes,4,opt,name=color,proto3" json:"color,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*MutationEdge) Descriptor 

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

func (*MutationEdge) GetColor 

func (m *MutationEdge) GetColor() *EdgeColor

func (*MutationEdge) GetFrom 

func (m *MutationEdge) GetFrom() string

func (*MutationEdge) GetId 

func (m *MutationEdge) GetId() string

func (*MutationEdge) GetTo 

func (m *MutationEdge) GetTo() string

func (*MutationEdge) Marshal 

func (m *MutationEdge) Marshal() (dAtA []byte, err error)

func (*MutationEdge) MarshalTo 

func (m *MutationEdge) MarshalTo(dAtA []byte) (int, error)

func (*MutationEdge) MarshalToSizedBuffer 

func (m *MutationEdge) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MutationEdge) ProtoMessage 

func (*MutationEdge) ProtoMessage()

func (*MutationEdge) Reset 

func (m *MutationEdge) Reset()

func (*MutationEdge) Size 

func (m *MutationEdge) Size() (n int)

func (*MutationEdge) String 

func (m *MutationEdge) String() string

func (*MutationEdge) Unmarshal 

func (m *MutationEdge) Unmarshal(dAtA []byte) error

func (*MutationEdge) XXX_DiscardUnknown 

func (m *MutationEdge) XXX_DiscardUnknown()

func (*MutationEdge) XXX_Marshal 

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

func (*MutationEdge) XXX_Merge 

func (m *MutationEdge) XXX_Merge(src proto.Message)

func (*MutationEdge) XXX_MessageName 

func (*MutationEdge) XXX_MessageName() string

func (*MutationEdge) XXX_Size 

func (m *MutationEdge) XXX_Size() int

func (*MutationEdge) XXX_Unmarshal 

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

type MutationEdgeList 

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

func (*MutationEdgeList) Descriptor 

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

func (*MutationEdgeList) GetMutationEdgeList 

func (m *MutationEdgeList) GetMutationEdgeList() []*MutationEdge

func (*MutationEdgeList) Marshal 

func (m *MutationEdgeList) Marshal() (dAtA []byte, err error)

func (*MutationEdgeList) MarshalTo 

func (m *MutationEdgeList) MarshalTo(dAtA []byte) (int, error)

func (*MutationEdgeList) MarshalToSizedBuffer 

func (m *MutationEdgeList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MutationEdgeList) ProtoMessage 

func (*MutationEdgeList) ProtoMessage()

func (*MutationEdgeList) Reset 

func (m *MutationEdgeList) Reset()

func (*MutationEdgeList) Size 

func (m *MutationEdgeList) Size() (n int)

func (*MutationEdgeList) String 

func (m *MutationEdgeList) String() string

func (*MutationEdgeList) Unmarshal 

func (m *MutationEdgeList) Unmarshal(dAtA []byte) error

func (*MutationEdgeList) XXX_DiscardUnknown 

func (m *MutationEdgeList) XXX_DiscardUnknown()

func (*MutationEdgeList) XXX_Marshal 

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

func (*MutationEdgeList) XXX_Merge 

func (m *MutationEdgeList) XXX_Merge(src proto.Message)

func (*MutationEdgeList) XXX_MessageName 

func (*MutationEdgeList) XXX_MessageName() string

func (*MutationEdgeList) XXX_Size 

func (m *MutationEdgeList) XXX_Size() int

func (*MutationEdgeList) XXX_Unmarshal 

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

type MutationNode 

type MutationNode struct {
	Label                string     `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Id                   string     `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Color                *NodeColor `protobuf:"bytes,3,opt,name=color,proto3" json:"color,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*MutationNode) Descriptor 

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

func (*MutationNode) GetColor 

func (m *MutationNode) GetColor() *NodeColor

func (*MutationNode) GetId 

func (m *MutationNode) GetId() string

func (*MutationNode) GetLabel 

func (m *MutationNode) GetLabel() string

func (*MutationNode) Marshal 

func (m *MutationNode) Marshal() (dAtA []byte, err error)

func (*MutationNode) MarshalTo 

func (m *MutationNode) MarshalTo(dAtA []byte) (int, error)

func (*MutationNode) MarshalToSizedBuffer 

func (m *MutationNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MutationNode) ProtoMessage 

func (*MutationNode) ProtoMessage()

func (*MutationNode) Reset 

func (m *MutationNode) Reset()

func (*MutationNode) Size 

func (m *MutationNode) Size() (n int)

func (*MutationNode) String 

func (m *MutationNode) String() string

func (*MutationNode) Unmarshal 

func (m *MutationNode) Unmarshal(dAtA []byte) error

func (*MutationNode) XXX_DiscardUnknown 

func (m *MutationNode) XXX_DiscardUnknown()

func (*MutationNode) XXX_Marshal 

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

func (*MutationNode) XXX_Merge 

func (m *MutationNode) XXX_Merge(src proto.Message)

func (*MutationNode) XXX_MessageName 

func (*MutationNode) XXX_MessageName() string

func (*MutationNode) XXX_Size 

func (m *MutationNode) XXX_Size() int

func (*MutationNode) XXX_Unmarshal 

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

type MutationNodeList 

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

func (*MutationNodeList) Descriptor 

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

func (*MutationNodeList) GetMutationNodeList 

func (m *MutationNodeList) GetMutationNodeList() []*MutationNode

func (*MutationNodeList) Marshal 

func (m *MutationNodeList) Marshal() (dAtA []byte, err error)

func (*MutationNodeList) MarshalTo 

func (m *MutationNodeList) MarshalTo(dAtA []byte) (int, error)

func (*MutationNodeList) MarshalToSizedBuffer 

func (m *MutationNodeList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MutationNodeList) ProtoMessage 

func (*MutationNodeList) ProtoMessage()

func (*MutationNodeList) Reset 

func (m *MutationNodeList) Reset()

func (*MutationNodeList) Size 

func (m *MutationNodeList) Size() (n int)

func (*MutationNodeList) String 

func (m *MutationNodeList) String() string

func (*MutationNodeList) Unmarshal 

func (m *MutationNodeList) Unmarshal(dAtA []byte) error

func (*MutationNodeList) XXX_DiscardUnknown 

func (m *MutationNodeList) XXX_DiscardUnknown()

func (*MutationNodeList) XXX_Marshal 

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

func (*MutationNodeList) XXX_Merge 

func (m *MutationNodeList) XXX_Merge(src proto.Message)

func (*MutationNodeList) XXX_MessageName 

func (*MutationNodeList) XXX_MessageName() string

func (*MutationNodeList) XXX_Size 

func (m *MutationNodeList) XXX_Size() int

func (*MutationNodeList) XXX_Unmarshal 

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

type MutationPath 

type MutationPath struct {
	Cur                  int64           `protobuf:"varint,1,opt,name=cur,proto3" json:"cur,omitempty"`
	Cmplt                bool            `protobuf:"varint,2,opt,name=cmplt,proto3" json:"cmplt,omitempty"`
	Chain                []*MutationEdge `protobuf:"bytes,3,rep,name=chain,proto3" json:"chain,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*MutationPath) Descriptor 

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

func (*MutationPath) GetChain 

func (m *MutationPath) GetChain() []*MutationEdge

func (*MutationPath) GetCmplt 

func (m *MutationPath) GetCmplt() bool

func (*MutationPath) GetCur 

func (m *MutationPath) GetCur() int64

func (*MutationPath) Marshal 

func (m *MutationPath) Marshal() (dAtA []byte, err error)

func (*MutationPath) MarshalTo 

func (m *MutationPath) MarshalTo(dAtA []byte) (int, error)

func (*MutationPath) MarshalToSizedBuffer 

func (m *MutationPath) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MutationPath) ProtoMessage 

func (*MutationPath) ProtoMessage()

func (*MutationPath) Reset 

func (m *MutationPath) Reset()

func (*MutationPath) Size 

func (m *MutationPath) Size() (n int)

func (*MutationPath) String 

func (m *MutationPath) String() string

func (*MutationPath) Unmarshal 

func (m *MutationPath) Unmarshal(dAtA []byte) error

func (*MutationPath) XXX_DiscardUnknown 

func (m *MutationPath) XXX_DiscardUnknown()

func (*MutationPath) XXX_Marshal 

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

func (*MutationPath) XXX_Merge 

func (m *MutationPath) XXX_Merge(src proto.Message)

func (*MutationPath) XXX_MessageName 

func (*MutationPath) XXX_MessageName() string

func (*MutationPath) XXX_Size 

func (m *MutationPath) XXX_Size() int

func (*MutationPath) XXX_Unmarshal 

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

type Node 

type Node struct {
	Id                   *github_com_kraken_hpc_kraken_core_proto_customtypes.NodeID `` /* 127-byte string literal not displayed */
	Nodename             string                                                      `protobuf:"bytes,2,opt,name=nodename,proto3" json:"nodename,omitempty"`
	RunState             Node_RunState                                               `protobuf:"varint,3,opt,name=run_state,json=runState,proto3,enum=proto.Node_RunState" json:"run_state,omitempty"`
	PhysState            Node_PhysState                                              `protobuf:"varint,4,opt,name=phys_state,json=physState,proto3,enum=proto.Node_PhysState" json:"phys_state,omitempty"`
	Arch                 string                                                      `protobuf:"bytes,5,opt,name=arch,proto3" json:"arch,omitempty"`
	Platform             string                                                      `protobuf:"bytes,6,opt,name=platform,proto3" json:"platform,omitempty"`
	ParentId             *github_com_kraken_hpc_kraken_core_proto_customtypes.NodeID `` /* 155-byte string literal not displayed */
	Busy                 Node_FreeBusy                                               `protobuf:"varint,8,opt,name=busy,proto3,enum=proto.Node_FreeBusy" json:"busy,omitempty"`
	Services             []*ServiceInstance                                          `protobuf:"bytes,14,rep,name=services,proto3" json:"services,omitempty"`
	Extensions           []*types.Any                                                `protobuf:"bytes,15,rep,name=extensions,proto3" json:"extensions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                                    `json:"-"`
	XXX_unrecognized     []byte                                                      `json:"-"`
	XXX_sizecache        int32                                                       `json:"-"`
}

func (*Node) Descriptor 

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

func (*Node) GetArch 

func (m *Node) GetArch() string

func (*Node) GetBusy 

func (m *Node) GetBusy() Node_FreeBusy

func (*Node) GetExtensions 

func (m *Node) GetExtensions() []*types.Any

func (*Node) GetId 

func (n *Node) GetId() *customtypes.NodeID

func (*Node) GetNodename 

func (m *Node) GetNodename() string

func (*Node) GetPhysState 

func (m *Node) GetPhysState() Node_PhysState

func (*Node) GetPlatform 

func (m *Node) GetPlatform() string

func (*Node) GetRunState 

func (m *Node) GetRunState() Node_RunState

func (*Node) GetServices 

func (m *Node) GetServices() []*ServiceInstance

func (*Node) Marshal 

func (m *Node) Marshal() (dAtA []byte, err error)

func (*Node) MarshalJSON 

func (n *Node) MarshalJSON() ([]byte, error)

MarshalJSON creats a JSON version of Node

func (*Node) MarshalTo 

func (m *Node) MarshalTo(dAtA []byte) (int, error)

func (*Node) MarshalToSizedBuffer 

func (m *Node) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

func (m *Node) Size() (n int)

func (*Node) String 

func (m *Node) String() string

func (*Node) Unmarshal 

func (m *Node) Unmarshal(dAtA []byte) error

func (*Node) UnmarshalJSON 

func (n *Node) UnmarshalJSON(j []byte) error

UnmarshalJSON populates a node from JSON

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

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

func (*Node) XXX_Merge 

func (m *Node) XXX_Merge(src proto.Message)

func (*Node) XXX_MessageName 

func (*Node) XXX_MessageName() string

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

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

type NodeColor 

type NodeColor struct {
	Border               string   `protobuf:"bytes,1,opt,name=border,proto3" json:"border,omitempty"`
	Background           string   `protobuf:"bytes,2,opt,name=background,proto3" json:"background,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

This is only nessessary for the json mutation node color to output in the correct format for the dashboard

func (*NodeColor) Descriptor 

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

func (*NodeColor) GetBackground 

func (m *NodeColor) GetBackground() string

func (*NodeColor) GetBorder 

func (m *NodeColor) GetBorder() string

func (*NodeColor) Marshal 

func (m *NodeColor) Marshal() (dAtA []byte, err error)

func (*NodeColor) MarshalTo 

func (m *NodeColor) MarshalTo(dAtA []byte) (int, error)

func (*NodeColor) MarshalToSizedBuffer 

func (m *NodeColor) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeColor) ProtoMessage 

func (*NodeColor) ProtoMessage()

func (*NodeColor) Reset 

func (m *NodeColor) Reset()

func (*NodeColor) Size 

func (m *NodeColor) Size() (n int)

func (*NodeColor) String 

func (m *NodeColor) String() string

func (*NodeColor) Unmarshal 

func (m *NodeColor) Unmarshal(dAtA []byte) error

func (*NodeColor) XXX_DiscardUnknown 

func (m *NodeColor) XXX_DiscardUnknown()

func (*NodeColor) XXX_Marshal 

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

func (*NodeColor) XXX_Merge 

func (m *NodeColor) XXX_Merge(src proto.Message)

func (*NodeColor) XXX_MessageName 

func (*NodeColor) XXX_MessageName() string

func (*NodeColor) XXX_Size 

func (m *NodeColor) XXX_Size() int

func (*NodeColor) XXX_Unmarshal 

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

type NodeList 

type NodeList struct {
	Nodes                []*Node  `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeList) Descriptor 

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

func (*NodeList) GetNodes 

func (m *NodeList) GetNodes() []*Node

func (*NodeList) Marshal 

func (m *NodeList) Marshal() (dAtA []byte, err error)

func (*NodeList) MarshalTo 

func (m *NodeList) MarshalTo(dAtA []byte) (int, error)

func (*NodeList) MarshalToSizedBuffer 

func (m *NodeList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeList) ProtoMessage 

func (*NodeList) ProtoMessage()

func (*NodeList) Reset 

func (m *NodeList) Reset()

func (*NodeList) Size 

func (m *NodeList) Size() (n int)

func (*NodeList) String 

func (m *NodeList) String() string

func (*NodeList) Unmarshal 

func (m *NodeList) Unmarshal(dAtA []byte) error

func (*NodeList) XXX_DiscardUnknown 

func (m *NodeList) XXX_DiscardUnknown()

func (*NodeList) XXX_Marshal 

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

func (*NodeList) XXX_Merge 

func (m *NodeList) XXX_Merge(src proto.Message)

func (*NodeList) XXX_MessageName 

func (*NodeList) XXX_MessageName() string

func (*NodeList) XXX_Size 

func (m *NodeList) XXX_Size() int

func (*NodeList) XXX_Unmarshal 

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

type Node_FreeBusy 

type Node_FreeBusy int32
const (
	Node_FREE Node_FreeBusy = 0
	Node_BUSY Node_FreeBusy = 1
)

func (Node_FreeBusy) EnumDescriptor 

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

func (Node_FreeBusy) String 

func (x Node_FreeBusy) String() string

type Node_PhysState 

type Node_PhysState int32
const (
	Node_PHYS_UNKNOWN Node_PhysState = 0
	Node_POWER_OFF    Node_PhysState = 1
	Node_POWER_ON     Node_PhysState = 2
	Node_POWER_CYCLE  Node_PhysState = 3
	Node_PHYS_HANG    Node_PhysState = 4
	Node_PHYS_ERROR   Node_PhysState = 5
)

func (Node_PhysState) EnumDescriptor 

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

func (Node_PhysState) String 

func (x Node_PhysState) String() string

type Node_RunState 

type Node_RunState int32
const (
	Node_UNKNOWN Node_RunState = 0
	Node_INIT    Node_RunState = 1
	Node_SYNC    Node_RunState = 2
	Node_ERROR   Node_RunState = 3
)

func (Node_RunState) EnumDescriptor 

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

func (Node_RunState) String 

func (x Node_RunState) String() string

type PhoneHomeReply 

type PhoneHomeReply struct {
	Pid                  []byte            `protobuf:"bytes,1,opt,name=pid,proto3" json:"pid,omitempty"`
	Key                  []byte            `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Cfg                  *StateSyncMessage `protobuf:"bytes,3,opt,name=cfg,proto3" json:"cfg,omitempty"`
	Dsc                  *StateSyncMessage `protobuf:"bytes,4,opt,name=dsc,proto3" json:"dsc,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*PhoneHomeReply) Descriptor 

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

func (*PhoneHomeReply) GetCfg 

func (m *PhoneHomeReply) GetCfg() *StateSyncMessage

func (*PhoneHomeReply) GetDsc 

func (m *PhoneHomeReply) GetDsc() *StateSyncMessage

func (*PhoneHomeReply) GetKey 

func (m *PhoneHomeReply) GetKey() []byte

func (*PhoneHomeReply) GetPid 

func (m *PhoneHomeReply) GetPid() []byte

func (*PhoneHomeReply) Marshal 

func (m *PhoneHomeReply) Marshal() (dAtA []byte, err error)

func (*PhoneHomeReply) MarshalTo 

func (m *PhoneHomeReply) MarshalTo(dAtA []byte) (int, error)

func (*PhoneHomeReply) MarshalToSizedBuffer 

func (m *PhoneHomeReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PhoneHomeReply) ProtoMessage 

func (*PhoneHomeReply) ProtoMessage()

func (*PhoneHomeReply) Reset 

func (m *PhoneHomeReply) Reset()

func (*PhoneHomeReply) Size 

func (m *PhoneHomeReply) Size() (n int)

func (*PhoneHomeReply) String 

func (m *PhoneHomeReply) String() string

func (*PhoneHomeReply) Unmarshal 

func (m *PhoneHomeReply) Unmarshal(dAtA []byte) error

func (*PhoneHomeReply) XXX_DiscardUnknown 

func (m *PhoneHomeReply) XXX_DiscardUnknown()

func (*PhoneHomeReply) XXX_Marshal 

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

func (*PhoneHomeReply) XXX_Merge 

func (m *PhoneHomeReply) XXX_Merge(src proto.Message)

func (*PhoneHomeReply) XXX_MessageName 

func (*PhoneHomeReply) XXX_MessageName() string

func (*PhoneHomeReply) XXX_Size 

func (m *PhoneHomeReply) XXX_Size() int

func (*PhoneHomeReply) XXX_Unmarshal 

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

type PhoneHomeRequest 

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

func (*PhoneHomeRequest) Descriptor 

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

func (*PhoneHomeRequest) GetId 

func (m *PhoneHomeRequest) GetId() []byte

func (*PhoneHomeRequest) Marshal 

func (m *PhoneHomeRequest) Marshal() (dAtA []byte, err error)

func (*PhoneHomeRequest) MarshalTo 

func (m *PhoneHomeRequest) MarshalTo(dAtA []byte) (int, error)

func (*PhoneHomeRequest) MarshalToSizedBuffer 

func (m *PhoneHomeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PhoneHomeRequest) ProtoMessage 

func (*PhoneHomeRequest) ProtoMessage()

func (*PhoneHomeRequest) Reset 

func (m *PhoneHomeRequest) Reset()

func (*PhoneHomeRequest) Size 

func (m *PhoneHomeRequest) Size() (n int)

func (*PhoneHomeRequest) String 

func (m *PhoneHomeRequest) String() string

func (*PhoneHomeRequest) Unmarshal 

func (m *PhoneHomeRequest) Unmarshal(dAtA []byte) error

func (*PhoneHomeRequest) XXX_DiscardUnknown 

func (m *PhoneHomeRequest) XXX_DiscardUnknown()

func (*PhoneHomeRequest) XXX_Marshal 

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

func (*PhoneHomeRequest) XXX_Merge 

func (m *PhoneHomeRequest) XXX_Merge(src proto.Message)

func (*PhoneHomeRequest) XXX_MessageName 

func (*PhoneHomeRequest) XXX_MessageName() string

func (*PhoneHomeRequest) XXX_Size 

func (m *PhoneHomeRequest) XXX_Size() int

func (*PhoneHomeRequest) XXX_Unmarshal 

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

type Query 

type Query struct {
	URL string `protobuf:"bytes,1,opt,name=URL,proto3" json:"URL,omitempty"`
	// Types that are valid to be assigned to Payload:
	//	*Query_Node
	//	*Query_Text
	//	*Query_Bool
	//	*Query_MutationNodeList
	//	*Query_MutationEdgeList
	//	*Query_MutationPath
	Payload              isQuery_Payload `protobuf_oneof:"payload"`
	Filter               []string        `protobuf:"bytes,8,rep,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Query) Descriptor 

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

func (*Query) GetBool 

func (m *Query) GetBool() bool

func (*Query) GetFilter 

func (m *Query) GetFilter() []string

func (*Query) GetMutationEdgeList 

func (m *Query) GetMutationEdgeList() *MutationEdgeList

func (*Query) GetMutationNodeList 

func (m *Query) GetMutationNodeList() *MutationNodeList

func (*Query) GetMutationPath 

func (m *Query) GetMutationPath() *MutationPath

func (*Query) GetNode 

func (m *Query) GetNode() *Node

func (*Query) GetPayload 

func (m *Query) GetPayload() isQuery_Payload

func (*Query) GetText 

func (m *Query) GetText() string

func (*Query) GetURL 

func (m *Query) GetURL() string

func (*Query) Marshal 

func (m *Query) Marshal() (dAtA []byte, err error)

func (*Query) MarshalTo 

func (m *Query) MarshalTo(dAtA []byte) (int, error)

func (*Query) MarshalToSizedBuffer 

func (m *Query) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) Size 

func (m *Query) Size() (n int)

func (*Query) String 

func (m *Query) String() string

func (*Query) Unmarshal 

func (m *Query) Unmarshal(dAtA []byte) error

func (*Query) XXX_DiscardUnknown 

func (m *Query) XXX_DiscardUnknown()

func (*Query) XXX_Marshal 

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

func (*Query) XXX_Merge 

func (m *Query) XXX_Merge(src proto.Message)

func (*Query) XXX_MessageName 

func (*Query) XXX_MessageName() string

func (*Query) XXX_OneofWrappers 

func (*Query) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Query) XXX_Size 

func (m *Query) XXX_Size() int

func (*Query) XXX_Unmarshal 

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

type QueryMulti 

type QueryMulti struct {
	Queries              []*Query `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryMulti) Descriptor 

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

func (*QueryMulti) GetQueries 

func (m *QueryMulti) GetQueries() []*Query

func (*QueryMulti) Marshal 

func (m *QueryMulti) Marshal() (dAtA []byte, err error)

func (*QueryMulti) MarshalTo 

func (m *QueryMulti) MarshalTo(dAtA []byte) (int, error)

func (*QueryMulti) MarshalToSizedBuffer 

func (m *QueryMulti) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryMulti) ProtoMessage 

func (*QueryMulti) ProtoMessage()

func (*QueryMulti) Reset 

func (m *QueryMulti) Reset()

func (*QueryMulti) Size 

func (m *QueryMulti) Size() (n int)

func (*QueryMulti) String 

func (m *QueryMulti) String() string

func (*QueryMulti) Unmarshal 

func (m *QueryMulti) Unmarshal(dAtA []byte) error

func (*QueryMulti) XXX_DiscardUnknown 

func (m *QueryMulti) XXX_DiscardUnknown()

func (*QueryMulti) XXX_Marshal 

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

func (*QueryMulti) XXX_Merge 

func (m *QueryMulti) XXX_Merge(src proto.Message)

func (*QueryMulti) XXX_MessageName 

func (*QueryMulti) XXX_MessageName() string

func (*QueryMulti) XXX_Size 

func (m *QueryMulti) XXX_Size() int

func (*QueryMulti) XXX_Unmarshal 

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

type Query_Bool 

type Query_Bool struct {
	Bool bool `protobuf:"varint,4,opt,name=bool,proto3,oneof" json:"bool,omitempty"`
}

func (*Query_Bool) MarshalTo 

func (m *Query_Bool) MarshalTo(dAtA []byte) (int, error)

func (*Query_Bool) MarshalToSizedBuffer 

func (m *Query_Bool) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Query_Bool) Size 

func (m *Query_Bool) Size() (n int)

type Query_MutationEdgeList 

type Query_MutationEdgeList struct {
	MutationEdgeList *MutationEdgeList `protobuf:"bytes,6,opt,name=mutationEdgeList,proto3,oneof" json:"mutationEdgeList,omitempty"`
}

func (*Query_MutationEdgeList) MarshalTo 

func (m *Query_MutationEdgeList) MarshalTo(dAtA []byte) (int, error)

func (*Query_MutationEdgeList) MarshalToSizedBuffer 

func (m *Query_MutationEdgeList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Query_MutationEdgeList) Size 

func (m *Query_MutationEdgeList) Size() (n int)

type Query_MutationNodeList 

type Query_MutationNodeList struct {
	MutationNodeList *MutationNodeList `protobuf:"bytes,5,opt,name=mutationNodeList,proto3,oneof" json:"mutationNodeList,omitempty"`
}

func (*Query_MutationNodeList) MarshalTo 

func (m *Query_MutationNodeList) MarshalTo(dAtA []byte) (int, error)

func (*Query_MutationNodeList) MarshalToSizedBuffer 

func (m *Query_MutationNodeList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Query_MutationNodeList) Size 

func (m *Query_MutationNodeList) Size() (n int)

type Query_MutationPath 

type Query_MutationPath struct {
	MutationPath *MutationPath `protobuf:"bytes,7,opt,name=mutationPath,proto3,oneof" json:"mutationPath,omitempty"`
}

func (*Query_MutationPath) MarshalTo 

func (m *Query_MutationPath) MarshalTo(dAtA []byte) (int, error)

func (*Query_MutationPath) MarshalToSizedBuffer 

func (m *Query_MutationPath) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Query_MutationPath) Size 

func (m *Query_MutationPath) Size() (n int)

type Query_Node 

type Query_Node struct {
	Node *Node `protobuf:"bytes,2,opt,name=node,proto3,oneof" json:"node,omitempty"`
}

func (*Query_Node) MarshalTo 

func (m *Query_Node) MarshalTo(dAtA []byte) (int, error)

func (*Query_Node) MarshalToSizedBuffer 

func (m *Query_Node) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Query_Node) Size 

func (m *Query_Node) Size() (n int)

type Query_Text 

type Query_Text struct {
	Text string `protobuf:"bytes,3,opt,name=text,proto3,oneof" json:"text,omitempty"`
}

func (*Query_Text) MarshalTo 

func (m *Query_Text) MarshalTo(dAtA []byte) (int, error)

func (*Query_Text) MarshalToSizedBuffer 

func (m *Query_Text) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Query_Text) Size 

func (m *Query_Text) Size() (n int)

type ServiceControl 

type ServiceControl struct {
	Command              ServiceControl_Command `protobuf:"varint,1,opt,name=command,proto3,enum=proto.ServiceControl_Command" json:"command,omitempty"`
	Config               *types.Any             `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ServiceControl) Descriptor 

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

func (*ServiceControl) GetCommand 

func (m *ServiceControl) GetCommand() ServiceControl_Command

func (*ServiceControl) GetConfig 

func (m *ServiceControl) GetConfig() *types.Any

func (*ServiceControl) Marshal 

func (m *ServiceControl) Marshal() (dAtA []byte, err error)

func (*ServiceControl) MarshalTo 

func (m *ServiceControl) MarshalTo(dAtA []byte) (int, error)

func (*ServiceControl) MarshalToSizedBuffer 

func (m *ServiceControl) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceControl) ProtoMessage 

func (*ServiceControl) ProtoMessage()

func (*ServiceControl) Reset 

func (m *ServiceControl) Reset()

func (*ServiceControl) Size 

func (m *ServiceControl) Size() (n int)

func (*ServiceControl) String 

func (m *ServiceControl) String() string

func (*ServiceControl) Unmarshal 

func (m *ServiceControl) Unmarshal(dAtA []byte) error

func (*ServiceControl) XXX_DiscardUnknown 

func (m *ServiceControl) XXX_DiscardUnknown()

func (*ServiceControl) XXX_Marshal 

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

func (*ServiceControl) XXX_Merge 

func (m *ServiceControl) XXX_Merge(src proto.Message)

func (*ServiceControl) XXX_MessageName 

func (*ServiceControl) XXX_MessageName() string

func (*ServiceControl) XXX_Size 

func (m *ServiceControl) XXX_Size() int

func (*ServiceControl) XXX_Unmarshal 

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

type ServiceControl_Command 

type ServiceControl_Command int32
const (
	ServiceControl_STOP   ServiceControl_Command = 0
	ServiceControl_UPDATE ServiceControl_Command = 1
	ServiceControl_INIT   ServiceControl_Command = 2
)

func (ServiceControl_Command) EnumDescriptor 

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

func (ServiceControl_Command) String 

func (x ServiceControl_Command) String() string

type ServiceInitRequest 

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

func (*ServiceInitRequest) Descriptor 

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

func (*ServiceInitRequest) GetId 

func (m *ServiceInitRequest) GetId() string

func (*ServiceInitRequest) GetModule 

func (m *ServiceInitRequest) GetModule() string

func (*ServiceInitRequest) Marshal 

func (m *ServiceInitRequest) Marshal() (dAtA []byte, err error)

func (*ServiceInitRequest) MarshalTo 

func (m *ServiceInitRequest) MarshalTo(dAtA []byte) (int, error)

func (*ServiceInitRequest) MarshalToSizedBuffer 

func (m *ServiceInitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceInitRequest) ProtoMessage 

func (*ServiceInitRequest) ProtoMessage()

func (*ServiceInitRequest) Reset 

func (m *ServiceInitRequest) Reset()

func (*ServiceInitRequest) Size 

func (m *ServiceInitRequest) Size() (n int)

func (*ServiceInitRequest) String 

func (m *ServiceInitRequest) String() string

func (*ServiceInitRequest) Unmarshal 

func (m *ServiceInitRequest) Unmarshal(dAtA []byte) error

func (*ServiceInitRequest) XXX_DiscardUnknown 

func (m *ServiceInitRequest) XXX_DiscardUnknown()

func (*ServiceInitRequest) XXX_Marshal 

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

func (*ServiceInitRequest) XXX_Merge 

func (m *ServiceInitRequest) XXX_Merge(src proto.Message)

func (*ServiceInitRequest) XXX_MessageName 

func (*ServiceInitRequest) XXX_MessageName() string

func (*ServiceInitRequest) XXX_Size 

func (m *ServiceInitRequest) XXX_Size() int

func (*ServiceInitRequest) XXX_Unmarshal 

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

type ServiceInstance 

type ServiceInstance struct {
	Id                   string                       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Module               string                       `protobuf:"bytes,2,opt,name=module,proto3" json:"module,omitempty"`
	State                ServiceInstance_ServiceState `protobuf:"varint,3,opt,name=state,proto3,enum=proto.ServiceInstance_ServiceState" json:"state,omitempty"`
	Config               *types.Any                   `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	ErrorMsg             string                       `protobuf:"bytes,5,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*ServiceInstance) Descriptor 

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

func (*ServiceInstance) GetConfig 

func (m *ServiceInstance) GetConfig() *types.Any

func (*ServiceInstance) GetErrorMsg 

func (m *ServiceInstance) GetErrorMsg() string

func (*ServiceInstance) GetId 

func (m *ServiceInstance) GetId() string

func (*ServiceInstance) GetModule 

func (m *ServiceInstance) GetModule() string

func (*ServiceInstance) GetState 

func (m *ServiceInstance) GetState() ServiceInstance_ServiceState

func (*ServiceInstance) Marshal 

func (m *ServiceInstance) Marshal() (dAtA []byte, err error)

func (*ServiceInstance) MarshalTo 

func (m *ServiceInstance) MarshalTo(dAtA []byte) (int, error)

func (*ServiceInstance) MarshalToSizedBuffer 

func (m *ServiceInstance) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServiceInstance) ProtoMessage 

func (*ServiceInstance) ProtoMessage()

func (*ServiceInstance) Reset 

func (m *ServiceInstance) Reset()

func (*ServiceInstance) Size 

func (m *ServiceInstance) Size() (n int)

func (*ServiceInstance) String 

func (m *ServiceInstance) String() string

func (*ServiceInstance) Unmarshal 

func (m *ServiceInstance) Unmarshal(dAtA []byte) error

func (*ServiceInstance) XXX_DiscardUnknown 

func (m *ServiceInstance) XXX_DiscardUnknown()

func (*ServiceInstance) XXX_Marshal 

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

func (*ServiceInstance) XXX_Merge 

func (m *ServiceInstance) XXX_Merge(src proto.Message)

func (*ServiceInstance) XXX_MessageName 

func (*ServiceInstance) XXX_MessageName() string

func (*ServiceInstance) XXX_Size 

func (m *ServiceInstance) XXX_Size() int

func (*ServiceInstance) XXX_Unmarshal 

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

type ServiceInstance_ServiceState 

type ServiceInstance_ServiceState int32
const (
	ServiceInstance_UNKNOWN ServiceInstance_ServiceState = 0
	ServiceInstance_INIT    ServiceInstance_ServiceState = 1
	ServiceInstance_STOP    ServiceInstance_ServiceState = 2
	ServiceInstance_RUN     ServiceInstance_ServiceState = 3
	ServiceInstance_ERROR   ServiceInstance_ServiceState = 4
)

func (ServiceInstance_ServiceState) EnumDescriptor 

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

func (ServiceInstance_ServiceState) String 

func (x ServiceInstance_ServiceState) String() string

type StateChangeControl 

type StateChangeControl struct {
	Type                 StateChangeControl_Type `protobuf:"varint,1,opt,name=type,proto3,enum=proto.StateChangeControl_Type" json:"type,omitempty"`
	Url                  string                  `protobuf:"bytes,2,opt,name=url,proto3" json:"url,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:"-"`
}

func (*StateChangeControl) Descriptor 

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

func (*StateChangeControl) GetType 

func (m *StateChangeControl) GetType() StateChangeControl_Type

func (*StateChangeControl) GetUrl 

func (m *StateChangeControl) GetUrl() string

func (*StateChangeControl) GetValue 

func (m *StateChangeControl) GetValue() string

func (*StateChangeControl) Marshal 

func (m *StateChangeControl) Marshal() (dAtA []byte, err error)

func (*StateChangeControl) MarshalTo 

func (m *StateChangeControl) MarshalTo(dAtA []byte) (int, error)

func (*StateChangeControl) MarshalToSizedBuffer 

func (m *StateChangeControl) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StateChangeControl) ProtoMessage 

func (*StateChangeControl) ProtoMessage()

func (*StateChangeControl) Reset 

func (m *StateChangeControl) Reset()

func (*StateChangeControl) Size 

func (m *StateChangeControl) Size() (n int)

func (*StateChangeControl) String 

func (m *StateChangeControl) String() string

func (*StateChangeControl) Unmarshal 

func (m *StateChangeControl) Unmarshal(dAtA []byte) error

func (*StateChangeControl) XXX_DiscardUnknown 

func (m *StateChangeControl) XXX_DiscardUnknown()

func (*StateChangeControl) XXX_Marshal 

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

func (*StateChangeControl) XXX_Merge 

func (m *StateChangeControl) XXX_Merge(src proto.Message)

func (*StateChangeControl) XXX_MessageName 

func (*StateChangeControl) XXX_MessageName() string

func (*StateChangeControl) XXX_Size 

func (m *StateChangeControl) XXX_Size() int

func (*StateChangeControl) XXX_Unmarshal 

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

type StateChangeControl_Type 

type StateChangeControl_Type int32
const (
	StateChangeControl_CREATE     StateChangeControl_Type = 0
	StateChangeControl_READ       StateChangeControl_Type = 1
	StateChangeControl_UPDATE     StateChangeControl_Type = 2
	StateChangeControl_DELETE     StateChangeControl_Type = 3
	StateChangeControl_CFG_READ   StateChangeControl_Type = 4
	StateChangeControl_CFG_UPDATE StateChangeControl_Type = 5
)

func (StateChangeControl_Type) EnumDescriptor 

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

func (StateChangeControl_Type) String 

func (x StateChangeControl_Type) String() string

type StateSyncClient 

type StateSyncClient interface {
	RPCPhoneHome(ctx context.Context, in *PhoneHomeRequest, opts ...grpc.CallOption) (*PhoneHomeReply, error)
}

StateSyncClient is the client API for StateSync service.

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

func NewStateSyncClient 

func NewStateSyncClient(cc *grpc.ClientConn) StateSyncClient

type StateSyncMessage 

type StateSyncMessage struct {
	Id                   []byte   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Hmac                 []byte   `protobuf:"bytes,2,opt,name=hmac,proto3" json:"hmac,omitempty"`
	Message              []byte   `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

StateSyncMessage are messages sent by StateSync

func (*StateSyncMessage) Descriptor 

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

func (*StateSyncMessage) GetHmac 

func (m *StateSyncMessage) GetHmac() []byte

func (*StateSyncMessage) GetId 

func (m *StateSyncMessage) GetId() []byte

func (*StateSyncMessage) GetMessage 

func (m *StateSyncMessage) GetMessage() []byte

func (*StateSyncMessage) Marshal 

func (m *StateSyncMessage) Marshal() (dAtA []byte, err error)

func (*StateSyncMessage) MarshalTo 

func (m *StateSyncMessage) MarshalTo(dAtA []byte) (int, error)

func (*StateSyncMessage) MarshalToSizedBuffer 

func (m *StateSyncMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StateSyncMessage) ProtoMessage 

func (*StateSyncMessage) ProtoMessage()

func (*StateSyncMessage) Reset 

func (m *StateSyncMessage) Reset()

func (*StateSyncMessage) Size 

func (m *StateSyncMessage) Size() (n int)

func (*StateSyncMessage) String 

func (m *StateSyncMessage) String() string

func (*StateSyncMessage) Unmarshal 

func (m *StateSyncMessage) Unmarshal(dAtA []byte) error

func (*StateSyncMessage) XXX_DiscardUnknown 

func (m *StateSyncMessage) XXX_DiscardUnknown()

func (*StateSyncMessage) XXX_Marshal 

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

func (*StateSyncMessage) XXX_Merge 

func (m *StateSyncMessage) XXX_Merge(src proto.Message)

func (*StateSyncMessage) XXX_MessageName 

func (*StateSyncMessage) XXX_MessageName() string

func (*StateSyncMessage) XXX_Size 

func (m *StateSyncMessage) XXX_Size() int

func (*StateSyncMessage) XXX_Unmarshal 

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

type StateSyncServer 

type StateSyncServer interface {
	RPCPhoneHome(context.Context, *PhoneHomeRequest) (*PhoneHomeReply, error)
}

StateSyncServer is the server API for StateSync service.

type UnimplementedModuleAPIServer 

type UnimplementedModuleAPIServer struct {
}

UnimplementedModuleAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedModuleAPIServer) DiscoveryInit 

func (*UnimplementedModuleAPIServer) DiscoveryInit(srv ModuleAPI_DiscoveryInitServer) error

func (*UnimplementedModuleAPIServer) EventInit 

func (*UnimplementedModuleAPIServer) EventInit(req *ServiceInitRequest, srv ModuleAPI_EventInitServer) error

func (*UnimplementedModuleAPIServer) LoggerInit 

func (*UnimplementedModuleAPIServer) LoggerInit(srv ModuleAPI_LoggerInitServer) error

func (*UnimplementedModuleAPIServer) MutationInit 

func (*UnimplementedModuleAPIServer) MutationInit(req *ServiceInitRequest, srv ModuleAPI_MutationInitServer) error

func (*UnimplementedModuleAPIServer) QueryCreate 

func (*UnimplementedModuleAPIServer) QueryCreate(ctx context.Context, req *Query) (*Query, error)

func (*UnimplementedModuleAPIServer) QueryDelete 

func (*UnimplementedModuleAPIServer) QueryDelete(ctx context.Context, req *Query) (*Query, error)

func (*UnimplementedModuleAPIServer) QueryDeleteAll 

func (*UnimplementedModuleAPIServer) QueryDeleteAll(ctx context.Context, req *types.Empty) (*QueryMulti, error)

func (*UnimplementedModuleAPIServer) QueryFreeze 

func (*UnimplementedModuleAPIServer) QueryFreeze(ctx context.Context, req *types.Empty) (*Query, error)

func (*UnimplementedModuleAPIServer) QueryFrozen 

func (*UnimplementedModuleAPIServer) QueryFrozen(ctx context.Context, req *types.Empty) (*Query, error)

func (*UnimplementedModuleAPIServer) QueryMutationEdges 

func (*UnimplementedModuleAPIServer) QueryMutationEdges(ctx context.Context, req *types.Empty) (*Query, error)

func (*UnimplementedModuleAPIServer) QueryMutationNodes 

func (*UnimplementedModuleAPIServer) QueryMutationNodes(ctx context.Context, req *types.Empty) (*Query, error)

func (*UnimplementedModuleAPIServer) QueryNodeMutationEdges 

func (*UnimplementedModuleAPIServer) QueryNodeMutationEdges(ctx context.Context, req *Query) (*Query, error)

func (*UnimplementedModuleAPIServer) QueryNodeMutationNodes 

func (*UnimplementedModuleAPIServer) QueryNodeMutationNodes(ctx context.Context, req *Query) (*Query, error)

func (*UnimplementedModuleAPIServer) QueryNodeMutationPath 

func (*UnimplementedModuleAPIServer) QueryNodeMutationPath(ctx context.Context, req *Query) (*Query, error)

func (*UnimplementedModuleAPIServer) QueryRead 

func (*UnimplementedModuleAPIServer) QueryRead(ctx context.Context, req *Query) (*Query, error)

func (*UnimplementedModuleAPIServer) QueryReadAll 

func (*UnimplementedModuleAPIServer) QueryReadAll(ctx context.Context, req *types.Empty) (*QueryMulti, error)

func (*UnimplementedModuleAPIServer) QueryReadAllDsc 

func (*UnimplementedModuleAPIServer) QueryReadAllDsc(ctx context.Context, req *types.Empty) (*QueryMulti, error)

func (*UnimplementedModuleAPIServer) QueryReadDsc 

func (*UnimplementedModuleAPIServer) QueryReadDsc(ctx context.Context, req *Query) (*Query, error)

func (*UnimplementedModuleAPIServer) QueryThaw 

func (*UnimplementedModuleAPIServer) QueryThaw(ctx context.Context, req *types.Empty) (*Query, error)

func (*UnimplementedModuleAPIServer) QueryUpdate 

func (*UnimplementedModuleAPIServer) QueryUpdate(ctx context.Context, req *Query) (*Query, error)

func (*UnimplementedModuleAPIServer) QueryUpdateDsc 

func (*UnimplementedModuleAPIServer) QueryUpdateDsc(ctx context.Context, req *Query) (*Query, error)

func (*UnimplementedModuleAPIServer) ServiceInit 

func (*UnimplementedModuleAPIServer) ServiceInit(req *ServiceInitRequest, srv ModuleAPI_ServiceInitServer) error

type UnimplementedStateSyncServer 

type UnimplementedStateSyncServer struct {
}

UnimplementedStateSyncServer can be embedded to have forward compatible implementations.

func (*UnimplementedStateSyncServer) RPCPhoneHome 

func (*UnimplementedStateSyncServer) RPCPhoneHome(ctx context.Context, req *PhoneHomeRequest) (*PhoneHomeReply, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.