sc

package module

Go to main page

Versions in this module

v0

v0.7.0

Aug 18, 2022

Changes in this version

+ const DefaultTokenExpiration

+ const HeaderAuth

+ const TokenPath

+ var ErrNil = errors.New("input is nil")

type AddressPool

+ func NewPool(protocol string) *AddressPool

type Client

+ func (c *Client) GetToken(a *rbac.AuthUser) (string, error)

+ func (c *Client) WSHeartbeat(microServiceID, microServiceInstanceID string, callback func()) error

type Options

+ AuthUser *rbac.AuthUser

+ EnableAuth bool

+ TokenExpiration time.Duration

type RegistryException

+ Err error

v0.6.0

Jan 22, 2021

Changes in this version

+ type Client struct

+ Config *RegistryConfig

+ func (c *Client) AddSchemas(microServiceID, schemaName, schemaInfo string) error

+ func (c *Client) BatchFindInstances(consumerID string, keys []*discovery.FindService, opts ...CallOption) (*discovery.BatchFindInstancesResponse, error)

+ func (c *Client) Close() error

+ func (c *Client) FindMicroServiceInstances(consumerID, appID, microServiceName, versionRule string, opts ...CallOption) ([]*discovery.MicroServiceInstance, error)

+ func (c *Client) GetAllApplications(opts ...CallOption) ([]string, error)

+ func (c *Client) GetAllMicroServices(opts ...CallOption) ([]*discovery.MicroService, error)

+ func (c *Client) GetAllResources(resource string, opts ...CallOption) ([]*discovery.ServiceDetail, error)

+ func (c *Client) GetDefaultHeaders() http.Header

+ func (c *Client) GetMicroService(microServiceID string, opts ...CallOption) (*discovery.MicroService, error)

+ func (c *Client) GetMicroServiceID(appID, microServiceName, version, env string, opts ...CallOption) (string, error)

+ func (c *Client) GetMicroServiceInstances(consumerID, providerID string, opts ...CallOption) ([]*discovery.MicroServiceInstance, error)

+ func (c *Client) GetProviders(consumer string, opts ...CallOption) (*MicroServiceProvideResponse, error)

+ func (c *Client) GetSchema(microServiceID, schemaName string, opts ...CallOption) ([]byte, error)

+ func (c *Client) Health() ([]*discovery.MicroServiceInstance, error)

+ func (c *Client) Heartbeat(microServiceID, microServiceInstanceID string) (bool, error)

+ func (c *Client) RegisterMicroServiceInstance(microServiceInstance *discovery.MicroServiceInstance) (string, error)

+ func (c *Client) RegisterService(microService *discovery.MicroService) (string, error)

+ func (c *Client) ResetRevision()

+ func (c *Client) SyncEndpoints() error

+ func (c *Client) UnregisterMicroService(microServiceID string) (bool, error)

+ func (c *Client) UnregisterMicroServiceInstance(microServiceID, microServiceInstanceID string) (bool, error)

+ func (c *Client) UpdateMicroServiceInstanceProperties(microServiceID, microServiceInstanceID string, ...) (bool, error)

+ func (c *Client) UpdateMicroServiceInstanceStatus(microServiceID, microServiceInstanceID, status string) (bool, error)

+ func (c *Client) UpdateMicroServiceProperties(microServiceID string, microService *discovery.MicroService) (bool, error)

+ func (c *Client) WatchMicroService(microServiceID string, callback func(*MicroServiceInstanceChangedEvent)) error

type Options

+ Endpoints []string

v0.5.0

Dec 10, 2020

Changes in this version

+ const APIPath

+ const AppsPath

+ const BatchInstancePath

+ const CheckByHeartbeat

+ const DefaultAddr

+ const DefaultLeaseRenewalInterval

+ const DefaultRetryTimeout

+ const DependencyPath

+ const EnvCheckSCIInterval

+ const EnvProjectID

+ const EventCreate

+ const EventDelete

+ const EventError

+ const EventUpdate

+ const ExistencePath

+ const HeaderContentType

+ const HeaderRevision

+ const HeaderUserAgent

+ const HeartbeatPath

+ const InstancePath

+ const MSIinstanceDown

+ const MSInstanceUP

+ const MicorserviceUp

+ const MicroserviceDown

+ const MicroservicePath

+ const PropertiesPath

+ const SchemaPath

+ const StatusPath

+ const WatchPath

+ var ErrEmptyCriteria = errors.New("batch find criteria is empty")

+ var ErrMicroServiceExists = errors.New("micro-service already exists")

+ var ErrMicroServiceNotExists = errors.New("micro-service does not exist")

+ var ErrNoneAvailable = errors.New("no available")

+ var ErrNotModified = errors.New("instance is not changed since last query")

+ var GovernAPIPATH = ""

+ var MSAPIPath = ""

+ var TenantHeader = "X-Domain-Name"

+ func NewCommonException(format string, args ...interface{}) error

+ func NewIOException(e error, args ...interface{}) error

+ func NewJSONException(e error, args ...interface{}) error

+ type AddressPool struct

+ func GetInstance() *AddressPool

+ func (p *AddressPool) GetAvailableAddress() string

+ func (p *AddressPool) Monitor()

+ func (p *AddressPool) SetAddress(addresses []string)

+ type CallOption func(*CallOptions)

+ func WithGlobal() CallOption

+ func WithoutRevision() CallOption

+ type CallOptions struct

+ Revision string

+ WithGlobal bool

+ WithoutRevision bool

+ type MicroServiceInstanceChangedEvent struct

+ Action string

+ Instance *discovery.MicroServiceInstance

+ Key *discovery.MicroServiceKey

+ type MicroServiceProvideResponse struct

+ Services []*discovery.MicroService

+ type Next func() (string, error)

+ func RoundRobin(eps []string) Next

+ type Options struct

+ Addrs []string

+ Compressed bool

+ Context context.Context

+ EnableSSL bool

+ TLSConfig *tls.Config

+ Timeout time.Duration

+ Verbose bool

+ Version string

+ type RegistryClient struct

+ Config *RegistryConfig

+ func NewClient(opt Options) (*RegistryClient, error)

+ func (c *RegistryClient) AddSchemas(microServiceID, schemaName, schemaInfo string) error

+ func (c *RegistryClient) BatchFindInstances(consumerID string, keys []*discovery.FindService, opts ...CallOption) (*discovery.BatchFindInstancesResponse, error)

+ func (c *RegistryClient) Close() error

+ func (c *RegistryClient) FindMicroServiceInstances(consumerID, appID, microServiceName, versionRule string, opts ...CallOption) ([]*discovery.MicroServiceInstance, error)

+ func (c *RegistryClient) GetAllApplications(opts ...CallOption) ([]string, error)

+ func (c *RegistryClient) GetAllMicroServices(opts ...CallOption) ([]*discovery.MicroService, error)

+ func (c *RegistryClient) GetAllResources(resource string, opts ...CallOption) ([]*discovery.ServiceDetail, error)

+ func (c *RegistryClient) GetDefaultHeaders() http.Header

+ func (c *RegistryClient) GetMicroService(microServiceID string, opts ...CallOption) (*discovery.MicroService, error)

+ func (c *RegistryClient) GetMicroServiceID(appID, microServiceName, version, env string, opts ...CallOption) (string, error)

+ func (c *RegistryClient) GetMicroServiceInstances(consumerID, providerID string, opts ...CallOption) ([]*discovery.MicroServiceInstance, error)

+ func (c *RegistryClient) GetProviders(consumer string, opts ...CallOption) (*MicroServiceProvideResponse, error)

+ func (c *RegistryClient) GetSchema(microServiceID, schemaName string, opts ...CallOption) ([]byte, error)

+ func (c *RegistryClient) Health() ([]*discovery.MicroServiceInstance, error)

+ func (c *RegistryClient) Heartbeat(microServiceID, microServiceInstanceID string) (bool, error)

+ func (c *RegistryClient) RegisterMicroServiceInstance(microServiceInstance *discovery.MicroServiceInstance) (string, error)

+ func (c *RegistryClient) RegisterService(microService *discovery.MicroService) (string, error)

+ func (c *RegistryClient) ResetRevision()

+ func (c *RegistryClient) SyncEndpoints() error

+ func (c *RegistryClient) UnregisterMicroService(microServiceID string) (bool, error)

+ func (c *RegistryClient) UnregisterMicroServiceInstance(microServiceID, microServiceInstanceID string) (bool, error)

+ func (c *RegistryClient) UpdateMicroServiceInstanceProperties(microServiceID, microServiceInstanceID string, ...) (bool, error)

+ func (c *RegistryClient) UpdateMicroServiceInstanceStatus(microServiceID, microServiceInstanceID, status string) (bool, error)

+ func (c *RegistryClient) UpdateMicroServiceProperties(microServiceID string, microService *discovery.MicroService) (bool, error)

+ func (c *RegistryClient) WatchMicroService(microServiceID string, callback func(*MicroServiceInstanceChangedEvent)) error

+ type RegistryConfig struct

+ SSL bool

+ type RegistryException struct

+ Message string

+ OrglErr error

+ Title string

+ func (e *RegistryException) Error() string

+ type URLBuilder struct

+ CallOptions *CallOptions

+ Host string

+ Path string

+ Protocol string

+ URLParameters []URLParameter

+ func (b *URLBuilder) String() string

+ type URLParameter map[string]string

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