broker

Documentation

Index

• func FileExists(filename string) bool
• func FindCertificates() string
• func GetPublisherConfig(cid string, sigs []*base.Signal, frequency int32) *base.PublisherConfig
• func GetSignalId(signalName string, namespaceName string) *base.SignalId
• func GetSubscriberConfig(cid string, signalids []*base.SignalId) *base.SubscriberConfig
• func PrintSignalTree(clientconnection *grpc.ClientConn, md metadata.MD) error
• func PublishSignals(signame string, sigvalue any, namespace string, ...)
• func SeverConfig() error
• func StartStreaming(connection base.NetworkServiceClient, grpc_settings *GRPCBrokerSettings) (base.NetworkService_SubscribeToSignalsClient, error)
• type Configuration
• type GRPCBrokerSettings
  • func GetBrokerConnections() (base.NetworkServiceClient, base.NetworkServiceClient, *GRPCBrokerSettings, ...)
  • func GetGRPCBrokerSettingInstance() *GRPCBrokerSettings
  • func (settings *GRPCBrokerSettings) SetCredsApiMetadata() *GRPCBrokerSettings
• type GrpcSetting

Functions

func FileExists

func FileExists(filename string) bool

func FindCertificates

func FindCertificates() string

func GetPublisherConfig

func GetPublisherConfig(cid string, sigs []*base.Signal, frequency int32) *base.PublisherConfig

func GetSignalId

func GetSignalId(signalName string, namespaceName string) *base.SignalId

func GetSubscriberConfig

func GetSubscriberConfig(cid string, signalids []*base.SignalId) *base.SubscriberConfig

func PrintSignalTree

func PrintSignalTree(clientconnection *grpc.ClientConn, md metadata.MD) error

print current configuration to the console

func PublishSignals

func PublishSignals(signame string, sigvalue any, namespace string, serviceClient base.NetworkServiceClient)

func SeverConfig

func SeverConfig() error

prints current server config to the console

func StartStreaming

func StartStreaming(connection base.NetworkServiceClient, grpc_settings *GRPCBrokerSettings) (base.NetworkService_SubscribeToSignalsClient, error)

Types

type Configuration

type Configuration struct {
	Tls                       string   `json:"tls"`
	CertPathName              string   `json:"cert_path_name"`
	NameSpaces                []string `json:"name_spaces"`
	BrokerUrl                 string   `json:"broker_url"`
	Port                      string   `json:"port"`
	ClientId                  string   `json:"client_id"`
	ApiKey                    string   `json:"api_key"`
	VssTreePath               string   `json:"vss_tree_path"`
	Signalfilter              []string `json:"signalfilter"`
	PublishSeparateConnection bool     `json:"publish-separate-connection"`
	PublishUrl                string   `json:"publish_url"`
	PublishApiKey             string   `json:"publish_api-key"`
}

type GRPCBrokerSettings

type GRPCBrokerSettings struct {
	Creds     credentials.TransportCredentials
	Creds_pub credentials.TransportCredentials
	Md        metadata.MD
	Uri       string
	Conf      Configuration
	Uri_pub   string
	Md_pub    metadata.MD
}

func GetBrokerConnections

func GetBrokerConnections() (base.NetworkServiceClient, base.NetworkServiceClient, *GRPCBrokerSettings, error)

func GetGRPCBrokerSettingInstance

func GetGRPCBrokerSettingInstance() *GRPCBrokerSettings

func (*GRPCBrokerSettings) SetCredsApiMetadata

func (settings *GRPCBrokerSettings) SetCredsApiMetadata() *GRPCBrokerSettings

type GrpcSetting

type GrpcSetting interface {
	SetCredsApiMetadata()
}