interfaces

type ConfigLoadProcessor interface {
	// LoadProcessReferenceConfig customizes ReferenceConfig's params.
	// LoadProcessReferenceConfig emits on refer reference (event: before-reference-connect, reference-connect-success, reference-connect-fail)
	LoadProcessReferenceConfig(url *common.URL, event string, errMsg *string)

	// LoadProcessServiceConfig customizes ServiceConfig's params.
	// LoadProcessServiceConfig emits on export service (event: before-service-listen, service-listen-success, service-listen-fail)
	LoadProcessServiceConfig(url *common.URL, event string, errMsg *string)

	// AfterAllReferencesConnectComplete emits on all references export complete
	AfterAllReferencesConnectComplete(urls ConfigLoadProcessorURLBinder)

	// AfterAllServicesListenComplete emits on all services export complete
	AfterAllServicesListenComplete(urls ConfigLoadProcessorURLBinder)

	// BeforeShutdown emits on before shutdown
	BeforeShutdown()
}

type ConfigLoadProcessorHolder struct {
	sync.Mutex
}

type ConfigLoadProcessorURLBinder struct {
	Success []*common.URL
	Fail    []*common.URL
}

type ConfigPostProcessor interface {
	// PostProcessReferenceConfig customizes ReferenceConfig's params.
	PostProcessReferenceConfig(*common.URL)

	// PostProcessServiceConfig customizes ServiceConfig's params.
	PostProcessServiceConfig(*common.URL)
}

type ConfigReader interface {
	ReadConsumerConfig(reader *bytes.Buffer) error
	ReadProviderConfig(reader *bytes.Buffer) error
}