71
ctx context.Context,
72
request *UpdateShardRequest,
74
>
shardInfo := request.ShardInfo
75
>
shardInfo.UpdateTime = timestamp.TimeNowPtrUtc()
76
>
77
>
shardInfoBlob, err := m.serializer.ShardInfoToBlob(shardInfo)
78
>
if err != nil {
79
return err
80
}
82
>
ShardID: request.ShardInfo.GetShardId(),
83
>
RangeID: request.ShardInfo.GetRangeId(),
84
>
Owner: request.ShardInfo.GetOwner(),
85
>
ShardInfo: shardInfoBlob,
86
>
PreviousRangeID: request.PreviousRangeID,
87
>
}
88
>
return m.shardStore.UpdateShard(ctx, internalRequest)
89
}
90