gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 03:24:40 -07:00
Code Issues Packages Projects Releases Wiki Activity

Removed stream state for advisories

Browse Source 
Signed-off-by: Derek Collison <derek@nats.io>
This commit is contained in:
Derek Collison
2021-01-28 09:52:56 -08:00
parent 9d4951d2bb
commit 67dc580a39
2 changed files with 0 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/jetstream_cluster.go
View File

@@ -1273,7 +1273,6 @@ func (js *jetStream) processStreamLeaderChange(mset *Stream, sa *streamAssignmen
Time: time.Now().UTC(),
},
Stream: stream,
State: mset.State(),
Leader: s.serverNameForNode(node.GroupLeader()),
Replicas: s.replicas(node),
})
@@ -1290,7 +1289,6 @@ func (js *jetStream) processStreamLeaderChange(mset *Stream, sa *streamAssignmen
Time: time.Now().UTC(),
},
Stream: stream,
State: mset.State(),
Replicas: s.replicas(node),
})
}

2
server/jetstream_events.go
View File

@@ -155,7 +155,6 @@ const JSStreamLeaderElectedAdvisoryType = "io.nats.jetstream.advisory.v1.stream_
type JSStreamLeaderElectedAdvisory struct {
TypedEvent
Stream string `json:"stream"`
State StreamState `json:"state"`
Leader string `json:"leader"`
Replicas []*PeerInfo `json:"replicas"`
}
@@ -168,7 +167,6 @@ const JSStreamQuorumLostAdvisoryType = "io.nats.jetstream.advisory.v1.stream_quo
type JSStreamQuorumLostAdvisory struct {
TypedEvent
Stream string `json:"stream"`
State StreamState `json:"state"`
Replicas []*PeerInfo `json:"replicas"`
}