inmemory

Documentation

Overview

* Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

Index

• func NewMetadataService() (service.MetadataService, error)
• type Comparator
  • func (c Comparator) Compare(comp cm.Comparator) int
• type MetadataService
  • func (mts *MetadataService) ExportURL(url common.URL) (bool, error)
  • func (mts *MetadataService) GetExportedURLs(serviceInterface string, group string, version string, protocol string) ([]interface{}, error)
  • func (mts *MetadataService) GetServiceDefinition(interfaceName string, group string, version string) (string, error)
  • func (mts *MetadataService) GetServiceDefinitionByServiceKey(serviceKey string) (string, error)
  • func (mts *MetadataService) GetSubscribedURLs() ([]common.URL, error)
  • func (mts *MetadataService) PublishServiceDefinition(url common.URL) error
  • func (mts *MetadataService) RefreshMetadata(exportedRevision string, subscribedRevision string) (bool, error)
  • func (mts *MetadataService) SubscribeURL(url common.URL) (bool, error)
  • func (mts *MetadataService) UnexportURL(url common.URL) error
  • func (mts *MetadataService) UnsubscribeURL(url common.URL) error
  • func (mts *MetadataService) Version() (string, error)
• type MetadataServiceProxy
  • func (m *MetadataServiceProxy) ExportURL(url common.URL) (bool, error)
  • func (m *MetadataServiceProxy) GetExportedURLs(serviceInterface string, group string, version string, protocol string) ([]interface{}, error)
  • func (m *MetadataServiceProxy) GetServiceDefinition(interfaceName string, group string, version string) (string, error)
  • func (m *MetadataServiceProxy) GetServiceDefinitionByServiceKey(serviceKey string) (string, error)
  • func (m *MetadataServiceProxy) GetSubscribedURLs() ([]common.URL, error)
  • func (m *MetadataServiceProxy) MethodMapper() map[string]string
  • func (m *MetadataServiceProxy) PublishServiceDefinition(url common.URL) error
  • func (m *MetadataServiceProxy) Reference() string
  • func (m *MetadataServiceProxy) RefreshMetadata(exportedRevision string, subscribedRevision string) (bool, error)
  • func (m *MetadataServiceProxy) ServiceName() (string, error)
  • func (m *MetadataServiceProxy) SubscribeURL(url common.URL) (bool, error)
  • func (m *MetadataServiceProxy) UnexportURL(url common.URL) error
  • func (m *MetadataServiceProxy) UnsubscribeURL(url common.URL) error
  • func (m *MetadataServiceProxy) Version() (string, error)

Functions

func NewMetadataService

func NewMetadataService() (service.MetadataService, error)

NewMetadataService: initiate a metadata service it should be singleton

Types

type Comparator

type Comparator common.URL

Comparator is defined as Comparator for skip list to compare the URL

func (Comparator) Compare

func (c Comparator) Compare(comp cm.Comparator) int

Compare is defined as Comparator for skip list to compare the URL

type MetadataService

type MetadataService struct {
	service.BaseMetadataService
	// contains filtered or unexported fields
}

MetadataService is store and query the metadata info in memory when each service registry

func (*MetadataService) ExportURL

func (mts *MetadataService) ExportURL(url common.URL) (bool, error)

ExportURL can store the in memory

func (*MetadataService) GetExportedURLs

func (mts *MetadataService) GetExportedURLs(serviceInterface string, group string, version string, protocol string) ([]interface{}, error)

GetExportedURLs get all exported urls

func (*MetadataService) GetServiceDefinition

func (mts *MetadataService) GetServiceDefinition(interfaceName string, group string, version string) (string, error)

GetServiceDefinition can get service definition by interfaceName, group and version

func (*MetadataService) GetServiceDefinitionByServiceKey

func (mts *MetadataService) GetServiceDefinitionByServiceKey(serviceKey string) (string, error)

GetServiceDefinition can get service definition by serviceKey

func (*MetadataService) GetSubscribedURLs

func (mts *MetadataService) GetSubscribedURLs() ([]common.URL, error)

GetSubscribedURLs get all subscribedUrl

func (*MetadataService) PublishServiceDefinition

func (mts *MetadataService) PublishServiceDefinition(url common.URL) error

PublishServiceDefinition: publish url's service metadata info, and write into memory

func (*MetadataService) RefreshMetadata

func (mts *MetadataService) RefreshMetadata(exportedRevision string, subscribedRevision string) (bool, error)

RefreshMetadata will always return true because it will be implement by remote service

func (*MetadataService) SubscribeURL

func (mts *MetadataService) SubscribeURL(url common.URL) (bool, error)

SubscribeURL can store the in memory

func (*MetadataService) UnexportURL

func (mts *MetadataService) UnexportURL(url common.URL) error

UnexportURL can remove the url store in memory

func (*MetadataService) UnsubscribeURL

func (mts *MetadataService) UnsubscribeURL(url common.URL) error

UnsubscribeURL can remove the url store in memory

func (*MetadataService) Version

func (mts *MetadataService) Version() (string, error)

Version will return the version of metadata service

type MetadataServiceProxy

type MetadataServiceProxy struct {
	// contains filtered or unexported fields
}

actually it's RPC stub this will only be used by client-side if the metadata service is "local" metadata service in server side, which means that metadata service is RPC service too. so in client-side, if we want to get the metadata information, we must call metadata service this is the stub, or proxy for now, only GetExportedURLs need to be implemented

func (*MetadataServiceProxy) ExportURL

func (m *MetadataServiceProxy) ExportURL(url common.URL) (bool, error)

func (*MetadataServiceProxy) GetExportedURLs

func (m *MetadataServiceProxy) GetExportedURLs(serviceInterface string, group string, version string, protocol string) ([]interface{}, error)

func (*MetadataServiceProxy) GetServiceDefinition

func (m *MetadataServiceProxy) GetServiceDefinition(interfaceName string, group string, version string) (string, error)

func (*MetadataServiceProxy) GetServiceDefinitionByServiceKey

func (m *MetadataServiceProxy) GetServiceDefinitionByServiceKey(serviceKey string) (string, error)

func (*MetadataServiceProxy) GetSubscribedURLs

func (m *MetadataServiceProxy) GetSubscribedURLs() ([]common.URL, error)

func (*MetadataServiceProxy) MethodMapper

func (m *MetadataServiceProxy) MethodMapper() map[string]string

func (*MetadataServiceProxy) PublishServiceDefinition

func (m *MetadataServiceProxy) PublishServiceDefinition(url common.URL) error

func (*MetadataServiceProxy) Reference

func (m *MetadataServiceProxy) Reference() string

func (*MetadataServiceProxy) RefreshMetadata

func (m *MetadataServiceProxy) RefreshMetadata(exportedRevision string, subscribedRevision string) (bool, error)

func (*MetadataServiceProxy) ServiceName

func (m *MetadataServiceProxy) ServiceName() (string, error)

func (*MetadataServiceProxy) SubscribeURL

func (m *MetadataServiceProxy) SubscribeURL(url common.URL) (bool, error)

func (*MetadataServiceProxy) UnexportURL

func (m *MetadataServiceProxy) UnexportURL(url common.URL) error

func (*MetadataServiceProxy) UnsubscribeURL

func (m *MetadataServiceProxy) UnsubscribeURL(url common.URL) error

func (*MetadataServiceProxy) Version

func (m *MetadataServiceProxy) Version() (string, error)