(ctx context.Context)
| 1076 | } |
| 1077 | |
| 1078 | func (c *clusterStateHolder) Reload(ctx context.Context) (*clusterState, error) { |
| 1079 | state, err := c.load(ctx) |
| 1080 | if err != nil { |
| 1081 | return nil, err |
| 1082 | } |
| 1083 | c.state.Store(state) |
| 1084 | return state, nil |
| 1085 | } |
| 1086 | |
| 1087 | func (c *clusterStateHolder) LazyReload() { |
| 1088 | // If already reloading, mark that another reload is pending |
no outgoing calls