unistack-org/micro
4
0
Fork 2
Code Issues 18 Pull Requests Actions Packages Projects Releases 331 Wiki Activity

Add type of service (#1385)

Browse Source
This commit is contained in:
Asim Aslam
2020-03-20 12:48:12 +00:00
committed by GitHub
parent e49be1da42
commit d2f153d795
2 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
runtime/kubernetes/kubernetes.go
View File

@@ -84,6 +84,8 @@ func (k *kubernetes) getService(labels map[string]string) ([]*service, error) {
address := kservice.Spec.ClusterIP address := kservice.Spec.ClusterIP
port := kservice.Spec.Ports[0] port := kservice.Spec.Ports[0]
srv.Service.Metadata["address"] = fmt.Sprintf("%s:%d", address, port.Port) srv.Service.Metadata["address"] = fmt.Sprintf("%s:%d", address, port.Port)
// set the type of service
srv.Service.Metadata["type"] = kservice.Metadata.Labels["micro"]
// copy annotations metadata into service metadata // copy annotations metadata into service metadata
for k, v := range kservice.Metadata.Annotations { for k, v := range kservice.Metadata.Annotations {

2
runtime/service.go
View File

@@ -125,6 +125,8 @@ func (s *service) Start() error {
s.running = true s.running = true
// set status // set status
s.Metadata["status"] = "running" s.Metadata["status"] = "running"
// set started
s.Metadata["started"] = time.Now().Format(time.RFC3339)
if s.output != nil { if s.output != nil {
s.streamOutput() s.streamOutput()