Documentation

Index

Constants

This section is empty.

Variables

View Source
var Request_Type_name = map[int32]string{
	0: "NOIT_SET",
	1: "GET_TECHNICAL_INFO",
	2: "GET_TECHNICAL_INFO_PORT",
}
View Source
var Request_Type_value = map[string]int32{
	"NOIT_SET":                0,
	"GET_TECHNICAL_INFO":      1,
	"GET_TECHNICAL_INFO_PORT": 2,
}

Functions

func RegisterCoreServer

func RegisterCoreServer(s *grpc.Server, srv CoreServer)

Types

type CoreClient

type CoreClient interface {
	GetTechnicalInformation(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
}

    CoreClient is the client API for Core service.

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

    func NewCoreClient

    func NewCoreClient(cc grpc.ClientConnInterface) CoreClient

    type CoreServer

    type CoreServer interface {
    	GetTechnicalInformation(context.Context, *Request) (*Response, error)
    }

      CoreServer is the server API for Core service.

      type Error

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

      func (*Error) Descriptor

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

      func (*Error) GetCode

      func (m *Error) GetCode() int32

      func (*Error) GetMessage

      func (m *Error) GetMessage() string

      func (*Error) ProtoMessage

      func (*Error) ProtoMessage()

      func (*Error) Reset

      func (m *Error) Reset()

      func (*Error) String

      func (m *Error) String() string

      func (*Error) XXX_DiscardUnknown

      func (m *Error) XXX_DiscardUnknown()

      func (*Error) XXX_Marshal

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

      func (*Error) XXX_Merge

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

      func (*Error) XXX_Size

      func (m *Error) XXX_Size() int

      func (*Error) XXX_Unmarshal

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

      type Request

      type Request struct {
      	// settings for the request
      	ProviderPlugin         string       `protobuf:"bytes,1,opt,name=provider_plugin,json=providerPlugin,proto3" json:"provider_plugin,omitempty"`
      	ResourcePlugin         string       `protobuf:"bytes,2,opt,name=resource_plugin,json=resourcePlugin,proto3" json:"resource_plugin,omitempty"`
      	RecreateIndex          bool         `protobuf:"varint,3,opt,name=recreate_index,json=recreateIndex,proto3" json:"recreate_index,omitempty"`
      	DisableDistributedLock bool         `` /* 130-byte string literal not displayed */
      	Timeout                string       `protobuf:"bytes,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
      	CacheTtl               string       `protobuf:"bytes,6,opt,name=cache_ttl,json=cacheTtl,proto3" json:"cache_ttl,omitempty"`
      	Type                   Request_Type `protobuf:"varint,7,opt,name=type,proto3,enum=core.Request_Type" json:"type,omitempty"`
      	// used to locate the resource
      	ObjectId             string   `protobuf:"bytes,8,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
      	Hostname             string   `protobuf:"bytes,9,opt,name=hostname,proto3" json:"hostname,omitempty"`
      	Port                 string   `protobuf:"bytes,10,opt,name=port,proto3" json:"port,omitempty"`
      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
      	XXX_unrecognized     []byte   `json:"-"`
      	XXX_sizecache        int32    `json:"-"`
      }

      func (*Request) Descriptor

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

      func (*Request) GetCacheTtl

      func (m *Request) GetCacheTtl() string

      func (*Request) GetDisableDistributedLock

      func (m *Request) GetDisableDistributedLock() bool

      func (*Request) GetHostname

      func (m *Request) GetHostname() string

      func (*Request) GetObjectId

      func (m *Request) GetObjectId() string

      func (*Request) GetPort

      func (m *Request) GetPort() string

      func (*Request) GetProviderPlugin

      func (m *Request) GetProviderPlugin() string

      func (*Request) GetRecreateIndex

      func (m *Request) GetRecreateIndex() bool

      func (*Request) GetResourcePlugin

      func (m *Request) GetResourcePlugin() string

      func (*Request) GetTimeout

      func (m *Request) GetTimeout() string

      func (*Request) GetType

      func (m *Request) GetType() Request_Type

      func (*Request) ProtoMessage

      func (*Request) ProtoMessage()

      func (*Request) Reset

      func (m *Request) Reset()

      func (*Request) String

      func (m *Request) String() string

      func (*Request) XXX_DiscardUnknown

      func (m *Request) XXX_DiscardUnknown()

      func (*Request) XXX_Marshal

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

      func (*Request) XXX_Merge

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

      func (*Request) XXX_Size

      func (m *Request) XXX_Size() int

      func (*Request) XXX_Unmarshal

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

      type Request_Type

      type Request_Type int32
      const (
      	Request_NOIT_SET                Request_Type = 0
      	Request_GET_TECHNICAL_INFO      Request_Type = 1
      	Request_GET_TECHNICAL_INFO_PORT Request_Type = 2
      )

      func (Request_Type) EnumDescriptor

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

      func (Request_Type) String

      func (x Request_Type) String() string

      type Response

      type Response struct {
      	Request              *Request                `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
      	NetworkElement       *networkelement.Element `protobuf:"bytes,2,opt,name=network_element,json=networkElement,proto3" json:"network_element,omitempty"`
      	PhysicalPort         string                  `protobuf:"bytes,3,opt,name=physical_port,json=physicalPort,proto3" json:"physical_port,omitempty"`
      	Error                *Error                  `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
      	RequestObjectId      string                  `protobuf:"bytes,5,opt,name=request_object_id,json=requestObjectId,proto3" json:"request_object_id,omitempty"`
      	ExecutionTime        string                  `protobuf:"bytes,6,opt,name=execution_time,json=executionTime,proto3" json:"execution_time,omitempty"`
      	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
      	XXX_unrecognized     []byte                  `json:"-"`
      	XXX_sizecache        int32                   `json:"-"`
      }

      func (*Response) Descriptor

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

      func (*Response) GetError

      func (m *Response) GetError() *Error

      func (*Response) GetExecutionTime

      func (m *Response) GetExecutionTime() string

      func (*Response) GetNetworkElement

      func (m *Response) GetNetworkElement() *networkelement.Element

      func (*Response) GetPhysicalPort

      func (m *Response) GetPhysicalPort() string

      func (*Response) GetRequest

      func (m *Response) GetRequest() *Request

      func (*Response) GetRequestObjectId

      func (m *Response) GetRequestObjectId() string

      func (*Response) ProtoMessage

      func (*Response) ProtoMessage()

      func (*Response) Reset

      func (m *Response) Reset()

      func (*Response) String

      func (m *Response) String() string

      func (*Response) XXX_DiscardUnknown

      func (m *Response) XXX_DiscardUnknown()

      func (*Response) XXX_Marshal

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

      func (*Response) XXX_Merge

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

      func (*Response) XXX_Size

      func (m *Response) XXX_Size() int

      func (*Response) XXX_Unmarshal

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

      type UnimplementedCoreServer

      type UnimplementedCoreServer struct {
      }

        UnimplementedCoreServer can be embedded to have forward compatible implementations.

        func (*UnimplementedCoreServer) GetTechnicalInformation

        func (*UnimplementedCoreServer) GetTechnicalInformation(ctx context.Context, req *Request) (*Response, error)

        Source Files